X-Git-Url: https://osm.etsi.org/gitweb/?a=blobdiff_plain;f=osm_ro%2Fvimconn_openvim.py;h=6f584c5e190b796cff2dfa6a8662073f96a06cec;hb=1fa49b16e92ff2e4f512ccc466fdc3dff31559e4;hp=e86b54db2734fa6d363252f089d86f603a1064af;hpb=05a8b7bc29197345f9718796c110d6cf3c2ad176;p=osm%2FRO.git diff --git a/osm_ro/vimconn_openvim.py b/osm_ro/vimconn_openvim.py index e86b54db..6f584c5e 100644 --- a/osm_ro/vimconn_openvim.py +++ b/osm_ro/vimconn_openvim.py @@ -1,7 +1,7 @@ # -*- coding: utf-8 -*- ## -# Copyright 2015 Telefónica Investigación y Desarrollo, S.A.U. +# Copyright 2015 Telefonica Investigacion y Desarrollo, S.A.U. # This file is part of openmano # All Rights Reserved. # @@ -32,6 +32,7 @@ import requests import json import yaml import logging +import math from openmano_schemas import id_schema, name_schema, nameshort_schema, description_schema, \ vlan1000_schema, integer0_schema from jsonschema import validate as js_v, exceptions as js_e @@ -484,9 +485,31 @@ class vimconnector(vimconn.vimconnector): self._format_request_exception(e) def new_network(self,net_name, net_type, ip_profile=None, shared=False, vlan=None): #, **vim_specific): - '''Adds a tenant network to VIM''' - '''Returns the network identifier''' + """Adds a tenant network to VIM + Params: + 'net_name': name of the network + 'net_type': one of: + 'bridge': overlay isolated network + 'data': underlay E-LAN network for Passthrough and SRIOV interfaces + 'ptp': underlay E-LINE network for Passthrough and SRIOV interfaces. + 'ip_profile': is a dict containing the IP parameters of the network + 'ip_version': can be "IPv4" or "IPv6" (Currently only IPv4 is implemented) + 'subnet_address': ip_prefix_schema, that is X.X.X.X/Y + 'gateway_address': (Optional) ip_schema, that is X.X.X.X + 'dns_address': (Optional) comma separated list of ip_schema, e.g. X.X.X.X[,X,X,X,X] + 'dhcp_enabled': True or False + 'dhcp_start_address': ip_schema, first IP to grant + 'dhcp_count': number of IPs to grant. + 'shared': if this network can be seen/use by other tenants/organization + 'vlan': in case of a data or ptp net_type, the intended vlan tag to be used for the network + Returns a tuple with the network identifier and created_items, or raises an exception on error + created_items can be None or a dictionary where this method can include key-values that will be passed to + the method delete_network. Can be used to store created segments, created l2gw connections, etc. + Format is vimconnector dependent, but do not use nested dictionaries and a value of None should be the same + as not present. + """ try: + created_items = {} self._get_my_tenant() if net_type=="bridge": net_type="bridge_data" @@ -506,7 +529,7 @@ class vimconnector(vimconn.vimconnector): #if r is not None: # self.logger.warn("Warning: remove extra items %s", str(r)) network_id = response['network']['id'] - return network_id + return network_id, created_items except (requests.exceptions.RequestException, js_e.ValidationError) as e: self._format_request_exception(e) @@ -557,9 +580,13 @@ class vimconnector(vimconn.vimconnector): except (requests.exceptions.RequestException, js_e.ValidationError) as e: self._format_request_exception(e) - def delete_network(self, net_id): - '''Deletes a tenant network from VIM''' - '''Returns the network identifier''' + def delete_network(self, net_id, created_items=None): + """ + Removes a tenant network from VIM and its associated elements + :param net_id: VIM identifier of the network, provided by method new_network + :param created_items: dictionary with extra items to be deleted. provided by method new_network + Returns the network identifier or raises an exception upon error or when network is not found + """ try: self._get_my_tenant() url = self.url+'/networks/'+net_id @@ -596,6 +623,23 @@ class vimconnector(vimconn.vimconnector): '''Returns the flavor identifier''' try: new_flavor_dict = flavor_data.copy() + for device in new_flavor_dict.get('extended', {}).get('devices', ()): + if 'image name' in device: + del device['image name'] + if 'name' in device: + del device['name'] + numas = new_flavor_dict.get('extended', {}).get('numas') + if numas: + numa = numas[0] + # translate memory, cpus to EPA + if "cores" not in numa and "threads" not in numa and "paired-threads" not in numa: + numa["paired-threads"] = new_flavor_dict["vcpus"] + if "memory" not in numa: + numa["memory"] = int(math.ceil(new_flavor_dict["ram"]/1024.0)) + for iface in numa.get("interfaces", ()): + if not iface.get("bandwidth"): + iface["bandwidth"] = "1 Mbps" + new_flavor_dict["name"] = flavor_data["name"][:64] self._get_my_tenant() payload_req = json.dumps({'flavor': new_flavor_dict}) @@ -692,7 +736,6 @@ class vimconnector(vimconn.vimconnector): except (requests.exceptions.RequestException, js_e.ValidationError) as e: self._format_request_exception(e) - def get_image_id_from_path(self, path): '''Get the image id from image path in the VIM database. Returns the image_id''' try: @@ -782,8 +825,9 @@ class vimconnector(vimconn.vimconnector): #print text return -vim_response.status_code,text - def new_vminstance(self,name,description,start,image_id,flavor_id,net_list, cloud_config=None, disk_list=None): - '''Adds a VM instance to VIM + def new_vminstance(self, name, description, start, image_id, flavor_id, net_list, cloud_config=None, disk_list=None, + availability_zone_index=None, availability_zone_list=None): + """Adds a VM instance to VIM Params: start: indicates if VM must start or boot in pause mode. Ignored image_id,flavor_id: image and flavor uuid @@ -791,14 +835,18 @@ class vimconnector(vimconn.vimconnector): name: net_id: network uuid to connect vpci: virtual vcpi to assign - model: interface model, virtio, e2000, ... + model: interface model, virtio, e1000, ... mac_address: use: 'data', 'bridge', 'mgmt' - type: 'virtual', 'PF', 'VF', 'VFnotShared' + type: 'virtual', 'PCI-PASSTHROUGH'('PF'), 'SR-IOV'('VF'), 'VFnotShared' vim_id: filled/added by this function #TODO ip, security groups - Returns the instance identifier - ''' + Returns a tuple with the instance identifier and created_items or raises an exception on error + created_items can be None or a dictionary where this method can include key-values that will be passed to + the method delete_vminstance and action_vminstance. Can be used to store created ports, volumes, etc. + Format is vimconnector dependent, but do not use nested dictionaries and a value of None should be the same + as not present. + """ self.logger.debug("new_vminstance input: image='%s' flavor='%s' nics='%s'", image_id, flavor_id, str(net_list)) try: self._get_my_tenant() @@ -811,12 +859,27 @@ class vimconnector(vimconn.vimconnector): for net in net_list: if not net.get("net_id"): continue - net_dict={'uuid': net["net_id"]} - if net.get("type"): net_dict["type"] = net["type"] - if net.get("name"): net_dict["name"] = net["name"] - if net.get("vpci"): net_dict["vpci"] = net["vpci"] - if net.get("model"): net_dict["model"] = net["model"] - if net.get("mac_address"): net_dict["mac_address"] = net["mac_address"] + net_dict = {'uuid': net["net_id"]} + if net.get("type"): + if net["type"] == "SR-IOV": + net_dict["type"] = "VF" + elif net["type"] == "PCI-PASSTHROUGH": + net_dict["type"] = "PF" + else: + net_dict["type"] = net["type"] + if net.get("name"): + net_dict["name"] = net["name"] + if net.get("vpci"): + net_dict["vpci"] = net["vpci"] + if net.get("model"): + if net["model"] == "VIRTIO" or net["model"] == "paravirt": + net_dict["model"] = "virtio" + else: + net_dict["model"] = net["model"] + if net.get("mac_address"): + net_dict["mac_address"] = net["mac_address"] + if net.get("ip_address"): + net_dict["ip_address"] = net["ip_address"] virtio_net_list.append(net_dict) payload_dict={ "name": name[:64], "description": description, @@ -870,7 +933,7 @@ class vimconnector(vimconn.vimconnector): # return result, error_text break - return vminstance_id + return vminstance_id, None except (requests.exceptions.RequestException, js_e.ValidationError) as e: self._format_request_exception(e) @@ -894,7 +957,7 @@ class vimconnector(vimconn.vimconnector): except (requests.exceptions.RequestException, js_e.ValidationError) as e: self._format_request_exception(e) - def delete_vminstance(self, vm_id): + def delete_vminstance(self, vm_id, created_items=None): '''Removes a VM instance from VIM, returns the deleted vm_id''' try: self._get_my_tenant() @@ -919,7 +982,7 @@ class vimconnector(vimconn.vimconnector): vm={} #print "VIMConnector refresh_tenant_vms and nets: Getting tenant VM instance information from VIM" try: - url = self.url+'/'+self.tenant+'/servers/'+ vm_id + url = self.url + '/' + self.tenant + '/servers/' + vm_id self.logger.info("Getting vm GET %s", url) vim_response = requests.get(url, headers = self.headers_req) self._check_http_request_response(vim_response) @@ -936,7 +999,7 @@ class vimconnector(vimconn.vimconnector): #get interfaces info try: management_ip = False - url2 = self.url+'/ports?device_id='+ quote(vm_id) + url2 = self.url + '/ports?device_id=' + quote(vm_id) self.logger.info("Getting PORTS GET %s", url2) vim_response2 = requests.get(url2, headers = self.headers_req) self._check_http_request_response(vim_response2) @@ -945,7 +1008,7 @@ class vimconnector(vimconn.vimconnector): vm["interfaces"]=[] for port in client_data.get("ports"): interface={} - interface['vim_info'] = yaml.safe_dump(port) + interface['vim_info'] = yaml.safe_dump(port) interface["mac_address"] = port.get("mac_address") interface["vim_net_id"] = port.get("network_id") interface["vim_interface_id"] = port["id"] @@ -1023,7 +1086,7 @@ class vimconnector(vimconn.vimconnector): net_dict[net_id] = net return net_dict - def action_vminstance(self, vm_id, action_dict): + def action_vminstance(self, vm_id, action_dict, created_items={}): '''Send and action over a VM instance from VIM''' '''Returns the status''' try: @@ -1034,7 +1097,7 @@ class vimconnector(vimconn.vimconnector): self.logger.info("Action over VM instance POST %s", url) vim_response = requests.post(url, headers = self.headers_req, data=json.dumps(action_dict) ) self._check_http_request_response(vim_response) - return vm_id + return None except (requests.exceptions.RequestException, js_e.ValidationError) as e: self._format_request_exception(e)