1 # Copyright 2016-2018 ZTE Corporation.
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
7 # http://www.apache.org/licenses/LICENSE-2.0
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.
20 from lcm.pub.config.config import REPORT_TO_AAI
21 from lcm.pub.database.models import NfInstModel, VmInstModel, OOFDataModel
22 from lcm.pub.exceptions import NSLCMException
23 from lcm.pub.msapi import resmgr
24 from lcm.pub.msapi.aai import query_vnf_aai, delete_vnf_aai, query_vserver_aai, delete_vserver_aai
25 from lcm.pub.msapi.extsys import split_vim_to_owner_region, get_vim_by_id
26 from lcm.pub.msapi.vnfmdriver import send_nf_terminate_request
27 from lcm.pub.utils.jobutil import JobUtil
28 from lcm.jobs.enum import JOB_MODEL_STATUS
29 from lcm.pub.utils.values import ignore_case_get
30 from lcm.ns_vnfs.const import NFVO_VNF_INST_TIMEOUT_SECOND
31 from lcm.ns_vnfs.enum import VNF_STATUS, INST_TYPE
32 from lcm.ns_vnfs.biz.wait_job import wait_job_finish
33 from lcm.ns_vnfs.biz.subscribe import SubscriptionDeletion
35 logger = logging.getLogger(__name__)
38 class TerminateVnfs(threading.Thread):
39 def __init__(self, data, vnf_inst_id, job_id):
40 threading.Thread.__init__(self)
41 self.vnf_inst_id = vnf_inst_id
43 self.vnfm_inst_id = ''
46 self.terminationType = data['terminationType']
47 self.gracefulTerminationTimeout = data['gracefulTerminationTimeout']
48 if not self.gracefulTerminationTimeout:
49 self.gracefulTerminationTimeout = 120
51 self.gracefulTerminationTimeout = int(self.gracefulTerminationTimeout)
58 self.send_nf_terminate_to_vnfmDriver()
59 self.wait_vnfm_job_finish()
60 self.send_terminate_vnf_to_resMgr()
62 self.delete_vserver_in_aai()
63 self.delete_vnf_in_aai()
64 self.delete_subscription()
65 self.delete_data_from_db()
66 except NSLCMException as e:
67 self.set_job_err(e.args[0])
68 except Exception as ex:
69 logger.error(traceback.format_exc())
70 self.set_job_err(ex.args[0])
72 def set_vnf_status(self, vnf_inst_info):
73 vnf_status = vnf_inst_info.status
74 if (vnf_status == VNF_STATUS.TERMINATING):
75 logger.info('[VNF terminate] VNF is dealing by other application,try again later.')
76 raise NSLCMException('[VNF terminate] VNF is dealing by other application,try again later.')
78 vnf_inst_info.status = VNF_STATUS.TERMINATING
81 def get_vnf_inst(self):
82 vnf_inst = NfInstModel.objects.filter(nfinstid=self.vnf_inst_id)
83 if not vnf_inst.exists():
84 logger.warning('[VNF terminate] Vnf terminate [%s] does not exist.' % self.vnf_inst_id)
88 def add_progress(self, progress, status_decs, error_code=""):
89 JobUtil.add_job_status(self.job_id, progress, status_decs, error_code)
92 vnf_inst_info = self.get_vnf_inst()
94 self.add_progress(100, "TERM_VNF_NOT_EXIST_SUCCESS", "finished")
95 self.add_progress(2, "GET_VNF_INST_SUCCESS")
96 self.vnfm_inst_id = vnf_inst_info.vnfm_inst_id
97 self.vnf_uuid = vnf_inst_info.mnfinstid
99 self.add_progress(100, "TERM_VNF_NOT_EXIST_SUCCESS", "finished")
101 def check_nf_valid(self):
102 vnf_inst = NfInstModel.objects.filter(nfinstid=self.vnf_inst_id)
103 if not vnf_inst.exists():
104 logger.warning('[VNF terminate] Vnf instance [%s] is not exist.' % self.vnf_inst_id)
105 raise NSLCMException('[VNF terminate] Vnf instance is not exist.')
107 self.add_progress(100, "TERM_VNF_NOT_EXIST_SUCCESS", "finished")
108 raise NSLCMException('[VNF terminate] Vnf instance is not exist.')
109 self.set_vnf_status(vnf_inst[0])
111 def set_job_err(self, error_msg):
112 logger.error('VNF Terminate failed, detail message: %s' % error_msg)
113 NfInstModel.objects.filter(nfinstid=self.vnf_inst_id).update(status=VNF_STATUS.FAILED)
114 JobUtil.add_job_status(self.job_id, 255, 'VNF Terminate failed, detail message: %s' % error_msg, 0)
116 def send_nf_terminate_to_vnfmDriver(self):
117 req_param = json.JSONEncoder().encode({
118 'terminationType': self.terminationType,
119 'gracefulTerminationTimeout': self.gracefulTerminationTimeout})
120 rsp = send_nf_terminate_request(self.vnfm_inst_id, self.vnf_uuid, req_param)
121 self.vnfm_job_id = ignore_case_get(rsp, 'jobId')
123 def send_terminate_vnf_to_resMgr(self):
124 resmgr.terminate_vnf(self.vnf_inst_id)
126 def wait_vnfm_job_finish(self):
127 if not self.vnfm_job_id:
128 logger.warn("No Job, need not wait")
130 ret = wait_job_finish(vnfm_id=self.vnfm_inst_id,
131 vnfo_job_id=self.job_id,
132 vnfm_job_id=self.vnfm_job_id,
133 progress_range=[10, 90],
134 timeout=NFVO_VNF_INST_TIMEOUT_SECOND)
136 if ret != JOB_MODEL_STATUS.FINISHED:
137 logger.error('VNF terminate failed on VNFM side.')
138 raise NSLCMException('VNF terminate failed on VNFM side.')
140 def delete_subscription(self):
142 SubscriptionDeletion(self.vnfm_inst_id, self.vnf_inst_id).do_biz()
143 except Exception as e:
144 logger.error("delete_subscription failed: %s", e.args[0])
146 def delete_data_from_db(self):
147 NfInstModel.objects.filter(nfinstid=self.vnf_inst_id).delete()
148 VmInstModel.objects.filter(instid=self.vnf_inst_id).delete()
149 OOFDataModel.objects.filter(service_resource_id=self.vnf_inst_id).delete()
150 JobUtil.add_job_status(self.job_id, 100, 'vnf terminate success', 0)
152 def delete_vnf_in_aai(self):
153 logger.debug("TerminateVnfs::delete_vnf_in_aai::delete vnf instance[%s] in aai." % self.vnf_inst_id)
155 # query vnf instance in aai, get resource_version
156 customer_info = query_vnf_aai(self.vnf_inst_id)
157 resource_version = customer_info["resource-version"]
159 # delete vnf instance from aai
160 resp_data, resp_status = delete_vnf_aai(self.vnf_inst_id, resource_version)
162 "Success to delete vnf[%s] from aai, resp_status: [%s]." % (self.vnf_inst_id, resp_status))
163 except NSLCMException as e:
164 logger.debug("Fail to delete vnf from aai[%s], detail message: %s" % (self.vnf_inst_id, e.args[0]))
166 logger.error(traceback.format_exc())
168 def delete_vserver_in_aai(self):
169 logger.debug("delete_vserver_in_aai start!")
171 vm_inst_infos = VmInstModel.objects.filter(insttype=INST_TYPE.VNF, instid=self.vnf_inst_id)
172 for vm_inst_info in vm_inst_infos:
173 vserver_id = vm_inst_info.resouceid
174 vim_id = vm_inst_info.vimid
175 cloud_owner, cloud_region_id = split_vim_to_owner_region(vim_id)
176 # query vim_info from aai, get tenant
177 vim_info = get_vim_by_id({"cloud_owner": cloud_owner, 'cloud_regionid': cloud_region_id})
178 tenant_id = vim_info["tenantId"]
180 # query vserver instance in aai, get resource_version
181 vserver_info = query_vserver_aai(cloud_owner, cloud_region_id, tenant_id, vserver_id)
182 resource_version = vserver_info["resource-version"]
184 # delete vserver instance from aai
185 resp_data, resp_status = delete_vserver_aai(cloud_owner, cloud_region_id,
186 tenant_id, vserver_id, resource_version)
188 "Success to delete vserver instance[%s] from aai, resp_status: [%s]." %
189 (vserver_id, resp_status))
190 logger.debug("delete_vserver_in_aai end!")
191 except NSLCMException as e:
192 logger.debug("Fail to delete vserver from aai, detail message: %s" % e.args[0])
194 logger.error(traceback.format_exc())