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.
21 from rest_framework.decorators import api_view
22 from rest_framework.response import Response
24 from driver.pub.utils import restcall
25 from driver.pub.utils.restcall import req_by_msb, call_aai
26 from driver.pub.config.config import VNF_FTP
28 logger = logging.getLogger(__name__)
31 def load_json_file(file_name):
32 json_file = os.path.join(os.path.dirname(__file__), "data/" + file_name)
34 json_data = json.JSONDecoder().decode(f.read())
40 return "=================%s==================" % inspect.stack()[1][3]
43 def ignorcase_get(args, key):
51 if old_key.upper() == key.upper():
56 def mapping_conv(keyword_map, rest_return):
58 for param in keyword_map:
59 if keyword_map[param]:
60 resp_data[keyword_map[param]] = ignorcase_get(rest_return, param)
64 query_vnfd_url = "api/nslcm/v1/vnfpackage/%s"
65 query_vnfm_url = "api/extsys/v1/vnfms/%s"
66 query_package_url = "api/nslcm/v1/vnfpackage/%s"
69 # Query vnfm_info from nslcm
70 def get_vnfminfo_from_nslcm(vnfmid):
71 ret = req_by_msb("api/nslcm/v1/vnfms/%s" % vnfmid, "GET")
75 # Query vnfm_info from esr
77 ret = call_aai("api/aai-esr-server/v1/vnfms/%s" % vnfmid, "GET")
81 # Query vnfd_info from nslcm
82 def vnfd_get(vnfpackageid):
83 ret = req_by_msb("api/nslcm/v1/vnfpackage/%s" % vnfpackageid, "GET")
87 # Query vnfpackage_info from nslcm
88 def vnfpackage_get(csarid):
89 ret = req_by_msb("api/nslcm/v1/vnfpackage/%s" % csarid, "GET")
93 # ==================================================
94 create_vnf_url = "v1/vnfs"
95 create_vnf_param_mapping = {
98 "instantiationLevel": "",
99 "vnfInstanceName": "",
101 "vnfDescriptorId": "",
103 "vnfInstanceDescription": "",
104 "extVirtualLink": "",
105 "additionalParam": ""}
106 create_vnf_resp_mapping = {
107 "VNFInstanceID": "vnfInstanceId",
112 @api_view(http_method_names=['POST'])
113 def instantiate_vnf(request, *args, **kwargs):
115 logger.debug("[%s] request.data=%s", fun_name(), request.data)
116 vnfm_id = ignorcase_get(kwargs, "vnfmid")
117 ret = get_vnfminfo_from_nslcm(vnfm_id)
119 return Response(data={'error': ret[1]}, status=ret[2])
120 vnfm_info = json.JSONDecoder().decode(ret[1])
121 logger.debug("[%s] vnfm_info=%s", fun_name(), vnfm_info)
122 vnf_package_id = ignorcase_get(request.data, "vnfPackageId")
123 ret = vnfd_get(vnf_package_id)
125 return Response(data={'error': ret[1]}, status=ret[2])
126 vnfd_info = json.JSONDecoder().decode(ret[1])
127 logger.debug("[%s] vnfd_info=%s", fun_name(), vnfd_info)
128 csar_id = ignorcase_get(vnfd_info, "csarId")
129 ret = vnfpackage_get(csar_id)
131 return Response(data={'error': ret[1]}, status=ret[2])
132 vnf_package_info = json.JSONDecoder().decode(ret[1])
133 packageInfo = ignorcase_get(vnf_package_info, "packageInfo")
134 logger.debug("[%s] packageInfo=%s", fun_name(), packageInfo)
137 data["VNFMID"] = vnfm_id
138 # vnfdId = ignorcase_get(packageInfo, "vnfdId")
139 vnfdModel = json.loads(ignorcase_get(packageInfo, "vnfdModel"))
140 metadata = ignorcase_get(vnfdModel, "metadata")
141 vnfd_name = ignorcase_get(metadata, "name")
142 # TODO convert sdc vnf package to vnf vender package
145 if "SPGW" in vnfd_name.upper():
146 data["VNFD"] = VNF_FTP + "SPGW"
147 inputs = load_json_file("SPGW" + "_inputs.json")
148 elif "MME" in vnfd_name.upper():
149 data["VNFD"] = VNF_FTP + "MME"
150 inputs = load_json_file("MME" + "_inputs.json")
152 data["VNFD"] = ignorcase_get(packageInfo, "downloadUri")
154 data["VNFURL"] = data["VNFD"]
156 data["extension"] = {}
157 for name, value in ignorcase_get(ignorcase_get(request.data, "additionalParam"), "inputs").items():
158 inputs.append({"name": name, "value": value})
161 "ignorcase_get(request.data, \"additionalParam\") = %s" % ignorcase_get(request.data, "additionalParam"))
162 data["extension"]["inputs"] = json.dumps(inputs)
163 data["extension"]["extVirtualLinks"] = ignorcase_get(
164 ignorcase_get(request.data, "additionalParam"), "extVirtualLinks")
165 data["extension"]["vnfinstancename"] = ignorcase_get(request.data, "vnfInstanceName")
166 data["extension"]["vnfid"] = data["VNFD"]
167 data["extension"]["multivim"] = 0
168 logger.debug("[%s] call_req data=%s", fun_name(), data)
170 ret = restcall.call_req(
171 base_url=ignorcase_get(vnfm_info, "url"),
172 user=ignorcase_get(vnfm_info, "userName"),
173 passwd=ignorcase_get(vnfm_info, "password"),
174 auth_type=restcall.rest_no_auth,
175 resource=create_vnf_url,
177 content=json.JSONEncoder().encode(data))
179 logger.debug("[%s] call_req ret=%s", fun_name(), ret)
181 return Response(data={'error': ret[1]}, status=ret[2])
182 resp = json.JSONDecoder().decode(ret[1])
183 resp_data = mapping_conv(create_vnf_resp_mapping, resp)
184 logger.info("[%s]resp_data=%s", fun_name(), resp_data)
185 except Exception as e:
186 logger.error("Error occurred when instantiating VNF")
188 return Response(data=resp_data, status=ret[2])
191 # ==================================================
192 vnf_delete_url = "v1/vnfs/%s"
193 vnf_delete_param_mapping = {
194 "terminationType": "terminationType",
195 "gracefulTerminationTimeout": "gracefulTerminationTimeout"}
196 vnf_delete_resp_mapping = {
197 "vnfInstanceId": "vnfInstanceId",
201 @api_view(http_method_names=['POST'])
202 def terminate_vnf(request, *args, **kwargs):
204 logger.debug("[%s] request.data=%s", fun_name(), request.data)
205 vnfm_id = ignorcase_get(kwargs, "vnfmid")
206 ret = get_vnfminfo_from_nslcm(vnfm_id)
208 return Response(data={'error': ret[1]}, status=ret[2])
209 vnfm_info = json.JSONDecoder().decode(ret[1])
210 logger.debug("[%s] vnfm_info=%s", fun_name(), vnfm_info)
212 logger.debug("[%s]req_data=%s", fun_name(), data)
213 ret = restcall.call_req(
214 base_url=ignorcase_get(vnfm_info, "url"),
215 user=ignorcase_get(vnfm_info, "userName"),
216 passwd=ignorcase_get(vnfm_info, "password"),
217 auth_type=restcall.rest_no_auth,
218 resource=vnf_delete_url % (ignorcase_get(kwargs, "vnfInstanceID")),
220 content=json.JSONEncoder().encode(data))
222 return Response(data={'error': ret[1]}, status=ret[2])
223 resp = json.JSONDecoder().decode(ret[1])
224 resp_data = mapping_conv(vnf_delete_resp_mapping, resp)
225 logger.debug("[%s]resp_data=%s", fun_name(), resp_data)
226 except Exception as e:
227 logger.error("Error occurred when terminating VNF")
229 return Response(data=resp_data, status=ret[2])
232 # ==================================================
235 vnf_detail_url = "v1/vnfs/%s"
236 vnf_detail_resp_mapping = {
237 "VNFInstanseStatus": "status"
241 @api_view(http_method_names=['GET'])
242 def query_vnf(request, *args, **kwargs):
244 logger.debug("[%s] request.data=%s", fun_name(), request.data)
245 vnfm_id = ignorcase_get(kwargs, "vnfmid")
246 ret = get_vnfminfo_from_nslcm(vnfm_id)
248 return Response(data={'error': ret[1]}, status=ret[2])
249 vnfm_info = json.JSONDecoder().decode(ret[1])
250 logger.debug("[%s] vnfm_info=%s", fun_name(), vnfm_info)
252 ret = restcall.call_req(
253 base_url=ignorcase_get(vnfm_info, "url"),
254 user=ignorcase_get(vnfm_info, "userName"),
255 passwd=ignorcase_get(vnfm_info, "password"),
256 auth_type=restcall.rest_no_auth,
257 resource=vnf_detail_url % (ignorcase_get(kwargs, "vnfInstanceID")),
259 content=json.JSONEncoder().encode(data))
261 return Response(data={'error': ret[1]}, status=ret[2])
262 resp = json.JSONDecoder().decode(ret[1])
263 vnf_status = ignorcase_get(resp, "vnfinstancestatus")
264 resp_data = {"vnfInfo": {"vnfStatus": vnf_status}}
265 logger.debug("[%s]resp_data=%s", fun_name(), resp_data)
266 except Exception as e:
267 logger.error("Error occurred when querying VNF information.")
269 return Response(data=resp_data, status=ret[2])
272 # Get Operation Status
273 operation_status_url = '/v1/jobs/{jobId}?NFVOID={nfvoId}&VNFMID={vnfmId}&ResponseID={responseId}'
274 operation_status_resp_map = {
277 "Progress": "progress",
278 "StatusDescription": "currentStep",
279 "ErrorCode": "errorCode",
280 "ResponseId": "responseId",
281 "ResponseHistoryList": "responseHistoryList",
282 "ResponseDescriptor": "responseDescriptor"
286 @api_view(http_method_names=['GET'])
287 def operation_status(request, *args, **kwargs):
290 logger.debug("[%s] request.data=%s", fun_name(), request.data)
291 vnfm_id = ignorcase_get(kwargs, "vnfmid")
292 ret = get_vnfminfo_from_nslcm(vnfm_id)
294 return Response(data={'error': ret[1]}, status=ret[2])
295 vnfm_info = json.JSONDecoder().decode(ret[1])
296 logger.debug("[%s] vnfm_info=%s", fun_name(), vnfm_info)
297 ret = restcall.call_req(
298 base_url=ignorcase_get(vnfm_info, 'url'),
299 user=ignorcase_get(vnfm_info, 'userName'),
300 passwd=ignorcase_get(vnfm_info, 'password'),
301 auth_type=restcall.rest_no_auth,
302 resource=operation_status_url.format(jobId=ignorcase_get(kwargs, 'jobid'), nfvoId=1,
303 vnfmId=ignorcase_get(kwargs, 'vnfmid'),
304 responseId=ignorcase_get(request.GET, 'responseId')),
306 content=json.JSONEncoder().encode(data))
309 return Response(data={'error': ret[1]}, status=ret[2])
310 resp_data = json.JSONDecoder().decode(ret[1])
311 logger.info("[%s]resp_data=%s", fun_name(), resp_data)
312 except Exception as e:
313 logger.error("Error occurred when getting operation status information.")
315 return Response(data=resp_data, status=ret[2])
318 # Grant VNF Lifecycle Operation
319 grant_vnf_url = 'api/nslcm/v1/ns/grantvnf'
320 grant_vnf_param_map = {
327 "VNFInstanceID": "vnfInstanceId",
328 "OperationRight": "",
334 @api_view(http_method_names=['PUT'])
335 def grantvnf(request, *args, **kwargs):
336 logger.info("=====grantvnf=====")
339 logger.info("req_data = %s", request.data)
340 data = mapping_conv(grant_vnf_param_map, request.data)
341 logger.info("grant_vnf_url = %s", grant_vnf_url)
342 data["vnfDescriptorId"] = ""
343 if ignorcase_get(request.data, "operationright") == 0:
344 data["lifecycleOperation"] = "Instantiate"
345 data["addresource"] = []
346 for vm in ignorcase_get(request.data, "vmlist"):
347 for i in range(int(ignorcase_get(vm, "vmnumber"))):
348 data["addresource"].append(
350 "resourceDefinitionId": i,
351 "vdu": ignorcase_get(vm, "vmflavor"),
352 "vimid": ignorcase_get(vm, "vimid"),
353 "tenant": ignorcase_get(vm, "tenant")
356 data["additionalparam"] = {}
357 data["additionalparam"]["vnfmid"] = ignorcase_get(request.data, "vnfmid")
358 data["additionalparam"]["vimid"] = ignorcase_get(request.data, "vimid")
359 data["additionalparam"]["tenant"] = ignorcase_get(request.data, "tenant")
361 logger.info("data = %s", data)
362 ret = req_by_msb(grant_vnf_url, "POST", content=json.JSONEncoder().encode(data))
363 logger.info("ret = %s", ret)
365 return Response(data={'error': ret[1]}, status=ret[2])
366 resp = json.JSONDecoder().decode(ret[1])
368 resp_data['vimid'] = ignorcase_get(resp['vim'], 'vimid')
369 resp_data['tenant'] = ignorcase_get(ignorcase_get(resp['vim'], 'accessinfo'), 'tenant')
371 logger.info("[%s]resp_data=%s", fun_name(), resp_data)
372 except Exception as e:
373 logger.error("Error occurred in Grant VNF.")
375 return Response(data=resp_data, status=ret[2])
379 notify_url = 'api/nslcm/v1/ns/{vnfmid}/vnfs/{vnfInstanceId}/Notify'
384 "VNFInstanceID": "vnfInstanceId",
386 "EventType": "operation",
395 @api_view(http_method_names=['POST'])
396 def notify(request, *args, **kwargs):
398 logger.info("[%s]req_data = %s", fun_name(), request.data)
399 data = mapping_conv(notify_param_map, request.data)
400 logger.info("[%s]data = %s", fun_name(), data)
402 data["status"] = "result"
403 data["jobId"] = "notMust"
404 data["affectedVnfc"] = []
405 data["affectedVl"] = []
406 data["affectedVirtualStorage"] = []
407 data["affectedCp"] = []
409 extension = ignorcase_get(request.data, "extension")
410 openo_notification = ignorcase_get(extension, "openo_notification")
411 if openo_notification:
412 affectedvnfcs = ignorcase_get(openo_notification, "affectedVnfc")
414 affectedvnfcs = ignorcase_get(ignorcase_get(request.data, "extension"), "affectedvnfc")
416 affectedvls = ignorcase_get(ignorcase_get(request.data, "extension"), "affectedvl")
417 affectedcps = ignorcase_get(ignorcase_get(request.data, "extension"), "affectedcp")
418 vnfdmodule = ignorcase_get(ignorcase_get(request.data, "extension"), "vnfdmodule")
420 data["vnfdmodule"] = vnfdmodule
422 for affectedvnfc in affectedvnfcs:
423 data["affectedVnfc"].append({
424 "vnfcInstanceId": ignorcase_get(affectedvnfc, "vnfcInstanceId"),
425 "vduId": ignorcase_get(affectedvnfc, "vduId"),
426 "changeType": ignorcase_get(affectedvnfc, "changeType"),
427 "vimid": ignorcase_get(ignorcase_get(affectedvnfc, "computeResource"), "vimId"),
428 "vmId": ignorcase_get(ignorcase_get(affectedvnfc, "computeResource"), "resourceId"),
429 "vmName": ignorcase_get(ignorcase_get(affectedvnfc, "computeResource"), "resourceName")
432 for affectedvl in affectedvls:
433 data["affectedVl"].append({
434 "vlInstanceId": ignorcase_get(affectedvl, "virtuallinkinstanceid"),
435 "vimid": ignorcase_get(ignorcase_get(affectedvl, "networkresource"), "vimid"),
436 "vldid": ignorcase_get(affectedvl, "virtuallinkdescid"),
437 "vllid": ignorcase_get(ignorcase_get(affectedvl, "networkresource"), "resourceid"),
438 "vlName": ignorcase_get(ignorcase_get(affectedvl, "networkresource"), "resourcename")
441 for affectedcp in affectedcps:
442 data["affectedCp"].append(affectedcp)
444 # "virtualLinkInstanceId": ignorcase_get(affectedcp, "virtuallinkinstanceid"),
445 # "ownerId": ignorcase_get(affectedcp, "ownerId"),
446 # "ownerType": ignorcase_get(affectedcp, "ownerType")
448 ret = req_by_msb(notify_url.format(vnfmid=ignorcase_get(data, 'VNFMID'),
449 vnfInstanceId=ignorcase_get(data, 'vnfinstanceid')),
450 "POST", content=json.JSONEncoder().encode(data))
452 logger.info("[%s]data = %s", fun_name(), ret)
454 return Response(data={'error': ret[1]}, status=ret[2])
455 except Exception as e:
456 logger.error("Error occurred in LCM notification.")
457 logger.error(traceback.format_exc())
459 return Response(data=None, status=ret[2])
462 nf_scaling_url = '/v1/vnfs/{vnfInstanceID}/scale'
465 @api_view(http_method_names=['POST'])
466 def scale(request, *args, **kwargs):
467 logger.info("====scale_vnf===")
469 logger.info("request.data = %s", request.data)
470 logger.info("requested_url = %s", request.get_full_path())
471 vnfm_id = ignorcase_get(kwargs, "vnfmid")
472 nf_instance_id = ignorcase_get(kwargs, "vnfInstanceId")
473 ret = get_vnfminfo_from_nslcm(vnfm_id)
475 return Response(data={'error': ret[1]}, status=ret[2])
476 vnfm_info = json.JSONDecoder().decode(ret[1])
477 scale_type = ignorcase_get(request.data, "type")
478 aspect_id = ignorcase_get(request.data, "aspectId")
479 number_of_steps = ignorcase_get(request.data, "numberOfSteps")
480 # extension = ignorcase_get(request.data, "additionalParam")
481 # vnfd_model = ignorcase_get(extension, "vnfdModel")
485 'scaletype': '0' if scale_type == 'SCALE_OUT' else '1',
486 'vmlist': [{'VMNumber': number_of_steps, 'VMFlavor': aspect_id}],
490 for vdu_id in get_vdus(vnfd_model, aspect_id):
491 data['vmlist'].append({
493 "VMNumber": number_of_steps
496 logger.info("data = %s", data)
497 ret = restcall.call_req(
498 base_url=ignorcase_get(vnfm_info, "url"),
499 user=ignorcase_get(vnfm_info, "userName"),
500 passwd=ignorcase_get(vnfm_info, "password"),
501 auth_type=restcall.rest_no_auth,
502 resource=nf_scaling_url.format(vnfInstanceID=nf_instance_id),
504 content=json.JSONEncoder().encode(data))
505 logger.info("ret=%s", ret)
507 return Response(data={'error': 'scale error'}, status=ret[2])
508 resp_data = json.JSONDecoder().decode(ret[1])
509 # jobId = resp_data["jobid"]
510 logger.info("resp_data=%s", resp_data)
511 except Exception as e:
512 logger.error("Error occurred when scaling VNF,error:%s", e.message)
513 logger.error(traceback.format_exc())
514 return Response(data={'error': 'scale expection'}, status='500')
515 return Response(data=resp_data, status=ret[2])
518 nf_healing_url = '/api/v1/nf_m_i/nfs/{vnfInstanceID}/vms/operation'
521 @api_view(http_method_names=['POST'])
522 def heal(request, *args, **kwargs):
523 logger.info("====heal_vnf===")
525 logger.info("request.data = %s", request.data)
526 logger.info("requested_url = %s", request.get_full_path())
527 vnfm_id = ignorcase_get(kwargs, "vnfmid")
528 nf_instance_id = ignorcase_get(kwargs, "vnfInstanceId")
529 ret = get_vnfminfo_from_nslcm(vnfm_id)
531 return Response(data={'error': ret[1]}, status=ret[2])
532 vnfm_info = json.JSONDecoder().decode(ret[1])
534 data['action'] = ignorcase_get(request.data, 'action')
535 affectedvm = ignorcase_get(request.data, 'affectedvm')
536 data['affectedvm'] = []
537 if isinstance(affectedvm, list):
538 data['affectedvm'] = affectedvm
540 data['affectedvm'].append(affectedvm)
541 data['lifecycleoperation'] = 'operate'
542 data['isgrace'] = 'force'
544 logger.info("data = %s", data)
545 ret = restcall.call_req(
546 base_url=ignorcase_get(vnfm_info, "url"),
547 user=ignorcase_get(vnfm_info, "userName"),
548 passwd=ignorcase_get(vnfm_info, "password"),
549 auth_type=restcall.rest_no_auth,
550 resource=nf_healing_url.format(vnfInstanceID=nf_instance_id),
552 content=json.JSONEncoder().encode(data))
553 logger.info("ret=%s", ret)
555 return Response(data={'error': 'heal error'}, status=ret[2])
556 resp_data = json.JSONDecoder().decode(ret[1])
557 # jobId = resp_data["jobid"]
558 logger.info("resp_data=%s", resp_data)
559 except Exception as e:
560 logger.error("Error occurred when healing VNF,error:%s", e.message)
561 logger.error(traceback.format_exc())
562 return Response(data={'error': 'heal expection'}, status='500')
563 return Response(data=resp_data, status=ret[2])
566 def get_vdus(nf_model, aspect_id):
567 associated_group = ''
569 vnf_flavours = nf_model['vnf_flavours']
570 for vnf_flaour in vnf_flavours:
571 scaling_aspects = vnf_flaour['scaling_aspects']
572 for aspect in scaling_aspects:
573 if aspect_id == aspect['id']:
574 associated_group = aspect['associated_group']
576 if not associated_group:
577 logger.error('Cannot find the corresponding element group')
578 raise Exception('Cannot find the corresponding element group')
579 for element_group in nf_model['element_groups']:
580 if element_group['group_id'] == associated_group:
581 members = element_group['members']
583 logger.error('Cannot find the corresponding members')
584 raise Exception('Cannot find the corresponding members')
588 @api_view(http_method_names=['GET'])
589 def samples(request, *args, **kwargs):
590 return Response(data={"status": "ok"})