标签：__ url flow REST headers API SDN type requests

（一）基本要求

1.编写Python程序，调用OpenDaylight的北向接口实现以下功能

（1）利用Mininet平台搭建下图所示网络拓扑，并连接OpenDaylight；

（2）下发指令删除s1上的流表数据。

1-2

import requests
from requests.auth import HTTPBasicAuth
def http_detele(url):
    url = url
    headers = {'Content-Type': 'application/json'}
    resp = requests.delete(url, headers=headers, auth=HTTPBasicAuth('admin', 'admin'))
    return resp


if __name__ == '__main__':
    url = 'http://127.0.0.1:8181/restconf/config/opendaylight-inventory:nodes/node/openflow:1/'
    resp = http_detele(url)
    print(resp.content)

（3）下发硬超时流表，实现拓扑内主机h1和h3网络中断20s。

1-3

 import requests
from requests.auth import HTTPBasicAuth

if __name__ == "__main__":
    url = 'http://127.0.0.1:8181/restconf/config/opendaylight-inventory:nodes/node/openflow:1/flow-node-inventory:table/0/flow/1'
    with open("./time.json") as f: #中断规则
        jstr = f.read()
    headers = {'Content-Type': 'application/json'}
    res = requests.put(url, jstr, headers=headers, auth=HTTPBasicAuth('admin', 'admin'))
    print (res.content)

time.json

 {
  "flow": [
    {
      "id": "1",
      "match": {
        "in-port": "1",
        "ethernet-match": {
          "ethernet-type": {
            "type": "0x0800"
          }
        },
        "ipv4-destination": "10.0.0.3/32"
      },
      "instructions": {
        "instruction": [
          {
            "order": "0",
            "apply-actions": {
              "action": [
                {
                  "order": "0",
                  "drop-action": {}
                }
              ]
            }
          }
        ]
      },
      "flow-name": "flow1",
      "priority": "65535",
      "hard-timeout": "20",
      "cookie": "2",
      "table_id": "0"
    }
  ]
}

（4）获取s1上活动的流表数。

1-4

 import requests
from requests.auth import HTTPBasicAuth
if __name__ == "__main__":
    url = 'http://127.0.0.1:8181/restconf/operational/opendaylight-inventory:nodes/node/openflow:1/flow-node-inventory:table/0/opendaylight-flow-table-statistics:flow-table-statistics'
    headers = {'Content-Type': 'application/json'}
    res = requests.get(url,headers=headers, auth=HTTPBasicAuth('admin', 'admin'))
    print (res.content)

2.编写Python程序，调用Ryu的北向接口实现以下功能
（1）实现上述OpenDaylight实验拓扑上相同的硬超时流表下发。

2-1

 import requests
if __name__ == "__main__":
    url = 'http://127.0.0.1:8080/stats/flowentry/add'
    with open("./Ryutimeout.json") as file:
        str = file.read()
    headers = {'Content-Type': 'application/json'}
    res = requests.post(url, str, headers=headers)
    print (res.content)

Ryutimeout.json

 {
    "dpid": 1,
    "cookie": 1,
    "cookie_mask": 1,
    "table_id": 0,
    "hard_timeout": 20,
    "priority": 65535,
    "flags": 1,
    "match":{
        "in_port":1
    },
    "actions":[

    ]
 }

（2）参考Ryu REST API的文档，基于VLAN实验的网络拓扑，编程实现相同的VLAN配置。

提示：拓扑生成后需连接Ryu，且Ryu应能够提供REST API服务

VLAN_ID	Hosts
0	h1 h3
1	h2 h4

2-2

 import json
import requests

