1 # Copyright 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.
18 from functools import reduce
20 from catalog.pub.database.models import JobStatusModel, JobModel
21 from catalog.pub.utils import idutil
23 logger = logging.getLogger(__name__)
27 return type('Enum', (), enums)
30 JOB_STATUS = enum(PROCESSING=0, FINISH=1)
31 JOB_MODEL_STATUS = enum(STARTED='started', PROCESSING='processing', FINISHED='finished', ERROR='error',
33 JOB_TYPE = enum(CREATE_VNF="create vnf", TERMINATE_VNF="terminate vnf", GRANT_VNF="grant vnf", MANUAL_SCALE_VNF="manual scale vnf",
37 class JobUtil(object):
42 def __gen_job_id(job_name):
43 return "%s-%s" % (job_name if job_name else "UnknownJob", uuid.uuid1())
46 def query_job_status(job_id, index_id=-1):
47 # logger.info("Query job status, jobid =[%s], responseid [%d]" % (job_id, index_id))
50 row = JobStatusModel.objects.filter(jobid=job_id).order_by("-indexid").first()
54 [jobs.append(job) for job in JobStatusModel.objects.filter(jobid=job_id).order_by("-indexid")
55 if job.indexid > index_id]
57 # logger.info("Query job status, rows=%s" % str(jobs))
61 def is_job_exists(job_id):
62 jobs = JobModel.objects.filter(jobid=job_id)
66 def create_job(inst_type, jobaction, inst_id, user='', job_id=None, res_name=''):
68 job_id = JobUtil.__gen_job_id(
69 '%s-%s-%s' % (str(inst_type).replace(' ', '_'), str(jobaction).replace(' ', '_'), str(inst_id)))
72 job.jobtype = inst_type
73 job.jobaction = jobaction
74 job.resid = str(inst_id)
75 job.status = JOB_STATUS.PROCESSING
77 job.starttime = datetime.datetime.now().strftime('%Y-%m-%d %X')
79 job.resname = res_name
80 logger.debug("create a new job, jobid=%s, jobtype=%s, jobaction=%s, resid=%s, status=%d" %
81 (job.jobid, job.jobtype, job.jobaction, job.resid, job.status))
86 def clear_job(job_id):
87 [job.delete() for job in JobModel.objects.filter(jobid=job_id)]
88 logger.debug("Clear job, job_id=%s" % job_id)
91 def add_job_status(job_id, progress, status_decs, error_code=""):
92 jobs = JobModel.objects.filter(jobid=job_id)
94 logger.error("Job[%s] is not exists, please create job first." % job_id)
95 raise Exception("Job[%s] is not exists." % job_id)
97 int_progress = int(progress)
98 job_status = JobStatusModel()
99 job_status.indexid = int(idutil.get_auto_id(job_id))
100 job_status.jobid = job_id
101 job_status.status = "processing"
102 job_status.progress = int_progress
104 if job_status.progress == 0:
105 job_status.status = "started"
106 elif job_status.progress == 100:
107 job_status.status = "finished"
108 elif job_status.progress == 101:
109 job_status.status = "partly_finished"
110 elif job_status.progress > 101:
111 job_status.status = "error"
113 if error_code == "255":
114 job_status.status = "error"
116 job_status.descp = status_decs
117 # job_status.errcode = error_code
118 job_status.errcode = error_code if error_code else "0"
119 job_status.addtime = datetime.datetime.now().strftime('%Y-%m-%d %X')
121 logger.debug("Add a new job status, jobid=%s, indexid=%d,"
122 " status=%s, description=%s, progress=%d, errcode=%s, addtime=%r" %
123 (job_status.jobid, job_status.indexid, job_status.status, job_status.descp,
124 job_status.progress, job_status.errcode, job_status.addtime))
127 job.progress = int_progress
128 if job_status.progress >= 100:
129 job.status = JOB_STATUS.FINISH
130 job.endtime = datetime.datetime.now().strftime('%Y-%m-%d %X')
132 logger.debug("update job, jobid=%s, progress=%d" % (job_status.jobid, int_progress))
134 logger.error(traceback.format_exc())
137 def clear_job_status(job_id):
138 [job.delete() for job in JobStatusModel.objects.filter(jobid=job_id)]
139 logger.debug("Clear job status, job_id=%s" % job_id)
142 def get_unfinished_jobs(url_prefix, inst_id, inst_type):
143 jobs = JobModel.objects.filter(resid=inst_id, jobtype=inst_type, status=JOB_STATUS.PROCESSING)
144 progresses = reduce(lambda content, job: content + [url_prefix + "/" + job.jobid], jobs, [])