lcm/lcm/nf/vnfs/vnf_create/inst_vnf.py

   1 # Copyright 2017 ZTE Corporation.
   2 #
   3 # Licensed under the Apache License, Version 2.0 (the "License");
   4 # you may not use this file except in compliance with the License.
   5 # You may obtain a copy of the License at
   6 #
   7 #         http://www.apache.org/licenses/LICENSE-2.0
   8 #
   9 # Unless required by applicable law or agreed to in writing, software
  10 # distributed under the License is distributed on an "AS IS" BASIS,
  11 # WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
  12 # See the License for the specific language governing permissions and
  13 # limitations under the License.
  14 import json
  15 import logging
  16 import traceback
  17 from threading import Thread
  18
  19 from lcm.pub.database.models import NfInstModel, JobStatusModel, NfvoRegInfoModel, VmInstModel, NetworkInstModel, SubNetworkInstModel, \
  20     PortInstModel, StorageInstModel, FlavourInstModel, VNFCInstModel, VLInstModel, CPInstModel
  21 from lcm.pub.exceptions import NFLCMException
  22 from lcm.pub.msapi.nfvolcm import vnfd_rawdata_get, apply_grant_to_nfvo, notify_lcm_to_nfvo
  23 from lcm.pub.utils.jobutil import JobUtil
  24 from lcm.pub.utils.timeutil import now_time
  25 from lcm.pub.utils.values import ignore_case_get
  26 from lcm.pub.vimapi import adaptor
  27
  28 logger = logging.getLogger(__name__)
  29
  30
  31 class InstVnf(Thread):
  32     def __init__(self, data, nf_inst_id, job_id):
  33         super(InstVnf, self).__init__()
  34         self.data = data
  35         self.nf_inst_id = nf_inst_id
  36         self.job_id = job_id
  37         self.nfvo_inst_id = ''
  38         self.vnfm_inst_id = ''
  39         self.vnfd_info = []
  40         self.inst_resource = {'volumn':[],#'volumn':[{"vim_id": "1"}, {"res_id": "2"}]
  41                               'network':[],
  42                               'subnet':[],
  43                               'port':[],
  44                               'flavor':[],
  45                               'vm':[],
  46                               }
  47         # self.create_res_result = {
  48         #     'jobid': 'res_001',
  49         #     'resourceResult': [{'name': 'vm01'}, {'name': 'vm02'}],
  50         #     'resource_result':{
  51         #         'affectedvnfc':[
  52         #             {
  53         #                 'status':'success',
  54         #                 'vnfcinstanceid':'1',
  55         #                 'computeresource':{'resourceid':'11'},
  56         #                 'vduid':'111',
  57         #                 'vdutype':'1111'
  58         #             }
  59         #         ],
  60         #         'affectedvirtuallink':[
  61         #             {
  62         #                 'status': 'success',
  63         #                 'virtuallinkinstanceid':'',
  64         #                 'networkresource':{'resourceid':'1'},
  65         #                 'subnetworkresource':{'resourceid':'1'},
  66         #                 'virtuallinkdescid': '',
  67         #             }
  68         #         ],
  69         #         'affectedcp':[{
  70         #             'status': 'success',
  71         #             'portresource':{'resourceid':'1'},
  72         #             'cpinstanceid':'2',
  73         #             'cpdid':'22',
  74         #             'ownertype':'222',
  75         #             'ownerid':'2222',
  76         #             'virtuallinkinstanceid':'22222',
  77         #
  78         #         }],
  79         #
  80         #     }
  81         # }
  82
  83     def run(self):
  84         try:
  85             self.inst_pre()
  86             self.apply_grant()
  87             self.create_res()
  88             # self.check_res_status()
  89             # self.wait_inst_finish(args)
  90             # self.lcm_notify()
  91             JobUtil.add_job_status(self.job_id, 100, "Instantiate Vnf success.")
  92             is_exist = JobStatusModel.objects.filter(jobid=self.job_id).exists()
  93             logger.debug("check_ns_inst_name_exist::is_exist=%s" % is_exist)
  94         except NFLCMException as e:
  95             self.vnf_inst_failed_handle(e.message)
  96             # self.rollback(e.message)
  97         except:
  98             self.vnf_inst_failed_handle('unexpected exception')
  99             logger.error(traceback.format_exc())
 100             # self.rollback('unexpected exception')
 101
 102     def inst_pre(self):
 103         vnf_insts = NfInstModel.objects.filter(nfinstid=self.nf_inst_id)
 104         if not vnf_insts.exists():
 105             raise NFLCMException('VNF nf_inst_id is not exist.')
 106
 107         self.vnfm_inst_id = vnf_insts[0].vnfm_inst_id
 108         if vnf_insts[0].instantiationState != 'NOT_INSTANTIATED':
 109             raise NFLCMException('VNF instantiationState is not NOT_INSTANTIATED.')
 110
 111         #get rawdata by vnfd_id
 112         ret = vnfd_rawdata_get(vnf_insts[0].vnfdid)
 113         if ret[0] != 0:
 114             raise NFLCMException("Get vnfd_raw_data failed.")
 115         self.vnfd_info = json.JSONDecoder().decode(ret[1])
 116         #checkParameterExist
 117         for cp in self.data:
 118             if cp not in self.vnfd_info:
 119                 raise NFLCMException('Input parameter is not defined in vnfd_info.')
 120         #get nfvo info
 121         JobUtil.add_job_status(self.job_id, 5, 'GET_NFVO_CONNECTION_INFO')
 122         self.load_nfvo_config()
 123
 124         #update NfInstModel
 125         NfInstModel.objects.filter(nfinstid=self.nf_inst_id).update(flavour_id=ignore_case_get(self.data, "flavourId"),
 126                                                                     vnf_level=ignore_case_get(self.data, 'instantiationLevelId'),
 127                                                                     input_params=ignore_case_get(self.data, 'additionalParams'),
 128                                                                     extension=ignore_case_get(self.data, ''),
 129                                                                     initallocatedata=self.vnfd_info,
 130                                                                     localizationLanguage=ignore_case_get(self.data, 'localizationLanguage'),
 131                                                                     lastuptime=now_time())
 132         JobUtil.add_job_status(self.job_id, 10, 'Nf instancing pre-check finish')
 133         logger.info("Nf instancing pre-check finish")
 134
 135     def apply_grant(self):
 136         logger.info('[NF instantiation] send resource grand request to nfvo start')
 137         #self.check_vm_capacity()
 138         content_args = {'nfvoInstanceId': self.nfvo_inst_id, 'vnfmInstanceId': self.vnfm_inst_id,
 139                         'nfInstanceId': self.nf_inst_id, 'nfDescriptorId': '',
 140                         'lifecycleOperation': 'Instantiate', 'jobId': self.job_id, 'addResource': [],
 141                         'removeResource': [], 'placementConstraint': [], 'exVimIdList': [], 'additionalParam': {}}
 142
 143         vdus = self.vnfd_info['vdus']
 144         res_index = 1
 145         for vdu in vdus:
 146             res_def = {'type': 'VDU', 'resourceDefinitionId': str(res_index), 'vduId': vdu['vdu_id'],
 147                        'vimid': '', 'tenant': ''}
 148             if self.vnfd_info['metadata']['cross_dc']:
 149                 res_def['vimid'] = vdu['properties']['location_info']['vimId']
 150                 res_def['tenant'] = vdu['properties']['location_info']['tenant']
 151             content_args['addResource'].append(res_def)
 152             res_index += 1
 153         logger.info('content_args=%s' % content_args)
 154         resp = apply_grant_to_nfvo(content_args)
 155         logger.info("[NF instantiation] get grant response = %s" % resp)
 156         if resp[0] != 0:
 157             raise NFLCMException('Nf instancing apply grant exception')
 158
 159         #update_resources_table()
 160         NfInstModel.objects.filter(nfinstid=self.nf_inst_id).update(instantiationState='INSTANTIATED', lastuptime=now_time())
 161         JobUtil.add_job_status(self.job_id, 20, 'Nf instancing apply grant finish')
 162         logger.info("Nf instancing apply grant finish")
 163
 164     def create_res(self):
 165         logger.info("[NF instantiation] create resource start")
 166         adaptor.create_vim_res(self.vnfd_info, self.do_notify, self.do_rollback)
 167
 168         JobUtil.add_job_status(self.job_id, 70, '[NF instantiation] create resource finish')
 169         logger.info("[NF instantiation] create resource finish")
 170
 171     # def check_res_status(self):
 172     #     logger.info("[NF instantiation] confirm all vms are active start")
 173     #     vnfcs = self.create_res_result['resource_result']['affectedvnfc']
 174     #     for vnfc in vnfcs:
 175     #         if 'success' != vnfc['status']:
 176     #             logger.error("VNFC_STATUS_IS_NOT_ACTIVE[vduid=%s]" % vnfc['vduId'])
 177     #             raise NFLCMException(msgid="VNFC_STATUS_IS_NOT_ACTIVE[vduid=%s]", args=vnfc['vduId'])
 178     #
 179     #     JobUtil.add_job_status(self.job_id, 80, 'SAVE_VNFC_TO_DB')
 180     #     vls = self.create_res_result['resource_result']['affectedvirtuallink']
 181     #     cps = self.create_res_result['resource_result']['affectedcp']
 182     #
 183     #     for vnfc in vnfcs:
 184     #         if 'failed' == vnfc['status']:
 185     #             continue
 186     #         compute_resource = vnfc['computeresource']
 187     #         vminst = VmInstModel.objects.filter(resouceid=compute_resource['resourceid']).first()
 188     #         VNFCInstModel.objects.create(
 189     #             vnfcinstanceid=vnfc['vnfcinstanceid'],
 190     #             vduid=vnfc['vduid'],
 191     #             vdutype=vnfc['vdutype'],
 192     #             nfinstid=self.nf_inst_id,
 193     #             vmid=vminst.vmid)
 194     #     for vl in vls:
 195     #         if 'failed' == vl['status']:
 196     #             continue
 197     #         network_resource = vl['networkresource']
 198     #         subnet_resource = vl['subnetworkresource']
 199     #         networkinst = NetworkInstModel.objects.filter(resouceid=network_resource['resourceid']).first()
 200     #         subnetinst = SubNetworkInstModel.objects.filter(resouceid=subnet_resource['resourceid']).first()
 201     #         VLInstModel.objects.create(
 202     #             vlinstanceid=vl['virtuallinkinstanceid'],
 203     #             vldid=vl['virtuallinkdescid'],
 204     #             ownertype='0',
 205     #             ownerid=self.nf_inst_id,
 206     #             relatednetworkid=networkinst.networkid,
 207     #             relatedsubnetworkid=subnetinst.subnetworkid)
 208     #     # # for vs in vss:
 209     #     for cp in cps:
 210     #         if 'failed' == cp['status']:
 211     #             continue
 212     #         port_resource = cp['portresource']
 213     #         portinst = PortInstModel.objects.filter(resouceid=port_resource['resourceid']).first()
 214     #         ttt = portinst.portid
 215     #         CPInstModel.objects.create(
 216     #             cpinstanceid=cp['cpinstanceid'],
 217     #             cpdid=cp['cpdid'],
 218     #             relatedtype='2',
 219     #             relatedport=portinst.portid,
 220     #             ownertype=cp['ownertype'],
 221     #             ownerid=cp['ownerid'],
 222     #             vlinstanceid=cp['virtuallinkinstanceid'])
 223     #     # self.add_job(43, 'INST_DPLY_VM_PRGS')
 224     #     logger.info("[NF instantiation] confirm all vms are active end")
 225
 226     # def wait_inst_finish(self, args):
 227     #     try:
 228     #         logger.info('wait_inst_finish, args=%s' % args)
 229     #         # WaitInstFinishTask(args).do_biz()
 230     #         return {'result': '100', 'msg': 'Nf instancing wait finish', 'context': {}}
 231     #     except Exception as e:
 232     #         logger.error('Nf instancing wait exception=%s' % e.message)
 233     #         logger.error(traceback.format_exc())
 234     #         return {'result': '255', 'msg': 'Nf instancing wait exception', 'context': {}}
 235
 236     def lcm_notify(self):
 237         logger.info('[NF instantiation] send notify request to nfvo start')
 238         reg_info = NfvoRegInfoModel.objects.filter(vnfminstid=self.vnfm_inst_id).first()
 239         nfs = NfInstModel.objects.filter(nfinstid=self.nf_inst_id)
 240         nf = nfs[0]
 241         allocate_data = json.loads(nf.initallocatedata)
 242         vmlist = json.loads(nf.predefinedvm)
 243         addition_param = {'vmList': vmlist}
 244         affected_vnfc = []
 245         vnfcs = VNFCInstModel.objects.filter(nfinstid=self.nf_inst_id)
 246         for vnfc in vnfcs:
 247             compute_resource = {}
 248             if vnfc.vmid:
 249                 vm = VmInstModel.objects.filter(vmid=vnfc.vmid)
 250                 if vm:
 251                     compute_resource = {'vimId': vm[0].vimid, 'resourceId': vm[0].resouceid,
 252                                         'resourceName': vm[0].vmname, 'tenant': vm[0].tenant}
 253             affected_vnfc.append(
 254                 {'vnfcInstanceId': vnfc.vnfcinstanceid, 'vduId': vnfc.vduid, 'changeType': 'added',
 255                  'computeResource': compute_resource, 'storageResource': [], 'vduType': vnfc.vdutype})
 256         affected_vl = []
 257         vls = VLInstModel.objects.filter(ownerid=self.nf_inst_id)
 258         for vl in vls:
 259             network_resource = {}
 260             subnet_resource = {}
 261             if vl.relatednetworkid:
 262                 network = NetworkInstModel.objects.filter(networkid=vl.relatednetworkid)
 263                 subnet = SubNetworkInstModel.objects.filter(subnetworkid=vl.relatedsubnetworkid)
 264                 if network:
 265                     network_resource = {'vimId': network[0].vimid, 'resourceId': network[0].resouceid,
 266                                         'resourceName': network[0].name, 'tenant': network[0].tenant}
 267                 if subnet:
 268                     subnet_resource = {'vimId': subnet[0].vimid, 'resourceId': subnet[0].resouceid,
 269                                        'resourceName': subnet[0].name, 'tenant': subnet[0].tenant}
 270             affected_vl.append(
 271                 {'virtualLinkInstanceId': vl.vlinstanceid, 'virtualLinkDescId': vl.vldid, 'changeType': 'added',
 272                  'networkResource': network_resource, 'subnetworkResource': subnet_resource, 'tenant': vl.tenant})
 273         affected_vs = []
 274         vss = StorageInstModel.objects.filter(instid=self.nf_inst_id)
 275         for vs in vss:
 276             affected_vs.append(
 277                 {'virtualStorageInstanceId': vs.storageid, 'virtualStorageDescId': '', 'changeType': 'added',
 278                  'storageResource': {'vimId': vs.vimid, 'resourceId': vs.resouceid,
 279                                      'resourceName': vs.name, 'tenant': vs.tenant}})
 280         affected_cp = []
 281         #vnfc cps
 282         for vnfc in vnfcs:
 283             cps = CPInstModel.objects.filter(ownerid=vnfc.vnfcinstanceid, ownertype=3)
 284             for cp in cps:
 285                 port_resource = {}
 286                 if cp.relatedport:
 287                     port = PortInstModel.objects.filter(portid=cp.relatedport)
 288                     if port:
 289                         port_resource = {'vimId': port[0].vimid, 'resourceId': port[0].resouceid,
 290                                          'resourceName': port[0].name, 'tenant': port[0].tenant}
 291                 affected_cp.append(
 292                     {'cPInstanceId': cp.cpinstanceid, 'cpdId': cp.cpdid, 'ownerid': cp.ownerid,
 293                      'ownertype': cp.ownertype, 'changeType': 'added', 'portResource': port_resource,
 294                      'virtualLinkInstanceId': cp.vlinstanceid})
 295         #nf cps
 296         cps = CPInstModel.objects.filter(ownerid=self.nf_inst_id, ownertype=0)
 297         logger.info('vnf_inst_id=%s, cps size=%s' % (self.nf_inst_id, cps.count()))
 298         for cp in cps:
 299             port_resource = {}
 300             if cp.relatedport:
 301                 port = PortInstModel.objects.filter(portid=cp.relatedport)
 302                 if port:
 303                     port_resource = {'vimId': port[0].vimid, 'resourceId': port[0].resouceid,
 304                                      'resourceName': port[0].name, 'tenant': port[0].tenant}
 305             affected_cp.append(
 306                 {'cPInstanceId': cp.cpinstanceid, 'cpdId': cp.cpdid, 'ownerid': cp.ownerid, 'ownertype': cp.ownertype,
 307                  'changeType': 'added', 'portResource': port_resource,
 308                  'virtualLinkInstanceId': cp.vlinstanceid})
 309         affectedcapacity = {}
 310         reserved_total = allocate_data.get('reserved_total', {})
 311         affectedcapacity['vm'] = str(reserved_total.get('vmnum', 0))
 312         affectedcapacity['vcpu'] = str(reserved_total.get('vcpunum', 0))
 313         affectedcapacity['vMemory'] = str(reserved_total.get('memorysize', 0))
 314         affectedcapacity['port'] = str(reserved_total.get('portnum', 0))
 315         affectedcapacity['localStorage'] = str(reserved_total.get('hdsize', 0))
 316         affectedcapacity['sharedStorage'] = str(reserved_total.get('shdsize', 0))
 317         content_args = {
 318             "vnfdmodule": allocate_data,
 319             "additionalParam": addition_param,
 320             "nfvoInstanceId": reg_info.nfvoid,
 321             "vnfmInstanceId": self.vnfm_inst_id,
 322             "status": 'finished',
 323             "nfInstanceId": self.nf_inst_id,
 324             "operation": 'instantiate',
 325             "jobId": '',
 326             'affectedcapacity': affectedcapacity,
 327             'affectedService': [],
 328             'affectedVnfc': affected_vnfc,
 329             'affectedVirtualLink': affected_vl,
 330             'affectedVirtualStorage': affected_vs,
 331             'affectedCp': affected_cp}
 332         logger.info('content_args=%s' % content_args)
 333         #call rest api
 334         resp = notify_lcm_to_nfvo(content_args, self.nf_inst_id)
 335         logger.info('[NF instantiation] get lcm response %s' % resp)
 336         if resp[0] != 0:
 337             logger.error("notify lifecycle to nfvo failed.[%s]" % resp[1])
 338             raise NFLCMException("send notify request to nfvo failed")
 339         logger.info('[NF instantiation] send notify request to nfvo end')
 340
 341     # def rollback(self, args):
 342     #     try:
 343     #         logger.info('inst_exception, args=%s' % args)
 344     #         # InstExceptionTask(args).do_biz()
 345     #         return {'result': '100', 'msg': 'Nf instancing exception process finish', 'context': {}}
 346     #     except Exception as e:
 347     #         logger.error('Nf instancing exception process exception=%s' % e.message)
 348     #         logger.error(traceback.format_exc())
 349     #         return {'result': '255', 'msg': 'Nf instancing exception process exception', 'context': {}}
 350
 351     def load_nfvo_config(self):
 352         logger.info("[NF instantiation]get nfvo connection info start")
 353         reg_info = NfvoRegInfoModel.objects.filter(vnfminstid='vnfm111').first()
 354         if reg_info:
 355             self.vnfm_inst_id = reg_info.vnfminstid
 356             self.nfvo_inst_id = reg_info.nfvoid
 357             logger.info("[NF instantiation] Registered nfvo id is [%s]"%self.nfvo_inst_id)
 358         else:
 359             raise NFLCMException("Nfvo was not registered")
 360         logger.info("[NF instantiation]get nfvo connection info end")
 361
 362     def vnf_inst_failed_handle(self, error_msg):
 363         logger.error('VNF instantiation failed, detail message: %s' % error_msg)
 364         NfInstModel.objects.filter(nfinstid=self.nf_inst_id).update(status='failed', lastuptime=now_time())
 365         JobUtil.add_job_status(self.job_id, 255, error_msg)
 366
 367     def do_notify(self, res_type, progress, ret):
 368         logger.info('creating [%s] resource'%res_type)
 369         progress = 20 + int(progress/2)     #20-70
 370         if res_type == adaptor.RES_VOLUME:
 371             logger.info('Create vloumns!')
 372             if ret["returnCode"] == adaptor.RES_NEW:#new create
 373                 self.inst_resource['volumn'].append({"vim_id": ignore_case_get(ret, "vim_id")}, {"res_id": ignore_case_get(ret, "res_id")})
 374             JobUtil.add_job_status(self.job_id, progress, 'Create vloumns!')
 375             StorageInstModel.objects.create(
 376                 storageid='1',
 377                 vimid='1',
 378                 resouceid='1',
 379                 name='40G',
 380                 tenant='admin',
 381                 insttype=0,
 382                 instid=self.nf_inst_id)
 383         elif res_type == adaptor.RES_NETWORK:
 384             logger.info('Create networks!')
 385             if ret["returnCode"] == adaptor.RES_NEW:
 386                 self.inst_resource['network'].append({"vim_id": ignore_case_get(ret, "vim_id")}, {"res_id": ignore_case_get(ret, "res_id")})
 387             # self.inst_resource['network'].append({"vim_id": "1"}, {"res_id": "2"})
 388             JobUtil.add_job_status(self.job_id, progress, 'Create networks!')
 389             NetworkInstModel.objects.create(
 390                 networkid='1',
 391                 vimid='1',
 392                 resouceid='1',
 393                 name='pnet_network',
 394                 tenant='admin',
 395                 insttype=0,
 396                 instid=self.nf_inst_id)
 397         elif res_type == adaptor.RES_SUBNET:
 398             logger.info('Create subnets!')
 399             if ret["returnCode"] == adaptor.RES_NEW:
 400                 self.inst_resource['subnet'].append({"vim_id": ignore_case_get(ret, "vim_id")}, {"res_id": ignore_case_get(ret, "res_id")})
 401             # self.inst_resource['subnet'].append({"vim_id": "1"}, {"res_id": "2"})
 402             JobUtil.add_job_status(self.job_id, progress, 'Create subnets!')
 403             SubNetworkInstModel.objects.create(
 404                 subnetworkid='1',
 405                 vimid='1',
 406                 resouceid='1',
 407                 networkid='1',
 408                 name='sub_pnet',
 409                 tenant='admin',
 410                 insttype=0,
 411                 instid=self.nf_inst_id)
 412         elif res_type == adaptor.RES_PORT:
 413             logger.info('Create ports!')
 414             if ret["returnCode"] == adaptor.RES_NEW:
 415                 self.inst_resource['port'].append({"vim_id": ignore_case_get(ret, "vim_id")}, {"res_id": ignore_case_get(ret, "res_id")})
 416             # self.inst_resource['port'].append({"vim_id": "1"}, {"res_id": "2"})
 417             JobUtil.add_job_status(self.job_id, progress, 'Create ports!')
 418             PortInstModel.objects.create(
 419                 portid='1',
 420                 networkid='1',
 421                 subnetworkid='1',
 422                 vimid='1',
 423                 resouceid='1',
 424                 name='aaa_pnet_cp',
 425                 tenant='admin',
 426                 insttype=0,
 427                 instid=self.nf_inst_id)
 428         elif res_type == adaptor.RES_FLAVOR:
 429             logger.info('Create flavors!')
 430             if ret["returnCode"] == adaptor.RES_NEW:
 431                 self.inst_resource['flavor'].append({"vim_id": ignore_case_get(ret, "vim_id")}, {"res_id": ignore_case_get(ret, "res_id")})
 432             # self.inst_resource['flavor'].append({"vim_id": "1"}, {"res_id": "2"})
 433             JobUtil.add_job_status(self.job_id, progress, 'Create flavors!')
 434             FlavourInstModel.objects.create(
 435                 falavourid='1',
 436                 name='1',
 437                 vcpu='1',
 438                 extraspecs='1',
 439                 instid=self.nf_inst_id)
 440         elif res_type == adaptor.RES_VM:
 441             logger.info('Create vms!')
 442             if ret["returnCode"] == adaptor.RES_NEW:
 443                 self.inst_resource['vm'].append({"vim_id": ignore_case_get(ret, "vim_id")}, {"res_id": ignore_case_get(ret, "res_id")})
 444             # self.inst_resource['vm'].append({"vim_id": "1"}, {"res_id": "2"})
 445             JobUtil.add_job_status(self.job_id, progress, 'Create vms!')
 446             VmInstModel.objects.create(
 447                 vmid="1",
 448                 vimid="1",
 449                 resouceid="11",
 450                 insttype=0,
 451                 instid=self.nf_inst_id,
 452                 vmname="test_01",
 453                 operationalstate=1)
 454
 455     def do_rollback(self, args_=None):
 456         logger.error('error info : %s'%(args_))
 457         adaptor.delete_vim_res(self.inst_resource, self.do_notify_delete)
 458         logger.error('rollback resource complete')
 459
 460         StorageInstModel.objects.filter(instid=self.nf_inst_id).delete()
 461         NetworkInstModel.objects.filter(instid=self.nf_inst_id).delete()
 462         SubNetworkInstModel.objects.filter(instid=self.nf_inst_id).delete()
 463         PortInstModel.objects.filter(instid=self.nf_inst_id).delete()
 464         FlavourInstModel.objects.filter(instid=self.nf_inst_id).delete()
 465         VmInstModel.objects.filter(instid=self.nf_inst_id).delete()
 466         logger.error('delete table complete')
 467         raise NFLCMException("Create resource failed")
 468
 469     def do_notify_delete(ret):
 470         logger.error('Deleting [%s] resource'%ret)
 471
 472