if __name__ == "__main__":
    url = 'http://127.0.0.1:8080/stats/flowentry/add'
    headers = {'Content-Type': 'application/json'}
    flow1 = {
        "dpid": 1,
        "priority": 1,
        "match":{
            "in_port": 1
        },
        "actions":[
            {
                "type": "PUSH_VLAN",    
                "ethertype": 33024      
            },
            {
                "type": "SET_FIELD",
                "field": "vlan_vid",    
                "value": 4096           
            },
            {
                "type": "OUTPUT",
                "port": 3
            }
        ]
    }
    flow2 = {
        "dpid": 1,
        "priority": 1,
        "match":{
            "in_port": 2
        },
        "actions":[
            {
                "type": "PUSH_VLAN",     
                "ethertype": 33024      
            },
            {
                "type": "SET_FIELD",
                "field": "vlan_vid",     
                "value": 4097           
            },
            {
                "type": "OUTPUT",
                "port": 3
            }
        ]
    }
    flow3 = {
        "dpid": 1,
        "priority": 1,
        "match":{
            "vlan_vid": 0
        },
        "actions":[
            {
                "type": "POP_VLAN",    
                "ethertype": 33024     
            },
            {
                "type": "OUTPUT",
                "port": 1
            }
        ]
    }
    flow4 = {
        "dpid": 1,
        "priority": 1,
        "match": {
            "vlan_vid": 1
        },
        "actions": [
            {
                "type": "POP_VLAN", 
                "ethertype": 33024  
            },
            {
                "type": "OUTPUT",
                "port": 2
            }
        ]
    }
    flow5 = {
        "dpid": 2,
        "priority": 1,
        "match": {
            "in_port": 1
        },
        "actions": [
            {
                "type": "PUSH_VLAN", 
                "ethertype": 33024 
            },
            {
                "type": "SET_FIELD",
                "field": "vlan_vid", 
                "value": 4096  
            },
            {
                "type": "OUTPUT",
                "port": 3
            }
        ]
    }
    flow6 = {
        "dpid": 2,
        "priority": 1,
        "match": {
            "in_port": 2
        },
        "actions": [
            {
                "type": "PUSH_VLAN",  
                "ethertype": 33024  
            },
            {
                "type": "SET_FIELD",
                "field": "vlan_vid",  
                "value": 4097 
            },
            {
                "type": "OUTPUT",
                "port": 3
            }
        ]
    }
    flow7 = {
        "dpid": 2,
        "priority": 1,
        "match": {
            "vlan_vid": 0
        },
        "actions": [
            {
                "type": "POP_VLAN", 
                "ethertype": 33024  
            },
            {
                "type": "OUTPUT",
                "port": 1
            }
        ]
    }
    flow8 = {
        "dpid": 2,
        "priority": 1,
        "match": {
            "vlan_vid": 1
        },
        "actions": [
            {
                "type": "POP_VLAN", 
                "ethertype": 33024  
            },
            {
                "type": "OUTPUT",
                "port": 2
            }
        ]
    }
    res1 = requests.post(url, json.dumps(flow1), headers=headers)
    res2 = requests.post(url, json.dumps(flow2), headers=headers)
    res3 = requests.post(url, json.dumps(flow3), headers=headers)
    res4 = requests.post(url, json.dumps(flow4), headers=headers)
    res5 = requests.post(url, json.dumps(flow5), headers=headers)
    res6 = requests.post(url, json.dumps(flow6), headers=headers)
    res7 = requests.post(url, json.dumps(flow7), headers=headers)
    res8 = requests.post(url, json.dumps(flow8), headers=headers)

（二）进阶要求

OpenDaylight或Ryu任选其一，编程实现查看前序VLAN实验拓扑中所有节点（含交换机、主机）的名称，以及显示每台交换机的所有流表项。

3-1

 import requests
import time
import re


