X-Git-Url: https://gerrit.onap.org/r/gitweb?a=blobdiff_plain;f=lcm%2Flcm%2Fnf%2Fvnfs%2Fvnf_create%2Finst_vnf.py;h=32f139a39b12d9fdd61dbcffee1dd497fbe28b7a;hb=c01d024dfe5e9399844073ee81b43a855fa312f2;hp=bcadce0828d57f1f796e4b228e8f077ed8742e76;hpb=66fec31207eea8854c5dbaa571c82280eb910ab0;p=vfc%2Fgvnfm%2Fvnflcm.git diff --git a/lcm/lcm/nf/vnfs/vnf_create/inst_vnf.py b/lcm/lcm/nf/vnfs/vnf_create/inst_vnf.py index bcadce08..32f139a3 100644 --- a/lcm/lcm/nf/vnfs/vnf_create/inst_vnf.py +++ b/lcm/lcm/nf/vnfs/vnf_create/inst_vnf.py @@ -16,12 +16,14 @@ import logging import traceback from threading import Thread -from lcm.pub.database.models import NfInstModel, JobStatusModel, NfvoRegInfoModel +from lcm.pub.database.models import NfInstModel, JobStatusModel, NfvoRegInfoModel, VmInstModel, NetworkInstModel, \ + SubNetworkInstModel, PortInstModel, StorageInstModel, FlavourInstModel, VNFCInstModel, VLInstModel, CPInstModel from lcm.pub.exceptions import NFLCMException -from lcm.pub.msapi.nfvolcm import vnfd_rawdata_get, apply_grant_to_nfvo, apply_res_to_nfvo +from lcm.pub.msapi.nfvolcm import vnfd_rawdata_get, apply_grant_to_nfvo, notify_lcm_to_nfvo from lcm.pub.utils.jobutil import JobUtil from lcm.pub.utils.timeutil import now_time from lcm.pub.utils.values import ignore_case_get +from lcm.pub.vimapi import adaptor logger = logging.getLogger(__name__) @@ -34,15 +36,58 @@ class InstVnf(Thread): self.job_id = job_id self.nfvo_inst_id = '' self.vnfm_inst_id = '' + self.vnfd_info = [] + self.inst_resource = {'volumn': [], # [{"vim_id": ignore_case_get(ret, "vim_id")},{}]11 + 'network': [], + 'subnet': [], + 'port': [], + 'flavor': [], + 'vm': [], + } + # self.create_res_result = { + # 'jobid': 'res_001', + # 'resourceResult': [{'name': 'vm01'}, {'name': 'vm02'}], + # 'resource_result':{ + # 'affectedvnfc':[ + # { + # 'status':'success', + # 'vnfcinstanceid':'1', + # 'computeresource':{'resourceid':'11'}, + # 'vduid':'111', + # 'vdutype':'1111' + # } + # ], + # 'affectedvirtuallink':[ + # { + # 'status': 'success', + # 'virtuallinkinstanceid':'', + # 'networkresource':{'resourceid':'1'}, + # 'subnetworkresource':{'resourceid':'1'}, + # 'virtuallinkdescid': '', + # } + # ], + # 'affectedcp':[{ + # 'status': 'success', + # 'portresource':{'resourceid':'1'}, + # 'cpinstanceid':'2', + # 'cpdid':'22', + # 'ownertype':'222', + # 'ownerid':'2222', + # 'virtuallinkinstanceid':'22222', + # + # }], + # + # } + # } def run(self): try: self.inst_pre() self.apply_grant() self.create_res() - # self.check_res_status(args) + # self.check_res_status() # self.wait_inst_finish(args) - # self.lcm_notify(args) + self.lcm_notify() JobUtil.add_job_status(self.job_id, 100, "Instantiate Vnf success.") is_exist = JobStatusModel.objects.filter(jobid=self.job_id).exists() logger.debug("check_ns_inst_name_exist::is_exist=%s" % is_exist) @@ -59,45 +104,51 @@ class InstVnf(Thread): if not vnf_insts.exists(): raise NFLCMException('VNF nf_inst_id is not exist.') - self.vnfm_inst_id = vnf_insts[0].vnfm_inst_id + # self.vnfm_inst_id = vnf_insts[0].vnfm_inst_id if vnf_insts[0].instantiationState != 'NOT_INSTANTIATED': raise NFLCMException('VNF instantiationState is not NOT_INSTANTIATED.') - #get rawdata by vnfd_id + # get rawdata by vnfd_id ret = vnfd_rawdata_get(vnf_insts[0].vnfdid) if ret[0] != 0: raise NFLCMException("Get vnfd_raw_data failed.") self.vnfd_info = json.JSONDecoder().decode(ret[1]) - #checkParameterExist + # checkParameterExist for cp in self.data: if cp not in self.vnfd_info: raise NFLCMException('Input parameter is not defined in vnfd_info.') - #get nfvo info - JobUtil.add_job_status(self.job_id, 5, 'GET_NFVO_CONNECTION_INFO') + # get nfvo info + JobUtil.add_job_status(self.job_id, 5, 'Get nfvo connection info') self.load_nfvo_config() - #update NfInstModel - NfInstModel.objects.filter(nfinstid=self.nf_inst_id).update(flavour_id=ignore_case_get(self.data, "flavourId"), - vnf_level=ignore_case_get(self.data, 'instantiationLevelId'), - input_params=ignore_case_get(self.data, 'additionalParams'), - extension=ignore_case_get(self.data, ''), - initallocatedata=self.vnfd_info, - localizationLanguage=ignore_case_get(self.data, 'localizationLanguage'), - lastuptime=now_time()) + # update NfInstModel + NfInstModel.objects.filter(nfinstid=self.nf_inst_id).\ + update(flavour_id=ignore_case_get(self.data, "flavourId"), + vnf_level=ignore_case_get(self.data, 'instantiationLevelId'), + input_params=ignore_case_get(self.data, 'additionalParams'), + extension=ignore_case_get(self.data, ''), + initallocatedata=self.vnfd_info, + localizationLanguage=ignore_case_get(self.data, 'localizationLanguage'), + lastuptime=now_time()) + JobUtil.add_job_status(self.job_id, 10, 'Nf instancing pre-check finish') + logger.info("Nf instancing pre-check finish") def apply_grant(self): logger.info('[NF instantiation] send resource grand request to nfvo start') - #self.check_vm_capacity() + # self.check_vm_capacity() content_args = {'nfvoInstanceId': self.nfvo_inst_id, 'vnfmInstanceId': self.vnfm_inst_id, 'nfInstanceId': self.nf_inst_id, 'nfDescriptorId': '', 'lifecycleOperation': 'Instantiate', 'jobId': self.job_id, 'addResource': [], 'removeResource': [], 'placementConstraint': [], 'exVimIdList': [], 'additionalParam': {}} - vdus = self.vnfd_info['vdus'] + vdus = ignore_case_get(self.vnfd_info, "vdus") res_index = 1 for vdu in vdus: - res_def = {'type': 'VDU', 'resourceDefinitionId': str(res_index), 'vduId': vdu['vdu_id'], - 'vimid': '', 'tenant': ''} + res_def = {'type': 'VDU', + 'resourceDefinitionId': str(res_index), + 'vduId': ignore_case_get(vdu, "vdu_id"), + 'vimid': '', + 'tenant': ''} if self.vnfd_info['metadata']['cross_dc']: res_def['vimid'] = vdu['properties']['location_info']['vimId'] res_def['tenant'] = vdu['properties']['location_info']['tenant'] @@ -109,72 +160,208 @@ class InstVnf(Thread): if resp[0] != 0: raise NFLCMException('Nf instancing apply grant exception') - #update_resources_table() - NfInstModel.objects.filter(nfinstid=self.nf_inst_id).update(instantiationState='INSTANTIATED', lastuptime=now_time()) - JobUtil.add_job_status(self.job_id, 15, 'Nf instancing apply grant finish') + # update_resources_table() + NfInstModel.objects.filter(nfinstid=self.nf_inst_id).update(instantiationState='INSTANTIATED', + lastuptime=now_time()) + JobUtil.add_job_status(self.job_id, 20, 'Nf instancing apply grant finish') logger.info("Nf instancing apply grant finish") def create_res(self): - logger.info("[NF instantiation] send resource apply request start") - content_args = {'nfvoInstanceId': self.nfvo_inst_id, 'vnfmInstanceId': self.vnfm_inst_id, - 'nfInstanceId': self.nf_inst_id, 'nfDescriptorId': '', - 'lifecycleOperation': 'Instantiate', 'jobId': '', - 'allocateData': self.vnfd_info} - volumns = ignore_case_get(self.data, "volumn_storages") - #call vim driver api - #create_volumns(volumns) - JobUtil.add_job_status(self.job_id, 35, 'Nf instancing create resource(volumn_storages) finish') - # create_networks(self.vnfd_info) - JobUtil.add_job_status(self.job_id, 45, 'Nf instancing create resource(networks) finish') - # create_vdus(self.vnfd_info) - JobUtil.add_job_status(self.job_id, 65, 'Nf instancing create resource(vms) finish') - - def check_res_status(self, args): - try: - logger.info('check_res_status, args=%s' % args) - # CheckResStatusTask(args).do_biz() - return {'result': '100', 'msg': 'Nf instancing check resource status finish', 'context': {}} - except Exception as e: - logger.error('Nf instancing check resource status exception=%s' % e.message) - logger.error(traceback.format_exc()) - return {'result': '255', 'msg': 'Nf instancing check resource status exception', 'context': {}} + logger.info("[NF instantiation] create resource start") + adaptor.create_vim_res('', self.do_notify, self.do_rollback) - def wait_inst_finish(self, args): - try: - logger.info('wait_inst_finish, args=%s' % args) - # WaitInstFinishTask(args).do_biz() - return {'result': '100', 'msg': 'Nf instancing wait finish', 'context': {}} - except Exception as e: - logger.error('Nf instancing wait exception=%s' % e.message) - logger.error(traceback.format_exc()) - return {'result': '255', 'msg': 'Nf instancing wait exception', 'context': {}} + JobUtil.add_job_status(self.job_id, 70, '[NF instantiation] create resource finish') + logger.info("[NF instantiation] create resource finish") - def lcm_notify(self, args): - try: - logger.info('lcm_notify, args=%s' % args) - # LcmNotifyTask(args).do_biz() - return {'result': '100', 'msg': 'Nf instancing lcm notify finish', 'context': {}} - except Exception as e: - logger.error('Nf instancing lcm notify exception=%s' % e.message) - logger.error(traceback.format_exc()) - return {'result': '255', 'msg': 'Nf instancing lcm notify exception', 'context': {}} + # def check_res_status(self): + # logger.info("[NF instantiation] confirm all vms are active start") + # vnfcs = self.create_res_result['resource_result']['affectedvnfc'] + # for vnfc in vnfcs: + # if 'success' != vnfc['status']: + # logger.error("VNFC_STATUS_IS_NOT_ACTIVE[vduid=%s]" % vnfc['vduId']) + # raise NFLCMException(msgid="VNFC_STATUS_IS_NOT_ACTIVE[vduid=%s]", args=vnfc['vduId']) + # + # JobUtil.add_job_status(self.job_id, 80, 'SAVE_VNFC_TO_DB') + # vls = self.create_res_result['resource_result']['affectedvirtuallink'] + # cps = self.create_res_result['resource_result']['affectedcp'] + # + # for vnfc in vnfcs: + # if 'failed' == vnfc['status']: + # continue + # compute_resource = vnfc['computeresource'] + # vminst = VmInstModel.objects.filter(resouceid=compute_resource['resourceid']).first() + # VNFCInstModel.objects.create( + # vnfcinstanceid=vnfc['vnfcinstanceid'], + # vduid=vnfc['vduid'], + # vdutype=vnfc['vdutype'], + # nfinstid=self.nf_inst_id, + # vmid=vminst.vmid) + # for vl in vls: + # if 'failed' == vl['status']: + # continue + # network_resource = vl['networkresource'] + # subnet_resource = vl['subnetworkresource'] + # networkinst = NetworkInstModel.objects.filter(resouceid=network_resource['resourceid']).first() + # subnetinst = SubNetworkInstModel.objects.filter(resouceid=subnet_resource['resourceid']).first() + # VLInstModel.objects.create( + # vlinstanceid=vl['virtuallinkinstanceid'], + # vldid=vl['virtuallinkdescid'], + # ownertype='0', + # ownerid=self.nf_inst_id, + # relatednetworkid=networkinst.networkid, + # relatedsubnetworkid=subnetinst.subnetworkid) + # # # for vs in vss: + # for cp in cps: + # if 'failed' == cp['status']: + # continue + # port_resource = cp['portresource'] + # portinst = PortInstModel.objects.filter(resouceid=port_resource['resourceid']).first() + # ttt = portinst.portid + # CPInstModel.objects.create( + # cpinstanceid=cp['cpinstanceid'], + # cpdid=cp['cpdid'], + # relatedtype='2', + # relatedport=portinst.portid, + # ownertype=cp['ownertype'], + # ownerid=cp['ownerid'], + # vlinstanceid=cp['virtuallinkinstanceid']) + # # self.add_job(43, 'INST_DPLY_VM_PRGS') + # logger.info("[NF instantiation] confirm all vms are active end") - def rollback(self, args): - try: - logger.info('inst_exception, args=%s' % args) - # InstExceptionTask(args).do_biz() - return {'result': '100', 'msg': 'Nf instancing exception process finish', 'context': {}} - except Exception as e: - logger.error('Nf instancing exception process exception=%s' % e.message) - logger.error(traceback.format_exc()) - return {'result': '255', 'msg': 'Nf instancing exception process exception', 'context': {}} + # def wait_inst_finish(self, args): + # try: + # logger.info('wait_inst_finish, args=%s' % args) + # # WaitInstFinishTask(args).do_biz() + # return {'result': '100', 'msg': 'Nf instancing wait finish', 'context': {}} + # except Exception as e: + # logger.error('Nf instancing wait exception=%s' % e.message) + # logger.error(traceback.format_exc()) + # return {'result': '255', 'msg': 'Nf instancing wait exception', 'context': {}} + + def lcm_notify(self): + logger.info('[NF instantiation] send notify request to nfvo start') + reg_info = NfvoRegInfoModel.objects.filter(vnfminstid=self.vnfm_inst_id).first() + # vm_info = VmInstModel.objects.filter(nfinstid=self.nf_inst_id) + vmlist = [] + # nfs = NfInstModel.objects.filter(nfinstid=self.nf_inst_id) + # nf = nfs[0] + # allocate_data = json.loads(nf.initallocatedata) + # vmlist = json.loads(nf.predefinedvm) + addition_param = {'vmList': vmlist} + affected_vnfc = [] + vnfcs = VNFCInstModel.objects.filter(nfinstid=self.nf_inst_id) + for vnfc in vnfcs: + compute_resource = {} + if vnfc.vmid: + vm = VmInstModel.objects.filter(vmid=vnfc.vmid) + if vm: + compute_resource = {'vimId': vm[0].vimid, 'resourceId': vm[0].resouceid, + 'resourceName': vm[0].vmname, 'tenant': vm[0].tenant} + affected_vnfc.append( + {'vnfcInstanceId': vnfc.vnfcinstanceid, 'vduId': vnfc.vduid, 'changeType': 'added', + 'computeResource': compute_resource, 'storageResource': [], 'vduType': vnfc.vdutype}) + affected_vl = [] + vls = VLInstModel.objects.filter(ownerid=self.nf_inst_id) + for vl in vls: + network_resource = {} + subnet_resource = {} + if vl.relatednetworkid: + network = NetworkInstModel.objects.filter(networkid=vl.relatednetworkid) + subnet = SubNetworkInstModel.objects.filter(subnetworkid=vl.relatedsubnetworkid) + if network: + network_resource = {'vimId': network[0].vimid, 'resourceId': network[0].resouceid, + 'resourceName': network[0].name, 'tenant': network[0].tenant} + if subnet: + subnet_resource = {'vimId': subnet[0].vimid, 'resourceId': subnet[0].resouceid, + 'resourceName': subnet[0].name, 'tenant': subnet[0].tenant} + affected_vl.append( + {'virtualLinkInstanceId': vl.vlinstanceid, 'virtualLinkDescId': vl.vldid, 'changeType': 'added', + 'networkResource': network_resource, 'subnetworkResource': subnet_resource, 'tenant': vl.tenant}) + affected_vs = [] + vss = StorageInstModel.objects.filter(instid=self.nf_inst_id) + for vs in vss: + affected_vs.append( + {'virtualStorageInstanceId': vs.storageid, 'virtualStorageDescId': '', 'changeType': 'added', + 'storageResource': {'vimId': vs.vimid, 'resourceId': vs.resouceid, + 'resourceName': vs.name, 'tenant': vs.tenant}}) + affected_cp = [] + # vnfc cps + for vnfc in vnfcs: + cps = CPInstModel.objects.filter(ownerid=vnfc.vnfcinstanceid, ownertype=3) + for cp in cps: + port_resource = {} + if cp.relatedport: + port = PortInstModel.objects.filter(portid=cp.relatedport) + if port: + port_resource = {'vimId': port[0].vimid, 'resourceId': port[0].resouceid, + 'resourceName': port[0].name, 'tenant': port[0].tenant} + affected_cp.append( + {'cPInstanceId': cp.cpinstanceid, 'cpdId': cp.cpdid, 'ownerid': cp.ownerid, + 'ownertype': cp.ownertype, 'changeType': 'added', 'portResource': port_resource, + 'virtualLinkInstanceId': cp.vlinstanceid}) + # nf cps + cps = CPInstModel.objects.filter(ownerid=self.nf_inst_id, ownertype=0) + logger.info('vnf_inst_id=%s, cps size=%s' % (self.nf_inst_id, cps.count())) + for cp in cps: + port_resource = {} + if cp.relatedport: + port = PortInstModel.objects.filter(portid=cp.relatedport) + if port: + port_resource = {'vimId': port[0].vimid, 'resourceId': port[0].resouceid, + 'resourceName': port[0].name, 'tenant': port[0].tenant} + affected_cp.append( + {'cPInstanceId': cp.cpinstanceid, 'cpdId': cp.cpdid, 'ownerid': cp.ownerid, 'ownertype': cp.ownertype, + 'changeType': 'added', 'portResource': port_resource, + 'virtualLinkInstanceId': cp.vlinstanceid}) + # affectedcapacity = {} + # reserved_total = allocate_data.get('reserved_total', {}) + # affectedcapacity['vm'] = str(reserved_total.get('vmnum', 0)) + # affectedcapacity['vcpu'] = str(reserved_total.get('vcpunum', 0)) + # affectedcapacity['vMemory'] = str(reserved_total.get('memorysize', 0)) + # affectedcapacity['port'] = str(reserved_total.get('portnum', 0)) + # affectedcapacity['localStorage'] = str(reserved_total.get('hdsize', 0)) + # affectedcapacity['sharedStorage'] = str(reserved_total.get('shdsize', 0)) + content_args = { + # "vnfdmodule": allocate_data, + "additionalParam": addition_param, + "nfvoInstanceId": reg_info.nfvoid, + "vnfmInstanceId": self.vnfm_inst_id, + "status": 'finished', + "nfInstanceId": self.nf_inst_id, + "operation": 'instantiate', + "jobId": '', + # 'affectedcapacity': affectedcapacity, + 'affectedService': [], + 'affectedVnfc': affected_vnfc, + 'affectedVirtualLink': affected_vl, + 'affectedVirtualStorage': affected_vs, + 'affectedCp': affected_cp} + logger.info('content_args=%s' % content_args) + # call rest api + resp = notify_lcm_to_nfvo(content_args, self.nf_inst_id) + logger.info('[NF instantiation] get lcm response %s' % resp) + if resp[0] != 0: + logger.error("notify lifecycle to nfvo failed.[%s]" % resp[1]) + raise NFLCMException("send notify request to nfvo failed") + logger.info('[NF instantiation] send notify request to nfvo end') + + # def rollback(self, args): + # try: + # logger.info('inst_exception, args=%s' % args) + # # InstExceptionTask(args).do_biz() + # return {'result': '100', 'msg': 'Nf instancing exception process finish', 'context': {}} + # except Exception as e: + # logger.error('Nf instancing exception process exception=%s' % e.message) + # logger.error(traceback.format_exc()) + # return {'result': '255', 'msg': 'Nf instancing exception process exception', 'context': {}} def load_nfvo_config(self): logger.info("[NF instantiation]get nfvo connection info start") reg_info = NfvoRegInfoModel.objects.filter(vnfminstid='vnfm111').first() if reg_info: + self.vnfm_inst_id = reg_info.vnfminstid self.nfvo_inst_id = reg_info.nfvoid - logger.info("[NF instantiation] Registered nfvo id is [%s]"%self.nfvo_inst_id) + logger.info("[NF instantiation] Registered nfvo id is [%s]" % self.nfvo_inst_id) else: raise NFLCMException("Nfvo was not registered") logger.info("[NF instantiation]get nfvo connection info end") @@ -183,6 +370,114 @@ class InstVnf(Thread): logger.error('VNF instantiation failed, detail message: %s' % error_msg) NfInstModel.objects.filter(nfinstid=self.nf_inst_id).update(status='failed', lastuptime=now_time()) JobUtil.add_job_status(self.job_id, 255, error_msg) - # JobUtil.add_job_status(self.job_id, 255, 'VNF instantiation failed, detail message: %s' % error_msg, 0) + def do_notify(self, res_type, progress, ret): + logger.info('creating [%s] resource' % res_type) + progress = 20 + int(progress/2) # 20-70 + if res_type == adaptor.OPT_CREATE_VOLUME: + logger.info('Create vloumns!') + if ret["returnCode"] == adaptor.RES_NEW: # new create + self.inst_resource['volumn'].append({"vim_id": ignore_case_get(ret, "vim_id"), + "res_id": ignore_case_get(ret, "res_id")}) + JobUtil.add_job_status(self.job_id, progress, 'Create vloumns!') + StorageInstModel.objects.create( + storageid='1', + vimid='1', + resouceid='1', + name='40G', + tenant='admin', + insttype=0, + instid=self.nf_inst_id) + elif res_type == adaptor.OPT_CREATE_NETWORK: + logger.info('Create networks!') + if ret["returnCode"] == adaptor.RES_NEW: + self.inst_resource['network'].append({"vim_id": ignore_case_get(ret, "vim_id"), + "res_id": ignore_case_get(ret, "res_id")}) + # self.inst_resource['network'].append({"vim_id": "1"}, {"res_id": "2"}) + JobUtil.add_job_status(self.job_id, progress, 'Create networks!') + NetworkInstModel.objects.create( + networkid='1', + vimid='1', + resouceid='1', + name='pnet_network', + tenant='admin', + insttype=0, + instid=self.nf_inst_id) + elif res_type == adaptor.OPT_CREATE_SUBNET: + logger.info('Create subnets!') + if ret["returnCode"] == adaptor.RES_NEW: + self.inst_resource['subnet'].append({"vim_id": ignore_case_get(ret, "vim_id"), + "res_id": ignore_case_get(ret, "res_id")}) + # self.inst_resource['subnet'].append({"vim_id": "1"}, {"res_id": "2"}) + JobUtil.add_job_status(self.job_id, progress, 'Create subnets!') + SubNetworkInstModel.objects.create( + subnetworkid='1', + vimid='1', + resouceid='1', + networkid='1', + name='sub_pnet', + tenant='admin', + insttype=0, + instid=self.nf_inst_id) + elif res_type == adaptor.OPT_CREATE_PORT: + logger.info('Create ports!') + if ret["returnCode"] == adaptor.RES_NEW: + self.inst_resource['port'].append({"vim_id": ignore_case_get(ret, "vim_id"), + "res_id": ignore_case_get(ret, "res_id")}) + # self.inst_resource['port'].append({"vim_id": "1"}, {"res_id": "2"}) + JobUtil.add_job_status(self.job_id, progress, 'Create ports!') + PortInstModel.objects.create( + portid='1', + networkid='1', + subnetworkid='1', + vimid='1', + resouceid='1', + name='aaa_pnet_cp', + tenant='admin', + insttype=0, + instid=self.nf_inst_id) + elif res_type == adaptor.OPT_CREATE_FLAVOR: + logger.info('Create flavors!') + if ret["returnCode"] == adaptor.RES_NEW: + self.inst_resource['flavor'].append({"vim_id": ignore_case_get(ret, "vim_id"), + "res_id": ignore_case_get(ret, "res_id")}) + # self.inst_resource['flavor'].append({"vim_id": "1"}, {"res_id": "2"}) + JobUtil.add_job_status(self.job_id, progress, 'Create flavors!') + FlavourInstModel.objects.create( + falavourid='1', + name='1', + vcpu='1', + extraspecs='1', + instid=self.nf_inst_id) + elif res_type == adaptor.OPT_CREATE_VM: + logger.info('Create vms!') + if ret["returnCode"] == adaptor.RES_NEW: + self.inst_resource['vm'].append({"vim_id": ignore_case_get(ret, "vim_id"), + "res_id": ignore_case_get(ret, "res_id")}) + # self.inst_resource['vm'].append({"vim_id": "1"}, {"res_id": "2"}) + JobUtil.add_job_status(self.job_id, progress, 'Create vms!') + VmInstModel.objects.create( + vmid="1", + vimid="1", + resouceid="11", + insttype=0, + instid=self.nf_inst_id, + vmname="test_01", + operationalstate=1) + + def do_rollback(self, args_=None): + logger.error('error info : %s' % args_) + adaptor.delete_vim_res(self.inst_resource, self.do_notify_delete) + logger.error('rollback resource complete') + + StorageInstModel.objects.filter(instid=self.nf_inst_id).delete() + NetworkInstModel.objects.filter(instid=self.nf_inst_id).delete() + SubNetworkInstModel.objects.filter(instid=self.nf_inst_id).delete() + PortInstModel.objects.filter(instid=self.nf_inst_id).delete() + FlavourInstModel.objects.filter(instid=self.nf_inst_id).delete() + VmInstModel.objects.filter(instid=self.nf_inst_id).delete() + logger.error('delete table complete') + raise NFLCMException("Create resource failed") + def do_notify_delete(self, ret): + logger.error('Deleting [%s] resource' % ret)