1 # Copyright 2016-2017 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.
19 from lcm.pub.database.models import JobStatusModel, JobModel
20 from lcm.pub.utils import idutil
22 logger = logging.getLogger(__name__)
26 return type('Enum', (), enums)
29 JOB_STATUS = enum(PROCESSING=0, FINISH=1)
30 JOB_MODEL_STATUS = enum(STARTED='started', PROCESSING='processing', FINISHED='finished', ERROR='error',
32 JOB_TYPE = enum(CREATE_VNF="create vnf", TERMINATE_VNF="terminate vnf", GRANT_VNF="grant vnf", MANUAL_SCALE_VNF="manual scale vnf",
36 class JobUtil(object):
41 def __gen_job_id(job_name):
42 return "%s-%s" % (job_name if job_name else "UnknownJob", uuid.uuid1())
45 def query_job_status(job_id, index_id=-1):
46 # logger.info("Query job status, jobid =[%s], responseid [%d]" % (job_id, index_id))
49 row = JobStatusModel.objects.filter(jobid=job_id).order_by("-indexid").first()
53 [jobs.append(job) for job in JobStatusModel.objects.filter(jobid=job_id).order_by("-indexid")
54 if job.indexid > index_id]
56 # logger.info("Query job status, rows=%s" % str(jobs))
60 def is_job_exists(job_id):
61 jobs = JobModel.objects.filter(jobid=job_id)
65 def create_job(inst_type, jobaction, inst_id, user='', job_id=None, res_name=''):
67 job_id = JobUtil.__gen_job_id(
68 '%s-%s-%s' % (str(inst_type).replace(' ', '_'), str(jobaction).replace(' ', '_'), str(inst_id)))
71 job.jobtype = inst_type
72 job.jobaction = jobaction
73 job.resid = str(inst_id)
74 job.status = JOB_STATUS.PROCESSING
76 job.starttime = datetime.datetime.now().strftime('%Y-%m-%d %X')
78 job.resname = res_name
79 logger.debug("create a new job, jobid=%s, jobtype=%s, jobaction=%s, resid=%s, status=%d" %
80 (job.jobid, job.jobtype, job.jobaction, job.resid, job.status))
85 def clear_job(job_id):
86 [job.delete() for job in JobModel.objects.filter(jobid=job_id)]
87 logger.debug("Clear job, job_id=%s" % job_id)
90 def add_job_status(job_id, progress, status_decs, error_code=""):
91 jobs = JobModel.objects.filter(jobid=job_id)
93 logger.error("Job[%s] is not exists, please create job first." % job_id)
94 raise Exception("Job[%s] is not exists." % job_id)
96 int_progress = int(progress)
97 job_status = JobStatusModel()
98 job_status.indexid = int(idutil.get_auto_id(job_id))
99 job_status.jobid = job_id
100 job_status.status = "processing"
101 job_status.progress = int_progress
103 if job_status.progress == 0:
104 job_status.status = "started"
105 elif job_status.progress == 100:
106 job_status.status = "finished"
107 elif job_status.progress == 101:
108 job_status.status = "partly_finished"
109 elif job_status.progress > 101:
110 job_status.status = "error"
112 if error_code == "255":
113 job_status.status = "error"
115 job_status.descp = status_decs
116 job_status.errcode = error_code if error_code else "0"
117 job_status.addtime = datetime.datetime.now().strftime('%Y-%m-%d %X')
119 logger.debug("Add a new job status, jobid=%s, indexid=%d,"
120 " status=%s, description=%s, progress=%d, errcode=%s, addtime=%r" %
121 (job_status.jobid, job_status.indexid, job_status.status, job_status.descp,
122 job_status.progress, job_status.errcode, job_status.addtime))
125 job.progress = int_progress
126 if job_status.progress >= 100:
127 job.status = JOB_STATUS.FINISH
128 job.endtime = datetime.datetime.now().strftime('%Y-%m-%d %X')
130 logger.debug("update job, jobid=%s, progress=%d" % (job_status.jobid, int_progress))
132 logger.error(traceback.format_exc())
135 def clear_job_status(job_id):
136 [job.delete() for job in JobStatusModel.objects.filter(jobid=job_id)]
137 logger.debug("Clear job status, job_id=%s" % job_id)
140 def get_unfinished_jobs(url_prefix, inst_id, inst_type):
141 jobs = JobModel.objects.filter(resid=inst_id, jobtype=inst_type, status=JOB_STATUS.PROCESSING)
142 progresses = reduce(lambda content, job: content + [url_prefix + "/" + job.jobid], jobs, [])