2 # -*- coding: utf-8 -*-
3 # PYTHON_ARGCOMPLETE_OK
6 # Copyright 2015 Telefónica Investigación y Desarrollo, S.A.U.
7 # This file is part of openmano
10 # Licensed under the Apache License, Version 2.0 (the "License"); you may
11 # not use this file except in compliance with the License. You may obtain
12 # a copy of the License at
14 # http://www.apache.org/licenses/LICENSE-2.0
16 # Unless required by applicable law or agreed to in writing, software
17 # distributed under the License is distributed on an "AS IS" BASIS, WITHOUT
18 # WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the
19 # License for the specific language governing permissions and limitations
22 # For those usages not covered by the Apache License, Version 2.0 please
23 # contact with: nfvlabs@tid.es
27 openmano client used to interact with openmano-server (openmanod)
29 __author__ = "Alfonso Tierno, Gerardo Garcia, Pablo Montes"
30 __date__ = "$09-oct-2014 09:09:48$"
31 __version__ = "0.4.21-r531"
32 version_date = "Oct 2017"
34 from argcomplete.completers import FilesCompleter
42 #from jsonschema import validate as js_v, exceptions as js_e
44 class ArgumentParserError(Exception): pass
46 class OpenmanoCLIError(Exception): pass
48 class ThrowingArgumentParser(argparse.ArgumentParser):
49 def error(self, message):
50 print "Error: %s" %message
55 print "Type 'openmano -h' for help"
56 raise ArgumentParserError
60 print "OPENMANO_HOST: %s" %mano_host
61 print "OPENMANO_PORT: %s" %mano_port
63 logger.debug("resolving tenant and datacenter names")
64 mano_tenant_id = "None"
65 mano_tenant_name = "None"
66 mano_datacenter_id = "None"
67 mano_datacenter_name = "None"
69 mano_tenant_id = _get_item_uuid("tenants", mano_tenant)
70 URLrequest = "http://%s:%s/openmano/tenants/%s" %(mano_host, mano_port, mano_tenant_id)
71 mano_response = requests.get(URLrequest)
72 logger.debug("openmano response: %s", mano_response.text )
73 content = mano_response.json()
74 mano_tenant_name = content["tenant"]["name"]
75 URLrequest = "http://%s:%s/openmano/%s/datacenters/%s" %(mano_host, mano_port, mano_tenant_id, mano_datacenter)
76 mano_response = requests.get(URLrequest)
77 logger.debug("openmano response: %s", mano_response.text )
78 content = mano_response.json()
79 if "error" not in content:
80 mano_datacenter_id = content["datacenter"]["uuid"]
81 mano_datacenter_name = content["datacenter"]["name"]
82 except OpenmanoCLIError:
84 print "OPENMANO_TENANT: %s" %mano_tenant
85 print " Id: %s" %mano_tenant_id
86 print " Name: %s" %mano_tenant_name
87 print "OPENMANO_DATACENTER: %s" %str (mano_datacenter)
88 print " Id: %s" %mano_datacenter_id
89 print " Name: %s" %mano_datacenter_name
91 print "OPENMANO_TENANT: %s" %mano_tenant
92 print "OPENMANO_DATACENTER: %s" %str (mano_datacenter)
94 def _print_verbose(mano_response, verbose_level=0):
95 content = mano_response.json()
96 result = 0 if mano_response.status_code==200 else mano_response.status_code
97 if type(content)!=dict or len(content)!=1:
98 #print "Non expected format output"
102 val=content.values()[0]
106 elif type(val) == list:
108 elif type(val)==dict:
111 #print "Non expected dict/list format output"
116 if verbose_level==None:
118 if verbose_level >= 3:
119 print yaml.safe_dump(content, indent=4, default_flow_style=False)
122 if mano_response.status_code == 200:
124 for content in content_list:
125 if "uuid" in content:
126 uuid = content['uuid']
127 elif "id" in content:
129 elif "vim_id" in content:
130 uuid = content['vim_id']
131 name = content.get('name');
136 myoutput = "{:38} {:20}".format(uuid, name)
137 if content.get("status"):
138 myoutput += " {:20}".format(content['status'])
139 elif "enabled" in content and not content["enabled"]:
140 myoutput += " enabled=False".ljust(20)
141 if verbose_level >=1:
142 if content.get('created_at'):
143 myoutput += " {:20}".format(content['created_at'])
144 if content.get('sdn_attached_ports'):
145 #myoutput += " " + str(content['sdn_attached_ports']).ljust(20)
146 myoutput += "\nsdn_attached_ports:\n" + yaml.safe_dump(content['sdn_attached_ports'], indent=4, default_flow_style=False)
147 if verbose_level >=2:
149 if content.get('type'):
150 myoutput += new_line + " Type: {:29}".format(content['type'])
152 if content.get('description'):
153 myoutput += new_line + " Description: {:20}".format(content['description'])
156 print content['error']['description']
159 def parser_json_yaml(file_name):
161 f = file(file_name, "r")
164 except Exception as e:
165 return (False, str(e))
168 if file_name[-5:]=='.yaml' or file_name[-4:]=='.yml' or (file_name[-5:]!='.json' and '\t' not in text):
170 config = yaml.load(text)
171 except yaml.YAMLError as exc:
173 if hasattr(exc, 'problem_mark'):
174 mark = exc.problem_mark
175 error_pos = " at line:%s column:%s" % (mark.line+1, mark.column+1)
176 return (False, "Error loading file '"+file_name+"' yaml format error" + error_pos)
179 config = json.loads(text)
180 except Exception as e:
181 return (False, "Error loading file '"+file_name+"' json format error " + str(e) )
185 def _load_file_or_yaml(content):
187 'content' can be or a yaml/json file or a text containing a yaml/json text format
188 This function autodetect, trying to load and parse the file,
189 if fails trying to parse the 'content' text
190 Returns the dictionary once parsed, or print an error and finish the program
192 #Check config file exists
193 if os.path.isfile(content):
194 r,payload = parser_json_yaml(content)
198 elif "{" in content or ":" in content:
200 payload = yaml.load(content)
201 except yaml.YAMLError as exc:
203 if hasattr(exc, 'problem_mark'):
204 mark = exc.problem_mark
205 error_pos = " at position: (%s:%s)" % (mark.line+1, mark.column+1)
206 print "Error loading yaml/json text"+error_pos
209 print "'%s' is neither a valid file nor a yaml/json content" % content
213 def _get_item_uuid(item, item_name_id, tenant=None):
215 URLrequest = "http://%s:%s/openmano/%s/%s" %(mano_host, mano_port, tenant, item)
217 URLrequest = "http://%s:%s/openmano/%s" %(mano_host, mano_port, item)
218 mano_response = requests.get(URLrequest)
219 logger.debug("openmano response: %s", mano_response.text )
220 content = mano_response.json()
223 for i in content[item]:
224 if i["uuid"] == item_name_id:
226 if i["name"] == item_name_id:
229 if item_name_id.startswith("osm_id=") and i.get("osm_id") == item_name_id[7:]:
233 raise OpenmanoCLIError("No %s found with name/uuid '%s'" %(item[:-1], item_name_id))
235 raise OpenmanoCLIError("%d %s found with name '%s'. uuid must be used" %(found, item, item_name_id))
238 # def check_valid_uuid(uuid):
239 # id_schema = {"type" : "string", "pattern": "^[a-fA-F0-9]{8}(-[a-fA-F0-9]{4}){3}-[a-fA-F0-9]{12}$"}
241 # js_v(uuid, id_schema)
243 # except js_e.ValidationError:
246 def _get_tenant(tenant_name_id = None):
247 if not tenant_name_id:
248 tenant_name_id = mano_tenant
250 raise OpenmanoCLIError("'OPENMANO_TENANT' environment variable is not set")
251 return _get_item_uuid("tenants", tenant_name_id)
253 def _get_datacenter(datacenter_name_id = None, tenant = "any"):
254 if not datacenter_name_id:
255 datacenter_name_id = mano_datacenter
256 if not datacenter_name_id:
257 raise OpenmanoCLIError("neither 'OPENMANO_DATACENTER' environment variable is set nor --datacenter option is used")
258 return _get_item_uuid("datacenters", datacenter_name_id, tenant)
260 def vnf_create(args):
261 #print "vnf-create",args
262 headers_req = {'Accept': 'application/json', 'content-type': 'application/json'}
263 tenant = _get_tenant()
264 myvnf = _load_file_or_yaml(args.file)
266 if "vnfd:vnfd-catalog" in myvnf or "vnfd-catalog" in myvnf:
269 vnfd_catalog = myvnf.get("vnfd:vnfd-catalog")
271 vnfd_catalog = myvnf.get("vnfd-catalog")
272 vnfds = vnfd_catalog.get("vnfd:vnfd")
274 vnfds = vnfd_catalog.get("vnfd")
276 vdu_list = vnfd["vdu"]
282 vdu_list = vnfd["VNFC"]
284 if args.name or args.description or args.image_path or args.image_name or args.image_checksum:
285 # TODO, change this for API v3
289 vnfd['name'] = args.name
291 vnfd['description'] = args.description
294 for image_path_ in args.image_path.split(","):
295 # print "image-path", image_path_
296 if api_version == "/v3":
297 if vdu_list[index].get("image"):
298 vdu_list[index]['image'] = image_path_
299 if "image-checksum" in vdu_list[index]:
300 del vdu_list[index]["image-checksum"]
301 else: # image name in volumes
302 vdu_list[index]["volumes"][0]["image"] = image_path_
303 if "image-checksum" in vdu_list[index]["volumes"][0]:
304 del vdu_list[index]["volumes"][0]["image-checksum"]
306 vdu_list[index]['VNFC image'] = image_path_
307 if "image name" in vdu_list[index]:
308 del vdu_list[index]["image name"]
309 if "image checksum" in vdu_list[index]:
310 del vdu_list[index]["image checksum"]
312 if args.image_name: # image name precedes if both are supplied
314 for image_name_ in args.image_name.split(","):
315 if api_version == "/v3":
316 if vdu_list[index].get("image"):
317 vdu_list[index]['image'] = image_name_
318 if "image-checksum" in vdu_list[index]:
319 del vdu_list[index]["image-checksum"]
320 else: # image name in volumes
321 vdu_list[index]["volumes"][0]["image"] = image_name_
322 if "image-checksum" in vdu_list[index]["volumes"][0]:
323 del vdu_list[index]["volumes"][0]["image-checksum"]
325 vdu_list[index]['image name'] = image_name_
326 if "VNFC image" in vdu_list[index]:
327 del vdu_list[index]["VNFC image"]
329 if args.image_checksum:
331 for image_checksum_ in args.image_checksum.split(","):
332 if api_version == "/v3":
333 if vdu_list[index].get("image"):
334 vdu_list[index]['image-checksum'] = image_checksum_
335 else: # image name in volumes
336 vdu_list[index]["volumes"][0]["image-checksum"] = image_checksum_
338 vdu_list[index]['image checksum'] = image_checksum_
340 except (KeyError, TypeError), e:
341 if str(e) == 'vnf': error_pos= "missing field 'vnf'"
342 elif str(e) == 'name': error_pos= "missing field 'vnf':'name'"
343 elif str(e) == 'description': error_pos= "missing field 'vnf':'description'"
344 elif str(e) == 'VNFC': error_pos= "missing field 'vnf':'VNFC'"
345 elif str(e) == str(index): error_pos= "field 'vnf':'VNFC' must be an array"
346 elif str(e) == 'VNFC image': error_pos= "missing field 'vnf':'VNFC'['VNFC image']"
347 elif str(e) == 'image name': error_pos= "missing field 'vnf':'VNFC'['image name']"
348 elif str(e) == 'image checksum': error_pos= "missing field 'vnf':'VNFC'['image checksum']"
349 else: error_pos="wrong format"
350 print "Wrong VNF descriptor: " + error_pos
352 payload_req = json.dumps(myvnf)
356 URLrequest = "http://{}:{}/openmano{}/{}/{token}".format(mano_host, mano_port, api_version, tenant, token=token)
357 logger.debug("openmano request: %s", payload_req)
358 mano_response = requests.post(URLrequest, headers = headers_req, data=payload_req)
359 logger.debug("openmano response: %s", mano_response.text )
361 return _print_verbose(mano_response, args.verbose)
364 #print "vnf-list",args
368 tenant = _get_tenant()
370 toshow = _get_item_uuid("vnfs", args.name, tenant)
371 URLrequest = "http://%s:%s/openmano/%s/vnfs/%s" %(mano_host, mano_port, tenant, toshow)
373 URLrequest = "http://%s:%s/openmano/%s/vnfs" %(mano_host, mano_port, tenant)
374 mano_response = requests.get(URLrequest)
375 logger.debug("openmano response: %s", mano_response.text )
376 content = mano_response.json()
377 # print json.dumps(content, indent=4)
378 if args.verbose==None:
380 result = 0 if mano_response.status_code==200 else mano_response.status_code
381 if mano_response.status_code == 200:
383 if args.verbose >= 3:
384 print yaml.safe_dump(content, indent=4, default_flow_style=False)
386 if len(content['vnfs']) == 0:
387 print "No VNFs were found."
388 return 404 # HTTP_Not_Found
389 for vnf in content['vnfs']:
390 myoutput = "{:38} {:20}".format(vnf['uuid'], vnf['name'])
391 if vnf.get('osm_id') or args.verbose >= 1:
392 myoutput += " osm_id={:20}".format(vnf.get('osm_id'))
393 if args.verbose >= 1:
394 myoutput += " {}".format(vnf['created_at'])
396 if args.verbose >= 2:
397 print (" Description: {}".format(vnf['description']))
398 # print (" VNF descriptor file: {}".format(vnf['path']))
401 print yaml.safe_dump(content, indent=4, default_flow_style=False)
404 print ("{:38} {:20} osm_id={:20} {:20}".format(vnf['uuid'], vnf['name'], vnf.get('osm_id'),
406 print (" Description: {}".format(vnf['description']))
407 # print " VNF descriptor file: %s" %vnf['path']
409 for vm in vnf['VNFC']:
410 print (" {:20} osm_id={:20} {}".format(vm['name'], vm.get('osm_id'), vm['description']))
411 if len(vnf['nets']) > 0:
412 print (" Internal nets:")
413 for net in vnf['nets']:
414 print (" {:20} {}".format(net['name'], net['description']))
415 if len(vnf['external-connections']) > 0:
416 print (" External interfaces:")
417 for interface in vnf['external-connections']:
418 print (" {:20} {:20} {:20} {:14}".format(
419 interface['external_name'], interface['vm_name'],
420 interface['internal_name'],
421 interface.get('vpci') if interface.get('vpci') else ""))
423 print content['error']['description']
425 print yaml.safe_dump(content, indent=4, default_flow_style=False)
428 def vnf_delete(args):
429 #print "vnf-delete",args
433 tenant = _get_tenant()
434 todelete = _get_item_uuid("vnfs", args.name, tenant=tenant)
436 r = raw_input("Delete VNF %s (y/N)? " %(todelete))
437 if not (len(r)>0 and r[0].lower()=="y"):
439 URLrequest = "http://%s:%s/openmano/%s/vnfs/%s" %(mano_host, mano_port, tenant, todelete)
440 mano_response = requests.delete(URLrequest)
441 logger.debug("openmano response: %s", mano_response.text )
442 result = 0 if mano_response.status_code==200 else mano_response.status_code
443 content = mano_response.json()
444 #print json.dumps(content, indent=4)
445 if mano_response.status_code == 200:
446 print content['result']
448 print content['error']['description']
451 def scenario_create(args):
452 # print "scenario-create",args
453 tenant = _get_tenant()
454 headers_req = {'content-type': 'application/yaml'}
455 myscenario = _load_file_or_yaml(args.file)
456 if "nsd:nsd-catalog" in myscenario or "nsd-catalog" in myscenario:
459 nsd_catalog = myscenario.get("nsd:nsd-catalog")
461 nsd_catalog = myscenario.get("nsd-catalog")
462 nsds = nsd_catalog.get("nsd:nsd")
464 nsds = nsd_catalog.get("nsd")
469 if "scenario" in myscenario:
470 nsd = myscenario["scenario"]
473 # TODO modify for API v3
475 nsd['name'] = args.name
477 nsd['description'] = args.description
478 payload_req = yaml.safe_dump(myscenario, explicit_start=True, indent=4, default_flow_style=False, tags=False,
479 encoding='utf-8', allow_unicode=True)
482 URLrequest = "http://{host}:{port}/openmano{api}/{tenant}/{token}".format(
483 host=mano_host, port=mano_port, api=api_version, tenant=tenant, token=token)
484 logger.debug("openmano request: %s", payload_req)
485 mano_response = requests.post(URLrequest, headers = headers_req, data=payload_req)
486 logger.debug("openmano response: %s", mano_response.text )
487 return _print_verbose(mano_response, args.verbose)
489 def scenario_list(args):
490 #print "scenario-list",args
494 tenant = _get_tenant()
496 toshow = _get_item_uuid("scenarios", args.name, tenant)
497 URLrequest = "http://%s:%s/openmano/%s/scenarios/%s" %(mano_host, mano_port, tenant, toshow)
499 URLrequest = "http://%s:%s/openmano/%s/scenarios" %(mano_host, mano_port, tenant)
500 mano_response = requests.get(URLrequest)
501 logger.debug("openmano response: %s", mano_response.text )
502 content = mano_response.json()
503 #print json.dumps(content, indent=4)
504 if args.verbose==None:
507 result = 0 if mano_response.status_code==200 else mano_response.status_code
508 if mano_response.status_code == 200:
510 if args.verbose >= 3:
511 print yaml.safe_dump(content, indent=4, default_flow_style=False)
513 if len(content['scenarios']) == 0:
514 print "No scenarios were found."
515 return 404 #HTTP_Not_Found
516 for scenario in content['scenarios']:
517 myoutput = "{:38} {:20}".format(scenario['uuid'], scenario['name'])
518 if scenario.get('osm_id') or args.verbose >= 1:
519 myoutput += " osm_id={:20}".format(scenario.get('osm_id'))
520 if args.verbose >= 1:
521 myoutput += " {}".format(scenario['created_at'])
524 print (" Description: {}".format(scenario['description']))
527 print yaml.safe_dump(content, indent=4, default_flow_style=False)
529 scenario = content['scenario']
530 print ("{:38} {:20} osm_id={:20} {:20}".format(scenario['uuid'], scenario['name'], scenario.get('osm_id'),
531 scenario['created_at']))
532 print (" Description: {}".format(scenario['description']))
534 for vnf in scenario['vnfs']:
535 print (" {:38} {:20} vnf_index={} {}".format(vnf['vnf_id'], vnf['name'], vnf.get("member_vnf_index"),
537 if len(scenario['nets']) > 0:
539 for net in scenario['nets']:
540 description = net['description']
541 if not description: # if description does not exist, description is "-". Valid for external and internal nets.
544 if net.get('vim_id'):
545 vim_id = " vim_id=" + net["vim_id"]
548 external = " external"
549 print (" {:20} {:38} {:30}{}{}".format(net['name'], net['uuid'], description, vim_id, external))
551 print (content['error']['description'])
553 print yaml.safe_dump(content, indent=4, default_flow_style=False)
556 def scenario_delete(args):
557 #print "scenario-delete",args
561 tenant = _get_tenant()
562 todelete = _get_item_uuid("scenarios", args.name, tenant=tenant)
564 r = raw_input("Delete scenario %s (y/N)? " %(args.name))
565 if not (len(r)>0 and r[0].lower()=="y"):
567 URLrequest = "http://%s:%s/openmano/%s/scenarios/%s" %(mano_host, mano_port, tenant, todelete)
568 mano_response = requests.delete(URLrequest)
569 logger.debug("openmano response: %s", mano_response.text )
570 result = 0 if mano_response.status_code==200 else mano_response.status_code
571 content = mano_response.json()
572 #print json.dumps(content, indent=4)
573 if mano_response.status_code == 200:
574 print content['result']
576 print content['error']['description']
579 def scenario_deploy(args):
580 print "This command is deprecated, use 'openmano instance-scenario-create --scenario %s --name %s' instead!!!" % (args.scenario, args.name)
583 args.netmap_use = None
584 args.netmap_create = None
586 args.keypair_auto = None
587 return instance_create(args)
589 # #print "scenario-deploy",args
590 # headers_req = {'content-type': 'application/json'}
594 # actionCmd="reserve"
595 # action[actionCmd] = {}
596 # action[actionCmd]["instance_name"] = args.name
597 # if args.datacenter != None:
598 # action[actionCmd]["datacenter"] = args.datacenter
599 # elif mano_datacenter != None:
600 # action[actionCmd]["datacenter"] = mano_datacenter
602 # if args.description:
603 # action[actionCmd]["description"] = args.description
604 # payload_req = json.dumps(action, indent=4)
607 # URLrequest = "http://%s:%s/openmano/%s/scenarios/%s/action" %(mano_host, mano_port, mano_tenant, args.scenario)
608 # logger.debug("openmano request: %s", payload_req)
609 # mano_response = requests.post(URLrequest, headers = headers_req, data=payload_req)
610 # logger.debug("openmano response: %s", mano_response.text )
611 # if args.verbose==None:
614 # result = 0 if mano_response.status_code==200 else mano_response.status_code
615 # content = mano_response.json()
616 # #print json.dumps(content, indent=4)
617 # if args.verbose >= 3:
618 # print yaml.safe_dump(content, indent=4, default_flow_style=False)
621 # if mano_response.status_code == 200:
622 # myoutput = "%s %s" %(content['uuid'].ljust(38),content['name'].ljust(20))
623 # if args.verbose >=1:
624 # myoutput = "%s %s" %(myoutput, content['created_at'].ljust(20))
625 # if args.verbose >=2:
626 # myoutput = "%s %s %s" %(myoutput, content['description'].ljust(30))
629 # print "To check the status, run the following command:"
630 # print "openmano instance-scenario-list <instance_id>"
632 # print content['error']['description']
635 def scenario_verify(args):
636 #print "scenario-verify",args
637 tenant = _get_tenant()
638 headers_req = {'content-type': 'application/json'}
640 action["verify"] = {}
641 action["verify"]["instance_name"] = "scen-verify-return5"
642 payload_req = json.dumps(action, indent=4)
645 URLrequest = "http://%s:%s/openmano/%s/scenarios/%s/action" %(mano_host, mano_port, tenant, args.scenario)
646 logger.debug("openmano request: %s", payload_req)
647 mano_response = requests.post(URLrequest, headers = headers_req, data=payload_req)
648 logger.debug("openmano response: %s", mano_response.text )
650 result = 0 if mano_response.status_code==200 else mano_response.status_code
651 content = mano_response.json()
652 #print json.dumps(content, indent=4)
653 if mano_response.status_code == 200:
654 print content['result']
656 print content['error']['description']
659 def instance_create(args):
660 tenant = _get_tenant()
661 headers_req = {'content-type': 'application/yaml'}
662 myInstance={"instance": {}, "schema_version": "0.1"}
664 instance_dict = _load_file_or_yaml(args.file)
665 if "instance" not in instance_dict:
666 myInstance = {"instance": instance_dict, "schema_version": "0.1"}
668 myInstance = instance_dict
670 myInstance["instance"]['name'] = args.name
672 myInstance["instance"]['description'] = args.description
674 myInstance["instance"]['action'] = "reserve"
676 datacenter = myInstance["instance"].get("datacenter")
677 if args.datacenter != None:
678 datacenter = args.datacenter
679 myInstance["instance"]["datacenter"] = _get_datacenter(datacenter, tenant)
681 scenario = myInstance["instance"].get("scenario")
682 if args.scenario != None:
683 scenario = args.scenario
685 print "you must provide a scenario in the file descriptor or with --scenario"
687 myInstance["instance"]["scenario"] = _get_item_uuid("scenarios", scenario, tenant)
689 if "networks" not in myInstance["instance"]:
690 myInstance["instance"]["networks"] = {}
691 for net in args.netmap_use:
692 net_comma_list = net.split(",")
693 for net_comma in net_comma_list:
694 net_tuple = net_comma.split("=")
695 if len(net_tuple) != 2:
696 print "error at netmap-use. Expected net-scenario=net-datacenter. (%s)?" % net_comma
698 net_scenario = net_tuple[0].strip()
699 net_datacenter = net_tuple[1].strip()
700 if net_scenario not in myInstance["instance"]["networks"]:
701 myInstance["instance"]["networks"][net_scenario] = {}
702 if "sites" not in myInstance["instance"]["networks"][net_scenario]:
703 myInstance["instance"]["networks"][net_scenario]["sites"] = [ {} ]
704 myInstance["instance"]["networks"][net_scenario]["sites"][0]["netmap-use"] = net_datacenter
705 if args.netmap_create:
706 if "networks" not in myInstance["instance"]:
707 myInstance["instance"]["networks"] = {}
708 for net in args.netmap_create:
709 net_comma_list = net.split(",")
710 for net_comma in net_comma_list:
711 net_tuple = net_comma.split("=")
712 if len(net_tuple) == 1:
713 net_scenario = net_tuple[0].strip()
714 net_datacenter = None
715 elif len(net_tuple) == 2:
716 net_scenario = net_tuple[0].strip()
717 net_datacenter = net_tuple[1].strip()
719 print "error at netmap-create. Expected net-scenario=net-datacenter or net-scenario. (%s)?" % net_comma
721 if net_scenario not in myInstance["instance"]["networks"]:
722 myInstance["instance"]["networks"][net_scenario] = {}
723 if "sites" not in myInstance["instance"]["networks"][net_scenario]:
724 myInstance["instance"]["networks"][net_scenario]["sites"] = [ {} ]
725 myInstance["instance"]["networks"][net_scenario]["sites"][0]["netmap-create"] = net_datacenter
727 if "cloud-config" not in myInstance["instance"]:
728 myInstance["instance"]["cloud-config"] = {}
729 cloud_config = myInstance["instance"]["cloud-config"]
730 for key in args.keypair:
731 index = key.find(":")
733 if "key-pairs" not in cloud_config:
734 cloud_config["key-pairs"] = []
735 cloud_config["key-pairs"].append(key)
739 key_list = key_.split(",")
740 if "users" not in cloud_config:
741 cloud_config["users"] = []
742 cloud_config["users"].append({"name": user, "key-pairs": key_list })
743 if args.keypair_auto:
746 home = os.getenv("HOME")
747 user = os.getenv("USER")
748 files = os.listdir(home+'/.ssh')
750 if file[-4:] == ".pub":
751 with open(home+'/.ssh/'+file, 'r') as f:
752 keys.append(f.read())
754 print "Cannot obtain any public ssh key from '{}'. Try not using --keymap-auto".format(home+'/.ssh')
756 except Exception as e:
757 print "Cannot obtain any public ssh key. Error '{}'. Try not using --keymap-auto".format(str(e))
760 if "cloud-config" not in myInstance["instance"]:
761 myInstance["instance"]["cloud-config"] = {}
762 cloud_config = myInstance["instance"]["cloud-config"]
763 if "key-pairs" not in cloud_config:
764 cloud_config["key-pairs"] = []
766 if "users" not in cloud_config:
767 cloud_config["users"] = []
768 cloud_config["users"].append({"name": user, "key-pairs": keys })
770 payload_req = yaml.safe_dump(myInstance, explicit_start=True, indent=4, default_flow_style=False, tags=False, encoding='utf-8', allow_unicode=True)
771 logger.debug("openmano request: %s", payload_req)
772 URLrequest = "http://%s:%s/openmano/%s/instances" %(mano_host, mano_port, tenant)
773 mano_response = requests.post(URLrequest, headers = headers_req, data=payload_req)
774 logger.debug("openmano response: %s", mano_response.text )
775 if args.verbose==None:
778 result = 0 if mano_response.status_code==200 else mano_response.status_code
779 content = mano_response.json()
780 #print json.dumps(content, indent=4)
781 if args.verbose >= 3:
782 print yaml.safe_dump(content, indent=4, default_flow_style=False)
785 if mano_response.status_code == 200:
786 myoutput = "{:38} {:20}".format(content['uuid'], content['name'])
788 myoutput = "{} {:20}".format(myoutput, content['created_at'])
790 myoutput = "{} {:30}".format(myoutput, content['description'])
793 print content['error']['description']
796 def instance_scenario_list(args):
797 #print "instance-scenario-list",args
801 tenant = _get_tenant()
803 toshow = _get_item_uuid("instances", args.name, tenant)
804 URLrequest = "http://%s:%s/openmano/%s/instances/%s" %(mano_host, mano_port, tenant, toshow)
806 URLrequest = "http://%s:%s/openmano/%s/instances" %(mano_host, mano_port, tenant)
807 mano_response = requests.get(URLrequest)
808 logger.debug("openmano response: %s", mano_response.text )
809 content = mano_response.json()
810 #print json.dumps(content, indent=4)
811 if args.verbose==None:
814 result = 0 if mano_response.status_code==200 else mano_response.status_code
815 if mano_response.status_code == 200:
817 if args.verbose >= 3:
818 print yaml.safe_dump(content, indent=4, default_flow_style=False)
820 if len(content['instances']) == 0:
821 print "No scenario instances were found."
823 for instance in content['instances']:
824 myoutput = "{:38} {:20}".format(instance['uuid'], instance['name'])
826 myoutput = "{} {:20}".format(myoutput, instance['created_at'])
829 print "Description: %s" %instance['description']
832 print yaml.safe_dump(content, indent=4, default_flow_style=False)
835 print ("{:38} {:20} {:20}".format(instance['uuid'],instance['name'],instance['created_at']))
836 print ("Description: %s" %instance['description'])
837 print ("Template scenario id: {}".format(instance['scenario_id']))
838 print ("Template scenario name: {}".format(instance['scenario_name']))
839 print ("---------------------------------------")
840 print ("VNF instances: {}".format(len(instance['vnfs'])))
841 for vnf in instance['vnfs']:
842 #print " %s %s Template vnf name: %s Template vnf id: %s" %(vnf['uuid'].ljust(38), vnf['name'].ljust(20), vnf['vnf_name'].ljust(20), vnf['vnf_id'].ljust(38))
843 print (" {:38} {:20} Template vnf id: {:38}".format(vnf['uuid'], vnf['vnf_name'], vnf['vnf_id']))
844 if len(instance['nets'])>0:
845 print "---------------------------------------"
846 print "Internal nets:"
847 for net in instance['nets']:
849 print (" {:38} {:12} VIM ID: {}".format(net['uuid'], net['status'], net['vim_net_id']))
850 print "---------------------------------------"
851 print "External nets:"
852 for net in instance['nets']:
853 if not net['created']:
854 print (" {:38} {:12} VIM ID: {}".format(net['uuid'], net['status'], net['vim_net_id']))
855 print ("---------------------------------------")
856 print ("VM instances:")
857 for vnf in instance['vnfs']:
858 for vm in vnf['vms']:
859 print (" {:38} {:20} {:20} {:12} VIM ID: {}".format(vm['uuid'], vnf['vnf_name'], vm['name'],
860 vm['status'], vm['vim_vm_id']))
862 print content['error']['description']
864 print yaml.safe_dump(content, indent=4, default_flow_style=False)
867 def instance_scenario_status(args):
868 print "instance-scenario-status"
871 def instance_scenario_delete(args):
875 tenant = _get_tenant()
876 todelete = _get_item_uuid("instances", args.name, tenant=tenant)
877 #print "instance-scenario-delete",args
879 r = raw_input("Delete scenario instance %s (y/N)? " %(args.name))
880 if not (len(r)>0 and r[0].lower()=="y"):
882 URLrequest = "http://%s:%s/openmano/%s/instances/%s" %(mano_host, mano_port, tenant, todelete)
883 mano_response = requests.delete(URLrequest)
884 logger.debug("openmano response: %s", mano_response.text )
885 result = 0 if mano_response.status_code==200 else mano_response.status_code
886 content = mano_response.json()
887 #print json.dumps(content, indent=4)
888 if mano_response.status_code == 200:
889 print content['result']
891 print content['error']['description']
894 def get_action(args):
896 tenant = _get_tenant()
899 if not args.instance:
902 instance_id =args.instance
905 action_id = "/" + args.id
906 URLrequest = "http://{}:{}/openmano/{}/instances/{}/action{}".format(mano_host, mano_port, tenant, instance_id,
908 mano_response = requests.get(URLrequest)
909 logger.debug("openmano response: %s", mano_response.text )
910 if args.verbose == None:
914 return _print_verbose(mano_response, args.verbose)
916 def instance_scenario_action(args):
917 #print "instance-scenario-action", args
918 tenant = _get_tenant()
919 toact = _get_item_uuid("instances", args.name, tenant=tenant)
921 action[ args.action ] = args.param
923 action["vnfs"] = args.vnf
925 action["vms"] = args.vm
927 headers_req = {'content-type': 'application/json'}
928 payload_req = json.dumps(action, indent=4)
929 URLrequest = "http://%s:%s/openmano/%s/instances/%s/action" %(mano_host, mano_port, tenant, toact)
930 logger.debug("openmano request: %s", payload_req)
931 mano_response = requests.post(URLrequest, headers = headers_req, data=payload_req)
932 logger.debug("openmano response: %s", mano_response.text )
933 result = 0 if mano_response.status_code==200 else mano_response.status_code
934 content = mano_response.json()
935 #print json.dumps(content, indent=4)
936 if mano_response.status_code == 200:
938 print yaml.safe_dump(content, indent=4, default_flow_style=False)
940 for uuid,c in content.iteritems():
941 print ("{:38} {:20} {:20}".format(uuid, c['name'], c['description']))
943 print content['error']['description']
947 def instance_vnf_list(args):
948 print "instance-vnf-list"
951 def instance_vnf_status(args):
952 print "instance-vnf-status"
955 def tenant_create(args):
956 headers_req = {'Accept': 'application/json', 'content-type': 'application/json'}
957 tenant_dict={"name": args.name}
958 if args.description!=None:
959 tenant_dict["description"] = args.description
960 payload_req = json.dumps( {"tenant": tenant_dict })
964 URLrequest = "http://%s:%s/openmano/tenants" %(mano_host, mano_port)
965 logger.debug("openmano request: %s", payload_req)
966 mano_response = requests.post(URLrequest, headers=headers_req, data=payload_req)
967 logger.debug("openmano response: %s", mano_response.text )
968 return _print_verbose(mano_response, args.verbose)
970 def tenant_list(args):
971 #print "tenant-list",args
973 toshow = _get_item_uuid("tenants", args.name)
974 URLrequest = "http://%s:%s/openmano/tenants/%s" %(mano_host, mano_port, toshow)
976 URLrequest = "http://%s:%s/openmano/tenants" %(mano_host, mano_port)
977 mano_response = requests.get(URLrequest)
978 logger.debug("openmano response: %s", mano_response.text )
979 if args.verbose==None:
983 return _print_verbose(mano_response, args.verbose)
985 def tenant_delete(args):
986 #print "tenant-delete",args
987 todelete = _get_item_uuid("tenants", args.name)
989 r = raw_input("Delete tenant %s (y/N)? " %(args.name))
990 if not (len(r)>0 and r[0].lower()=="y"):
992 URLrequest = "http://%s:%s/openmano/tenants/%s" %(mano_host, mano_port, todelete)
993 mano_response = requests.delete(URLrequest)
994 logger.debug("openmano response: %s", mano_response.text )
995 result = 0 if mano_response.status_code==200 else mano_response.status_code
996 content = mano_response.json()
997 #print json.dumps(content, indent=4)
998 if mano_response.status_code == 200:
999 print content['result']
1001 print content['error']['description']
1004 def datacenter_attach(args):
1005 tenant = _get_tenant()
1006 datacenter = _get_datacenter(args.name)
1007 headers_req = {'Accept': 'application/json', 'content-type': 'application/json'}
1010 if args.vim_tenant_id != None:
1011 datacenter_dict['vim_tenant'] = args.vim_tenant_id
1012 if args.vim_tenant_name != None:
1013 datacenter_dict['vim_tenant_name'] = args.vim_tenant_name
1014 if args.user != None:
1015 datacenter_dict['vim_username'] = args.user
1016 if args.password != None:
1017 datacenter_dict['vim_password'] = args.password
1018 if args.config!=None:
1019 datacenter_dict["config"] = _load_file_or_yaml(args.config)
1020 payload_req = json.dumps( {"datacenter": datacenter_dict })
1024 URLrequest = "http://%s:%s/openmano/%s/datacenters/%s" %(mano_host, mano_port, tenant, datacenter)
1025 logger.debug("openmano request: %s", payload_req)
1026 mano_response = requests.post(URLrequest, headers=headers_req, data=payload_req)
1027 logger.debug("openmano response: %s", mano_response.text )
1028 result = _print_verbose(mano_response, args.verbose)
1029 #provide addional information if error
1030 if mano_response.status_code != 200:
1031 content = mano_response.json()
1032 if "already in use for 'name'" in content['error']['description'] and \
1033 "to database vim_tenants table" in content['error']['description']:
1034 print "Try to specify a different name with --vim-tenant-name"
1038 def datacenter_edit_vim_tenant(args):
1039 tenant = _get_tenant()
1040 datacenter = _get_datacenter(args.name)
1041 headers_req = {'Accept': 'application/json', 'content-type': 'application/json'}
1043 if not (args.vim_tenant_id or args.vim_tenant_name or args.user or args.password or args.config):
1044 raise OpenmanoCLIError("Error. At least one parameter must be updated.")
1046 datacenter_dict = {}
1047 if args.vim_tenant_id != None:
1048 datacenter_dict['vim_tenant'] = args.vim_tenant_id
1049 if args.vim_tenant_name != None:
1050 datacenter_dict['vim_tenant_name'] = args.vim_tenant_name
1051 if args.user != None:
1052 datacenter_dict['vim_username'] = args.user
1053 if args.password != None:
1054 datacenter_dict['vim_password'] = args.password
1055 if args.config != None:
1056 datacenter_dict["config"] = _load_file_or_yaml(args.config)
1057 payload_req = json.dumps({"datacenter": datacenter_dict})
1061 URLrequest = "http://%s:%s/openmano/%s/datacenters/%s" % (mano_host, mano_port, tenant, datacenter)
1062 logger.debug("openmano request: %s", payload_req)
1063 mano_response = requests.put(URLrequest, headers=headers_req, data=payload_req)
1064 logger.debug("openmano response: %s", mano_response.text)
1065 result = _print_verbose(mano_response, args.verbose)
1069 def datacenter_detach(args):
1073 tenant = _get_tenant()
1074 datacenter = _get_datacenter(args.name, tenant)
1075 headers_req = {'Accept': 'application/json', 'content-type': 'application/json'}
1076 URLrequest = "http://%s:%s/openmano/%s/datacenters/%s" %(mano_host, mano_port, tenant, datacenter)
1077 mano_response = requests.delete(URLrequest, headers=headers_req)
1078 logger.debug("openmano response: %s", mano_response.text )
1079 content = mano_response.json()
1080 #print json.dumps(content, indent=4)
1081 result = 0 if mano_response.status_code==200 else mano_response.status_code
1082 if mano_response.status_code == 200:
1083 print content['result']
1085 print content['error']['description']
1088 def datacenter_create(args):
1089 headers_req = {'Accept': 'application/json', 'content-type': 'application/json'}
1090 datacenter_dict={"name": args.name, "vim_url": args.url}
1091 if args.description!=None:
1092 datacenter_dict["description"] = args.description
1094 datacenter_dict["type"] = args.type
1096 datacenter_dict["vim_url_admin"] = args.url_admin
1097 if args.config!=None:
1098 datacenter_dict["config"] = _load_file_or_yaml(args.config)
1099 if args.sdn_controller!=None:
1100 tenant = _get_tenant()
1101 sdn_controller = _get_item_uuid("sdn_controllers", args.sdn_controller, tenant)
1102 if not 'config' in datacenter_dict:
1103 datacenter_dict['config'] = {}
1104 datacenter_dict['config']['sdn-controller'] = sdn_controller
1105 payload_req = json.dumps( {"datacenter": datacenter_dict })
1109 URLrequest = "http://%s:%s/openmano/datacenters" %(mano_host, mano_port)
1110 logger.debug("openmano request: %s", payload_req)
1111 mano_response = requests.post(URLrequest, headers=headers_req, data=payload_req)
1112 logger.debug("openmano response: %s", mano_response.text )
1113 return _print_verbose(mano_response, args.verbose)
1115 def datacenter_delete(args):
1116 #print "datacenter-delete",args
1117 todelete = _get_item_uuid("datacenters", args.name, "any")
1119 r = raw_input("Delete datacenter %s (y/N)? " %(args.name))
1120 if not (len(r)>0 and r[0].lower()=="y"):
1122 URLrequest = "http://%s:%s/openmano/datacenters/%s" %(mano_host, mano_port, todelete)
1123 mano_response = requests.delete(URLrequest)
1124 logger.debug("openmano response: %s", mano_response.text )
1125 result = 0 if mano_response.status_code==200 else mano_response.status_code
1126 content = mano_response.json()
1127 #print json.dumps(content, indent=4)
1128 if mano_response.status_code == 200:
1129 print content['result']
1131 print content['error']['description']
1135 def datacenter_list(args):
1136 #print "datacenter-list",args
1137 tenant='any' if args.all else _get_tenant()
1140 toshow = _get_item_uuid("datacenters", args.name, tenant)
1141 URLrequest = "http://%s:%s/openmano/%s/datacenters/%s" %(mano_host, mano_port, tenant, toshow)
1143 URLrequest = "http://%s:%s/openmano/%s/datacenters" %(mano_host, mano_port, tenant)
1144 mano_response = requests.get(URLrequest)
1145 logger.debug("openmano response: %s", mano_response.text )
1146 if args.verbose==None:
1150 return _print_verbose(mano_response, args.verbose)
1153 def datacenter_sdn_port_mapping_set(args):
1154 tenant = _get_tenant()
1155 datacenter = _get_datacenter(args.name, tenant)
1156 headers_req = {'Accept': 'application/json', 'content-type': 'application/json'}
1159 raise OpenmanoCLIError(
1160 "No yaml/json has been provided specifying the SDN port mapping")
1161 sdn_port_mapping = _load_file_or_yaml(args.file)
1162 payload_req = json.dumps({"sdn_port_mapping": sdn_port_mapping})
1165 URLrequest = "http://%s:%s/openmano/%s/datacenters/%s/sdn_mapping" % (mano_host, mano_port, tenant, datacenter)
1166 mano_response = requests.get(URLrequest)
1167 logger.debug("openmano response: %s", mano_response.text)
1168 port_mapping = mano_response.json()
1169 if mano_response.status_code != 200:
1170 str(mano_response.json())
1171 raise OpenmanoCLIError("openmano client error: {}".format(port_mapping['error']['description']))
1172 if len(port_mapping["sdn_port_mapping"]["ports_mapping"]) > 0:
1174 r = raw_input("Datacenter %s already contains a port mapping. Overwrite? (y/N)? " % (datacenter))
1175 if not (len(r) > 0 and r[0].lower() == "y"):
1179 URLrequest = "http://%s:%s/openmano/%s/datacenters/%s/sdn_mapping" % (mano_host, mano_port, tenant, datacenter)
1180 mano_response = requests.delete(URLrequest)
1181 logger.debug("openmano response: %s", mano_response.text)
1182 if mano_response.status_code != 200:
1183 return _print_verbose(mano_response, args.verbose)
1186 URLrequest = "http://%s:%s/openmano/%s/datacenters/%s/sdn_mapping" % (mano_host, mano_port, tenant, datacenter)
1187 logger.debug("openmano request: %s", payload_req)
1188 mano_response = requests.post(URLrequest, headers=headers_req, data=payload_req)
1189 logger.debug("openmano response: %s", mano_response.text)
1190 return _print_verbose(mano_response, args.verbose)
1193 def datacenter_sdn_port_mapping_list(args):
1194 tenant = _get_tenant()
1195 datacenter = _get_datacenter(args.name, tenant)
1197 URLrequest = "http://%s:%s/openmano/%s/datacenters/%s/sdn_mapping" % (mano_host, mano_port, tenant, datacenter)
1198 mano_response = requests.get(URLrequest)
1199 logger.debug("openmano response: %s", mano_response.text)
1201 return _print_verbose(mano_response, 4)
1204 def datacenter_sdn_port_mapping_clear(args):
1205 tenant = _get_tenant()
1206 datacenter = _get_datacenter(args.name, tenant)
1209 r = raw_input("Clean SDN port mapping for datacenter %s (y/N)? " %(datacenter))
1210 if not (len(r) > 0 and r[0].lower() == "y"):
1213 URLrequest = "http://%s:%s/openmano/%s/datacenters/%s/sdn_mapping" % (mano_host, mano_port, tenant, datacenter)
1214 mano_response = requests.delete(URLrequest)
1215 logger.debug("openmano response: %s", mano_response.text)
1217 return _print_verbose(mano_response, args.verbose)
1220 def sdn_controller_create(args):
1221 tenant = _get_tenant()
1222 headers_req = {'Accept': 'application/json', 'content-type': 'application/json'}
1225 if not args.ip: error_msg.append("'ip'")
1226 if not args.port: error_msg.append("'port'")
1227 if not args.dpid: error_msg.append("'dpid'")
1228 if not args.type: error_msg.append("'type'")
1230 raise OpenmanoCLIError("The following arguments are required: " + ",".join(error_msg))
1232 controller_dict = {}
1233 controller_dict['name'] = args.name
1234 controller_dict['ip'] = args.ip
1235 controller_dict['port'] = int(args.port)
1236 controller_dict['dpid'] = args.dpid
1237 controller_dict['type'] = args.type
1238 if args.description != None:
1239 controller_dict['description'] = args.description
1240 if args.user != None:
1241 controller_dict['user'] = args.user
1242 if args.password != None:
1243 controller_dict['password'] = args.password
1245 payload_req = json.dumps({"sdn_controller": controller_dict})
1249 URLrequest = "http://%s:%s/openmano/%s/sdn_controllers" % (mano_host, mano_port, tenant)
1250 logger.debug("openmano request: %s", payload_req)
1251 mano_response = requests.post(URLrequest, headers=headers_req, data=payload_req)
1252 logger.debug("openmano response: %s", mano_response.text)
1253 result = _print_verbose(mano_response, args.verbose)
1257 def sdn_controller_edit(args):
1258 tenant = _get_tenant()
1259 controller_uuid = _get_item_uuid("sdn_controllers", args.name, tenant)
1260 headers_req = {'Accept': 'application/json', 'content-type': 'application/json'}
1262 controller_dict = {}
1264 controller_dict['name'] = args.new_name
1266 controller_dict['ip'] = args.ip
1268 controller_dict['port'] = int(args.port)
1270 controller_dict['dpid'] = args.dpid
1272 controller_dict['type'] = args.type
1273 if args.description:
1274 controller_dict['description'] = args.description
1276 controller_dict['user'] = args.user
1278 controller_dict['password'] = args.password
1280 if not controller_dict:
1281 raise OpenmanoCLIError("At least one parameter must be edited")
1284 r = raw_input("Update SDN controller {} (y/N)? ".format(args.name))
1285 if not (len(r) > 0 and r[0].lower() == "y"):
1288 payload_req = json.dumps({"sdn_controller": controller_dict})
1291 URLrequest = "http://%s:%s/openmano/%s/sdn_controllers/%s" % (mano_host, mano_port, tenant, controller_uuid)
1292 logger.debug("openmano request: %s", payload_req)
1293 mano_response = requests.put(URLrequest, headers=headers_req, data=payload_req)
1294 logger.debug("openmano response: %s", mano_response.text)
1295 result = _print_verbose(mano_response, args.verbose)
1299 def sdn_controller_list(args):
1300 tenant = _get_tenant()
1301 headers_req = {'Accept': 'application/json', 'content-type': 'application/json'}
1304 toshow = _get_item_uuid("sdn_controllers", args.name, tenant)
1305 URLrequest = "http://%s:%s/openmano/%s/sdn_controllers/%s" %(mano_host, mano_port, tenant, toshow)
1307 URLrequest = "http://%s:%s/openmano/%s/sdn_controllers" %(mano_host, mano_port, tenant)
1309 mano_response = requests.get(URLrequest)
1310 logger.debug("openmano response: %s", mano_response.text )
1311 if args.verbose==None:
1316 # json.dumps(mano_response.json(), indent=4)
1317 return _print_verbose(mano_response, args.verbose)
1320 def sdn_controller_delete(args):
1321 tenant = _get_tenant()
1322 controller_uuid = _get_item_uuid("sdn_controllers", args.name, tenant)
1325 r = raw_input("Delete SDN controller %s (y/N)? " % (args.name))
1326 if not (len(r) > 0 and r[0].lower() == "y"):
1329 URLrequest = "http://%s:%s/openmano/%s/sdn_controllers/%s" % (mano_host, mano_port, tenant, controller_uuid)
1330 mano_response = requests.delete(URLrequest)
1331 logger.debug("openmano response: %s", mano_response.text)
1332 return _print_verbose(mano_response, args.verbose)
1334 def vim_action(args):
1335 #print "datacenter-net-action",args
1336 tenant = _get_tenant()
1337 datacenter = _get_datacenter(args.datacenter, tenant)
1338 if args.verbose==None:
1340 if args.action=="list":
1341 URLrequest = "http://%s:%s/openmano/%s/vim/%s/%ss" %(mano_host, mano_port, tenant, datacenter, args.item)
1344 URLrequest += "/" + args.name
1345 mano_response = requests.get(URLrequest)
1346 logger.debug("openmano response: %s", mano_response.text )
1347 return _print_verbose(mano_response, args.verbose)
1348 elif args.action=="delete":
1349 URLrequest = "http://%s:%s/openmano/%s/vim/%s/%ss/%s" %(mano_host, mano_port, tenant, datacenter, args.item, args.name)
1350 mano_response = requests.delete(URLrequest)
1351 logger.debug("openmano response: %s", mano_response.text )
1352 result = 0 if mano_response.status_code==200 else mano_response.status_code
1353 content = mano_response.json()
1354 #print json.dumps(content, indent=4)
1355 if mano_response.status_code == 200:
1356 print content['result']
1358 print content['error']['description']
1360 elif args.action=="create":
1361 headers_req = {'content-type': 'application/yaml'}
1363 create_dict = _load_file_or_yaml(args.file)
1364 if args.item not in create_dict:
1365 create_dict = {args.item: create_dict}
1367 create_dict = {args.item:{}}
1369 create_dict[args.item]['name'] = args.name
1370 #if args.description:
1371 # create_dict[args.item]['description'] = args.description
1372 if args.item=="network":
1374 create_dict[args.item]['bind_net'] = args.bind_net
1376 create_dict[args.item]['type'] = args.type
1378 create_dict[args.item]['shared'] = args.shared
1379 if "name" not in create_dict[args.item]:
1380 print "You must provide a name in the descriptor file or with the --name option"
1382 payload_req = yaml.safe_dump(create_dict, explicit_start=True, indent=4, default_flow_style=False, tags=False, encoding='utf-8', allow_unicode=True)
1383 logger.debug("openmano request: %s", payload_req)
1384 URLrequest = "http://%s:%s/openmano/%s/vim/%s/%ss" %(mano_host, mano_port, tenant, datacenter, args.item)
1385 mano_response = requests.post(URLrequest, headers = headers_req, data=payload_req)
1386 logger.debug("openmano response: %s", mano_response.text )
1387 if args.verbose==None:
1389 return _print_verbose(mano_response, args.verbose)
1392 def _get_items(item, item_name_id=None, datacenter=None, tenant=None):
1393 URLrequest = "http://%s:%s/openmano" %(mano_host, mano_port)
1395 URLrequest += "/" + tenant
1397 URLrequest += "/vim/" + datacenter
1399 URLrequest += "/" + item +"s"
1401 URLrequest += "/" + item_name_id
1402 mano_response = requests.get(URLrequest)
1403 logger.debug("openmano response: %s", mano_response.text )
1405 return mano_response
1408 def vim_net_sdn_attach(args):
1409 #Verify the network exists in the vim
1410 tenant = _get_tenant()
1411 datacenter = _get_datacenter(args.datacenter, tenant)
1412 result = _get_items('network', item_name_id=args.vim_net, datacenter=datacenter, tenant=tenant)
1413 content = yaml.load(result.content)
1414 if 'networks' in content:
1415 raise OpenmanoCLIError('More than one network in the vim named ' + args.vim_net + '. Use uuid instead')
1416 if 'error' in content:
1417 raise OpenmanoCLIError(yaml.safe_dump(content))
1418 network_uuid = content['network']['id']
1420 #Make call to attach the dataplane port to the SND network associated to the vim network
1421 headers_req = {'content-type': 'application/yaml'}
1422 payload_req = {'port': args.port}
1424 payload_req['vlan'] = int(args.vlan)
1426 payload_req['mac'] = args.mac
1428 URLrequest = "http://%s:%s/openmano/%s/vim/%s/network/%s/attach" % (mano_host, mano_port, tenant, datacenter, network_uuid)
1429 logger.debug("openmano request: %s", payload_req)
1430 mano_response = requests.post(URLrequest, headers=headers_req, data=json.dumps(payload_req))
1431 logger.debug("openmano response: %s", mano_response.text)
1432 result = _print_verbose(mano_response, args.verbose)
1436 def vim_net_sdn_detach(args):
1437 if not args.all and not args.id:
1438 print "--all or --id must be used"
1441 # Verify the network exists in the vim
1442 tenant = _get_tenant()
1443 datacenter = _get_datacenter(args.datacenter, tenant)
1444 result = _get_items('network', item_name_id=args.vim_net, datacenter=datacenter, tenant=tenant)
1445 content = yaml.load(result.content)
1446 if 'networks' in content:
1447 raise OpenmanoCLIError('More than one network in the vim named ' + args.vim_net + '. Use uuid instead')
1448 if 'error' in content:
1449 raise OpenmanoCLIError(yaml.safe_dump(content))
1450 network_uuid = content['network']['id']
1453 r = raw_input("Confirm action' (y/N)? ")
1454 if len(r) == 0 or r[0].lower() != "y":
1458 URLrequest = "http://%s:%s/openmano/%s/vim/%s/network/%s/detach/%s" % (
1459 mano_host, mano_port, tenant, datacenter, network_uuid, args.id)
1461 URLrequest = "http://%s:%s/openmano/%s/vim/%s/network/%s/detach" % (
1462 mano_host, mano_port, tenant, datacenter, network_uuid)
1463 mano_response = requests.delete(URLrequest)
1464 logger.debug("openmano response: %s", mano_response.text)
1465 result = _print_verbose(mano_response, args.verbose)
1469 def datacenter_net_action(args):
1470 if args.action == "net-update":
1471 print "This command is deprecated, use 'openmano datacenter-netmap-delete --all' and 'openmano datacenter-netmap-import' instead!!!"
1473 args.action = "netmap-delete"
1476 r = datacenter_netmap_action(args)
1479 args.action = "netmap-import"
1480 r = datacenter_netmap_action(args)
1483 if args.action == "net-edit":
1484 args.netmap = args.net
1486 elif args.action == "net-list":
1488 elif args.action == "net-delete":
1489 args.netmap = args.net
1492 args.action = "netmap" + args.action[3:]
1495 print "This command is deprecated, use 'openmano datacenter-%s' instead!!!" % args.action
1497 return datacenter_netmap_action(args)
1499 def datacenter_netmap_action(args):
1500 tenant = _get_tenant()
1501 datacenter = _get_datacenter(args.datacenter, tenant)
1502 #print "datacenter_netmap_action",args
1504 if args.verbose==None:
1506 headers_req = {'Accept': 'application/json', 'content-type': 'application/json'}
1507 URLrequest = "http://%s:%s/openmano/%s/datacenters/%s/netmaps" %(mano_host, mano_port, tenant, datacenter)
1509 if args.action=="netmap-list":
1511 URLrequest += "/" + args.netmap
1513 mano_response = requests.get(URLrequest)
1515 elif args.action=="netmap-delete":
1516 if args.netmap and args.all:
1517 print "you can not use a netmap name and the option --all at the same time"
1520 force_text= "Delete default netmap '%s' from datacenter '%s' (y/N)? " % (args.netmap, datacenter)
1521 URLrequest += "/" + args.netmap
1523 force_text="Delete all default netmaps from datacenter '%s' (y/N)? " % (datacenter)
1525 print "you must specify a netmap name or the option --all"
1528 r = raw_input(force_text)
1529 if len(r)>0 and r[0].lower()=="y":
1533 mano_response = requests.delete(URLrequest, headers=headers_req)
1534 elif args.action=="netmap-import":
1536 r = raw_input("Create all the available networks from datacenter '%s' as default netmaps (y/N)? " % (datacenter))
1537 if len(r)>0 and r[0].lower()=="y":
1541 URLrequest += "/upload"
1542 mano_response = requests.post(URLrequest, headers=headers_req)
1543 elif args.action=="netmap-edit" or args.action=="netmap-create":
1545 payload = _load_file_or_yaml(args.file)
1548 if "netmap" not in payload:
1549 payload = {"netmap": payload}
1551 payload["netmap"]["name"] = args.name
1553 payload["netmap"]["vim_id"] = args.vim_id
1554 if args.action=="netmap-create" and args.vim_name:
1555 payload["netmap"]["vim_name"] = args.vim_name
1556 payload_req = json.dumps(payload)
1557 logger.debug("openmano request: %s", payload_req)
1559 if args.action=="netmap-edit" and not args.force:
1560 if len(payload["netmap"]) == 0:
1561 print "You must supply some parameter to edit"
1563 r = raw_input("Edit default netmap '%s' from datacenter '%s' (y/N)? " % (args.netmap, datacenter))
1564 if len(r)>0 and r[0].lower()=="y":
1568 URLrequest += "/" + args.netmap
1569 mano_response = requests.put(URLrequest, headers=headers_req, data=payload_req)
1570 else: #netmap-create
1571 if "vim_name" not in payload["netmap"] and "vim_id" not in payload["netmap"]:
1572 print "You must supply either --vim-id or --vim-name option; or include one of them in the file descriptor"
1574 mano_response = requests.post(URLrequest, headers=headers_req, data=payload_req)
1576 logger.debug("openmano response: %s", mano_response.text )
1577 return _print_verbose(mano_response, args.verbose)
1580 def element_edit(args):
1581 element = _get_item_uuid(args.element, args.name)
1582 headers_req = {'Accept': 'application/json', 'content-type': 'application/json'}
1583 URLrequest = "http://%s:%s/openmano/%s/%s" %(mano_host, mano_port, args.element, element)
1584 payload=_load_file_or_yaml(args.file)
1585 if args.element[:-1] not in payload:
1586 payload = {args.element[:-1]: payload }
1587 payload_req = json.dumps(payload)
1590 if not args.force or (args.name==None and args.filer==None):
1591 r = raw_input(" Edit " + args.element[:-1] + " " + args.name + " (y/N)? ")
1592 if len(r)>0 and r[0].lower()=="y":
1596 logger.debug("openmano request: %s", payload_req)
1597 mano_response = requests.put(URLrequest, headers=headers_req, data=payload_req)
1598 logger.debug("openmano response: %s", mano_response.text )
1599 if args.verbose==None:
1603 return _print_verbose(mano_response, args.verbose)
1606 def datacenter_edit(args):
1607 tenant = _get_tenant()
1608 element = _get_item_uuid('datacenters', args.name, tenant)
1609 headers_req = {'Accept': 'application/json', 'content-type': 'application/json'}
1610 URLrequest = "http://%s:%s/openmano/datacenters/%s" % (mano_host, mano_port, element)
1612 has_arguments = False
1613 if args.file != None:
1614 has_arguments = True
1615 payload = _load_file_or_yaml(args.file)
1619 if args.sdn_controller != None:
1620 has_arguments = True
1621 if not 'config' in payload:
1622 payload['config'] = {}
1623 if not 'sdn-controller' in payload['config']:
1624 payload['config']['sdn-controller'] = {}
1625 if args.sdn_controller == 'null':
1626 payload['config']['sdn-controller'] = None
1628 payload['config']['sdn-controller'] = _get_item_uuid("sdn_controllers", args.sdn_controller, tenant)
1630 if not has_arguments:
1631 raise OpenmanoCLIError("At least one argument must be provided to modify the datacenter")
1633 if 'datacenter' not in payload:
1634 payload = {'datacenter': payload}
1635 payload_req = json.dumps(payload)
1638 if not args.force or (args.name == None and args.filer == None):
1639 r = raw_input(" Edit datacenter " + args.name + " (y/N)? ")
1640 if len(r) > 0 and r[0].lower() == "y":
1644 logger.debug("openmano request: %s", payload_req)
1645 mano_response = requests.put(URLrequest, headers=headers_req, data=payload_req)
1646 logger.debug("openmano response: %s", mano_response.text)
1647 if args.verbose == None:
1649 if args.name != None:
1651 return _print_verbose(mano_response, args.verbose)
1655 headers_req = {'Accept': 'application/json', 'content-type': 'application/json'}
1656 URLrequest = "http://%s:%s/openmano/version" % (mano_host, mano_port)
1658 mano_response = requests.get(URLrequest, headers=headers_req)
1659 logger.debug("openmano response: %s", mano_response.text)
1660 print mano_response.text
1667 if __name__=="__main__":
1669 mano_tenant = os.getenv('OPENMANO_TENANT', None)
1670 mano_host = os.getenv('OPENMANO_HOST',"localhost")
1671 mano_port = os.getenv('OPENMANO_PORT',"9090")
1672 mano_datacenter = os.getenv('OPENMANO_DATACENTER',None)
1674 main_parser = ThrowingArgumentParser(description='User program to interact with OPENMANO-SERVER (openmanod)')
1675 main_parser.add_argument('--version', action='version', help="get version of this client",
1676 version='%(prog)s client version ' + __version__ +
1677 " (Note: use '%(prog)s version' to get server version)")
1679 subparsers = main_parser.add_subparsers(help='commands')
1681 parent_parser = argparse.ArgumentParser(add_help=False)
1682 parent_parser.add_argument('--verbose', '-v', action='count', help="increase verbosity level. Use several times")
1683 parent_parser.add_argument('--debug', '-d', action='store_true', help="show debug information")
1685 config_parser = subparsers.add_parser('config', parents=[parent_parser], help="prints configuration values")
1686 config_parser.add_argument("-n", action="store_true", help="resolves tenant and datacenter names")
1687 config_parser.set_defaults(func=config)
1689 version_parser = subparsers.add_parser('version', parents=[parent_parser], help="get server version")
1690 version_parser.set_defaults(func=version)
1692 vnf_create_parser = subparsers.add_parser('vnf-create', parents=[parent_parser], help="adds a vnf into the catalogue")
1693 vnf_create_parser.add_argument("file", action="store", help="location of the JSON file describing the VNF").completer = FilesCompleter
1694 vnf_create_parser.add_argument("--name", action="store", help="name of the VNF (if it exists in the VNF descriptor, it is overwritten)")
1695 vnf_create_parser.add_argument("--description", action="store", help="description of the VNF (if it exists in the VNF descriptor, it is overwritten)")
1696 vnf_create_parser.add_argument("--image-path", action="store", help="change image path locations (overwritten)")
1697 vnf_create_parser.add_argument("--image-name", action="store", help="change image name (overwritten)")
1698 vnf_create_parser.add_argument("--image-checksum", action="store", help="change image checksum (overwritten)")
1699 vnf_create_parser.set_defaults(func=vnf_create)
1701 vnf_list_parser = subparsers.add_parser('vnf-list', parents=[parent_parser], help="lists information about a vnf")
1702 vnf_list_parser.add_argument("name", nargs='?', help="name of the VNF")
1703 vnf_list_parser.add_argument("-a", "--all", action="store_true", help="shows all vnfs, not only the owned or public ones")
1704 #vnf_list_parser.add_argument('--descriptor', help="prints the VNF descriptor", action="store_true")
1705 vnf_list_parser.set_defaults(func=vnf_list)
1707 vnf_delete_parser = subparsers.add_parser('vnf-delete', parents=[parent_parser], help="deletes a vnf from the catalogue")
1708 vnf_delete_parser.add_argument("name", action="store", help="name or uuid of the VNF to be deleted")
1709 vnf_delete_parser.add_argument("-f", "--force", action="store_true", help="forces deletion without asking")
1710 vnf_delete_parser.add_argument("-a", "--all", action="store_true", help="allow delete not owned or privated one")
1711 vnf_delete_parser.set_defaults(func=vnf_delete)
1713 scenario_create_parser = subparsers.add_parser('scenario-create', parents=[parent_parser], help="adds a scenario into the OPENMANO DB")
1714 scenario_create_parser.add_argument("file", action="store", help="location of the YAML file describing the scenario").completer = FilesCompleter
1715 scenario_create_parser.add_argument("--name", action="store", help="name of the scenario (if it exists in the YAML scenario, it is overwritten)")
1716 scenario_create_parser.add_argument("--description", action="store", help="description of the scenario (if it exists in the YAML scenario, it is overwritten)")
1717 scenario_create_parser.set_defaults(func=scenario_create)
1719 scenario_list_parser = subparsers.add_parser('scenario-list', parents=[parent_parser], help="lists information about a scenario")
1720 scenario_list_parser.add_argument("name", nargs='?', help="name of the scenario")
1721 #scenario_list_parser.add_argument('--descriptor', help="prints the scenario descriptor", action="store_true")
1722 scenario_list_parser.add_argument("-a", "--all", action="store_true", help="shows all scenarios, not only the owned or public ones")
1723 scenario_list_parser.set_defaults(func=scenario_list)
1725 scenario_delete_parser = subparsers.add_parser('scenario-delete', parents=[parent_parser], help="deletes a scenario from the OPENMANO DB")
1726 scenario_delete_parser.add_argument("name", action="store", help="name or uuid of the scenario to be deleted")
1727 scenario_delete_parser.add_argument("-f", "--force", action="store_true", help="forces deletion without asking")
1728 scenario_delete_parser.add_argument("-a", "--all", action="store_true", help="allow delete not owned or privated one")
1729 scenario_delete_parser.set_defaults(func=scenario_delete)
1731 scenario_deploy_parser = subparsers.add_parser('scenario-deploy', parents=[parent_parser], help="deploys a scenario")
1732 scenario_deploy_parser.add_argument("scenario", action="store", help="name or uuid of the scenario to be deployed")
1733 scenario_deploy_parser.add_argument("name", action="store", help="name of the instance")
1734 scenario_deploy_parser.add_argument("--nostart", action="store_true", help="does not start the vms, just reserve resources")
1735 scenario_deploy_parser.add_argument("--datacenter", action="store", help="specifies the datacenter. Needed if several datacenters are available")
1736 scenario_deploy_parser.add_argument("--description", action="store", help="description of the instance")
1737 scenario_deploy_parser.set_defaults(func=scenario_deploy)
1739 scenario_deploy_parser = subparsers.add_parser('scenario-verify', help="verifies if a scenario can be deployed (deploys it and deletes it)")
1740 scenario_deploy_parser.add_argument("scenario", action="store", help="name or uuid of the scenario to be verified")
1741 scenario_deploy_parser.add_argument('--debug', '-d', action='store_true', help="show debug information")
1742 scenario_deploy_parser.set_defaults(func=scenario_verify)
1744 instance_scenario_create_parser = subparsers.add_parser('instance-scenario-create', parents=[parent_parser], help="deploys a scenario")
1745 instance_scenario_create_parser.add_argument("file", nargs='?', help="descriptor of the instance. Must be a file or yaml/json text")
1746 instance_scenario_create_parser.add_argument("--scenario", action="store", help="name or uuid of the scenario to be deployed")
1747 instance_scenario_create_parser.add_argument("--name", action="store", help="name of the instance")
1748 instance_scenario_create_parser.add_argument("--nostart", action="store_true", help="does not start the vms, just reserve resources")
1749 instance_scenario_create_parser.add_argument("--datacenter", action="store", help="specifies the datacenter. Needed if several datacenters are available")
1750 instance_scenario_create_parser.add_argument("--netmap-use", action="append", type=str, dest="netmap_use", help="indicates a datacenter network to map a scenario network 'scenario-network=datacenter-network'. Can be used several times")
1751 instance_scenario_create_parser.add_argument("--netmap-create", action="append", type=str, dest="netmap_create", help="the scenario network must be created at datacenter 'scenario-network[=datacenter-network-name]' . Can be used several times")
1752 instance_scenario_create_parser.add_argument("--keypair", action="append", type=str, dest="keypair", help="public key for ssh access. Format '[user:]key1[,key2...]'. Can be used several times")
1753 instance_scenario_create_parser.add_argument("--keypair-auto", action="store_true", dest="keypair_auto", help="Inject the user ssh-keys found at $HOME/.ssh directory")
1754 instance_scenario_create_parser.add_argument("--description", action="store", help="description of the instance")
1755 instance_scenario_create_parser.set_defaults(func=instance_create)
1757 instance_scenario_list_parser = subparsers.add_parser('instance-scenario-list', parents=[parent_parser], help="lists information about a scenario instance")
1758 instance_scenario_list_parser.add_argument("name", nargs='?', help="name of the scenario instance")
1759 instance_scenario_list_parser.add_argument("-a", "--all", action="store_true", help="shows all instance-scenarios, not only the owned")
1760 instance_scenario_list_parser.set_defaults(func=instance_scenario_list)
1762 instance_scenario_delete_parser = subparsers.add_parser('instance-scenario-delete', parents=[parent_parser], help="deletes a scenario instance (and deletes all VM and net instances in VIM)")
1763 instance_scenario_delete_parser.add_argument("name", action="store", help="name or uuid of the scenario instance to be deleted")
1764 instance_scenario_delete_parser.add_argument("-f", "--force", action="store_true", help="forces deletion without asking")
1765 instance_scenario_delete_parser.add_argument("-a", "--all", action="store_true", help="allow delete not owned or privated one")
1766 instance_scenario_delete_parser.set_defaults(func=instance_scenario_delete)
1768 instance_scenario_action_parser = subparsers.add_parser('instance-scenario-action', parents=[parent_parser], help="invoke an action over part or the whole scenario instance")
1769 instance_scenario_action_parser.add_argument("name", action="store", help="name or uuid of the scenario instance")
1770 instance_scenario_action_parser.add_argument("action", action="store", type=str, \
1771 choices=["start","pause","resume","shutoff","shutdown","forceOff","rebuild","reboot", "console", "add_public_key"],\
1772 help="action to send")
1773 instance_scenario_action_parser.add_argument("param", nargs='?', help="addional param of the action. e.g. console type (novnc, ...), reboot type (TODO)")
1774 instance_scenario_action_parser.add_argument("--vnf", action="append", help="VNF to act on (can use several entries)")
1775 instance_scenario_action_parser.add_argument("--vm", action="append", help="VM to act on (can use several entries)")
1776 instance_scenario_action_parser.set_defaults(func=instance_scenario_action)
1778 action_parser = subparsers.add_parser('action-list', parents=[parent_parser], help="get action over an instance status")
1779 action_parser.add_argument("id", nargs='?', action="store", help="action id")
1780 action_parser.add_argument("--instance", action="store", help="fitler by this instance_id")
1781 action_parser.add_argument("--all", action="store", help="Not filter by tenant")
1782 action_parser.set_defaults(func=get_action)
1784 #instance_scenario_status_parser = subparsers.add_parser('instance-scenario-status', help="show the status of a scenario instance")
1785 #instance_scenario_status_parser.add_argument("name", action="store", help="name or uuid of the scenario instance")
1786 #instance_scenario_status_parser.set_defaults(func=instance_scenario_status)
1788 tenant_create_parser = subparsers.add_parser('tenant-create', parents=[parent_parser], help="creates a new tenant")
1789 tenant_create_parser.add_argument("name", action="store", help="name for the tenant")
1790 tenant_create_parser.add_argument("--description", action="store", help="description of the tenant")
1791 tenant_create_parser.set_defaults(func=tenant_create)
1793 tenant_delete_parser = subparsers.add_parser('tenant-delete', parents=[parent_parser], help="deletes a tenant from the catalogue")
1794 tenant_delete_parser.add_argument("name", action="store", help="name or uuid of the tenant to be deleted")
1795 tenant_delete_parser.add_argument("-f", "--force", action="store_true", help="forces deletion without asking")
1796 tenant_delete_parser.set_defaults(func=tenant_delete)
1798 tenant_list_parser = subparsers.add_parser('tenant-list', parents=[parent_parser], help="lists information about a tenant")
1799 tenant_list_parser.add_argument("name", nargs='?', help="name or uuid of the tenant")
1800 tenant_list_parser.set_defaults(func=tenant_list)
1802 element_edit_parser = subparsers.add_parser('tenant-edit', parents=[parent_parser], help="edits one tenant")
1803 element_edit_parser.add_argument("name", help="name or uuid of the tenant")
1804 element_edit_parser.add_argument("file", help="json/yaml text or file with the changes").completer = FilesCompleter
1805 element_edit_parser.add_argument("-f","--force", action="store_true", help="do not prompt for confirmation")
1806 element_edit_parser.set_defaults(func=element_edit, element='tenants')
1808 datacenter_create_parser = subparsers.add_parser('datacenter-create', parents=[parent_parser], help="creates a new datacenter")
1809 datacenter_create_parser.add_argument("name", action="store", help="name for the datacenter")
1810 datacenter_create_parser.add_argument("url", action="store", help="url for the datacenter")
1811 datacenter_create_parser.add_argument("--url_admin", action="store", help="url for administration for the datacenter")
1812 datacenter_create_parser.add_argument("--type", action="store", help="datacenter type: openstack or openvim (default)")
1813 datacenter_create_parser.add_argument("--config", action="store", help="aditional configuration in json/yaml format")
1814 datacenter_create_parser.add_argument("--description", action="store", help="description of the datacenter")
1815 datacenter_create_parser.add_argument("--sdn-controller", action="store", help="Name or uuid of the SDN controller to be used", dest='sdn_controller')
1816 datacenter_create_parser.set_defaults(func=datacenter_create)
1818 datacenter_delete_parser = subparsers.add_parser('datacenter-delete', parents=[parent_parser], help="deletes a datacenter from the catalogue")
1819 datacenter_delete_parser.add_argument("name", action="store", help="name or uuid of the datacenter to be deleted")
1820 datacenter_delete_parser.add_argument("-f", "--force", action="store_true", help="forces deletion without asking")
1821 datacenter_delete_parser.set_defaults(func=datacenter_delete)
1823 datacenter_edit_parser = subparsers.add_parser('datacenter-edit', parents=[parent_parser], help="Edit datacenter")
1824 datacenter_edit_parser.add_argument("name", help="name or uuid of the datacenter")
1825 datacenter_edit_parser.add_argument("--file", help="json/yaml text or file with the changes").completer = FilesCompleter
1826 datacenter_edit_parser.add_argument("--sdn-controller", action="store",
1827 help="Name or uuid of the SDN controller to be used. Specify 'null' to clear entry", dest='sdn_controller')
1828 datacenter_edit_parser.add_argument("-f", "--force", action="store_true", help="do not prompt for confirmation")
1829 datacenter_edit_parser.set_defaults(func=datacenter_edit)
1831 datacenter_list_parser = subparsers.add_parser('datacenter-list', parents=[parent_parser], help="lists information about a datacenter")
1832 datacenter_list_parser.add_argument("name", nargs='?', help="name or uuid of the datacenter")
1833 datacenter_list_parser.add_argument("-a", "--all", action="store_true", help="shows all datacenters, not only datacenters attached to tenant")
1834 datacenter_list_parser.set_defaults(func=datacenter_list)
1836 datacenter_attach_parser = subparsers.add_parser('datacenter-attach', parents=[parent_parser], help="associates a datacenter to the operating tenant")
1837 datacenter_attach_parser.add_argument("name", help="name or uuid of the datacenter")
1838 datacenter_attach_parser.add_argument('--vim-tenant-id', action='store', help="specify a datacenter tenant to use. A new one is created by default")
1839 datacenter_attach_parser.add_argument('--vim-tenant-name', action='store', help="specify a datacenter tenant name.")
1840 datacenter_attach_parser.add_argument("--user", action="store", help="user credentials for the datacenter")
1841 datacenter_attach_parser.add_argument("--password", action="store", help="password credentials for the datacenter")
1842 datacenter_attach_parser.add_argument("--config", action="store", help="aditional configuration in json/yaml format")
1843 datacenter_attach_parser.set_defaults(func=datacenter_attach)
1845 datacenter_edit_vim_tenant_parser = subparsers.add_parser('datacenter-edit-vim-tenant', parents=[parent_parser],
1846 help="Edit the association of a datacenter to the operating tenant")
1847 datacenter_edit_vim_tenant_parser.add_argument("name", help="name or uuid of the datacenter")
1848 datacenter_edit_vim_tenant_parser.add_argument('--vim-tenant-id', action='store',
1849 help="specify a datacenter tenant to use. A new one is created by default")
1850 datacenter_edit_vim_tenant_parser.add_argument('--vim-tenant-name', action='store', help="specify a datacenter tenant name.")
1851 datacenter_edit_vim_tenant_parser.add_argument("--user", action="store", help="user credentials for the datacenter")
1852 datacenter_edit_vim_tenant_parser.add_argument("--password", action="store", help="password credentials for the datacenter")
1853 datacenter_edit_vim_tenant_parser.add_argument("--config", action="store",
1854 help="aditional configuration in json/yaml format")
1855 datacenter_edit_vim_tenant_parser.set_defaults(func=datacenter_edit_vim_tenant)
1857 datacenter_detach_parser = subparsers.add_parser('datacenter-detach', parents=[parent_parser], help="removes the association between a datacenter and the operating tenant")
1858 datacenter_detach_parser.add_argument("name", help="name or uuid of the datacenter")
1859 datacenter_detach_parser.add_argument("-a", "--all", action="store_true", help="removes all associations from this datacenter")
1860 datacenter_detach_parser.set_defaults(func=datacenter_detach)
1862 #=======================datacenter_sdn_port_mapping_xxx section=======================
1863 #datacenter_sdn_port_mapping_set
1864 datacenter_sdn_port_mapping_set_parser = subparsers.add_parser('datacenter-sdn-port-mapping-set',
1865 parents=[parent_parser],
1866 help="Load a file with the mapping of physical ports "
1867 "and the ports of the dataplaneswitch controlled "
1869 datacenter_sdn_port_mapping_set_parser.add_argument("name", action="store", help="specifies the datacenter")
1870 datacenter_sdn_port_mapping_set_parser.add_argument("file",
1871 help="json/yaml text or file with the port mapping").completer = FilesCompleter
1872 datacenter_sdn_port_mapping_set_parser.add_argument("-f", "--force", action="store_true",
1873 help="forces overwriting without asking")
1874 datacenter_sdn_port_mapping_set_parser.set_defaults(func=datacenter_sdn_port_mapping_set)
1876 #datacenter_sdn_port_mapping_list
1877 datacenter_sdn_port_mapping_list_parser = subparsers.add_parser('datacenter-sdn-port-mapping-list',
1878 parents=[parent_parser],
1879 help="Show the SDN port mapping in a datacenter")
1880 datacenter_sdn_port_mapping_list_parser.add_argument("name", action="store", help="specifies the datacenter")
1881 datacenter_sdn_port_mapping_list_parser.set_defaults(func=datacenter_sdn_port_mapping_list)
1883 # datacenter_sdn_port_mapping_clear
1884 datacenter_sdn_port_mapping_clear_parser = subparsers.add_parser('datacenter-sdn-port-mapping-clear',
1885 parents=[parent_parser],
1886 help="Clean the the SDN port mapping in a datacenter")
1887 datacenter_sdn_port_mapping_clear_parser.add_argument("name", action="store",
1888 help="specifies the datacenter")
1889 datacenter_sdn_port_mapping_clear_parser.add_argument("-f", "--force", action="store_true",
1890 help="forces clearing without asking")
1891 datacenter_sdn_port_mapping_clear_parser.set_defaults(func=datacenter_sdn_port_mapping_clear)
1892 # =======================
1894 # =======================sdn_controller_xxx section=======================
1895 # sdn_controller_create
1896 sdn_controller_create_parser = subparsers.add_parser('sdn-controller-create', parents=[parent_parser],
1897 help="Creates an SDN controller entity within RO")
1898 sdn_controller_create_parser.add_argument("name", help="name of the SDN controller")
1899 sdn_controller_create_parser.add_argument("--description", action="store", help="description of the SDN controller")
1900 sdn_controller_create_parser.add_argument("--ip", action="store", help="IP of the SDN controller")
1901 sdn_controller_create_parser.add_argument("--port", action="store", help="Port of the SDN controller")
1902 sdn_controller_create_parser.add_argument("--dpid", action="store",
1903 help="DPID of the dataplane switch controlled by this SDN controller")
1904 sdn_controller_create_parser.add_argument("--type", action="store",
1905 help="Specify the SDN controller type. Valid types are 'opendaylight' and 'floodlight'")
1906 sdn_controller_create_parser.add_argument("--user", action="store", help="user credentials for the SDN controller")
1907 sdn_controller_create_parser.add_argument("--passwd", action="store", dest='password',
1908 help="password credentials for the SDN controller")
1909 sdn_controller_create_parser.set_defaults(func=sdn_controller_create)
1911 # sdn_controller_edit
1912 sdn_controller_edit_parser = subparsers.add_parser('sdn-controller-edit', parents=[parent_parser],
1913 help="Update one or more options of a SDN controller")
1914 sdn_controller_edit_parser.add_argument("name", help="name or uuid of the SDN controller", )
1915 sdn_controller_edit_parser.add_argument("--name", action="store", help="Update the name of the SDN controller",
1917 sdn_controller_edit_parser.add_argument("--description", action="store", help="description of the SDN controller")
1918 sdn_controller_edit_parser.add_argument("--ip", action="store", help="IP of the SDN controller")
1919 sdn_controller_edit_parser.add_argument("--port", action="store", help="Port of the SDN controller")
1920 sdn_controller_edit_parser.add_argument("--dpid", action="store",
1921 help="DPID of the dataplane switch controlled by this SDN controller")
1922 sdn_controller_edit_parser.add_argument("--type", action="store",
1923 help="Specify the SDN controller type. Valid types are 'opendaylight' and 'floodlight'")
1924 sdn_controller_edit_parser.add_argument("--user", action="store", help="user credentials for the SDN controller")
1925 sdn_controller_edit_parser.add_argument("--password", action="store",
1926 help="password credentials for the SDN controller", dest='password')
1927 sdn_controller_edit_parser.add_argument("-f", "--force", action="store_true", help="do not prompt for confirmation")
1928 #TODO: include option --file
1929 sdn_controller_edit_parser.set_defaults(func=sdn_controller_edit)
1931 #sdn_controller_list
1932 sdn_controller_list_parser = subparsers.add_parser('sdn-controller-list',
1933 parents=[parent_parser],
1934 help="List the SDN controllers")
1935 sdn_controller_list_parser.add_argument("name", nargs='?', help="name or uuid of the SDN controller")
1936 sdn_controller_list_parser.set_defaults(func=sdn_controller_list)
1938 # sdn_controller_delete
1939 sdn_controller_delete_parser = subparsers.add_parser('sdn-controller-delete',
1940 parents=[parent_parser],
1941 help="Delete the the SDN controller")
1942 sdn_controller_delete_parser.add_argument("name", help="name or uuid of the SDN controller")
1943 sdn_controller_delete_parser.add_argument("-f", "--force", action="store_true", help="forces deletion without asking")
1944 sdn_controller_delete_parser.set_defaults(func=sdn_controller_delete)
1945 # =======================
1947 action_dict={'net-update': 'retrieves external networks from datacenter',
1948 'net-edit': 'edits an external network',
1949 'net-delete': 'deletes an external network',
1950 'net-list': 'lists external networks from a datacenter'
1952 for item in action_dict:
1953 datacenter_action_parser = subparsers.add_parser('datacenter-'+item, parents=[parent_parser], help=action_dict[item])
1954 datacenter_action_parser.add_argument("datacenter", help="name or uuid of the datacenter")
1955 if item=='net-edit' or item=='net-delete':
1956 datacenter_action_parser.add_argument("net", help="name or uuid of the datacenter net")
1957 if item=='net-edit':
1958 datacenter_action_parser.add_argument("file", help="json/yaml text or file with the changes").completer = FilesCompleter
1959 if item!='net-list':
1960 datacenter_action_parser.add_argument("-f","--force", action="store_true", help="do not prompt for confirmation")
1961 datacenter_action_parser.set_defaults(func=datacenter_net_action, action=item)
1964 action_dict={'netmap-import': 'create network senario netmap base on the datacenter networks',
1965 'netmap-create': 'create a new network senario netmap',
1966 'netmap-edit': 'edit name of a network senario netmap',
1967 'netmap-delete': 'deletes a network scenario netmap (--all for clearing all)',
1968 'netmap-list': 'list/show network scenario netmaps'
1970 for item in action_dict:
1971 datacenter_action_parser = subparsers.add_parser('datacenter-'+item, parents=[parent_parser], help=action_dict[item])
1972 datacenter_action_parser.add_argument("--datacenter", help="name or uuid of the datacenter")
1973 #if item=='net-add':
1974 # datacenter_action_parser.add_argument("net", help="name of the network")
1975 if item=='netmap-delete':
1976 datacenter_action_parser.add_argument("netmap", nargs='?',help="name or uuid of the datacenter netmap to delete")
1977 datacenter_action_parser.add_argument("--all", action="store_true", help="delete all netmap of this datacenter")
1978 datacenter_action_parser.add_argument("-f","--force", action="store_true", help="do not prompt for confirmation")
1979 if item=='netmap-edit':
1980 datacenter_action_parser.add_argument("netmap", help="name or uuid of the datacenter netmap do edit")
1981 datacenter_action_parser.add_argument("file", nargs='?', help="json/yaml text or file with the changes").completer = FilesCompleter
1982 datacenter_action_parser.add_argument("--name", action='store', help="name to assign to the datacenter netmap")
1983 datacenter_action_parser.add_argument('--vim-id', action='store', help="specify vim network uuid")
1984 datacenter_action_parser.add_argument("-f","--force", action="store_true", help="do not prompt for confirmation")
1985 if item=='netmap-list':
1986 datacenter_action_parser.add_argument("netmap", nargs='?',help="name or uuid of the datacenter netmap to show")
1987 if item=='netmap-create':
1988 datacenter_action_parser.add_argument("file", nargs='?', help="json/yaml text or file descriptor with the changes").completer = FilesCompleter
1989 datacenter_action_parser.add_argument("--name", action='store', help="name to assign to the datacenter netmap, by default same as vim-name")
1990 datacenter_action_parser.add_argument('--vim-id', action='store', help="specify vim network uuid")
1991 datacenter_action_parser.add_argument('--vim-name', action='store', help="specify vim network name")
1992 if item=='netmap-import':
1993 datacenter_action_parser.add_argument("-f","--force", action="store_true", help="do not prompt for confirmation")
1994 datacenter_action_parser.set_defaults(func=datacenter_netmap_action, action=item)
1996 # =======================vim_net_sdn_xxx section=======================
1997 # vim_net_sdn_attach
1998 vim_net_sdn_attach_parser = subparsers.add_parser('vim-net-sdn-attach',
1999 parents=[parent_parser],
2000 help="Specify the port to access to an external network using SDN")
2001 vim_net_sdn_attach_parser.add_argument("vim_net", action="store",
2002 help="Name/id of the network in the vim that will be used to connect to the external network")
2003 vim_net_sdn_attach_parser.add_argument("port", action="store", help="Specifies the port in the dataplane switch to access to the external network")
2004 vim_net_sdn_attach_parser.add_argument("--vlan", action="store", help="Specifies the vlan (if any) to use in the defined port")
2005 vim_net_sdn_attach_parser.add_argument("--mac", action="store", help="Specifies the MAC (if known) of the physical device that will be reachable by this external port")
2006 vim_net_sdn_attach_parser.add_argument("--datacenter", action="store", help="specifies the datacenter")
2007 vim_net_sdn_attach_parser.set_defaults(func=vim_net_sdn_attach)
2009 # vim_net_sdn_detach
2010 vim_net_sdn_detach_parser = subparsers.add_parser('vim-net-sdn-detach',
2011 parents=[parent_parser],
2012 help="Remove the port information to access to an external network using SDN")
2014 vim_net_sdn_detach_parser.add_argument("vim_net", action="store", help="Name/id of the vim network")
2015 vim_net_sdn_detach_parser.add_argument("--id", action="store",help="Specify the uuid of the external ports from this network to be detached")
2016 vim_net_sdn_detach_parser.add_argument("--all", action="store_true", help="Detach all external ports from this network")
2017 vim_net_sdn_detach_parser.add_argument("-f", "--force", action="store_true", help="forces clearing without asking")
2018 vim_net_sdn_detach_parser.add_argument("--datacenter", action="store", help="specifies the datacenter")
2019 vim_net_sdn_detach_parser.set_defaults(func=vim_net_sdn_detach)
2020 # =======================
2022 for item in ("network", "tenant", "image"):
2024 command_name = 'vim-net'
2026 command_name = 'vim-'+item
2027 vim_item_list_parser = subparsers.add_parser(command_name + '-list', parents=[parent_parser], help="list the vim " + item + "s")
2028 vim_item_list_parser.add_argument("name", nargs='?', help="name or uuid of the " + item + "s")
2029 vim_item_list_parser.add_argument("--datacenter", action="store", help="specifies the datacenter")
2030 vim_item_list_parser.set_defaults(func=vim_action, item=item, action="list")
2032 vim_item_del_parser = subparsers.add_parser(command_name + '-delete', parents=[parent_parser], help="list the vim " + item + "s")
2033 vim_item_del_parser.add_argument("name", help="name or uuid of the " + item + "s")
2034 vim_item_del_parser.add_argument("--datacenter", action="store", help="specifies the datacenter")
2035 vim_item_del_parser.set_defaults(func=vim_action, item=item, action="delete")
2037 if item == "network" or item == "tenant":
2038 vim_item_create_parser = subparsers.add_parser(command_name + '-create', parents=[parent_parser], help="create a "+item+" at vim")
2039 vim_item_create_parser.add_argument("file", nargs='?', help="descriptor of the %s. Must be a file or yaml/json text" % item).completer = FilesCompleter
2040 vim_item_create_parser.add_argument("--name", action="store", help="name of the %s" % item )
2041 vim_item_create_parser.add_argument("--datacenter", action="store", help="specifies the datacenter")
2043 vim_item_create_parser.add_argument("--type", action="store", help="type of network, data, ptp, bridge")
2044 vim_item_create_parser.add_argument("--shared", action="store_true", help="Private or shared")
2045 vim_item_create_parser.add_argument("--bind-net", action="store", help="For openvim datacenter type, net to be bind to, for vlan type, use sufix ':<vlan_tag>'")
2047 vim_item_create_parser.add_argument("--description", action="store", help="description of the %s" % item)
2048 vim_item_create_parser.set_defaults(func=vim_action, item=item, action="create")
2050 argcomplete.autocomplete(main_parser)
2053 args = main_parser.parse_args()
2055 level = logging.CRITICAL
2056 streamformat = "%(asctime)s %(name)s %(levelname)s: %(message)s"
2057 if "debug" in args and args.debug:
2058 level = logging.DEBUG
2059 logging.basicConfig(format=streamformat, level= level)
2060 logger = logging.getLogger('mano')
2061 logger.setLevel(level)
2062 result = args.func(args)
2065 #for some reason it fails if call exit inside try instance. Need to call exit at the end !?
2066 except (requests.exceptions.ConnectionError):
2067 print "Connection error: not possible to contact OPENMANO-SERVER (openmanod)"
2069 except (KeyboardInterrupt):
2070 print 'Exiting openmano'
2072 except (SystemExit, ArgumentParserError):
2074 except OpenmanoCLIError as e: