from lcm.ns.enum import NS_INST_STATUS
from lcm.pub.database.models import JobModel, NSInstModel, NfInstModel, VNFCInstModel, VmInstModel
from lcm.pub.exceptions import NSLCMException
-from lcm.pub.utils.jobutil import JobUtil, JOB_MODEL_STATUS
+from lcm.pub.utils.jobutil import JobUtil
+from lcm.pub.enum import JOB_MODEL_STATUS, JOB_PROGRESS
from lcm.pub.utils.values import ignore_case_get
from lcm.ns_vnfs.biz.heal_vnfs import NFHealService
from lcm.ns.biz.ns_lcm_op_occ import NsLcmOpOcc
-JOB_ERROR = 255
logger = logging.getLogger(__name__)
try:
self.do_biz()
except NSLCMException as e:
- JobUtil.add_job_status(self.job_id, JOB_ERROR, e.message)
+ JobUtil.add_job_status(self.job_id, JOB_PROGRESS.ERROR, e.message)
NsLcmOpOcc.update(self.occ_id, operationState="FAILED", error=e.message)
except Exception as e:
logger.error(traceback.format_exc())
- JobUtil.add_job_status(self.job_id, JOB_ERROR, 'ns heal fail')
+ JobUtil.add_job_status(self.job_id, JOB_PROGRESS.ERROR, 'ns heal fail')
NsLcmOpOcc.update(self.occ_id, operationState="FAILED", error=e.message)
def do_biz(self):
ns_info = NSInstModel.objects.filter(id=self.ns_instance_id)
if not ns_info:
errmsg = 'NS [id=%s] does not exist' % self.ns_instance_id
- logger.error(errmsg)
raise NSLCMException(errmsg)
self.heal_ns_data = ignore_case_get(self.request_data, 'healNsData')
if not self.heal_ns_data and not self.heal_vnf_data:
errmsg = 'healNsData and healVnfData parameters does not exist or value is incorrect.'
- logger.error(errmsg)
raise NSLCMException(errmsg)
def do_heal(self):
self.update_job(90, desc='nf[%s] heal handle end' % vnf_heal_params.get('vnfInstanceId'))
else:
errmsg = 'nf heal failed'
- logger.error(errmsg)
raise NSLCMException(errmsg)
else:
ns_heal_params = self.prepare_ns_heal_params(self.heal_ns_data)
job_result = JobModel.objects.get(jobid=sub_job_id)
time.sleep(query_interval)
end_time = datetime.datetime.now()
- if job_result.progress == 100:
+ if job_result.progress == JOB_PROGRESS.FINISHED:
return JOB_MODEL_STATUS.FINISHED
- elif job_result.progress > 100:
+ elif job_result.progress > JOB_PROGRESS.FINISHED:
return JOB_MODEL_STATUS.ERROR
else:
continue
from lcm.pub.utils.syscomm import fun_name
from lcm.pub.utils.values import ignore_case_get
from lcm.pub.utils import restcall
+from lcm.pub.enum import JOB_PROGRESS, JOB_ERROR_CODE
from lcm.pub.exceptions import NSLCMException
from lcm.workflows.graphflow.flow.flow import GraphFlow
from lcm.ns.biz.ns_lcm_op_occ import NsLcmOpOcc
-logger = logging.getLogger(__name__)
-RESULT_OK, RESULT_NG = "0", "1"
-JOB_ERROR = 255
+logger = logging.getLogger(__name__)
config = {
"CreateVnf": {"module": "lcm.ns_vnfs", "class": "CreateVnf"},
logger.debug("Enter %s, input_data is %s", fun_name(), input_data)
ns_inst_id = ignore_case_get(input_data, "nsInstanceId")
job_id = ignore_case_get(input_data, "jobId")
- update_job(job_id, 10, "true", "Start to prepare the NS instantiate workflow parameter")
+ update_job(job_id, 10, JOB_ERROR_CODE.NO_ERROR, "Start to prepare the NS instantiate workflow parameter")
deploy_graph = build_deploy_graph(input_data)
TaskSet = build_TaskSet(input_data)
ns_instantiate_ok = False
gf.task_manager.wait_tasks_done(gf.sort_nodes)
if gf.task_manager.is_all_task_finished():
logger.debug("NS is instantiated!")
- update_job(job_id, 90, "true", "Start to post deal")
+ update_job(job_id, 90, JOB_ERROR_CODE.NO_ERROR, "Start to post deal")
post_deal(ns_inst_id, "true")
- update_job(job_id, 100, "true", "Create NS successfully.")
+ update_job(job_id, JOB_PROGRESS.FINISHED, JOB_ERROR_CODE.NO_ERROR, "Create NS successfully.")
NsLcmOpOcc.update(occ_id, "COMPLETED")
ns_instantiate_ok = True
except NSLCMException as e:
logger.error("Failded to Create NS: %s", e.message)
- update_job(job_id, JOB_ERROR, "255", "Failded to Create NS.")
+ update_job(job_id, JOB_PROGRESS.ERROR, JOB_ERROR_CODE.ERROR, "Failded to Create NS.")
NsLcmOpOcc.update(occ_id, operationState="FAILED", error=e.message)
post_deal(ns_inst_id, "false")
except Exception as e:
logger.error(traceback.format_exc())
- update_job(job_id, JOB_ERROR, "255", "Failded to Create NS.")
+ update_job(job_id, JOB_PROGRESS.ERROR, JOB_ERROR_CODE.ERROR, "Failded to Create NS.")
NsLcmOpOcc.update(occ_id, operationState="FAILED", error=e.message)
post_deal(ns_inst_id, "false")
return ns_instantiate_ok
from lcm.ns.enum import NS_INST_STATUS
from lcm.pub.database.models import JobModel, NSInstModel
from lcm.pub.exceptions import NSLCMException
-from lcm.pub.utils.jobutil import JobUtil, JOB_MODEL_STATUS
+from lcm.pub.utils.jobutil import JobUtil
+from lcm.pub.enum import JOB_MODEL_STATUS, JOB_PROGRESS
from lcm.pub.utils.values import ignore_case_get
from lcm.ns_vnfs.biz.scale_vnfs import NFManualScaleService
from lcm.ns.biz.ns_lcm_op_occ import NsLcmOpOcc
try:
self.do_biz()
except NSLCMException as e:
- JobUtil.add_job_status(self.job_id, JOB_ERROR, e.message)
+ JobUtil.add_job_status(self.job_id, JOB_PROGRESS.ERROR, e.message)
NsLcmOpOcc.update(self.occ_id, operationState="FAILED", error=e.message)
except Exception as e:
logger.error(e.message)
logger.error(traceback.format_exc())
- JobUtil.add_job_status(self.job_id, JOB_ERROR, 'ns scale fail')
+ JobUtil.add_job_status(self.job_id, JOB_PROGRESS.ERROR, 'ns scale fail')
NsLcmOpOcc.update(self.occ_id, operationState="FAILED", error=e.message)
finally:
self.update_ns_status(NS_INST_STATUS.ACTIVE)
self.update_ns_status(NS_INST_STATUS.SCALING)
self.check_and_set_params()
self.do_vnfs_scale()
- self.update_job(100, desc='ns scale success')
+ self.update_job(JOB_PROGRESS.FINISHED, desc='ns scale success')
NsLcmOpOcc.update(self.occ_id, "COMPLETED")
def check_and_set_params(self):
job_result = JobModel.objects.get(jobid=sub_job_id)
time.sleep(query_interval)
end_time = datetime.datetime.now()
- if job_result.progress == 100:
+ if job_result.progress == JOB_PROGRESS.FINISHED:
return JOB_MODEL_STATUS.FINISHED
- if job_result.progress > 100:
+ if job_result.progress > JOB_PROGRESS.FINISHED:
return JOB_MODEL_STATUS.ERROR
return JOB_MODEL_STATUS.TIMEOUT
from lcm.ns.enum import OWNER_TYPE
from lcm.pub.database.models import PNFInstModel
from lcm.ns.biz.ns_lcm_op_occ import NsLcmOpOcc
-
-JOB_ERROR = 255
+from lcm.pub.enum import JOB_PROGRESS
logger = logging.getLogger(__name__)
def run(self):
try:
if not NSInstModel.objects.filter(id=self.ns_inst_id):
- JobUtil.add_job_status(self.job_id, 100, "Need not terminate.", '')
+ JobUtil.add_job_status(self.job_id, JOB_PROGRESS.FINISHED, "Need not terminate.", '')
NsLcmOpOcc.update(self.occ_id, "COMPLETED")
return
JobUtil.add_job_status(self.job_id, 10, "Starting terminate...", '')
self.cancel_pnf_list()
NSInstModel.objects.filter(id=self.ns_inst_id).update(status='null')
- JobUtil.add_job_status(self.job_id, 100, "ns terminate ends.", '')
+ JobUtil.add_job_status(self.job_id, JOB_PROGRESS.FINISHED, "ns terminate ends.", '')
NsLcmOpOcc.update(self.occ_id, "COMPLETED")
except NSLCMException as e:
- JobUtil.add_job_status(self.job_id, JOB_ERROR, e.message)
+ JobUtil.add_job_status(self.job_id, JOB_PROGRESS.ERROR, e.message)
NsLcmOpOcc.update(self.occ_id, operationState="FAILED", error=e.message)
except Exception as e:
logger.error(e.message)
logger.error(traceback.format_exc())
- JobUtil.add_job_status(self.job_id, JOB_ERROR, "ns terminate fail.")
+ JobUtil.add_job_status(self.job_id, JOB_PROGRESS.ERROR, "ns terminate fail.")
NsLcmOpOcc.update(self.occ_id, operationState="FAILED", error=e.message)
def cancel_vl_list(self):
logger.debug("%s:%s:%s", progress, new_response_id, job_desc)
response_id = new_response_id
count = 0
- if progress == JOB_ERROR:
+ if progress == JOB_PROGRESS.ERROR:
job_timeout = False
logger.error("Job(%s) failed: %s", vnf_job_id, job_desc)
break
- elif progress == 100:
+ elif progress == JOB_PROGRESS.FINISHED:
job_end_normal, job_timeout = True, False
logger.info("Job(%s) ended normally", vnf_job_id)
break
import datetime
import time
-from lcm.ns.enum import NS_INST_STATUS
+from lcm.ns.enum import NS_INST_STATUS, OPERATIONAL_STATE, STOP_TYPE
from lcm.pub.database.models import JobModel, NSInstModel
from lcm.ns_vnfs.biz.update_vnfs import NFOperateService
from lcm.pub.exceptions import NSLCMException
-from lcm.pub.utils.jobutil import JobUtil, JOB_MODEL_STATUS
+from lcm.pub.utils.jobutil import JobUtil
+from lcm.pub.enum import JOB_MODEL_STATUS, JOB_PROGRESS
from lcm.pub.utils.values import ignore_case_get
-from lcm.pub.utils.enumutil import enum
from lcm.ns.biz.ns_lcm_op_occ import NsLcmOpOcc
-JOB_ERROR = 255
logger = logging.getLogger(__name__)
-OPERATIONAL_STATES = enum(STOPPED='STOPPED', STARTED='STARTED')
-STOP_TYPE = enum(GRACEFUL='GRACEFUL', FORCEFUL='FORCEFUL')
class NSUpdateService(threading.Thread):
self.do_biz()
except NSLCMException as e:
logger.error(traceback.format_exc())
- JobUtil.add_job_status(self.job_id, JOB_ERROR, e.message)
+ JobUtil.add_job_status(self.job_id, JOB_PROGRESS.ERROR, e.message)
NsLcmOpOcc.update(self.occ_id, operationState="FAILED", error=e.message)
except Exception as e:
logger.error(traceback.format_exc())
- JobUtil.add_job_status(self.job_id, JOB_ERROR, 'ns update fail')
+ JobUtil.add_job_status(self.job_id, JOB_PROGRESS.ERROR, 'ns update fail')
NsLcmOpOcc.update(self.occ_id, operationState="FAILED", error=e.message)
def do_biz(self):
- self.update_job(1, desc='ns update start')
+ self.update_job(JOB_PROGRESS.STARTED, desc='ns update start')
self.get_and_check_params()
self.update_ns_status(NS_INST_STATUS.UPDATING)
self.do_update()
self.update_ns_status(NS_INST_STATUS.ACTIVE)
- self.update_job(100, desc='ns update success')
+ self.update_job(JOB_PROGRESS.FINISHED, desc='ns update success')
NsLcmOpOcc.update(self.occ_id, "COMPLETED")
def get_and_check_params(self):
'ChangeStateTo does not exist or value is incorrect.')
graceful_stop_timeout = ''
operational_states = ignore_case_get(change_state_to, 'OperationalStates')
- if operational_states == OPERATIONAL_STATES.STOPPED:
+ if operational_states == OPERATIONAL_STATE.STOPPED:
stop_type = ignore_case_get(vnf_data, 'stopType')
if stop_type == STOP_TYPE.GRACEFUL:
graceful_stop_timeout = ignore_case_get(vnf_data, 'gracefulStopTimeout')
job_result = JobModel.objects.get(jobid=sub_job_id)
time.sleep(query_interval)
end_time = datetime.datetime.now()
- if job_result.progress == 100:
+ if job_result.progress == JOB_PROGRESS.FINISHED:
return JOB_MODEL_STATUS.FINISHED
- elif job_result.progress > 100:
+ elif job_result.progress > JOB_PROGRESS.FINISHED:
return JOB_MODEL_STATUS.ERROR
else:
continue
from lcm.ns_vnfs.enum import VNF_STATUS
logger = logging.getLogger(__name__)
-SCALE_TYPE = ("SCALE_NS", "SCALE_VNF")
scale_vnf_data_mapping = {
"vnfInstanceId": "",
from lcm.ns.enum import NS_INST_STATUS
from lcm.pub.database.models import NSInstModel, NfInstModel
from lcm.pub.exceptions import NSLCMException
-from lcm.pub.utils.jobutil import JobUtil, JOB_TYPE
+from lcm.pub.utils.jobutil import JobUtil
+from lcm.pub.enum import JOB_TYPE
from lcm.ns_vnfs.biz.heal_vnfs import NFHealService
from lcm.ns.tests import HEAL_NS_DICT, HEAL_VNF_DICT, VNFD_MODEL_DICT
heal_ns_json = HEAL_NS_DICT.copy()
heal_ns_json["healNsData"]["vnfInstanceId"] = self.nf_inst_id
response = self.client.post("/api/nslcm/v1/ns/%s/heal" % ns_inst_id, data=heal_ns_json, format='json')
+ print response.data
self.assertEqual(response.data["error"], "NS Not Found")
self.assertEqual(response.status_code, status.HTTP_500_INTERNAL_SERVER_ERROR)
self.assertIn("error", response.data)
from lcm.pub.exceptions import NSLCMException
from lcm.pub.msapi import catalog
from lcm.pub.utils import restcall
-from lcm.pub.utils.jobutil import JobUtil, JOB_TYPE, JOB_MODEL_STATUS
+from lcm.pub.utils.jobutil import JobUtil
+from lcm.pub.enum import JOB_MODEL_STATUS, JOB_TYPE
from lcm.ns.tests import SCALING_MAP_DICT, VNFD_MODEL_DICT, SCALE_NS_DICT
from lcm.ns.biz.ns_heal import NSHealService
from lcm.pub.database.models import NSInstModel, NfInstModel
from lcm.pub.exceptions import NSLCMException
-from lcm.pub.utils.jobutil import JobUtil, JOB_TYPE
+from lcm.pub.utils.jobutil import JobUtil
+from lcm.pub.enum import JOB_TYPE
from lcm.ns.tests import VNFD_MODEL_DICT, HEAL_NS_DICT, HEAL_VNF_DICT
from lcm.ns.biz.ns_manual_scale import NSManualScaleService
from lcm.pub.database.models import NSInstModel, JobModel, NfInstModel
from lcm.pub.exceptions import NSLCMException
-from lcm.pub.utils.jobutil import JobUtil, JOB_TYPE
+from lcm.pub.utils.jobutil import JobUtil
+from lcm.pub.enum import JOB_TYPE
from lcm.ns.tests import VNFD_MODEL_DICT, SCALE_NS_DICT
from lcm.ns.biz.ns_terminate import TerminateNsService
from lcm.pub.database.models import NfInstModel, NSInstModel
from lcm.pub.utils import restcall
-from lcm.pub.utils.jobutil import JOB_MODEL_STATUS
-from lcm.pub.utils.jobutil import JobUtil, JOB_TYPE
+from lcm.pub.enum import JOB_MODEL_STATUS, JOB_TYPE
+from lcm.pub.utils.jobutil import JobUtil
class TestTerminateNsViews(TestCase):
from lcm.ns.serializers.deprecated.ns_serializers import _HealNsReqSerializer
from lcm.ns.serializers.deprecated.ns_serializers import _NsOperateJobSerializer
from lcm.pub.exceptions import NSLCMException
-from lcm.pub.utils.jobutil import JobUtil, JOB_TYPE
+from lcm.pub.utils.jobutil import JobUtil
+from lcm.pub.enum import JOB_TYPE
logger = logging.getLogger(__name__)
logger.debug("Leave HealNSView::post ret=%s", resp_serializer.data)
return Response(data=resp_serializer.data, status=status.HTTP_202_ACCEPTED)
+ except NSLCMException as e:
+ logger.error("Exception in HealNSView: %s", e.message)
+ return Response(data={'error': e.message}, status=status.HTTP_500_INTERNAL_SERVER_ERROR)
except Exception as e:
logger.error("Exception in HealNSView: %s", e.message)
return Response(data={'error': e.message}, status=status.HTTP_500_INTERNAL_SERVER_ERROR)
from lcm.ns.serializers.deprecated.ns_serializers import _NsOperateJobSerializer
from lcm.ns.serializers.deprecated.ns_serializers import _ManualScaleNsReqSerializer
from lcm.pub.exceptions import NSLCMException
-from lcm.pub.utils.jobutil import JobUtil, JOB_TYPE
+from lcm.pub.utils.jobutil import JobUtil
+from lcm.pub.enum import JOB_TYPE
logger = logging.getLogger(__name__)
from lcm.ns.biz.ns_terminate import TerminateNsService
from lcm.pub.exceptions import NSLCMException
-from lcm.pub.utils.jobutil import JobUtil, JOB_TYPE
+from lcm.pub.utils.jobutil import JobUtil
+from lcm.pub.enum import JOB_TYPE
from lcm.ns.serializers.deprecated.ns_serializers import _TerminateNsReqSerializer, _NsOperateJobSerializer
logger = logging.getLogger(__name__)
from lcm.ns.serializers.deprecated.ns_serializers import _NsOperateJobSerializer
from lcm.ns.serializers.sol.update_serializers import UpdateNsReqSerializer
from lcm.pub.exceptions import NSLCMException
-from lcm.pub.utils.jobutil import JobUtil, JOB_TYPE
+from lcm.pub.utils.jobutil import JobUtil
+from lcm.pub.enum import JOB_TYPE
logger = logging.getLogger(__name__)
from lcm.ns.biz.ns_heal import NSHealService
from lcm.ns.serializers.sol.heal_serializers import HealNsReqSerializer
from lcm.pub.exceptions import BadRequestException
-from lcm.pub.utils.jobutil import JobUtil, JOB_TYPE
+from lcm.pub.utils.jobutil import JobUtil
+from lcm.pub.enum import JOB_TYPE
from lcm.ns.const import NS_OCC_BASE_URI
from lcm.ns.serializers.sol.pub_serializers import ProblemDetailsSerializer
from .common import view_safe_call_with_log
from rest_framework.views import APIView
from lcm.ns.biz.ns_manual_scale import NSManualScaleService
from lcm.ns.serializers.sol.scale_ns_serializers import ScaleNsRequestSerializer
-from lcm.pub.utils.jobutil import JobUtil, JOB_TYPE
+from lcm.pub.utils.jobutil import JobUtil
+from lcm.pub.enum import JOB_TYPE
from lcm.ns.const import NS_OCC_BASE_URI
from lcm.pub.exceptions import BadRequestException
from lcm.ns.serializers.sol.pub_serializers import ProblemDetailsSerializer
from lcm.ns.biz.ns_terminate import TerminateNsService
from lcm.pub.utils.jobutil import JobUtil
-from lcm.pub.utils.jobutil import JOB_TYPE
+from lcm.pub.enum import JOB_TYPE
from lcm.pub.utils.values import ignore_case_get
from lcm.ns.serializers.sol.terminate_ns_serializers import TerminateNsReqSerializer
from lcm.pub.exceptions import BadRequestException
from lcm.ns.biz.ns_update import NSUpdateService
from lcm.ns.serializers.sol.update_serializers import UpdateNsReqSerializer
from lcm.pub.exceptions import BadRequestException
-from lcm.pub.utils.jobutil import JobUtil, JOB_TYPE
+from lcm.pub.utils.jobutil import JobUtil
+from lcm.pub.enum import JOB_TYPE
from lcm.ns.const import NS_OCC_BASE_URI
from lcm.ns.serializers.sol.pub_serializers import ProblemDetailsSerializer
from .common import view_safe_call_with_log
import json
import logging
+from threading import Thread
import traceback
import uuid
-from threading import Thread
from lcm.ns.enum import OWNER_TYPE
+from lcm.ns_vnfs.const import NFVO_VNF_INST_TIMEOUT_SECOND
+from lcm.ns_vnfs.biz.subscribe import SubscriptionCreation
+from lcm.ns_vnfs.biz.wait_job import wait_job_finish
+from lcm.ns_vnfs.enum import VNF_STATUS, INST_TYPE, INST_TYPE_NAME
from lcm.pub.config.config import REPORT_TO_AAI
+from lcm.pub.config.config import REG_TO_MSB_REG_PARAM, OOF_BASE_URL, OOF_PASSWD, OOF_USER
+from lcm.pub.config.config import CUST_NAME, CUST_LAT, CUST_LONG
from lcm.pub.database.models import NfInstModel, NSInstModel, VmInstModel, VNFFGInstModel, VLInstModel, OOFDataModel
+from lcm.pub.enum import JOB_MODEL_STATUS, JOB_TYPE, JOB_PROGRESS, JOB_ERROR_CODE
from lcm.pub.exceptions import NSLCMException
from lcm.pub.msapi.aai import create_vnf_aai
from lcm.pub.msapi.extsys import get_vnfm_by_id
from lcm.pub.msapi.resmgr import create_vnf, create_vnf_creation_info
from lcm.pub.msapi.sdc_run_catalog import query_vnfpackage_by_id
from lcm.pub.msapi.vnfmdriver import send_nf_init_request
-from lcm.pub.utils.jobutil import JOB_MODEL_STATUS, JobUtil, JOB_TYPE
+from lcm.pub.utils import restcall
+from lcm.pub.utils.jobutil import JobUtil
from lcm.pub.utils.share_lock import do_biz_with_share_lock
from lcm.pub.utils.timeutil import now_time
from lcm.pub.utils.values import ignore_case_get
-from lcm.pub.utils import restcall
-from lcm.ns_vnfs.const import NFVO_VNF_INST_TIMEOUT_SECOND
-from lcm.ns_vnfs.enum import VNF_STATUS, INST_TYPE, INST_TYPE_NAME
-from lcm.ns_vnfs.biz.wait_job import wait_job_finish
-from lcm.pub.config.config import REG_TO_MSB_REG_PARAM, OOF_BASE_URL, OOF_PASSWD, OOF_USER
-from lcm.pub.config.config import CUST_NAME, CUST_LAT, CUST_LONG
-from lcm.ns_vnfs.biz.subscribe import SubscriptionCreation
+
logger = logging.getLogger(__name__)
def prepare_create_params():
nf_inst_id = str(uuid.uuid4())
- NfInstModel(nfinstid=nf_inst_id, status=VNF_STATUS.INSTANTIATING, create_time=now_time(),
- lastuptime=now_time()).save()
+ NfInstModel(
+ nfinstid=nf_inst_id,
+ status=VNF_STATUS.INSTANTIATING,
+ create_time=now_time(),
+ lastuptime=now_time()
+ ).save()
job_id = JobUtil.create_job(INST_TYPE_NAME.VNF, JOB_TYPE.CREATE_VNF, nf_inst_id)
- JobUtil.add_job_status(job_id, 0, 'create vnf record in database.', 0)
+ JobUtil.add_job_status(job_id, JOB_PROGRESS.STARTED, 'create vnf record in database.', JOB_ERROR_CODE.NO_ERROR)
return nf_inst_id, job_id
self.subscribe()
self.write_vnf_creation_info()
self.save_info_to_db()
- JobUtil.add_job_status(self.job_id, 100, 'vnf instantiation success', 0)
+ JobUtil.add_job_status(self.job_id, JOB_PROGRESS.FINISHED, 'vnf instantiation success', JOB_ERROR_CODE.NO_ERROR)
except NSLCMException as e:
self.vnf_inst_failed_handle(e.message)
except Exception:
def check_nf_name_exist(self):
is_exist = NfInstModel.objects.filter(nf_name=self.vnf_inst_name).exists()
if is_exist:
- logger.error('The name of NF instance already exists.')
- raise NSLCMException('The name of NF instance already exists.')
+ raise NSLCMException('The name of VNF instance already exists.')
def get_vnfd_id(self):
if self.vnfd_id:
self.vnf_inst_name = self.vnf_inst_name[:30]
self.vnf_inst_name = self.vnf_inst_name.replace("-", "_")
return
- logger.error('Can not found vnf in nsd model')
raise NSLCMException('Can not found vnf in nsd model')
def check_nf_package_valid(self):
req_body = self.build_homing_request()
base_url = OOF_BASE_URL
resources = "/api/oof/v1/placement"
- resp = restcall.call_req(base_url=base_url, user=OOF_USER, passwd=OOF_PASSWD,
- auth_type=restcall.rest_oneway_auth, resource=resources,
- method="POST", content=json.dumps(req_body), additional_headers="")
+ resp = restcall.call_req(
+ base_url=base_url,
+ user=OOF_USER,
+ passwd=OOF_PASSWD,
+ auth_type=restcall.rest_oneway_auth,
+ resource=resources,
+ method="POST",
+ content=json.dumps(req_body),
+ additional_headers="")
resp_body = resp[-2]
resp_status = resp[-1]
if resp_body:
logger.warn("Missing OOF sync response")
logger.debug(("OOF sync response code is %s") % resp_status)
if str(resp_status) != '202' or resp[0] != 0:
- OOFDataModel.objects.filter(request_id=req_body["requestInfo"]["requestId"],
- transaction_id=req_body["requestInfo"]["transactionId"]).update(
+ OOFDataModel.objects.filter(
+ request_id=req_body["requestInfo"]["requestId"],
+ transaction_id=req_body["requestInfo"]["transactionId"]
+ ).update(
request_status="failed",
vim_id="none",
cloud_owner="none",
create_vnf(data)
def wait_vnfm_job_finish(self):
- ret = wait_job_finish(vnfm_id=self.vnfm_inst_id,
- vnfo_job_id=self.job_id,
- vnfm_job_id=self.vnfm_job_id,
- progress_range=[10, 90],
- timeout=NFVO_VNF_INST_TIMEOUT_SECOND)
+ ret = wait_job_finish(
+ vnfm_id=self.vnfm_inst_id,
+ vnfo_job_id=self.job_id,
+ vnfm_job_id=self.vnfm_job_id,
+ progress_range=[10, 90],
+ timeout=NFVO_VNF_INST_TIMEOUT_SECOND)
if ret != JOB_MODEL_STATUS.FINISHED:
- logger.error('VNF instantiation failed on VNFM side. ret=[%s]', ret)
- raise NSLCMException('VNF instantiation failed on VNFM side.')
+ raise NSLCMException('VNF instantiation failed from VNFM. The job status is %s' % ret)
def subscribe(self):
data = {
'nf_inst_id': self.nf_inst_id,
'ns_inst_id': self.ns_inst_id,
'vnfm_inst_id': self.vnfm_inst_id,
- 'vms': [{'vmId': vm_inst_info.resouceid, 'vmName': vm_inst_info.vmname, 'vmStatus': 'ACTIVE'} for
- vm_inst_info in vm_inst_infos]}
+ 'vms': [{'vmId': vm_inst_info.resouceid, 'vmName': vm_inst_info.vmname, 'vmStatus': 'ACTIVE'} for vm_inst_info in vm_inst_infos]
+ }
create_vnf_creation_info(data)
logger.debug("write_vnf_creation_info end")
def vnf_inst_failed_handle(self, error_msg):
logger.error('VNF instantiation failed, detail message: %s' % error_msg)
- NfInstModel.objects.filter(nfinstid=self.nf_inst_id).update(status=VNF_STATUS.FAILED,
- lastuptime=now_time())
+ NfInstModel.objects.filter(nfinstid=self.nf_inst_id).update(status=VNF_STATUS.FAILED, lastuptime=now_time())
JobUtil.add_job_status(self.job_id, 255, 'VNF instantiation failed, detail message: %s' % error_msg, 0)
def save_vnf_inst_id_in_vnffg(self):
continue
vnffg_inst_infos = VNFFGInstModel.objects.filter(vnffgdid=vnffg['vnffg_Id'], nsinstid=self.ns_inst_id)
if not vnffg_inst_infos:
- logger.error('Vnffg instance not exist.')
raise NSLCMException('Vnffg instance not exist.')
vnf_list = vnffg_inst_infos[0].vnflist
vnffg_inst_infos.update(vnf_list=vnf_list + ',' + self.nf_inst_id if vnf_list else self.nf_inst_id)
from lcm.pub.exceptions import NSLCMException
from lcm.pub.msapi.vnfmdriver import send_nf_heal_request
from lcm.pub.utils import restcall
-from lcm.pub.utils.jobutil import JobUtil, JOB_TYPE, JOB_MODEL_STATUS
+from lcm.pub.utils.jobutil import JobUtil
+from lcm.pub.enum import JOB_MODEL_STATUS, JOB_TYPE, JOB_PROGRESS
from lcm.pub.utils.values import ignore_case_get
-from lcm.ns_vnfs.const import JOB_ERROR
from lcm.ns_vnfs.enum import VNF_STATUS
from lcm.ns_vnfs.biz.wait_job import wait_job_finish
self.vnf_instance_id = vnf_instance_id
self.data = data
self.job_id = JobUtil.create_job("NF", JOB_TYPE.HEAL_VNF, vnf_instance_id)
-
self.nf_model = {}
self.nf_additional_params = {}
self.nf_heal_params = {}
def run(self):
try:
- self.do_biz()
+ JobUtil.add_job_status(self.job_id, JOB_PROGRESS.STARTED, 'vnf heal start')
+ self.get_and_check_params()
+ self.update_nf_status(VNF_STATUS.HEALING)
+ self.send_nf_healing_request()
+ self.update_nf_status(VNF_STATUS.ACTIVE)
+ JobUtil.add_job_status(self.job_id, JOB_PROGRESS.FINISHED, 'vnf heal success')
except NSLCMException as e:
- JobUtil.add_job_status(self.job_id, JOB_ERROR, e.message)
+ JobUtil.add_job_status(self.job_id, JOB_PROGRESS.ERROR, e.message)
except:
logger.error(traceback.format_exc())
- JobUtil.add_job_status(self.job_id, JOB_ERROR, 'nf heal fail')
-
- def do_biz(self):
- self.update_job(1, desc='nf heal start')
- self.get_and_check_params()
- self.update_nf_status(VNF_STATUS.HEALING)
- self.send_nf_healing_request()
- self.update_nf_status(VNF_STATUS.ACTIVE)
- self.update_job(100, desc='nf heal success')
+ JobUtil.add_job_status(self.job_id, JOB_PROGRESS.ERROR, 'vnf heal fail')
def get_and_check_params(self):
nf_info = NfInstModel.objects.filter(nfinstid=self.vnf_instance_id)
if not nf_info:
- logger.error('NF instance[id=%s] does not exist' % self.vnf_instance_id)
- raise NSLCMException('NF instance[id=%s] does not exist' % self.vnf_instance_id)
+ raise NSLCMException('VNF instance[id=%s] does not exist' % self.vnf_instance_id)
logger.debug('vnfd_model = %s, vnf_instance_id = %s' % (nf_info[0].vnfd_model, self.vnf_instance_id))
self.nf_model = nf_info[0].vnfd_model
self.m_nf_inst_id = nf_info[0].mnfinstid
self.vnfm_inst_id = nf_info[0].vnfm_inst_id
self.nf_additional_params = ignore_case_get(self.data, 'additionalParams')
-
if not self.nf_additional_params:
- logger.error('additionalParams parameter does not exist or value incorrect')
raise NSLCMException('additionalParams parameter does not exist or value incorrect')
actionvminfo = ignore_case_get(self.nf_additional_params, 'actionvminfo')
vnfm_job_id = ignore_case_get(rsp, 'jobId')
if not vnfm_job_id:
return
- ret = wait_job_finish(self.vnfm_inst_id, self.job_id, vnfm_job_id, progress_range=None, timeout=1200,
- mode='1')
+ ret = wait_job_finish(self.vnfm_inst_id, self.job_id, vnfm_job_id, progress_range=None, timeout=1200, mode='1')
if ret != JOB_MODEL_STATUS.FINISHED:
logger.error('[NF heal] nf heal failed')
raise NSLCMException("nf heal failed")
return vmid
return vms.first().vmname
- def update_job(self, progress, desc=''):
- JobUtil.add_job_status(self.job_id, progress, desc)
-
def update_nf_status(self, status):
NfInstModel.objects.filter(nfinstid=self.vnf_instance_id).update(status=status)
from lcm.pub.database.models import NfInstModel
from lcm.pub.exceptions import NSLCMException
from lcm.pub.msapi.vnfmdriver import send_nf_scaling_request
-from lcm.pub.utils.jobutil import JobUtil, JOB_TYPE, JOB_MODEL_STATUS
+from lcm.pub.utils.jobutil import JobUtil
+from lcm.pub.enum import JOB_MODEL_STATUS, JOB_TYPE, JOB_PROGRESS
from lcm.pub.utils.values import ignore_case_get
-from lcm.ns_vnfs.const import JOB_ERROR
from lcm.ns_vnfs.enum import VNF_STATUS
from lcm.ns_vnfs.biz.wait_job import wait_job_finish
try:
self.do_biz()
except NSLCMException as e:
- JobUtil.add_job_status(self.job_id, JOB_ERROR, e.message)
+ JobUtil.add_job_status(self.job_id, JOB_PROGRESS.ERROR, e.message)
except Exception as ex:
logger.error(ex.message)
logger.error(traceback.format_exc())
- JobUtil.add_job_status(self.job_id, JOB_ERROR, 'VNF scale failed')
+ JobUtil.add_job_status(self.job_id, JOB_PROGRESS.ERROR, 'VNF scale failed')
finally:
self.update_nf_status()
from lcm.pub.msapi.aai import query_vnf_aai, delete_vnf_aai, query_vserver_aai, delete_vserver_aai
from lcm.pub.msapi.extsys import split_vim_to_owner_region, get_vim_by_id
from lcm.pub.msapi.vnfmdriver import send_nf_terminate_request
-from lcm.pub.utils.jobutil import JOB_MODEL_STATUS, JobUtil
+from lcm.pub.utils.jobutil import JobUtil
+from lcm.pub.enum import JOB_MODEL_STATUS
from lcm.pub.utils.values import ignore_case_get
from lcm.ns_vnfs.const import NFVO_VNF_INST_TIMEOUT_SECOND
from lcm.ns_vnfs.enum import VNF_STATUS, INST_TYPE
from lcm.pub.database.models import NfInstModel
from lcm.pub.exceptions import NSLCMException
from lcm.pub.msapi.vnfmdriver import send_nf_operate_request
-from lcm.pub.utils.jobutil import JobUtil, JOB_TYPE, JOB_MODEL_STATUS
+from lcm.pub.utils.jobutil import JobUtil
+from lcm.pub.enum import JOB_MODEL_STATUS, JOB_TYPE, JOB_PROGRESS
from lcm.pub.utils.values import ignore_case_get
-from lcm.ns_vnfs.const import JOB_ERROR
from lcm.ns_vnfs.enum import VNF_STATUS
from lcm.ns_vnfs.biz.wait_job import wait_job_finish
try:
self.do_biz()
except NSLCMException as e:
- JobUtil.add_job_status(self.job_id, JOB_ERROR, e.message)
+ JobUtil.add_job_status(self.job_id, JOB_PROGRESS.ERROR, e.message)
except:
logger.error(traceback.format_exc())
- JobUtil.add_job_status(self.job_id, JOB_ERROR, 'nf update fail')
+ JobUtil.add_job_status(self.job_id, JOB_PROGRESS.ERROR, 'nf update fail')
def do_biz(self):
self.update_job(1, desc='nf update start')
import traceback
import time
-from lcm.ns_vnfs.const import JOB_ERROR
from lcm.pub.exceptions import NSLCMException
-from lcm.pub.utils.jobutil import JobUtil, JOB_TYPE
+from lcm.pub.utils.jobutil import JobUtil
+from lcm.pub.enum import JOB_TYPE, JOB_PROGRESS
from lcm.pub.utils.values import ignore_case_get
from lcm.pub.utils.restcall import req_by_msb
self.do_func_test()
self.verify_ok = True
except NSLCMException as e:
- self.update_job(JOB_ERROR, e.message)
+ self.update_job(JOB_PROGRESS.ERROR, e.message)
except:
logger.error(traceback.format_exc())
- self.update_job(JOB_ERROR, 'Unknown error in vnf verify.')
+ self.update_job(JOB_PROGRESS.ERROR, 'Unknown error in vnf verify.')
finally:
logger.warn("Ignore terminate vnf operation")
if self.verify_ok:
if ret[0] != 0:
raise NSLCMException("Failed to call term vnf: %s" % ret[1])
rsp_data = json.JSONDecoder().decode(ret[1])
- end_progress = 100 if self.verify_ok else JOB_ERROR
- term_progress = 95 if self.verify_ok else JOB_ERROR
+ end_progress = 100 if self.verify_ok else JOB_PROGRESS.ERROR
+ term_progress = 95 if self.verify_ok else JOB_PROGRESS.ERROR
if not self.wait_until_job_done(rsp_data["jobId"], term_progress):
logger.error("Vnf(%s) term failed", self.vnf_inst_id)
- end_progress = JOB_ERROR
+ end_progress = JOB_PROGRESS.ERROR
self.update_job(end_progress, "Term vnf end.")
def update_job(self, progress, desc=''):
logger.debug("%s:%s:%s", progress, new_response_id, job_desc)
response_id = new_response_id
count = 0
- if progress == JOB_ERROR:
+ if progress == JOB_PROGRESS.ERROR:
if 'already onBoarded' in job_desc:
logger.warn("%s:%s", job_id, job_desc)
job_end_normal, job_timeout = True, False
logger.debug("%s:%s:%s", progress, new_response_id, job_desc)
response_id = new_response_id
count = 0
- if progress == JOB_ERROR:
+ if progress == JOB_PROGRESS.ERROR:
if 'already onBoarded' in job_desc:
logger.warn("%s:%s", job_id, job_desc)
job_end_normal, job_timeout = True, False
import math
-from lcm.pub.utils.jobutil import JobUtil, JOB_MODEL_STATUS
+from lcm.pub.utils.jobutil import JobUtil
+from lcm.pub.enum import JOB_MODEL_STATUS
from lcm.pub.msapi.vnfmdriver import query_vnfm_job
from lcm.pub.utils.values import ignore_case_get
# See the License for the specific language governing permissions and
# limitations under the License.
-DATETIME_FORMAT = '%Y-%m-%d %H:%M:%S'
-JOB_ERROR = 255
NFVO_VNF_INST_TIMEOUT_SECOND = 3000
SCALAR_UNIT_DICT = {
"B": 1,
from lcm.pub.database.models import NfInstModel, JobModel, NSInstModel, VmInstModel, OOFDataModel, SubscriptionModel
from lcm.pub.exceptions import NSLCMException
from lcm.pub.utils import restcall
-from lcm.pub.utils.jobutil import JOB_MODEL_STATUS
-from lcm.pub.utils.jobutil import JobUtil, JOB_TYPE
+from lcm.pub.enum import JOB_MODEL_STATUS, JOB_TYPE
+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.ns_vnfs.biz.create_vnfs import CreateVnfs
url(r'^api/nslcm/v1/vnfms/(?P<vnfmid>[0-9a-zA-Z_-]+)', NfVnfmInfoView.as_view()),
# url(r'^api/nslcm/v1/vims/(?P<vimid>[0-9a-zA-Z_-]+)', NfVimInfoView.as_view()),
url(r'^api/nslcm/v1/vims/(?P<cloudowner>[0-9a-zA-Z_-]+)/(?P<cloudregionid>[0-9a-zA-Z_-]+)', NfVimInfoView.as_view()),
-
- # move form v2
url(r'^api/nslcm/v2/grants$', VnfGrantView.as_view()),
- url(r'^api/nslcm/v2/ns/(?P<vnfmId>[0-9a-zA-Z_-]+)/vnfs/(?P<vnfInstanceId>[0-9a-zA-Z_-]+)/Notify$',
- VnfNotifyView.as_view()),
+ url(r'^api/nslcm/v2/ns/(?P<vnfmId>[0-9a-zA-Z_-]+)/vnfs/(?P<vnfInstanceId>[0-9a-zA-Z_-]+)/Notify$', VnfNotifyView.as_view()),
]
urlpatterns = format_suffix_patterns(urlpatterns)
from lcm.pub.exceptions import NSLCMException
from lcm.pub.msapi.extsys import get_vnfm_by_id, get_vim_by_id_vim_info
-from lcm.pub.utils.jobutil import JobUtil, JOB_TYPE
+from lcm.pub.utils.jobutil import JobUtil
+from lcm.pub.enum import JOB_TYPE
from lcm.pub.utils.values import ignore_case_get
from lcm.ns_vnfs.biz.create_vnfs import CreateVnfs
from lcm.ns_vnfs.biz.get_vnfs import GetVnf, GetVnfVms
--- /dev/null
+# Copyright 2016 ZTE Corporation.
+#
+# Licensed under the Apache License, Version 2.0 (the "License");
+# you may not use this file except in compliance with the License.
+# You may obtain a copy of the License at
+#
+# http://www.apache.org/licenses/LICENSE-2.0
+#
+# Unless required by applicable law or agreed to in writing, software
+# distributed under the License is distributed on an "AS IS" BASIS,
+# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+# See the License for the specific language governing permissions and
+# limitations under the License.
+
+DATETIME_FORMAT = '%Y-%m-%d %H:%M:%S'
--- /dev/null
+# Copyright 2019 ZTE Corporation.
+#
+# Licensed under the Apache License, Version 2.0 (the "License");
+# you may not use this file except in compliance with the License.
+# You may obtain a copy of the License at
+#
+# http://www.apache.org/licenses/LICENSE-2.0
+#
+# Unless required by applicable law or agreed to in writing, software
+# distributed under the License is distributed on an "AS IS" BASIS,
+# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+# See the License for the specific language governing permissions and
+# limitations under the License.
+
+from lcm.pub.utils.enumutil import enum
+
+JOB_STATUS = enum(
+ FINISH=1,
+ PROCESSING=0
+)
+JOB_MODEL_STATUS = enum(
+ ERROR='error',
+ FINISHED='finished',
+ PROCESSING='processing',
+ STARTED='started',
+ TIMEOUT='timeout'
+)
+JOB_TYPE = enum(
+ CREATE_VNF="create vnf",
+ HEAL_VNF="heal vnf",
+ GRANT_VNF="grant vnf",
+ MANUAL_SCALE_VNF="manual scale vnf",
+ TERMINATE_NS="terminate ns",
+ TERMINATE_VNF="terminate vnf",
+ UPDATE_NS="update ns"
+)
+JOB_PROGRESS = enum(
+ ERROR=255,
+ FINISHED=100,
+ PARTLY_FINISHED=101,
+ STARTED=0
+)
+JOB_ERROR_CODE = enum(
+ NO_ERROR="0",
+ ERROR="255"
+)
# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
# See the License for the specific language governing permissions and
# limitations under the License.
+import logging
+logger = logging.getLogger(__name__)
-class NSLCMException(Exception):
+
+class BaseException(Exception):
+ def __init__(self, message):
+ super(BaseException, self).__init__(message)
+ logger.error(self.message)
+
+
+class BadRequestException(BaseException):
pass
-class BadRequestException(Exception):
+class NSLCMException(BaseException):
pass
-class SeeOtherException(Exception):
+class SeeOtherException(BaseException):
pass
# See the License for the specific language governing permissions and
# limitations under the License.
import datetime
+from functools import reduce
import logging
-import uuid
import traceback
+import uuid
from lcm.pub.database.models import JobStatusModel, JobModel
+from lcm.pub.enum import JOB_STATUS
from lcm.pub.utils import idutil
-from functools import reduce
logger = logging.getLogger(__name__)
-def enum(**enums):
- return type('Enum', (), enums)
-
-
-JOB_STATUS = enum(PROCESSING=0, FINISH=1)
-JOB_MODEL_STATUS = enum(STARTED='started', PROCESSING='processing', FINISHED='finished', ERROR='error',
- TIMEOUT='timeout')
-JOB_TYPE = enum(CREATE_VNF="create vnf", TERMINATE_VNF="terminate vnf", GRANT_VNF="grant vnf", MANUAL_SCALE_VNF="manual scale vnf",
- HEAL_VNF="heal vnf", TERMINATE_NS="terminate ns", UPDATE_NS="update ns")
-
-
class JobUtil(object):
def __init__(self):
pass
Code Review / vfc / nfvo / lcm.git / commitdiff