class GetInformation:
    def __init__(self, ip):
        self.ip = ip
        

    def GetSwitch_id(self):
        url = 'http://' + self.ip + '/stats/switches'
        re_switch_id = requests.get(url=url).json()
        switch_id_hex = []
        for i in re_switch_id:
            switch_id_hex.append(hex(i))

        return switch_id_hex

    def GetFlow_table(self):
        url = 'http://' + self.ip + '/stats/flow/%d'
        list_switch = self.GetSwitch_id()
        all_flow = []
        for switch in list_switch:
            new_url = format(url % int(switch, 16))
            re_switch_flow = requests.get(url=new_url).json()
            all_flow.append(re_switch_flow)

        return all_flow

    def ShowFlow(self):
        list_flow = self.GetFlow_table()
        for flow in list_flow:
            for dpid in flow.keys():
                dp_id = dpid
                print('switch_name_s{1}:'.format(hex(int(dp_id)), int(dp_id)))
                
            for list_table in flow.values():
                for table in list_table:
                    print(table)
    def ShowName(self):
    	
        list_flow = self.GetFlow_table()
        for flow in list_flow:
            for dpid in flow.keys():
                dp_id = dpid
                switchnum= '{1}'.format(hex(int(dp_id)), int(dp_id))        
                print('----s'+switchnum+'----')
                switchnum = int(switchnum)
            for list_table in flow.values():
                count = 0
                for table in list_table:
                  
                    string1 = str(table)
                    
                    if re.search("'dl_vlan': '(.*?)'", string1) is not None:
                       num = re.search("'dl_vlan': '(.*?)'", string1).group(1);
                       if num == '0' and switchnum == 1:
                          print('(h1)',end=" ")
                       if num == '1' and switchnum == 1:
                          print('(h2)')
                       if num == '0' and switchnum == 2:
                          print('(h3)',end=" ")
                       if num == '1' and switchnum == 2:
                          print('(h4)')

S1 = GetInformation("127.0.0.1:8080");
S1.ShowName();
S1.ShowFlow();

（三）个人总结

本次实验的代码量也特别大，是一个比较消耗时间的实验，同时难度也相较于之前的实验有所提升，对Python代码编写能力和文档阅读能力都有一定要求。

本次实验中出现的问题：调用ryu北向接口时无法成功调用

解决方法：需要先行启动ryu控制器，再进行之后的操作

通过本次实验，结合了前面几次实验所学的知识，我加深了对SDN的认识，进一步熟悉了OpenDaylight和ryu的使用

标签：__,url,flow,REST,headers,API,SDN,type,requests
From： https://www.cnblogs.com/HypocriSY966/p/16840050.html

实验7：基于REST API的SDN北向应用实践

（一）基本要求

1.编写Python程序，调用OpenDaylight的北向接口实现以下功能

（1）利用Mininet平台搭建下图所示网络拓扑，并连接OpenDaylight；

（2）下发指令删除s1上的流表数据。

（3）下发硬超时流表，实现拓扑内主机h1和h3网络中断20s。

（4）获取s1上活动的流表数。

2.编写Python程序，调用Ryu的北向接口实现以下功能
（1）实现上述OpenDaylight实验拓扑上相同的硬超时流表下发。

（2）参考Ryu REST API的文档，基于VLAN实验的网络拓扑，编程实现相同的VLAN配置。

（二）进阶要求

（三）个人总结

相关文章

赞助商

阅读排行

实验7：基于REST API的SDN北向应用实践

（一）基本要求

1.编写Python程序，调用OpenDaylight的北向接口实现以下功能

（1） 利用Mininet平台搭建下图所示网络拓扑，并连接OpenDaylight；

（2） 下发指令删除s1上的流表数据。

（3） 下发硬超时流表，实现拓扑内主机h1和h3网络中断20s。

（4） 获取s1上活动的流表数。

2.编写Python程序，调用Ryu的北向接口实现以下功能（1） 实现上述OpenDaylight实验拓扑上相同的硬超时流表下发。

（2） 参考Ryu REST API的文档，基于VLAN实验的网络拓扑，编程实现相同的VLAN配置。

（二）进阶要求

（三）个人总结

相关文章

赞助商

阅读排行

（1）利用Mininet平台搭建下图所示网络拓扑，并连接OpenDaylight；

（2）下发指令删除s1上的流表数据。

（3）下发硬超时流表，实现拓扑内主机h1和h3网络中断20s。

（4）获取s1上活动的流表数。

2.编写Python程序，调用Ryu的北向接口实现以下功能
（1）实现上述OpenDaylight实验拓扑上相同的硬超时流表下发。

（2）参考Ryu REST API的文档，基于VLAN实验的网络拓扑，编程实现相同的VLAN配置。