- fl1 = flows[0]
- dev_id, flow_id = fl1
- url = 'http://' + cntl + ':' + '8181/onos/v1/flows/' + dev_id + '/' + flow_id
- req = requests.Request(method, url, auth=('onos', 'rocks'))
+ flow_list = []
+ for dev_id, flow_id in (flows):
+ flow = copy.deepcopy(template)
+ flow["deviceId"] = dev_id
+ flow["flowId"] = flow_id
+ flow_list.append(flow)
+ body = {"flows": flow_list}
+ url = 'http://' + cntl + ':' + '8181/onos/v1/flows/'
+ req_data = json.dumps(body)
+ req = requests.Request(method, url, headers={'Content-Type': 'application/json'},
+ data=req_data, auth=('onos', 'rocks'))