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.14-r521"
32 version_date = "May 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 = "%s %s" %(uuid.ljust(38),name.ljust(20))
137 if content.get("status"):
138 myoutput += " " + content['status'].ljust(20)
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 += " " + content['created_at'].ljust(20)
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: " + content['type'].ljust(29)
152 if content.get('description'):
153 myoutput += new_line + " Description: " + content['description'].ljust(20)
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:
230 raise OpenmanoCLIError("No %s found with name/uuid '%s'" %(item[:-1], item_name_id))
232 raise OpenmanoCLIError("%d %s found with name '%s'. uuid must be used" %(found, item, item_name_id))
235 # def check_valid_uuid(uuid):
236 # id_schema = {"type" : "string", "pattern": "^[a-fA-F0-9]{8}(-[a-fA-F0-9]{4}){3}-[a-fA-F0-9]{12}$"}
238 # js_v(uuid, id_schema)
240 # except js_e.ValidationError:
243 def _get_tenant(tenant_name_id = None):
244 if not tenant_name_id:
245 tenant_name_id = mano_tenant
247 raise OpenmanoCLIError("'OPENMANO_TENANT' environment variable is not set")
248 return _get_item_uuid("tenants", tenant_name_id)
250 def _get_datacenter(datacenter_name_id = None, tenant = "any"):
251 if not datacenter_name_id:
252 datacenter_name_id = mano_datacenter
253 if not datacenter_name_id:
254 raise OpenmanoCLIError("neither 'OPENMANO_DATACENTER' environment variable is set nor --datacenter option is used")
255 return _get_item_uuid("datacenters", datacenter_name_id, tenant)
257 def vnf_create(args):
258 #print "vnf-create",args
259 headers_req = {'Accept': 'application/json', 'content-type': 'application/json'}
260 tenant = _get_tenant()
261 myvnf = _load_file_or_yaml(args.file)
263 if args.name or args.description or args.image_path or args.image_name or args.image_checksum:
267 myvnf['vnf']['name'] = args.name
269 myvnf['vnf']['description'] = args.description
272 for image_path_ in args.image_path.split(","):
273 #print "image-path", image_path_
274 myvnf['vnf']['VNFC'][index]['VNFC image']=image_path_
275 if "image name" in myvnf['vnf']['VNFC'][index]:
276 del myvnf['vnf']['VNFC'][index]["image name"]
277 if "image checksum" in myvnf['vnf']['VNFC'][index]:
278 del myvnf['vnf']['VNFC'][index]["image checksum"]
280 if args.image_name: #image name precedes if both are supplied
282 for image_name_ in args.image_name.split(","):
283 myvnf['vnf']['VNFC'][index]['image name']=image_name_
284 if "VNFC image" in myvnf['vnf']['VNFC'][index]:
285 del myvnf['vnf']['VNFC'][index]["VNFC image"]
287 if args.image_checksum:
289 for image_checksum_ in args.image_checksum.split(","):
290 myvnf['vnf']['VNFC'][index]['image checksum']=image_checksum_
292 except (KeyError, TypeError), e:
293 if str(e)=='vnf': error_pos= "missing field 'vnf'"
294 elif str(e)=='name': error_pos= "missing field 'vnf':'name'"
295 elif str(e)=='description': error_pos= "missing field 'vnf':'description'"
296 elif str(e)=='VNFC': error_pos= "missing field 'vnf':'VNFC'"
297 elif str(e)==str(index): error_pos= "field 'vnf':'VNFC' must be an array"
298 elif str(e)=='VNFC image': error_pos= "missing field 'vnf':'VNFC'['VNFC image']"
299 elif str(e)=='image name': error_pos= "missing field 'vnf':'VNFC'['image name']"
300 elif str(e)=='image checksum': error_pos= "missing field 'vnf':'VNFC'['image checksum']"
301 else: error_pos="wrong format"
302 print "Wrong VNF descriptor: " + error_pos
304 payload_req = json.dumps(myvnf)
308 URLrequest = "http://%s:%s/openmano/%s/vnfs" %(mano_host, mano_port, tenant)
309 logger.debug("openmano request: %s", payload_req)
310 mano_response = requests.post(URLrequest, headers = headers_req, data=payload_req)
311 logger.debug("openmano response: %s", mano_response.text )
313 return _print_verbose(mano_response, args.verbose)
316 #print "vnf-list",args
320 tenant = _get_tenant()
322 toshow = _get_item_uuid("vnfs", args.name, tenant)
323 URLrequest = "http://%s:%s/openmano/%s/vnfs/%s" %(mano_host, mano_port, tenant, toshow)
325 URLrequest = "http://%s:%s/openmano/%s/vnfs" %(mano_host, mano_port, tenant)
326 mano_response = requests.get(URLrequest)
327 logger.debug("openmano response: %s", mano_response.text )
328 content = mano_response.json()
329 #print json.dumps(content, indent=4)
330 if args.verbose==None:
332 result = 0 if mano_response.status_code==200 else mano_response.status_code
333 if mano_response.status_code == 200:
335 if args.verbose >= 3:
336 print yaml.safe_dump(content, indent=4, default_flow_style=False)
338 if len(content['vnfs']) == 0:
339 print "No VNFs were found."
340 return 404 #HTTP_Not_Found
341 for vnf in content['vnfs']:
342 myoutput = "%s %s" %(vnf['uuid'].ljust(38),vnf['name'].ljust(20))
344 myoutput = "%s %s" %(myoutput, vnf['created_at'].ljust(20))
347 print " Description: %s" %vnf['description']
348 print " VNF descriptor file: %s" %vnf['path']
351 print yaml.safe_dump(content, indent=4, default_flow_style=False)
354 print "%s %s %s" %(vnf['uuid'].ljust(38),vnf['name'].ljust(20), vnf['created_at'].ljust(20))
355 print " Description: %s" %vnf['description']
356 #print " VNF descriptor file: %s" %vnf['path']
358 for vm in vnf['VNFC']:
359 #print " %s %s %s" %(vm['name'].ljust(20), vm['uuid'].ljust(38), vm['description'].ljust(30))
360 print " %s %s" %(vm['name'].ljust(20), vm['description'])
361 if len(vnf['nets'])>0:
362 print " Internal nets:"
363 for net in vnf['nets']:
364 print " %s %s" %(net['name'].ljust(20), net['description'])
365 if len(vnf['external-connections'])>0:
366 print " External interfaces:"
367 for interface in vnf['external-connections']:
368 print " %s %s %s %s" %(interface['external_name'].ljust(20), interface['vm_name'].ljust(20), interface['internal_name'].ljust(20), \
369 interface.get('vpci',"").ljust(14))
371 print content['error']['description']
373 print yaml.safe_dump(content, indent=4, default_flow_style=False)
376 def vnf_delete(args):
377 #print "vnf-delete",args
381 tenant = _get_tenant()
382 todelete = _get_item_uuid("vnfs", args.name, tenant=tenant)
384 r = raw_input("Delete VNF %s (y/N)? " %(todelete))
385 if not (len(r)>0 and r[0].lower()=="y"):
387 URLrequest = "http://%s:%s/openmano/%s/vnfs/%s" %(mano_host, mano_port, tenant, todelete)
388 mano_response = requests.delete(URLrequest)
389 logger.debug("openmano response: %s", mano_response.text )
390 result = 0 if mano_response.status_code==200 else mano_response.status_code
391 content = mano_response.json()
392 #print json.dumps(content, indent=4)
393 if mano_response.status_code == 200:
394 print content['result']
396 print content['error']['description']
399 def scenario_create(args):
400 #print "scenario-create",args
401 tenant = _get_tenant()
402 headers_req = {'content-type': 'application/yaml'}
403 myscenario = _load_file_or_yaml(args.file)
406 myscenario['name'] = args.name
408 myscenario['description'] = args.description
409 payload_req = yaml.safe_dump(myscenario, explicit_start=True, indent=4, default_flow_style=False, tags=False, encoding='utf-8', allow_unicode=True)
413 URLrequest = "http://%s:%s/openmano/%s/scenarios" %(mano_host, mano_port, tenant)
414 logger.debug("openmano request: %s", payload_req)
415 mano_response = requests.post(URLrequest, headers = headers_req, data=payload_req)
416 logger.debug("openmano response: %s", mano_response.text )
417 return _print_verbose(mano_response, args.verbose)
419 def scenario_list(args):
420 #print "scenario-list",args
424 tenant = _get_tenant()
426 toshow = _get_item_uuid("scenarios", args.name, tenant)
427 URLrequest = "http://%s:%s/openmano/%s/scenarios/%s" %(mano_host, mano_port, tenant, toshow)
429 URLrequest = "http://%s:%s/openmano/%s/scenarios" %(mano_host, mano_port, tenant)
430 mano_response = requests.get(URLrequest)
431 logger.debug("openmano response: %s", mano_response.text )
432 content = mano_response.json()
433 #print json.dumps(content, indent=4)
434 if args.verbose==None:
437 result = 0 if mano_response.status_code==200 else mano_response.status_code
438 if mano_response.status_code == 200:
440 if args.verbose >= 3:
441 print yaml.safe_dump(content, indent=4, default_flow_style=False)
443 if len(content['scenarios']) == 0:
444 print "No scenarios were found."
445 return 404 #HTTP_Not_Found
446 for scenario in content['scenarios']:
447 myoutput = "%s %s" %(scenario['uuid'].ljust(38),scenario['name'].ljust(20))
449 myoutput = "%s %s" %(myoutput, scenario['created_at'].ljust(20))
452 print " Description: %s" %scenario['description']
455 print yaml.safe_dump(content, indent=4, default_flow_style=False)
457 scenario = content['scenario']
458 myoutput = "%s %s %s" %(scenario['uuid'].ljust(38),scenario['name'].ljust(20), scenario['created_at'].ljust(20))
460 print " Description: %s" %scenario['description']
462 for vnf in scenario['vnfs']:
463 print " %s %s %s" %(vnf['name'].ljust(20), vnf['vnf_id'].ljust(38), vnf['description'])
464 if len(scenario['nets'])>0:
465 print " Internal nets:"
466 for net in scenario['nets']:
467 if net['description'] is None: #if description does not exist, description is "-". Valid for external and internal nets.
468 net['description'] = '-'
469 if not net['external']:
470 print " %s %s %s" %(net['name'].ljust(20), net['uuid'].ljust(38), net['description'].ljust(30))
471 print " External nets:"
472 for net in scenario['nets']:
474 print " %s %s %s vim-id:%s" %(net['name'].ljust(20), net['uuid'].ljust(38), net['description'].ljust(30), net['vim_id'])
476 print content['error']['description']
478 print yaml.safe_dump(content, indent=4, default_flow_style=False)
481 def scenario_delete(args):
482 #print "scenario-delete",args
486 tenant = _get_tenant()
487 todelete = _get_item_uuid("scenarios", args.name, tenant=tenant)
489 r = raw_input("Delete scenario %s (y/N)? " %(args.name))
490 if not (len(r)>0 and r[0].lower()=="y"):
492 URLrequest = "http://%s:%s/openmano/%s/scenarios/%s" %(mano_host, mano_port, tenant, todelete)
493 mano_response = requests.delete(URLrequest)
494 logger.debug("openmano response: %s", mano_response.text )
495 result = 0 if mano_response.status_code==200 else mano_response.status_code
496 content = mano_response.json()
497 #print json.dumps(content, indent=4)
498 if mano_response.status_code == 200:
499 print content['result']
501 print content['error']['description']
504 def scenario_deploy(args):
505 print "This command is deprecated, use 'openmano instance-scenario-create --scenario %s --name %s' instead!!!" % (args.scenario, args.name)
508 args.netmap_use = None
509 args.netmap_create = None
511 args.keypair_auto = None
512 return instance_create(args)
514 # #print "scenario-deploy",args
515 # headers_req = {'content-type': 'application/json'}
519 # actionCmd="reserve"
520 # action[actionCmd] = {}
521 # action[actionCmd]["instance_name"] = args.name
522 # if args.datacenter != None:
523 # action[actionCmd]["datacenter"] = args.datacenter
524 # elif mano_datacenter != None:
525 # action[actionCmd]["datacenter"] = mano_datacenter
527 # if args.description:
528 # action[actionCmd]["description"] = args.description
529 # payload_req = json.dumps(action, indent=4)
532 # URLrequest = "http://%s:%s/openmano/%s/scenarios/%s/action" %(mano_host, mano_port, mano_tenant, args.scenario)
533 # logger.debug("openmano request: %s", payload_req)
534 # mano_response = requests.post(URLrequest, headers = headers_req, data=payload_req)
535 # logger.debug("openmano response: %s", mano_response.text )
536 # if args.verbose==None:
539 # result = 0 if mano_response.status_code==200 else mano_response.status_code
540 # content = mano_response.json()
541 # #print json.dumps(content, indent=4)
542 # if args.verbose >= 3:
543 # print yaml.safe_dump(content, indent=4, default_flow_style=False)
546 # if mano_response.status_code == 200:
547 # myoutput = "%s %s" %(content['uuid'].ljust(38),content['name'].ljust(20))
548 # if args.verbose >=1:
549 # myoutput = "%s %s" %(myoutput, content['created_at'].ljust(20))
550 # if args.verbose >=2:
551 # myoutput = "%s %s %s" %(myoutput, content['description'].ljust(30))
554 # print "To check the status, run the following command:"
555 # print "openmano instance-scenario-list <instance_id>"
557 # print content['error']['description']
560 def scenario_verify(args):
561 #print "scenario-verify",args
562 tenant = _get_tenant()
563 headers_req = {'content-type': 'application/json'}
565 action["verify"] = {}
566 action["verify"]["instance_name"] = "scen-verify-return5"
567 payload_req = json.dumps(action, indent=4)
570 URLrequest = "http://%s:%s/openmano/%s/scenarios/%s/action" %(mano_host, mano_port, tenant, args.scenario)
571 logger.debug("openmano request: %s", payload_req)
572 mano_response = requests.post(URLrequest, headers = headers_req, data=payload_req)
573 logger.debug("openmano response: %s", mano_response.text )
575 result = 0 if mano_response.status_code==200 else mano_response.status_code
576 content = mano_response.json()
577 #print json.dumps(content, indent=4)
578 if mano_response.status_code == 200:
579 print content['result']
581 print content['error']['description']
584 def instance_create(args):
585 tenant = _get_tenant()
586 headers_req = {'content-type': 'application/yaml'}
587 myInstance={"instance": {}, "schema_version": "0.1"}
589 instance_dict = _load_file_or_yaml(args.file)
590 if "instance" not in instance_dict:
591 myInstance = {"instance": instance_dict, "schema_version": "0.1"}
593 myInstance = instance_dict
595 myInstance["instance"]['name'] = args.name
597 myInstance["instance"]['description'] = args.description
599 myInstance["instance"]['action'] = "reserve"
601 datacenter = myInstance["instance"].get("datacenter")
602 if args.datacenter != None:
603 datacenter = args.datacenter
604 myInstance["instance"]["datacenter"] = _get_datacenter(datacenter, tenant)
606 scenario = myInstance["instance"].get("scenario")
607 if args.scenario != None:
608 scenario = args.scenario
610 print "you must provide a scenario in the file descriptor or with --scenario"
612 myInstance["instance"]["scenario"] = _get_item_uuid("scenarios", scenario, tenant)
614 if "networks" not in myInstance["instance"]:
615 myInstance["instance"]["networks"] = {}
616 for net in args.netmap_use:
617 net_comma_list = net.split(",")
618 for net_comma in net_comma_list:
619 net_tuple = net_comma.split("=")
620 if len(net_tuple) != 2:
621 print "error at netmap-use. Expected net-scenario=net-datacenter. (%s)?" % net_comma
623 net_scenario = net_tuple[0].strip()
624 net_datacenter = net_tuple[1].strip()
625 if net_scenario not in myInstance["instance"]["networks"]:
626 myInstance["instance"]["networks"][net_scenario] = {}
627 if "sites" not in myInstance["instance"]["networks"][net_scenario]:
628 myInstance["instance"]["networks"][net_scenario]["sites"] = [ {} ]
629 myInstance["instance"]["networks"][net_scenario]["sites"][0]["netmap-use"] = net_datacenter
630 if args.netmap_create:
631 if "networks" not in myInstance["instance"]:
632 myInstance["instance"]["networks"] = {}
633 for net in args.netmap_create:
634 net_comma_list = net.split(",")
635 for net_comma in net_comma_list:
636 net_tuple = net_comma.split("=")
637 if len(net_tuple) == 1:
638 net_scenario = net_tuple[0].strip()
639 net_datacenter = None
640 elif len(net_tuple) == 2:
641 net_scenario = net_tuple[0].strip()
642 net_datacenter = net_tuple[1].strip()
644 print "error at netmap-create. Expected net-scenario=net-datacenter or net-scenario. (%s)?" % net_comma
646 if net_scenario not in myInstance["instance"]["networks"]:
647 myInstance["instance"]["networks"][net_scenario] = {}
648 if "sites" not in myInstance["instance"]["networks"][net_scenario]:
649 myInstance["instance"]["networks"][net_scenario]["sites"] = [ {} ]
650 myInstance["instance"]["networks"][net_scenario]["sites"][0]["netmap-create"] = net_datacenter
652 if "cloud-config" not in myInstance["instance"]:
653 myInstance["instance"]["cloud-config"] = {}
654 cloud_config = myInstance["instance"]["cloud-config"]
655 for key in args.keypair:
656 index = key.find(":")
658 if "key-pairs" not in cloud_config:
659 cloud_config["key-pairs"] = []
660 cloud_config["key-pairs"].append(key)
664 key_list = key_.split(",")
665 if "users" not in cloud_config:
666 cloud_config["users"] = []
667 cloud_config["users"].append({"name": user, "key-pairs": key_list })
668 if args.keypair_auto:
671 home = os.getenv("HOME")
672 user = os.getenv("USER")
673 files = os.listdir(home+'/.ssh')
675 if file[-4:] == ".pub":
676 with open(home+'/.ssh/'+file, 'r') as f:
677 keys.append(f.read())
679 print "Cannot obtain any public ssh key from '{}'. Try not using --keymap-auto".format(home+'/.ssh')
681 except Exception as e:
682 print "Cannot obtain any public ssh key. Error '{}'. Try not using --keymap-auto".format(str(e))
685 if "cloud-config" not in myInstance["instance"]:
686 myInstance["instance"]["cloud-config"] = {}
687 cloud_config = myInstance["instance"]["cloud-config"]
688 if "key-pairs" not in cloud_config:
689 cloud_config["key-pairs"] = []
691 if "users" not in cloud_config:
692 cloud_config["users"] = []
693 cloud_config["users"].append({"name": user, "key-pairs": keys })
695 payload_req = yaml.safe_dump(myInstance, explicit_start=True, indent=4, default_flow_style=False, tags=False, encoding='utf-8', allow_unicode=True)
696 logger.debug("openmano request: %s", payload_req)
697 URLrequest = "http://%s:%s/openmano/%s/instances" %(mano_host, mano_port, tenant)
698 mano_response = requests.post(URLrequest, headers = headers_req, data=payload_req)
699 logger.debug("openmano response: %s", mano_response.text )
700 if args.verbose==None:
703 result = 0 if mano_response.status_code==200 else mano_response.status_code
704 content = mano_response.json()
705 #print json.dumps(content, indent=4)
706 if args.verbose >= 3:
707 print yaml.safe_dump(content, indent=4, default_flow_style=False)
710 if mano_response.status_code == 200:
711 myoutput = "%s %s" %(content['uuid'].ljust(38),content['name'].ljust(20))
713 myoutput = "%s %s" %(myoutput, content['created_at'].ljust(20))
715 myoutput = "%s %s %s" %(myoutput, content['description'].ljust(30))
718 print content['error']['description']
721 def instance_scenario_list(args):
722 #print "instance-scenario-list",args
726 tenant = _get_tenant()
728 toshow = _get_item_uuid("instances", args.name, tenant)
729 URLrequest = "http://%s:%s/openmano/%s/instances/%s" %(mano_host, mano_port, tenant, toshow)
731 URLrequest = "http://%s:%s/openmano/%s/instances" %(mano_host, mano_port, tenant)
732 mano_response = requests.get(URLrequest)
733 logger.debug("openmano response: %s", mano_response.text )
734 content = mano_response.json()
735 #print json.dumps(content, indent=4)
736 if args.verbose==None:
739 result = 0 if mano_response.status_code==200 else mano_response.status_code
740 if mano_response.status_code == 200:
742 if args.verbose >= 3:
743 print yaml.safe_dump(content, indent=4, default_flow_style=False)
745 if len(content['instances']) == 0:
746 print "No scenario instances were found."
748 for instance in content['instances']:
749 myoutput = "%s %s" %(instance['uuid'].ljust(38),instance['name'].ljust(20))
751 myoutput = "%s %s" %(myoutput, instance['created_at'].ljust(20))
754 print "Description: %s" %instance['description']
757 print yaml.safe_dump(content, indent=4, default_flow_style=False)
760 print "%s %s %s" %(instance['uuid'].ljust(38),instance['name'].ljust(20),instance['created_at'].ljust(20))
761 print "Description: %s" %instance['description']
762 print "Template scenario id: %s" %instance['scenario_id']
763 print "Template scenario name: %s" %instance['scenario_name']
764 print "---------------------------------------"
765 print "VNF instances: %d" %len(instance['vnfs'])
766 for vnf in instance['vnfs']:
767 #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))
768 print " %s %s Template vnf id: %s" %(vnf['uuid'].ljust(38), vnf['vnf_name'].ljust(20), vnf['vnf_id'].ljust(38))
769 if len(instance['nets'])>0:
770 print "---------------------------------------"
771 print "Internal nets:"
772 for net in instance['nets']:
774 print " %s %s VIM ID: %s" %(net['uuid'].ljust(38), net['status'].ljust(12), net['vim_net_id'])
775 print "---------------------------------------"
776 print "External nets:"
777 for net in instance['nets']:
778 if not net['created']:
779 print " %s %s VIM ID: %s" %(net['uuid'].ljust(38), net['status'].ljust(12), net['vim_net_id'])
780 print "---------------------------------------"
781 print "VM instances:"
782 for vnf in instance['vnfs']:
783 for vm in vnf['vms']:
784 print " %s %s %s %s VIM ID: %s" %(vm['uuid'].ljust(38), vnf['vnf_name'].ljust(20), vm['name'].ljust(20), vm['status'].ljust(12), vm['vim_vm_id'])
786 print content['error']['description']
788 print yaml.safe_dump(content, indent=4, default_flow_style=False)
791 def instance_scenario_status(args):
792 print "instance-scenario-status"
795 def instance_scenario_delete(args):
799 tenant = _get_tenant()
800 todelete = _get_item_uuid("instances", args.name, tenant=tenant)
801 #print "instance-scenario-delete",args
803 r = raw_input("Delete scenario instance %s (y/N)? " %(args.name))
804 if not (len(r)>0 and r[0].lower()=="y"):
806 URLrequest = "http://%s:%s/openmano/%s/instances/%s" %(mano_host, mano_port, tenant, todelete)
807 mano_response = requests.delete(URLrequest)
808 logger.debug("openmano response: %s", mano_response.text )
809 result = 0 if mano_response.status_code==200 else mano_response.status_code
810 content = mano_response.json()
811 #print json.dumps(content, indent=4)
812 if mano_response.status_code == 200:
813 print content['result']
815 print content['error']['description']
818 def instance_scenario_action(args):
819 #print "instance-scenario-action", args
820 tenant = _get_tenant()
821 toact = _get_item_uuid("instances", args.name, tenant=tenant)
823 action[ args.action ] = args.param
825 action["vnfs"] = args.vnf
827 action["vms"] = args.vm
829 headers_req = {'content-type': 'application/json'}
830 payload_req = json.dumps(action, indent=4)
831 URLrequest = "http://%s:%s/openmano/%s/instances/%s/action" %(mano_host, mano_port, tenant, toact)
832 logger.debug("openmano request: %s", payload_req)
833 mano_response = requests.post(URLrequest, headers = headers_req, data=payload_req)
834 logger.debug("openmano response: %s", mano_response.text )
835 result = 0 if mano_response.status_code==200 else mano_response.status_code
836 content = mano_response.json()
837 #print json.dumps(content, indent=4)
838 if mano_response.status_code == 200:
840 print yaml.safe_dump(content, indent=4, default_flow_style=False)
842 for uuid,c in content.iteritems():
843 print "%s %s %s" %(uuid.ljust(38), c['name'].ljust(20),c['description'].ljust(20))
845 print content['error']['description']
849 def instance_vnf_list(args):
850 print "instance-vnf-list"
853 def instance_vnf_status(args):
854 print "instance-vnf-status"
857 def tenant_create(args):
858 headers_req = {'Accept': 'application/json', 'content-type': 'application/json'}
859 tenant_dict={"name": args.name}
860 if args.description!=None:
861 tenant_dict["description"] = args.description
862 payload_req = json.dumps( {"tenant": tenant_dict })
866 URLrequest = "http://%s:%s/openmano/tenants" %(mano_host, mano_port)
867 logger.debug("openmano request: %s", payload_req)
868 mano_response = requests.post(URLrequest, headers=headers_req, data=payload_req)
869 logger.debug("openmano response: %s", mano_response.text )
870 return _print_verbose(mano_response, args.verbose)
872 def tenant_list(args):
873 #print "tenant-list",args
875 toshow = _get_item_uuid("tenants", args.name)
876 URLrequest = "http://%s:%s/openmano/tenants/%s" %(mano_host, mano_port, toshow)
878 URLrequest = "http://%s:%s/openmano/tenants" %(mano_host, mano_port)
879 mano_response = requests.get(URLrequest)
880 logger.debug("openmano response: %s", mano_response.text )
881 if args.verbose==None:
885 return _print_verbose(mano_response, args.verbose)
887 def tenant_delete(args):
888 #print "tenant-delete",args
889 todelete = _get_item_uuid("tenants", args.name)
891 r = raw_input("Delete tenant %s (y/N)? " %(args.name))
892 if not (len(r)>0 and r[0].lower()=="y"):
894 URLrequest = "http://%s:%s/openmano/tenants/%s" %(mano_host, mano_port, todelete)
895 mano_response = requests.delete(URLrequest)
896 logger.debug("openmano response: %s", mano_response.text )
897 result = 0 if mano_response.status_code==200 else mano_response.status_code
898 content = mano_response.json()
899 #print json.dumps(content, indent=4)
900 if mano_response.status_code == 200:
901 print content['result']
903 print content['error']['description']
906 def datacenter_attach(args):
907 tenant = _get_tenant()
908 datacenter = _get_datacenter(args.name)
909 headers_req = {'Accept': 'application/json', 'content-type': 'application/json'}
912 if args.vim_tenant_id != None:
913 datacenter_dict['vim_tenant'] = args.vim_tenant_id
914 if args.vim_tenant_name != None:
915 datacenter_dict['vim_tenant_name'] = args.vim_tenant_name
916 if args.user != None:
917 datacenter_dict['vim_username'] = args.user
918 if args.password != None:
919 datacenter_dict['vim_password'] = args.password
920 if args.config!=None:
921 datacenter_dict["config"] = _load_file_or_yaml(args.config)
922 payload_req = json.dumps( {"datacenter": datacenter_dict })
926 URLrequest = "http://%s:%s/openmano/%s/datacenters/%s" %(mano_host, mano_port, tenant, datacenter)
927 logger.debug("openmano request: %s", payload_req)
928 mano_response = requests.post(URLrequest, headers=headers_req, data=payload_req)
929 logger.debug("openmano response: %s", mano_response.text )
930 result = _print_verbose(mano_response, args.verbose)
931 #provide addional information if error
932 if mano_response.status_code != 200:
933 content = mano_response.json()
934 if "already in use for 'name'" in content['error']['description'] and \
935 "to database vim_tenants table" in content['error']['description']:
936 print "Try to specify a different name with --vim-tenant-name"
940 def datacenter_edit_vim_tenant(args):
941 tenant = _get_tenant()
942 datacenter = _get_datacenter(args.name)
943 headers_req = {'Accept': 'application/json', 'content-type': 'application/json'}
945 if not (args.vim_tenant_id or args.vim_tenant_name or args.user or args.password or args.config):
946 raise OpenmanoCLIError("Error. At least one parameter must be updated.")
949 if args.vim_tenant_id != None:
950 datacenter_dict['vim_tenant'] = args.vim_tenant_id
951 if args.vim_tenant_name != None:
952 datacenter_dict['vim_tenant_name'] = args.vim_tenant_name
953 if args.user != None:
954 datacenter_dict['vim_username'] = args.user
955 if args.password != None:
956 datacenter_dict['vim_password'] = args.password
957 if args.config != None:
958 datacenter_dict["config"] = _load_file_or_yaml(args.config)
959 payload_req = json.dumps({"datacenter": datacenter_dict})
963 URLrequest = "http://%s:%s/openmano/%s/datacenters/%s" % (mano_host, mano_port, tenant, datacenter)
964 logger.debug("openmano request: %s", payload_req)
965 mano_response = requests.put(URLrequest, headers=headers_req, data=payload_req)
966 logger.debug("openmano response: %s", mano_response.text)
967 result = _print_verbose(mano_response, args.verbose)
971 def datacenter_detach(args):
975 tenant = _get_tenant()
976 datacenter = _get_datacenter(args.name, tenant)
977 headers_req = {'Accept': 'application/json', 'content-type': 'application/json'}
978 URLrequest = "http://%s:%s/openmano/%s/datacenters/%s" %(mano_host, mano_port, tenant, datacenter)
979 mano_response = requests.delete(URLrequest, headers=headers_req)
980 logger.debug("openmano response: %s", mano_response.text )
981 content = mano_response.json()
982 #print json.dumps(content, indent=4)
983 result = 0 if mano_response.status_code==200 else mano_response.status_code
984 if mano_response.status_code == 200:
985 print content['result']
987 print content['error']['description']
990 def datacenter_create(args):
991 headers_req = {'Accept': 'application/json', 'content-type': 'application/json'}
992 datacenter_dict={"name": args.name, "vim_url": args.url}
993 if args.description!=None:
994 datacenter_dict["description"] = args.description
996 datacenter_dict["type"] = args.type
998 datacenter_dict["vim_url_admin"] = args.url_admin
999 if args.config!=None:
1000 datacenter_dict["config"] = _load_file_or_yaml(args.config)
1001 if args.sdn_controller!=None:
1002 tenant = _get_tenant()
1003 sdn_controller = _get_item_uuid("sdn_controllers", args.sdn_controller, tenant)
1004 if not 'config' in datacenter_dict:
1005 datacenter_dict['config'] = {}
1006 datacenter_dict['config']['sdn-controller'] = sdn_controller
1007 payload_req = json.dumps( {"datacenter": datacenter_dict })
1011 URLrequest = "http://%s:%s/openmano/datacenters" %(mano_host, mano_port)
1012 logger.debug("openmano request: %s", payload_req)
1013 mano_response = requests.post(URLrequest, headers=headers_req, data=payload_req)
1014 logger.debug("openmano response: %s", mano_response.text )
1015 return _print_verbose(mano_response, args.verbose)
1017 def datacenter_delete(args):
1018 #print "datacenter-delete",args
1019 todelete = _get_item_uuid("datacenters", args.name, "any")
1021 r = raw_input("Delete datacenter %s (y/N)? " %(args.name))
1022 if not (len(r)>0 and r[0].lower()=="y"):
1024 URLrequest = "http://%s:%s/openmano/datacenters/%s" %(mano_host, mano_port, todelete)
1025 mano_response = requests.delete(URLrequest)
1026 logger.debug("openmano response: %s", mano_response.text )
1027 result = 0 if mano_response.status_code==200 else mano_response.status_code
1028 content = mano_response.json()
1029 #print json.dumps(content, indent=4)
1030 if mano_response.status_code == 200:
1031 print content['result']
1033 print content['error']['description']
1036 def datacenter_list(args):
1037 #print "datacenter-list",args
1038 tenant='any' if args.all else _get_tenant()
1041 toshow = _get_item_uuid("datacenters", args.name, tenant)
1042 URLrequest = "http://%s:%s/openmano/%s/datacenters/%s" %(mano_host, mano_port, tenant, toshow)
1044 URLrequest = "http://%s:%s/openmano/%s/datacenters" %(mano_host, mano_port, tenant)
1045 mano_response = requests.get(URLrequest)
1046 logger.debug("openmano response: %s", mano_response.text )
1047 if args.verbose==None:
1051 return _print_verbose(mano_response, args.verbose)
1053 def datacenter_sdn_port_mapping_set(args):
1054 tenant = _get_tenant()
1055 datacenter = _get_datacenter(args.name, tenant)
1056 headers_req = {'Accept': 'application/json', 'content-type': 'application/json'}
1059 raise OpenmanoCLIError(
1060 "No yaml/json has been provided specifying the SDN port mapping")
1062 port_mapping = yaml.load(datacenter_sdn_port_mapping_list(args))
1063 if 'error' in port_mapping:
1064 raise OpenmanoCLIError("openmano client error: {}".format(port_mapping['error']['description']))
1065 if len(port_mapping["sdn_port_mapping"]["ports_mapping"]) > 0:
1067 r = raw_input("Datacenter %s already contains a port mapping. Overwrite? (y/N)? " % (datacenter))
1068 if not (len(r) > 0 and r[0].lower() == "y"):
1071 print datacenter_sdn_port_mapping_clear(args)
1073 sdn_port_mapping = _load_file_or_yaml(args.file)
1074 payload_req = json.dumps({"sdn_port_mapping": sdn_port_mapping})
1076 URLrequest = "http://%s:%s/openmano/%s/datacenters/%s/sdn_mapping" % (mano_host, mano_port, tenant, datacenter)
1077 logger.debug("openmano request: %s", payload_req)
1078 mano_response = requests.post(URLrequest, headers=headers_req, data=payload_req)
1079 logger.debug("openmano response: %s", mano_response.text)
1081 if mano_response.status_code == 200:
1082 return yaml.safe_dump(mano_response.json())
1084 return mano_response.content
1086 def datacenter_sdn_port_mapping_list(args):
1087 tenant = _get_tenant()
1088 datacenter = _get_datacenter(args.name, tenant)
1090 URLrequest = "http://%s:%s/openmano/%s/datacenters/%s/sdn_mapping" % (mano_host, mano_port, tenant, datacenter)
1091 mano_response = requests.get(URLrequest)
1092 logger.debug("openmano response: %s", mano_response.text)
1094 if mano_response.status_code != 200:
1095 return mano_response.content
1097 return yaml.safe_dump(mano_response.json())
1099 def datacenter_sdn_port_mapping_clear(args):
1100 tenant = _get_tenant()
1101 datacenter = _get_datacenter(args.name, tenant)
1104 r = raw_input("Clean SDN port mapping for datacenter %s (y/N)? " %(datacenter))
1105 if not (len(r)>0 and r[0].lower()=="y"):
1108 URLrequest = "http://%s:%s/openmano/%s/datacenters/%s/sdn_mapping" % (mano_host, mano_port, tenant, datacenter)
1109 mano_response = requests.delete(URLrequest)
1110 logger.debug("openmano response: %s", mano_response.text)
1112 if mano_response.status_code != 200:
1113 if "No port mapping for datacenter" in mano_response.content:
1114 return "No port mapping for datacenter " + datacenter + " has been found"
1115 return mano_response.content
1117 return yaml.safe_dump(mano_response.json())
1119 def sdn_controller_create(args):
1120 tenant = _get_tenant()
1121 headers_req = {'Accept': 'application/json', 'content-type': 'application/json'}
1123 if not (args.ip and args.port and args.dpid and args.type):
1124 raise OpenmanoCLIError("The following arguments are required: ip, port, dpid, type")
1126 controller_dict = {}
1127 controller_dict['name'] = args.name
1128 controller_dict['ip'] = args.ip
1129 controller_dict['port'] = int(args.port)
1130 controller_dict['dpid'] = args.dpid
1131 controller_dict['type'] = args.type
1132 if args.description != None:
1133 controller_dict['description'] = args.description
1134 if args.user != None:
1135 controller_dict['user'] = args.user
1136 if args.password != None:
1137 controller_dict['password'] = args.password
1139 payload_req = json.dumps({"sdn_controller": controller_dict})
1143 URLrequest = "http://%s:%s/openmano/%s/sdn_controllers" % (mano_host, mano_port, tenant)
1144 logger.debug("openmano request: %s", payload_req)
1145 mano_response = requests.post(URLrequest, headers=headers_req, data=payload_req)
1146 logger.debug("openmano response: %s", mano_response.text)
1147 result = _print_verbose(mano_response, args.verbose)
1151 def sdn_controller_edit(args):
1152 tenant = _get_tenant()
1153 controller_uuid = _get_item_uuid("sdn_controllers", args.name, tenant)
1154 headers_req = {'Accept': 'application/json', 'content-type': 'application/json'}
1156 if not (args.new_name or args.ip or args.port or args.dpid or args.type):
1157 raise OpenmanoCLIError("At least one parameter must be editd")
1160 r = raw_input("Update SDN controller %s (y/N)? " %(args.name))
1161 if not (len(r)>0 and r[0].lower()=="y"):
1164 controller_dict = {}
1165 if args.new_name != None:
1166 controller_dict['name'] = args.new_name
1168 controller_dict['ip'] = args.ip
1169 if args.port != None:
1170 controller_dict['port'] = int(args.port)
1171 if args.dpid != None:
1172 controller_dict['dpid'] = args.dpid
1173 if args.type != None:
1174 controller_dict['type'] = args.type
1175 if args.description != None:
1176 controller_dict['description'] = args.description
1177 if args.user != None:
1178 controller_dict['user'] = args.user
1179 if args.password != None:
1180 controller_dict['password'] = args.password
1182 payload_req = json.dumps({"sdn_controller": controller_dict})
1186 URLrequest = "http://%s:%s/openmano/%s/sdn_controllers/%s" % (mano_host, mano_port, tenant, controller_uuid)
1187 logger.debug("openmano request: %s", payload_req)
1188 mano_response = requests.put(URLrequest, headers=headers_req, data=payload_req)
1189 logger.debug("openmano response: %s", mano_response.text)
1190 result = _print_verbose(mano_response, args.verbose)
1194 def sdn_controller_list(args):
1195 tenant = _get_tenant()
1196 headers_req = {'Accept': 'application/json', 'content-type': 'application/json'}
1199 toshow = _get_item_uuid("sdn_controllers", args.name, tenant)
1200 URLrequest = "http://%s:%s/openmano/%s/sdn_controllers/%s" %(mano_host, mano_port, tenant, toshow)
1202 URLrequest = "http://%s:%s/openmano/%s/sdn_controllers" %(mano_host, mano_port, tenant)
1204 mano_response = requests.get(URLrequest)
1205 logger.debug("openmano response: %s", mano_response.text )
1206 if args.verbose==None:
1211 result = json.dumps(mano_response.json(), indent=4)
1214 def sdn_controller_delete(args):
1215 tenant = _get_tenant()
1216 controller_uuid = _get_item_uuid("sdn_controllers", args.name, tenant)
1219 r = raw_input("Delete SDN controller %s (y/N)? " % (args.name))
1220 if not (len(r) > 0 and r[0].lower() == "y"):
1223 URLrequest = "http://%s:%s/openmano/%s/sdn_controllers/%s" % (mano_host, mano_port, tenant, controller_uuid)
1224 mano_response = requests.delete(URLrequest)
1225 logger.debug("openmano response: %s", mano_response.text)
1226 result = _print_verbose(mano_response, args.verbose)
1230 def vim_action(args):
1231 #print "datacenter-net-action",args
1232 tenant = _get_tenant()
1233 datacenter = _get_datacenter(args.datacenter, tenant)
1234 if args.verbose==None:
1236 if args.action=="list":
1237 URLrequest = "http://%s:%s/openmano/%s/vim/%s/%ss" %(mano_host, mano_port, tenant, datacenter, args.item)
1240 URLrequest += "/" + args.name
1241 mano_response = requests.get(URLrequest)
1242 logger.debug("openmano response: %s", mano_response.text )
1243 return _print_verbose(mano_response, args.verbose)
1244 elif args.action=="delete":
1245 URLrequest = "http://%s:%s/openmano/%s/vim/%s/%ss/%s" %(mano_host, mano_port, tenant, datacenter, args.item, args.name)
1246 mano_response = requests.delete(URLrequest)
1247 logger.debug("openmano response: %s", mano_response.text )
1248 result = 0 if mano_response.status_code==200 else mano_response.status_code
1249 content = mano_response.json()
1250 #print json.dumps(content, indent=4)
1251 if mano_response.status_code == 200:
1252 print content['result']
1254 print content['error']['description']
1256 elif args.action=="create":
1257 headers_req = {'content-type': 'application/yaml'}
1259 create_dict = _load_file_or_yaml(args.file)
1260 if args.item not in create_dict:
1261 create_dict = {args.item: create_dict}
1263 create_dict = {args.item:{}}
1265 create_dict[args.item]['name'] = args.name
1266 #if args.description:
1267 # create_dict[args.item]['description'] = args.description
1268 if args.item=="network":
1270 create_dict[args.item]['bind_net'] = args.bind_net
1272 create_dict[args.item]['type'] = args.type
1274 create_dict[args.item]['shared'] = args.shared
1275 if "name" not in create_dict[args.item]:
1276 print "You must provide a name in the descriptor file or with the --name option"
1278 payload_req = yaml.safe_dump(create_dict, explicit_start=True, indent=4, default_flow_style=False, tags=False, encoding='utf-8', allow_unicode=True)
1279 logger.debug("openmano request: %s", payload_req)
1280 URLrequest = "http://%s:%s/openmano/%s/vim/%s/%ss" %(mano_host, mano_port, tenant, datacenter, args.item)
1281 mano_response = requests.post(URLrequest, headers = headers_req, data=payload_req)
1282 logger.debug("openmano response: %s", mano_response.text )
1283 if args.verbose==None:
1285 return _print_verbose(mano_response, args.verbose)
1287 def _get_items(item, item_name_id=None, datacenter=None, tenant=None):
1288 URLrequest = "http://%s:%s/openmano" %(mano_host, mano_port)
1290 URLrequest += "/" + tenant
1292 URLrequest += "/vim/" + datacenter
1294 URLrequest += "/" + item +"s"
1296 URLrequest += "/" + item_name_id
1297 mano_response = requests.get(URLrequest)
1298 logger.debug("openmano response: %s", mano_response.text )
1300 return mano_response
1302 def vim_net_sdn_attach(args):
1303 #Verify the network exists in the vim
1304 tenant = _get_tenant()
1305 datacenter = _get_datacenter(args.datacenter, tenant)
1306 result = _get_items('network', item_name_id=args.vim_net, datacenter=datacenter, tenant=tenant)
1307 content = yaml.load(result.content)
1308 if 'networks' in content:
1309 raise OpenmanoCLIError('More than one network in the vim named ' + args.vim_net + '. Use uuid instead')
1310 if 'error' in content:
1311 raise OpenmanoCLIError(yaml.safe_dump(content))
1312 network_uuid = content['network']['id']
1314 #Make call to attach the dataplane port to the SND network associated to the vim network
1315 headers_req = {'content-type': 'application/yaml'}
1316 payload_req = {'port': args.port}
1318 payload_req['vlan'] = int(args.vlan)
1320 payload_req['mac'] = args.mac
1322 URLrequest = "http://%s:%s/openmano/%s/vim/%s/network/%s/attach" % (mano_host, mano_port, tenant, datacenter, network_uuid)
1323 logger.debug("openmano request: %s", payload_req)
1324 mano_response = requests.post(URLrequest, headers=headers_req, data=json.dumps(payload_req))
1325 logger.debug("openmano response: %s", mano_response.text)
1326 result = _print_verbose(mano_response, args.verbose)
1331 def vim_net_sdn_detach(args):
1332 if not args.all and not args.id:
1333 print "--all or --id must be used"
1336 # Verify the network exists in the vim
1337 tenant = _get_tenant()
1338 datacenter = _get_datacenter(args.datacenter, tenant)
1339 result = _get_items('network', item_name_id=args.vim_net, datacenter=datacenter, tenant=tenant)
1340 content = yaml.load(result.content)
1341 if 'networks' in content:
1342 raise OpenmanoCLIError('More than one network in the vim named ' + args.vim_net + '. Use uuid instead')
1343 if 'error' in content:
1344 raise OpenmanoCLIError(yaml.safe_dump(content))
1345 network_uuid = content['network']['id']
1348 r = raw_input("Confirm action' (y/N)? ")
1349 if len(r) == 0 or r[0].lower() != "y":
1353 URLrequest = "http://%s:%s/openmano/%s/vim/%s/network/%s/detach/%s" % (
1354 mano_host, mano_port, tenant, datacenter, network_uuid, args.id)
1356 URLrequest = "http://%s:%s/openmano/%s/vim/%s/network/%s/detach" % (
1357 mano_host, mano_port, tenant, datacenter, network_uuid)
1358 mano_response = requests.delete(URLrequest)
1359 logger.debug("openmano response: %s", mano_response.text)
1360 result = _print_verbose(mano_response, args.verbose)
1364 def datacenter_net_action(args):
1365 if args.action == "net-update":
1366 print "This command is deprecated, use 'openmano datacenter-netmap-delete --all' and 'openmano datacenter-netmap-import' instead!!!"
1368 args.action = "netmap-delete"
1371 r = datacenter_netmap_action(args)
1374 args.action = "netmap-import"
1375 r = datacenter_netmap_action(args)
1378 if args.action == "net-edit":
1379 args.netmap = args.net
1381 elif args.action == "net-list":
1383 elif args.action == "net-delete":
1384 args.netmap = args.net
1387 args.action = "netmap" + args.action[3:]
1390 print "This command is deprecated, use 'openmano datacenter-%s' instead!!!" % args.action
1392 return datacenter_netmap_action(args)
1394 def datacenter_netmap_action(args):
1395 tenant = _get_tenant()
1396 datacenter = _get_datacenter(args.datacenter, tenant)
1397 #print "datacenter_netmap_action",args
1399 if args.verbose==None:
1401 headers_req = {'Accept': 'application/json', 'content-type': 'application/json'}
1402 URLrequest = "http://%s:%s/openmano/%s/datacenters/%s/netmaps" %(mano_host, mano_port, tenant, datacenter)
1404 if args.action=="netmap-list":
1406 URLrequest += "/" + args.netmap
1408 mano_response = requests.get(URLrequest)
1410 elif args.action=="netmap-delete":
1411 if args.netmap and args.all:
1412 print "you can not use a netmap name and the option --all at the same time"
1415 force_text= "Delete default netmap '%s' from datacenter '%s' (y/N)? " % (args.netmap, datacenter)
1416 URLrequest += "/" + args.netmap
1418 force_text="Delete all default netmaps from datacenter '%s' (y/N)? " % (datacenter)
1420 print "you must specify a netmap name or the option --all"
1423 r = raw_input(force_text)
1424 if len(r)>0 and r[0].lower()=="y":
1428 mano_response = requests.delete(URLrequest, headers=headers_req)
1429 elif args.action=="netmap-import":
1431 r = raw_input("Create all the available networks from datacenter '%s' as default netmaps (y/N)? " % (datacenter))
1432 if len(r)>0 and r[0].lower()=="y":
1436 URLrequest += "/upload"
1437 mano_response = requests.post(URLrequest, headers=headers_req)
1438 elif args.action=="netmap-edit" or args.action=="netmap-create":
1440 payload = _load_file_or_yaml(args.file)
1443 if "netmap" not in payload:
1444 payload = {"netmap": payload}
1446 payload["netmap"]["name"] = args.name
1448 payload["netmap"]["vim_id"] = args.vim_id
1449 if args.action=="netmap-create" and args.vim_name:
1450 payload["netmap"]["vim_name"] = args.vim_name
1451 payload_req = json.dumps(payload)
1452 logger.debug("openmano request: %s", payload_req)
1454 if args.action=="netmap-edit" and not args.force:
1455 if len(payload["netmap"]) == 0:
1456 print "You must supply some parameter to edit"
1458 r = raw_input("Edit default netmap '%s' from datacenter '%s' (y/N)? " % (args.netmap, datacenter))
1459 if len(r)>0 and r[0].lower()=="y":
1463 URLrequest += "/" + args.netmap
1464 mano_response = requests.put(URLrequest, headers=headers_req, data=payload_req)
1465 else: #netmap-create
1466 if "vim_name" not in payload["netmap"] and "vim_id" not in payload["netmap"]:
1467 print "You must supply either --vim-id or --vim-name option; or include one of them in the file descriptor"
1469 mano_response = requests.post(URLrequest, headers=headers_req, data=payload_req)
1471 logger.debug("openmano response: %s", mano_response.text )
1472 return _print_verbose(mano_response, args.verbose)
1474 def element_edit(args):
1475 element = _get_item_uuid(args.element, args.name)
1476 headers_req = {'Accept': 'application/json', 'content-type': 'application/json'}
1477 URLrequest = "http://%s:%s/openmano/%s/%s" %(mano_host, mano_port, args.element, element)
1478 payload=_load_file_or_yaml(args.file)
1479 if args.element[:-1] not in payload:
1480 payload = {args.element[:-1]: payload }
1481 payload_req = json.dumps(payload)
1484 if not args.force or (args.name==None and args.filer==None):
1485 r = raw_input(" Edit " + args.element[:-1] + " " + args.name + " (y/N)? ")
1486 if len(r)>0 and r[0].lower()=="y":
1490 logger.debug("openmano request: %s", payload_req)
1491 mano_response = requests.put(URLrequest, headers=headers_req, data=payload_req)
1492 logger.debug("openmano response: %s", mano_response.text )
1493 if args.verbose==None:
1497 return _print_verbose(mano_response, args.verbose)
1500 def datacenter_edit(args):
1501 tenant = _get_tenant()
1502 element = _get_item_uuid('datacenters', args.name, tenant)
1503 headers_req = {'Accept': 'application/json', 'content-type': 'application/json'}
1504 URLrequest = "http://%s:%s/openmano/datacenters/%s" % (mano_host, mano_port, element)
1506 has_arguments = False
1507 if args.file != None:
1508 has_arguments = True
1509 payload = _load_file_or_yaml(args.file)
1513 if args.sdn_controller != None:
1514 has_arguments = True
1515 if not 'config' in payload:
1516 payload['config'] = {}
1517 if not 'sdn-controller' in payload['config']:
1518 payload['config']['sdn-controller'] = {}
1519 if args.sdn_controller == 'null':
1520 payload['config']['sdn-controller'] = None
1522 payload['config']['sdn-controller'] = _get_item_uuid("sdn_controllers", args.sdn_controller, tenant)
1524 if not has_arguments:
1525 raise OpenmanoCLIError("At least one argument must be provided to modify the datacenter")
1527 if 'datacenter' not in payload:
1528 payload = {'datacenter': payload}
1529 payload_req = json.dumps(payload)
1532 if not args.force or (args.name == None and args.filer == None):
1533 r = raw_input(" Edit datacenter " + args.name + " (y/N)? ")
1534 if len(r) > 0 and r[0].lower() == "y":
1538 logger.debug("openmano request: %s", payload_req)
1539 mano_response = requests.put(URLrequest, headers=headers_req, data=payload_req)
1540 logger.debug("openmano response: %s", mano_response.text)
1541 if args.verbose == None:
1543 if args.name != None:
1545 return _print_verbose(mano_response, args.verbose)
1548 headers_req = {'Accept': 'application/json', 'content-type': 'application/json'}
1549 URLrequest = "http://%s:%s/openmano/version" % (mano_host, mano_port)
1551 mano_response = requests.get(URLrequest, headers=headers_req)
1552 logger.debug("openmano response: %s", mano_response.text)
1553 print mano_response.text
1560 if __name__=="__main__":
1562 mano_tenant = os.getenv('OPENMANO_TENANT', None)
1563 mano_host = os.getenv('OPENMANO_HOST',"localhost")
1564 mano_port = os.getenv('OPENMANO_PORT',"9090")
1565 mano_datacenter = os.getenv('OPENMANO_DATACENTER',None)
1567 main_parser = ThrowingArgumentParser(description='User program to interact with OPENMANO-SERVER (openmanod)')
1568 main_parser.add_argument('--version', action='version', help="get version of this client",
1569 version='%(prog)s client version ' + __version__ +
1570 " (Note: use '%(prog)s version' to get server version)")
1572 subparsers = main_parser.add_subparsers(help='commands')
1574 parent_parser = argparse.ArgumentParser(add_help=False)
1575 parent_parser.add_argument('--verbose', '-v', action='count', help="increase verbosity level. Use several times")
1576 parent_parser.add_argument('--debug', '-d', action='store_true', help="show debug information")
1578 config_parser = subparsers.add_parser('config', parents=[parent_parser], help="prints configuration values")
1579 config_parser.add_argument("-n", action="store_true", help="resolves tenant and datacenter names")
1580 config_parser.set_defaults(func=config)
1582 version_parser = subparsers.add_parser('version', parents=[parent_parser], help="get server version")
1583 version_parser.set_defaults(func=version)
1585 vnf_create_parser = subparsers.add_parser('vnf-create', parents=[parent_parser], help="adds a vnf into the catalogue")
1586 vnf_create_parser.add_argument("file", action="store", help="location of the JSON file describing the VNF").completer = FilesCompleter
1587 vnf_create_parser.add_argument("--name", action="store", help="name of the VNF (if it exists in the VNF descriptor, it is overwritten)")
1588 vnf_create_parser.add_argument("--description", action="store", help="description of the VNF (if it exists in the VNF descriptor, it is overwritten)")
1589 vnf_create_parser.add_argument("--image-path", action="store", help="change image path locations (overwritten)")
1590 vnf_create_parser.add_argument("--image-name", action="store", help="change image name (overwritten)")
1591 vnf_create_parser.add_argument("--image-checksum", action="store", help="change image checksum (overwritten)")
1592 vnf_create_parser.set_defaults(func=vnf_create)
1594 vnf_list_parser = subparsers.add_parser('vnf-list', parents=[parent_parser], help="lists information about a vnf")
1595 vnf_list_parser.add_argument("name", nargs='?', help="name of the VNF")
1596 vnf_list_parser.add_argument("-a", "--all", action="store_true", help="shows all vnfs, not only the owned or public ones")
1597 #vnf_list_parser.add_argument('--descriptor', help="prints the VNF descriptor", action="store_true")
1598 vnf_list_parser.set_defaults(func=vnf_list)
1600 vnf_delete_parser = subparsers.add_parser('vnf-delete', parents=[parent_parser], help="deletes a vnf from the catalogue")
1601 vnf_delete_parser.add_argument("name", action="store", help="name or uuid of the VNF to be deleted")
1602 vnf_delete_parser.add_argument("-f", "--force", action="store_true", help="forces deletion without asking")
1603 vnf_delete_parser.add_argument("-a", "--all", action="store_true", help="allow delete not owned or privated one")
1604 vnf_delete_parser.set_defaults(func=vnf_delete)
1606 scenario_create_parser = subparsers.add_parser('scenario-create', parents=[parent_parser], help="adds a scenario into the OPENMANO DB")
1607 scenario_create_parser.add_argument("file", action="store", help="location of the YAML file describing the scenario").completer = FilesCompleter
1608 scenario_create_parser.add_argument("--name", action="store", help="name of the scenario (if it exists in the YAML scenario, it is overwritten)")
1609 scenario_create_parser.add_argument("--description", action="store", help="description of the scenario (if it exists in the YAML scenario, it is overwritten)")
1610 scenario_create_parser.set_defaults(func=scenario_create)
1612 scenario_list_parser = subparsers.add_parser('scenario-list', parents=[parent_parser], help="lists information about a scenario")
1613 scenario_list_parser.add_argument("name", nargs='?', help="name of the scenario")
1614 #scenario_list_parser.add_argument('--descriptor', help="prints the scenario descriptor", action="store_true")
1615 scenario_list_parser.add_argument("-a", "--all", action="store_true", help="shows all scenarios, not only the owned or public ones")
1616 scenario_list_parser.set_defaults(func=scenario_list)
1618 scenario_delete_parser = subparsers.add_parser('scenario-delete', parents=[parent_parser], help="deletes a scenario from the OPENMANO DB")
1619 scenario_delete_parser.add_argument("name", action="store", help="name or uuid of the scenario to be deleted")
1620 scenario_delete_parser.add_argument("-f", "--force", action="store_true", help="forces deletion without asking")
1621 scenario_delete_parser.add_argument("-a", "--all", action="store_true", help="allow delete not owned or privated one")
1622 scenario_delete_parser.set_defaults(func=scenario_delete)
1624 scenario_deploy_parser = subparsers.add_parser('scenario-deploy', parents=[parent_parser], help="deploys a scenario")
1625 scenario_deploy_parser.add_argument("scenario", action="store", help="name or uuid of the scenario to be deployed")
1626 scenario_deploy_parser.add_argument("name", action="store", help="name of the instance")
1627 scenario_deploy_parser.add_argument("--nostart", action="store_true", help="does not start the vms, just reserve resources")
1628 scenario_deploy_parser.add_argument("--datacenter", action="store", help="specifies the datacenter. Needed if several datacenters are available")
1629 scenario_deploy_parser.add_argument("--description", action="store", help="description of the instance")
1630 scenario_deploy_parser.set_defaults(func=scenario_deploy)
1632 scenario_deploy_parser = subparsers.add_parser('scenario-verify', help="verifies if a scenario can be deployed (deploys it and deletes it)")
1633 scenario_deploy_parser.add_argument("scenario", action="store", help="name or uuid of the scenario to be verified")
1634 scenario_deploy_parser.add_argument('--debug', '-d', action='store_true', help="show debug information")
1635 scenario_deploy_parser.set_defaults(func=scenario_verify)
1637 instance_scenario_create_parser = subparsers.add_parser('instance-scenario-create', parents=[parent_parser], help="deploys a scenario")
1638 instance_scenario_create_parser.add_argument("file", nargs='?', help="descriptor of the instance. Must be a file or yaml/json text")
1639 instance_scenario_create_parser.add_argument("--scenario", action="store", help="name or uuid of the scenario to be deployed")
1640 instance_scenario_create_parser.add_argument("--name", action="store", help="name of the instance")
1641 instance_scenario_create_parser.add_argument("--nostart", action="store_true", help="does not start the vms, just reserve resources")
1642 instance_scenario_create_parser.add_argument("--datacenter", action="store", help="specifies the datacenter. Needed if several datacenters are available")
1643 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")
1644 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")
1645 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")
1646 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")
1647 instance_scenario_create_parser.add_argument("--description", action="store", help="description of the instance")
1648 instance_scenario_create_parser.set_defaults(func=instance_create)
1650 instance_scenario_list_parser = subparsers.add_parser('instance-scenario-list', parents=[parent_parser], help="lists information about a scenario instance")
1651 instance_scenario_list_parser.add_argument("name", nargs='?', help="name of the scenario instance")
1652 instance_scenario_list_parser.add_argument("-a", "--all", action="store_true", help="shows all instance-scenarios, not only the owned")
1653 instance_scenario_list_parser.set_defaults(func=instance_scenario_list)
1655 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)")
1656 instance_scenario_delete_parser.add_argument("name", action="store", help="name or uuid of the scenario instance to be deleted")
1657 instance_scenario_delete_parser.add_argument("-f", "--force", action="store_true", help="forces deletion without asking")
1658 instance_scenario_delete_parser.add_argument("-a", "--all", action="store_true", help="allow delete not owned or privated one")
1659 instance_scenario_delete_parser.set_defaults(func=instance_scenario_delete)
1661 instance_scenario_action_parser = subparsers.add_parser('instance-scenario-action', parents=[parent_parser], help="invoke an action over part or the whole scenario instance")
1662 instance_scenario_action_parser.add_argument("name", action="store", help="name or uuid of the scenario instance")
1663 instance_scenario_action_parser.add_argument("action", action="store", type=str, \
1664 choices=["start","pause","resume","shutoff","shutdown","forceOff","rebuild","reboot", "console"],\
1665 help="action to send")
1666 instance_scenario_action_parser.add_argument("param", nargs='?', help="addional param of the action. e.g. console type (novnc, ...), reboot type (TODO)")
1667 instance_scenario_action_parser.add_argument("--vnf", action="append", help="VNF to act on (can use several entries)")
1668 instance_scenario_action_parser.add_argument("--vm", action="append", help="VM to act on (can use several entries)")
1669 instance_scenario_action_parser.set_defaults(func=instance_scenario_action)
1671 #instance_scenario_status_parser = subparsers.add_parser('instance-scenario-status', help="show the status of a scenario instance")
1672 #instance_scenario_status_parser.add_argument("name", action="store", help="name or uuid of the scenario instance")
1673 #instance_scenario_status_parser.set_defaults(func=instance_scenario_status)
1675 tenant_create_parser = subparsers.add_parser('tenant-create', parents=[parent_parser], help="creates a new tenant")
1676 tenant_create_parser.add_argument("name", action="store", help="name for the tenant")
1677 tenant_create_parser.add_argument("--description", action="store", help="description of the tenant")
1678 tenant_create_parser.set_defaults(func=tenant_create)
1680 tenant_delete_parser = subparsers.add_parser('tenant-delete', parents=[parent_parser], help="deletes a tenant from the catalogue")
1681 tenant_delete_parser.add_argument("name", action="store", help="name or uuid of the tenant to be deleted")
1682 tenant_delete_parser.add_argument("-f", "--force", action="store_true", help="forces deletion without asking")
1683 tenant_delete_parser.set_defaults(func=tenant_delete)
1685 tenant_list_parser = subparsers.add_parser('tenant-list', parents=[parent_parser], help="lists information about a tenant")
1686 tenant_list_parser.add_argument("name", nargs='?', help="name or uuid of the tenant")
1687 tenant_list_parser.set_defaults(func=tenant_list)
1689 element_edit_parser = subparsers.add_parser('tenant-edit', parents=[parent_parser], help="edits one tenant")
1690 element_edit_parser.add_argument("name", help="name or uuid of the tenant")
1691 element_edit_parser.add_argument("file", help="json/yaml text or file with the changes").completer = FilesCompleter
1692 element_edit_parser.add_argument("-f","--force", action="store_true", help="do not prompt for confirmation")
1693 element_edit_parser.set_defaults(func=element_edit, element='tenants')
1695 datacenter_create_parser = subparsers.add_parser('datacenter-create', parents=[parent_parser], help="creates a new datacenter")
1696 datacenter_create_parser.add_argument("name", action="store", help="name for the datacenter")
1697 datacenter_create_parser.add_argument("url", action="store", help="url for the datacenter")
1698 datacenter_create_parser.add_argument("--url_admin", action="store", help="url for administration for the datacenter")
1699 datacenter_create_parser.add_argument("--type", action="store", help="datacenter type: openstack or openvim (default)")
1700 datacenter_create_parser.add_argument("--config", action="store", help="aditional configuration in json/yaml format")
1701 datacenter_create_parser.add_argument("--description", action="store", help="description of the datacenter")
1702 datacenter_create_parser.add_argument("--sdn-controller", action="store", help="Name or uuid of the SDN controller to be used", dest='sdn_controller')
1703 datacenter_create_parser.set_defaults(func=datacenter_create)
1705 datacenter_delete_parser = subparsers.add_parser('datacenter-delete', parents=[parent_parser], help="deletes a datacenter from the catalogue")
1706 datacenter_delete_parser.add_argument("name", action="store", help="name or uuid of the datacenter to be deleted")
1707 datacenter_delete_parser.add_argument("-f", "--force", action="store_true", help="forces deletion without asking")
1708 datacenter_delete_parser.set_defaults(func=datacenter_delete)
1710 datacenter_edit_parser = subparsers.add_parser('datacenter-edit', parents=[parent_parser], help="Edit datacenter")
1711 datacenter_edit_parser.add_argument("name", help="name or uuid of the datacenter")
1712 datacenter_edit_parser.add_argument("--file", help="json/yaml text or file with the changes").completer = FilesCompleter
1713 datacenter_edit_parser.add_argument("--sdn-controller", action="store",
1714 help="Name or uuid of the SDN controller to be used. Specify 'null' to clear entry", dest='sdn_controller')
1715 datacenter_edit_parser.add_argument("-f", "--force", action="store_true", help="do not prompt for confirmation")
1716 datacenter_edit_parser.set_defaults(func=datacenter_edit)
1718 datacenter_list_parser = subparsers.add_parser('datacenter-list', parents=[parent_parser], help="lists information about a datacenter")
1719 datacenter_list_parser.add_argument("name", nargs='?', help="name or uuid of the datacenter")
1720 datacenter_list_parser.add_argument("-a", "--all", action="store_true", help="shows all datacenters, not only datacenters attached to tenant")
1721 datacenter_list_parser.set_defaults(func=datacenter_list)
1723 datacenter_attach_parser = subparsers.add_parser('datacenter-attach', parents=[parent_parser], help="associates a datacenter to the operating tenant")
1724 datacenter_attach_parser.add_argument("name", help="name or uuid of the datacenter")
1725 datacenter_attach_parser.add_argument('--vim-tenant-id', action='store', help="specify a datacenter tenant to use. A new one is created by default")
1726 datacenter_attach_parser.add_argument('--vim-tenant-name', action='store', help="specify a datacenter tenant name.")
1727 datacenter_attach_parser.add_argument("--user", action="store", help="user credentials for the datacenter")
1728 datacenter_attach_parser.add_argument("--password", action="store", help="password credentials for the datacenter")
1729 datacenter_attach_parser.add_argument("--config", action="store", help="aditional configuration in json/yaml format")
1730 datacenter_attach_parser.set_defaults(func=datacenter_attach)
1732 datacenter_edit_vim_tenant_parser = subparsers.add_parser('datacenter-edit-vim-tenant', parents=[parent_parser],
1733 help="Edit the association of a datacenter to the operating tenant")
1734 datacenter_edit_vim_tenant_parser.add_argument("name", help="name or uuid of the datacenter")
1735 datacenter_edit_vim_tenant_parser.add_argument('--vim-tenant-id', action='store',
1736 help="specify a datacenter tenant to use. A new one is created by default")
1737 datacenter_edit_vim_tenant_parser.add_argument('--vim-tenant-name', action='store', help="specify a datacenter tenant name.")
1738 datacenter_edit_vim_tenant_parser.add_argument("--user", action="store", help="user credentials for the datacenter")
1739 datacenter_edit_vim_tenant_parser.add_argument("--password", action="store", help="password credentials for the datacenter")
1740 datacenter_edit_vim_tenant_parser.add_argument("--config", action="store",
1741 help="aditional configuration in json/yaml format")
1742 datacenter_edit_vim_tenant_parser.set_defaults(func=datacenter_edit_vim_tenant)
1744 datacenter_detach_parser = subparsers.add_parser('datacenter-detach', parents=[parent_parser], help="removes the association between a datacenter and the operating tenant")
1745 datacenter_detach_parser.add_argument("name", help="name or uuid of the datacenter")
1746 datacenter_detach_parser.add_argument("-a", "--all", action="store_true", help="removes all associations from this datacenter")
1747 datacenter_detach_parser.set_defaults(func=datacenter_detach)
1749 #=======================datacenter_sdn_port_mapping_xxx section=======================
1750 #datacenter_sdn_port_mapping_set
1751 datacenter_sdn_port_mapping_set_parser = subparsers.add_parser('datacenter-sdn-port-mapping-set',
1752 parents=[parent_parser],
1753 help="Load a file with the mapping of physical ports "
1754 "and the ports of the dataplaneswitch controlled "
1756 datacenter_sdn_port_mapping_set_parser.add_argument("name", action="store", help="specifies the datacenter")
1757 datacenter_sdn_port_mapping_set_parser.add_argument("file",
1758 help="json/yaml text or file with the port mapping").completer = FilesCompleter
1759 datacenter_sdn_port_mapping_set_parser.add_argument("-f", "--force", action="store_true",
1760 help="forces overwriting without asking")
1761 datacenter_sdn_port_mapping_set_parser.set_defaults(func=datacenter_sdn_port_mapping_set)
1763 #datacenter_sdn_port_mapping_list
1764 datacenter_sdn_port_mapping_list_parser = subparsers.add_parser('datacenter-sdn-port-mapping-list',
1765 parents=[parent_parser],
1766 help="Show the SDN port mapping in a datacenter")
1767 datacenter_sdn_port_mapping_list_parser.add_argument("name", action="store", help="specifies the datacenter")
1768 datacenter_sdn_port_mapping_list_parser.set_defaults(func=datacenter_sdn_port_mapping_list)
1770 # datacenter_sdn_port_mapping_clear
1771 datacenter_sdn_port_mapping_clear_parser = subparsers.add_parser('datacenter-sdn-port-mapping-clear',
1772 parents=[parent_parser],
1773 help="Clean the the SDN port mapping in a datacenter")
1774 datacenter_sdn_port_mapping_clear_parser.add_argument("name", action="store",
1775 help="specifies the datacenter")
1776 datacenter_sdn_port_mapping_clear_parser.add_argument("-f", "--force", action="store_true",
1777 help="forces clearing without asking")
1778 datacenter_sdn_port_mapping_clear_parser.set_defaults(func=datacenter_sdn_port_mapping_clear)
1779 # =======================
1781 # =======================sdn_controller_xxx section=======================
1782 # sdn_controller_create
1783 sdn_controller_create_parser = subparsers.add_parser('sdn-controller-create', parents=[parent_parser],
1784 help="Creates an SDN controller entity within RO")
1785 sdn_controller_create_parser.add_argument("name", help="name of the SDN controller")
1786 sdn_controller_create_parser.add_argument("--description", action="store", help="description of the SDN controller")
1787 sdn_controller_create_parser.add_argument("--ip", action="store", help="IP of the SDN controller")
1788 sdn_controller_create_parser.add_argument("--port", action="store", help="Port of the SDN controller")
1789 sdn_controller_create_parser.add_argument("--dpid", action="store",
1790 help="DPID of the dataplane switch controlled by this SDN controller")
1791 sdn_controller_create_parser.add_argument("--type", action="store",
1792 help="Specify the SDN controller type. Valid types are 'opendaylight' and 'floodlight'")
1793 sdn_controller_create_parser.add_argument("--user", action="store", help="user credentials for the SDN controller")
1794 sdn_controller_create_parser.add_argument("--passwd", action="store", dest='password',
1795 help="password credentials for the SDN controller")
1796 sdn_controller_create_parser.set_defaults(func=sdn_controller_create)
1798 # sdn_controller_edit
1799 sdn_controller_edit_parser = subparsers.add_parser('sdn-controller-edit', parents=[parent_parser],
1800 help="Update one or more options of a SDN controller")
1801 sdn_controller_edit_parser.add_argument("name", help="name or uuid of the SDN controller", )
1802 sdn_controller_edit_parser.add_argument("--name", action="store", help="Update the name of the SDN controller",
1804 sdn_controller_edit_parser.add_argument("--description", action="store", help="description of the SDN controller")
1805 sdn_controller_edit_parser.add_argument("--ip", action="store", help="IP of the SDN controller")
1806 sdn_controller_edit_parser.add_argument("--port", action="store", help="Port of the SDN controller")
1807 sdn_controller_edit_parser.add_argument("--dpid", action="store",
1808 help="DPID of the dataplane switch controlled by this SDN controller")
1809 sdn_controller_edit_parser.add_argument("--type", action="store",
1810 help="Specify the SDN controller type. Valid types are 'opendaylight' and 'floodlight'")
1811 sdn_controller_edit_parser.add_argument("--user", action="store", help="user credentials for the SDN controller")
1812 sdn_controller_edit_parser.add_argument("--password", action="store",
1813 help="password credentials for the SDN controller", dest='password')
1814 sdn_controller_edit_parser.add_argument("-f", "--force", action="store_true", help="do not prompt for confirmation")
1815 #TODO: include option --file
1816 sdn_controller_edit_parser.set_defaults(func=sdn_controller_edit)
1818 #sdn_controller_list
1819 sdn_controller_list_parser = subparsers.add_parser('sdn-controller-list',
1820 parents=[parent_parser],
1821 help="List the SDN controllers")
1822 sdn_controller_list_parser.add_argument("name", nargs='?', help="name or uuid of the SDN controller")
1823 sdn_controller_list_parser.set_defaults(func=sdn_controller_list)
1825 # sdn_controller_delete
1826 sdn_controller_delete_parser = subparsers.add_parser('sdn-controller-delete',
1827 parents=[parent_parser],
1828 help="Delete the the SDN controller")
1829 sdn_controller_delete_parser.add_argument("name", help="name or uuid of the SDN controller")
1830 sdn_controller_delete_parser.add_argument("-f", "--force", action="store_true", help="forces deletion without asking")
1831 sdn_controller_delete_parser.set_defaults(func=sdn_controller_delete)
1832 # =======================
1834 action_dict={'net-update': 'retrieves external networks from datacenter',
1835 'net-edit': 'edits an external network',
1836 'net-delete': 'deletes an external network',
1837 'net-list': 'lists external networks from a datacenter'
1839 for item in action_dict:
1840 datacenter_action_parser = subparsers.add_parser('datacenter-'+item, parents=[parent_parser], help=action_dict[item])
1841 datacenter_action_parser.add_argument("datacenter", help="name or uuid of the datacenter")
1842 if item=='net-edit' or item=='net-delete':
1843 datacenter_action_parser.add_argument("net", help="name or uuid of the datacenter net")
1844 if item=='net-edit':
1845 datacenter_action_parser.add_argument("file", help="json/yaml text or file with the changes").completer = FilesCompleter
1846 if item!='net-list':
1847 datacenter_action_parser.add_argument("-f","--force", action="store_true", help="do not prompt for confirmation")
1848 datacenter_action_parser.set_defaults(func=datacenter_net_action, action=item)
1851 action_dict={'netmap-import': 'create network senario netmap base on the datacenter networks',
1852 'netmap-create': 'create a new network senario netmap',
1853 'netmap-edit': 'edit name of a network senario netmap',
1854 'netmap-delete': 'deletes a network scenario netmap (--all for clearing all)',
1855 'netmap-list': 'list/show network scenario netmaps'
1857 for item in action_dict:
1858 datacenter_action_parser = subparsers.add_parser('datacenter-'+item, parents=[parent_parser], help=action_dict[item])
1859 datacenter_action_parser.add_argument("--datacenter", help="name or uuid of the datacenter")
1860 #if item=='net-add':
1861 # datacenter_action_parser.add_argument("net", help="name of the network")
1862 if item=='netmap-delete':
1863 datacenter_action_parser.add_argument("netmap", nargs='?',help="name or uuid of the datacenter netmap to delete")
1864 datacenter_action_parser.add_argument("--all", action="store_true", help="delete all netmap of this datacenter")
1865 datacenter_action_parser.add_argument("-f","--force", action="store_true", help="do not prompt for confirmation")
1866 if item=='netmap-edit':
1867 datacenter_action_parser.add_argument("netmap", help="name or uuid of the datacenter netmap do edit")
1868 datacenter_action_parser.add_argument("file", nargs='?', help="json/yaml text or file with the changes").completer = FilesCompleter
1869 datacenter_action_parser.add_argument("--name", action='store', help="name to assign to the datacenter netmap")
1870 datacenter_action_parser.add_argument('--vim-id', action='store', help="specify vim network uuid")
1871 datacenter_action_parser.add_argument("-f","--force", action="store_true", help="do not prompt for confirmation")
1872 if item=='netmap-list':
1873 datacenter_action_parser.add_argument("netmap", nargs='?',help="name or uuid of the datacenter netmap to show")
1874 if item=='netmap-create':
1875 datacenter_action_parser.add_argument("file", nargs='?', help="json/yaml text or file descriptor with the changes").completer = FilesCompleter
1876 datacenter_action_parser.add_argument("--name", action='store', help="name to assign to the datacenter netmap, by default same as vim-name")
1877 datacenter_action_parser.add_argument('--vim-id', action='store', help="specify vim network uuid")
1878 datacenter_action_parser.add_argument('--vim-name', action='store', help="specify vim network name")
1879 if item=='netmap-import':
1880 datacenter_action_parser.add_argument("-f","--force", action="store_true", help="do not prompt for confirmation")
1881 datacenter_action_parser.set_defaults(func=datacenter_netmap_action, action=item)
1883 # =======================vim_net_sdn_xxx section=======================
1884 # vim_net_sdn_attach
1885 vim_net_sdn_attach_parser = subparsers.add_parser('vim-net-sdn-attach',
1886 parents=[parent_parser],
1887 help="Specify the port to access to an external network using SDN")
1888 vim_net_sdn_attach_parser.add_argument("vim_net", action="store",
1889 help="Name/id of the network in the vim that will be used to connect to the external network")
1890 vim_net_sdn_attach_parser.add_argument("port", action="store", help="Specifies the port in the dataplane switch to access to the external network")
1891 vim_net_sdn_attach_parser.add_argument("--vlan", action="store", help="Specifies the vlan (if any) to use in the defined port")
1892 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")
1893 vim_net_sdn_attach_parser.add_argument("--datacenter", action="store", help="specifies the datacenter")
1894 vim_net_sdn_attach_parser.set_defaults(func=vim_net_sdn_attach)
1896 # vim_net_sdn_detach
1897 vim_net_sdn_detach_parser = subparsers.add_parser('vim-net-sdn-detach',
1898 parents=[parent_parser],
1899 help="Remove the port information to access to an external network using SDN")
1901 vim_net_sdn_detach_parser.add_argument("vim_net", action="store", help="Name/id of the vim network")
1902 vim_net_sdn_detach_parser.add_argument("--id", action="store",help="Specify the uuid of the external ports from this network to be detached")
1903 vim_net_sdn_detach_parser.add_argument("--all", action="store_true", help="Detach all external ports from this network")
1904 vim_net_sdn_detach_parser.add_argument("-f", "--force", action="store_true", help="forces clearing without asking")
1905 vim_net_sdn_detach_parser.add_argument("--datacenter", action="store", help="specifies the datacenter")
1906 vim_net_sdn_detach_parser.set_defaults(func=vim_net_sdn_detach)
1907 # =======================
1909 for item in ("network", "tenant", "image"):
1911 command_name = 'vim-net'
1913 command_name = 'vim-'+item
1914 vim_item_list_parser = subparsers.add_parser(command_name + '-list', parents=[parent_parser], help="list the vim " + item + "s")
1915 vim_item_list_parser.add_argument("name", nargs='?', help="name or uuid of the " + item + "s")
1916 vim_item_list_parser.add_argument("--datacenter", action="store", help="specifies the datacenter")
1917 vim_item_list_parser.set_defaults(func=vim_action, item=item, action="list")
1919 vim_item_del_parser = subparsers.add_parser(command_name + '-delete', parents=[parent_parser], help="list the vim " + item + "s")
1920 vim_item_del_parser.add_argument("name", help="name or uuid of the " + item + "s")
1921 vim_item_del_parser.add_argument("--datacenter", action="store", help="specifies the datacenter")
1922 vim_item_del_parser.set_defaults(func=vim_action, item=item, action="delete")
1924 if item == "network" or item == "tenant":
1925 vim_item_create_parser = subparsers.add_parser(command_name + '-create', parents=[parent_parser], help="create a "+item+" at vim")
1926 vim_item_create_parser.add_argument("file", nargs='?', help="descriptor of the %s. Must be a file or yaml/json text" % item).completer = FilesCompleter
1927 vim_item_create_parser.add_argument("--name", action="store", help="name of the %s" % item )
1928 vim_item_create_parser.add_argument("--datacenter", action="store", help="specifies the datacenter")
1930 vim_item_create_parser.add_argument("--type", action="store", help="type of network, data, ptp, bridge")
1931 vim_item_create_parser.add_argument("--shared", action="store_true", help="Private or shared")
1932 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>'")
1934 vim_item_create_parser.add_argument("--description", action="store", help="description of the %s" % item)
1935 vim_item_create_parser.set_defaults(func=vim_action, item=item, action="create")
1937 argcomplete.autocomplete(main_parser)
1940 args = main_parser.parse_args()
1942 level = logging.CRITICAL
1943 streamformat = "%(asctime)s %(name)s %(levelname)s: %(message)s"
1944 if "debug" in args and args.debug:
1945 level = logging.DEBUG
1946 logging.basicConfig(format=streamformat, level= level)
1947 logger = logging.getLogger('mano')
1948 logger.setLevel(level)
1949 result = args.func(args)
1952 #for some reason it fails if call exit inside try instance. Need to call exit at the end !?
1953 except (requests.exceptions.ConnectionError):
1954 print "Connection error: not possible to contact OPENMANO-SERVER (openmanod)"
1956 except (KeyboardInterrupt):
1957 print 'Exiting openmano'
1959 except (SystemExit, ArgumentParserError):
1961 except OpenmanoCLIError as e: