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
27 logger = logging.getLogger(__name__)
30 def load_json_file(file_name):
31 json_file = os.path.join(os.path.dirname(__file__), "data/" + file_name)
33 json_data = json.JSONDecoder().decode(f.read())
39 return "=================%s==================" % inspect.stack()[1][3]
42 def ignorcase_get(args, key):
50 if old_key.upper() == key.upper():
55 def mapping_conv(keyword_map, rest_return):
57 for param in keyword_map:
58 if keyword_map[param]:
59 resp_data[keyword_map[param]] = ignorcase_get(rest_return, param)
63 query_vnfd_url = "api/nslcm/v1/vnfpackage/%s"
64 query_vnfm_url = "api/extsys/v1/vnfms/%s"
65 query_package_url = "api/nslcm/v1/vnfpackage/%s"
68 # Query vnfm_info from nslcm
69 def get_vnfminfo_from_nslcm(vnfmid):
70 ret = req_by_msb("api/nslcm/v1/vnfms/%s" % vnfmid, "GET")
74 # Query vnfm_info from esr
76 ret = call_aai("api/aai-esr-server/v1/vnfms/%s" % vnfmid, "GET")
80 # Query vnfd_info from nslcm
81 def vnfd_get(vnfpackageid):
82 ret = req_by_msb("api/nslcm/v1/vnfpackage/%s" % vnfpackageid, "GET")
86 # Query vnfpackage_info from nslcm
87 def vnfpackage_get(csarid):
88 ret = req_by_msb("api/nslcm/v1/vnfpackage/%s" % csarid, "GET")
92 # ==================================================
93 create_vnf_url = "v1/vnfs"
94 create_vnf_param_mapping = {
97 "instantiationLevel": "",
98 "vnfInstanceName": "",
100 "vnfDescriptorId": "",
102 "vnfInstanceDescription": "",
103 "extVirtualLink": "",
104 "additionalParam": ""}
105 create_vnf_resp_mapping = {
106 "VNFInstanceID": "vnfInstanceId",
111 @api_view(http_method_names=['POST'])
112 def instantiate_vnf(request, *args, **kwargs):
114 logger.debug("[%s] request.data=%s", fun_name(), request.data)
115 vnfm_id = ignorcase_get(kwargs, "vnfmid")
116 ret = get_vnfminfo_from_nslcm(vnfm_id)
118 return Response(data={'error': ret[1]}, status=ret[2])
119 vnfm_info = json.JSONDecoder().decode(ret[1])
120 logger.debug("[%s] vnfm_info=%s", fun_name(), vnfm_info)
121 vnf_package_id = ignorcase_get(request.data, "vnfPackageId")
122 ret = vnfd_get(vnf_package_id)
124 return Response(data={'error': ret[1]}, status=ret[2])
125 vnfd_info = json.JSONDecoder().decode(ret[1])
126 logger.debug("[%s] vnfd_info=%s", fun_name(), vnfd_info)
127 csar_id = ignorcase_get(vnfd_info, "csarId")
128 ret = vnfpackage_get(csar_id)
130 return Response(data={'error': ret[1]}, status=ret[2])
131 vnf_package_info = json.JSONDecoder().decode(ret[1])
132 packageInfo = ignorcase_get(vnf_package_info, "packageInfo")
133 logger.debug("[%s] packageInfo=%s", fun_name(), packageInfo)
136 data["VNFMID"] = vnfm_id
137 # vnfdId = ignorcase_get(packageInfo, "vnfdId")
138 vnfdModel = json.loads(ignorcase_get(packageInfo, "vnfdModel"))
139 metadata = ignorcase_get(vnfdModel, "metadata")
140 vnfd_name = ignorcase_get(metadata, "name")
141 # TODO convert sdc vnf package to vnf vender package
142 from urlparse import urlparse
143 vnfm_ip = urlparse(ignorcase_get(vnfm_info, "url")).netloc.split(':')[0]
146 if "SPGW" in vnfd_name.upper():
147 data["VNFD"] = "ftp://VMVNFM:Vnfm_1g3T@" + vnfm_ip + ":21/" + "SPGW"
148 data["VNFURL"] = "ftp://VMVNFM:Vnfm_1g3T@" + vnfm_ip + ":21/" + "SPGW"
149 inputs = load_json_file("SPGW" + "_inputs.json")
150 elif "MME" in vnfd_name.upper():
151 data["VNFD"] = "ftp://VMVNFM:Vnfm_1g3T@" + vnfm_ip + ":21/" + "MME"
152 data["VNFURL"] = "ftp://VMVNFM:Vnfm_1g3T@" + vnfm_ip + ":21/" + "MME"
153 inputs = load_json_file("MME" + "_inputs.json")
155 data["VNFD"] = ignorcase_get(packageInfo, "downloadUri")
156 data["VNFURL"] = ignorcase_get(packageInfo, "downloadUri")
158 data["extension"] = {}
159 for name, value in ignorcase_get(ignorcase_get(request.data, "additionalParam"), "inputs").items():
160 inputs.append({"name": name, "value": value})
163 "ignorcase_get(request.data, \"additionalParam\") = %s" % ignorcase_get(request.data, "additionalParam"))
164 data["extension"]["inputs"] = json.dumps(inputs)
165 data["extension"]["extVirtualLinks"] = ignorcase_get(
166 ignorcase_get(request.data, "additionalParam"), "extVirtualLinks")
167 data["extension"]["vnfinstancename"] = ignorcase_get(request.data, "vnfInstanceName")
168 data["extension"]["vnfid"] = data["VNFD"]
169 data["extension"]["multivim"] = 0
170 logger.debug("[%s] call_req data=%s", fun_name(), data)
172 ret = restcall.call_req(
173 base_url=ignorcase_get(vnfm_info, "url"),
174 user=ignorcase_get(vnfm_info, "userName"),
175 passwd=ignorcase_get(vnfm_info, "password"),
176 auth_type=restcall.rest_no_auth,
177 resource=create_vnf_url,
179 content=json.JSONEncoder().encode(data))
181 logger.debug("[%s] call_req ret=%s", fun_name(), ret)
183 return Response(data={'error': ret[1]}, status=ret[2])
184 resp = json.JSONDecoder().decode(ret[1])
185 resp_data = mapping_conv(create_vnf_resp_mapping, resp)
186 logger.info("[%s]resp_data=%s", fun_name(), resp_data)
187 except Exception as e:
188 logger.error("Error occurred when instantiating VNF")
190 return Response(data=resp_data, status=ret[2])
193 # ==================================================
194 vnf_delete_url = "v1/vnfs/%s"
195 vnf_delete_param_mapping = {
196 "terminationType": "terminationType",
197 "gracefulTerminationTimeout": "gracefulTerminationTimeout"}
198 vnf_delete_resp_mapping = {
199 "vnfInstanceId": "vnfInstanceId",
203 @api_view(http_method_names=['POST'])
204 def terminate_vnf(request, *args, **kwargs):
206 logger.debug("[%s] request.data=%s", fun_name(), request.data)
207 vnfm_id = ignorcase_get(kwargs, "vnfmid")
208 ret = get_vnfminfo_from_nslcm(vnfm_id)
210 return Response(data={'error': ret[1]}, status=ret[2])
211 vnfm_info = json.JSONDecoder().decode(ret[1])
212 logger.debug("[%s] vnfm_info=%s", fun_name(), vnfm_info)
214 logger.debug("[%s]req_data=%s", fun_name(), data)
215 ret = restcall.call_req(
216 base_url=ignorcase_get(vnfm_info, "url"),
217 user=ignorcase_get(vnfm_info, "userName"),
218 passwd=ignorcase_get(vnfm_info, "password"),
219 auth_type=restcall.rest_no_auth,
220 resource=vnf_delete_url % (ignorcase_get(kwargs, "vnfInstanceID")),
222 content=json.JSONEncoder().encode(data))
224 return Response(data={'error': ret[1]}, status=ret[2])
225 resp = json.JSONDecoder().decode(ret[1])
226 resp_data = mapping_conv(vnf_delete_resp_mapping, resp)
227 logger.debug("[%s]resp_data=%s", fun_name(), resp_data)
228 except Exception as e:
229 logger.error("Error occurred when terminating VNF")
231 return Response(data=resp_data, status=ret[2])
234 # ==================================================
237 vnf_detail_url = "v1/vnfs/%s"
238 vnf_detail_resp_mapping = {
239 "VNFInstanseStatus": "status"
243 @api_view(http_method_names=['GET'])
244 def query_vnf(request, *args, **kwargs):
246 logger.debug("[%s] request.data=%s", fun_name(), request.data)
247 vnfm_id = ignorcase_get(kwargs, "vnfmid")
248 ret = get_vnfminfo_from_nslcm(vnfm_id)
250 return Response(data={'error': ret[1]}, status=ret[2])
251 vnfm_info = json.JSONDecoder().decode(ret[1])
252 logger.debug("[%s] vnfm_info=%s", fun_name(), vnfm_info)
254 ret = restcall.call_req(
255 base_url=ignorcase_get(vnfm_info, "url"),
256 user=ignorcase_get(vnfm_info, "userName"),
257 passwd=ignorcase_get(vnfm_info, "password"),
258 auth_type=restcall.rest_no_auth,
259 resource=vnf_detail_url % (ignorcase_get(kwargs, "vnfInstanceID")),
261 content=json.JSONEncoder().encode(data))
263 return Response(data={'error': ret[1]}, status=ret[2])
264 resp = json.JSONDecoder().decode(ret[1])
265 vnf_status = ignorcase_get(resp, "vnfinstancestatus")
266 resp_data = {"vnfInfo": {"vnfStatus": vnf_status}}
267 logger.debug("[%s]resp_data=%s", fun_name(), resp_data)
268 except Exception as e:
269 logger.error("Error occurred when querying VNF information.")
271 return Response(data=resp_data, status=ret[2])
274 # Get Operation Status
275 operation_status_url = '/v1/jobs/{jobId}?NFVOID={nfvoId}&VNFMID={vnfmId}&ResponseID={responseId}'
276 operation_status_resp_map = {
279 "Progress": "progress",
280 "StatusDescription": "currentStep",
281 "ErrorCode": "errorCode",
282 "ResponseId": "responseId",
283 "ResponseHistoryList": "responseHistoryList",
284 "ResponseDescriptor": "responseDescriptor"
288 @api_view(http_method_names=['GET'])
289 def operation_status(request, *args, **kwargs):
292 logger.debug("[%s] request.data=%s", fun_name(), request.data)
293 vnfm_id = ignorcase_get(kwargs, "vnfmid")
294 ret = get_vnfminfo_from_nslcm(vnfm_id)
296 return Response(data={'error': ret[1]}, status=ret[2])
297 vnfm_info = json.JSONDecoder().decode(ret[1])
298 logger.debug("[%s] vnfm_info=%s", fun_name(), vnfm_info)
299 ret = restcall.call_req(
300 base_url=ignorcase_get(vnfm_info, 'url'),
301 user=ignorcase_get(vnfm_info, 'userName'),
302 passwd=ignorcase_get(vnfm_info, 'password'),
303 auth_type=restcall.rest_no_auth,
304 resource=operation_status_url.format(jobId=ignorcase_get(kwargs, 'jobid'), nfvoId=1,
305 vnfmId=ignorcase_get(kwargs, 'vnfmid'),
306 responseId=ignorcase_get(request.GET, 'responseId')),
308 content=json.JSONEncoder().encode(data))
311 return Response(data={'error': ret[1]}, status=ret[2])
312 resp_data = json.JSONDecoder().decode(ret[1])
313 logger.info("[%s]resp_data=%s", fun_name(), resp_data)
314 except Exception as e:
315 logger.error("Error occurred when getting operation status information.")
317 return Response(data=resp_data, status=ret[2])
320 # Grant VNF Lifecycle Operation
321 grant_vnf_url = 'api/nslcm/v1/ns/grantvnf'
322 grant_vnf_param_map = {
329 "VNFInstanceID": "vnfInstanceId",
330 "OperationRight": "",
336 @api_view(http_method_names=['PUT'])
337 def grantvnf(request, *args, **kwargs):
338 logger.info("=====grantvnf=====")
341 logger.info("req_data = %s", request.data)
342 data = mapping_conv(grant_vnf_param_map, request.data)
343 logger.info("grant_vnf_url = %s", grant_vnf_url)
344 data["vnfDescriptorId"] = ""
345 if ignorcase_get(request.data, "operationright") == 0:
346 data["lifecycleOperation"] = "Instantiate"
347 data["addresource"] = []
348 for vm in ignorcase_get(request.data, "vmlist"):
349 for i in range(int(ignorcase_get(vm, "vmnumber"))):
350 data["addresource"].append(
352 "resourceDefinitionId": i,
353 "vdu": ignorcase_get(vm, "vmflavor"),
354 "vimid": ignorcase_get(vm, "vimid"),
355 "tenant": ignorcase_get(vm, "tenant")
358 data["additionalparam"] = {}
359 data["additionalparam"]["vnfmid"] = ignorcase_get(request.data, "vnfmid")
360 data["additionalparam"]["vimid"] = ignorcase_get(request.data, "vimid")
361 data["additionalparam"]["tenant"] = ignorcase_get(request.data, "tenant")
363 logger.info("data = %s", data)
364 ret = req_by_msb(grant_vnf_url, "POST", content=json.JSONEncoder().encode(data))
365 logger.info("ret = %s", ret)
367 return Response(data={'error': ret[1]}, status=ret[2])
368 resp = json.JSONDecoder().decode(ret[1])
370 resp_data['vimid'] = ignorcase_get(resp['vim'], 'vimid')
371 resp_data['tenant'] = ignorcase_get(ignorcase_get(resp['vim'], 'accessinfo'), 'tenant')
373 logger.info("[%s]resp_data=%s", fun_name(), resp_data)
374 except Exception as e:
375 logger.error("Error occurred in Grant VNF.")
377 return Response(data=resp_data, status=ret[2])
381 notify_url = 'api/nslcm/v1/ns/{vnfmid}/vnfs/{vnfInstanceId}/Notify'
386 "VNFInstanceID": "vnfInstanceId",
388 "EventType": "operation",
397 @api_view(http_method_names=['POST'])
398 def notify(request, *args, **kwargs):
400 logger.info("[%s]req_data = %s", fun_name(), request.data)
401 data = mapping_conv(notify_param_map, request.data)
402 logger.info("[%s]data = %s", fun_name(), data)
404 data["status"] = "result"
405 data["jobId"] = "notMust"
406 data["affectedVnfc"] = []
407 data["affectedVl"] = []
408 data["affectedVirtualStorage"] = []
409 data["affectedCp"] = []
411 affectedvnfcs = ignorcase_get(ignorcase_get(request.data, "extension"), "affectedvnfc")
412 affectedvls = ignorcase_get(ignorcase_get(request.data, "extension"), "affectedvl")
413 affectedcps = ignorcase_get(ignorcase_get(request.data, "extension"), "affectedcp")
414 vnfdmodule = ignorcase_get(ignorcase_get(request.data, "extension"), "vnfdmodule")
416 data["vnfdmodule"] = vnfdmodule
418 for affectedvnfc in affectedvnfcs:
419 data["affectedVnfc"].append({
420 "vnfcInstanceId": ignorcase_get(affectedvnfc, "vnfcinstanceid"),
421 "vduId": ignorcase_get(affectedvnfc, "vduId"),
422 "changeType": ignorcase_get(affectedvnfc, "changeType"),
423 "vimid": ignorcase_get(ignorcase_get(affectedvnfc, "computeresource"), "vimid"),
424 "vmId": ignorcase_get(ignorcase_get(affectedvnfc, "computeresource"), "resourceid"),
425 "vmName": ignorcase_get(ignorcase_get(affectedvnfc, "computeresource"), "resourcename")
428 for affectedvl in affectedvls:
429 data["affectedVl"].append({
430 "vlInstanceId": ignorcase_get(affectedvl, "virtuallinkinstanceid"),
431 "vimid": ignorcase_get(ignorcase_get(affectedvl, "networkresource"), "vimid"),
432 "vldid": ignorcase_get(affectedvl, "virtuallinkdescid"),
433 "vllid": ignorcase_get(ignorcase_get(affectedvl, "networkresource"), "resourceid"),
434 "vlName": ignorcase_get(ignorcase_get(affectedvl, "networkresource"), "resourcename")
437 for affectedcp in affectedcps:
438 data["affectedCp"].append(affectedcp)
440 # "virtualLinkInstanceId": ignorcase_get(affectedcp, "virtuallinkinstanceid"),
441 # "ownerId": ignorcase_get(affectedcp, "ownerId"),
442 # "ownerType": ignorcase_get(affectedcp, "ownerType")
444 ret = req_by_msb(notify_url.format(vnfmid=ignorcase_get(data, 'VNFMID'),
445 vnfInstanceId=ignorcase_get(data, 'vnfinstanceid')),
446 "POST", content=json.JSONEncoder().encode(data))
448 logger.info("[%s]data = %s", fun_name(), ret)
450 return Response(data={'error': ret[1]}, status=ret[2])
451 except Exception as e:
452 logger.error("Error occurred in LCM notification.")
454 return Response(data=None, status=ret[2])
457 nf_scaling_url = '/v1/vnfs/{vnfInstanceID}/scale'
460 @api_view(http_method_names=['POST'])
461 def scale(request, *args, **kwargs):
462 logger.info("====scale_vnf===")
464 logger.info("request.data = %s", request.data)
465 logger.info("requested_url = %s", request.get_full_path())
466 vnfm_id = ignorcase_get(kwargs, "vnfmid")
467 nf_instance_id = ignorcase_get(kwargs, "vnfInstanceId")
468 ret = get_vnfminfo_from_nslcm(vnfm_id)
470 return Response(data={'error': ret[1]}, status=ret[2])
471 vnfm_info = json.JSONDecoder().decode(ret[1])
472 scale_type = ignorcase_get(request.data, "type")
473 aspect_id = ignorcase_get(request.data, "aspectId")
474 number_of_steps = ignorcase_get(request.data, "numberOfSteps")
475 # extension = ignorcase_get(request.data, "additionalParam")
476 # vnfd_model = ignorcase_get(extension, "vnfdModel")
480 'scaletype': '0' if scale_type == 'SCALE_OUT' else '1',
481 'vmlist': [{'VMNumber': number_of_steps, 'VMFlavor': aspect_id}],
485 for vdu_id in get_vdus(vnfd_model, aspect_id):
486 data['vmlist'].append({
488 "VMNumber": number_of_steps
491 logger.info("data = %s", data)
492 ret = restcall.call_req(
493 base_url=ignorcase_get(vnfm_info, "url"),
494 user=ignorcase_get(vnfm_info, "userName"),
495 passwd=ignorcase_get(vnfm_info, "password"),
496 auth_type=restcall.rest_no_auth,
497 resource=nf_scaling_url.format(vnfInstanceID=nf_instance_id),
499 content=json.JSONEncoder().encode(data))
500 logger.info("ret=%s", ret)
502 return Response(data={'error': 'scale error'}, status=ret[2])
503 resp_data = json.JSONDecoder().decode(ret[1])
504 # jobId = resp_data["jobid"]
505 logger.info("resp_data=%s", resp_data)
506 except Exception as e:
507 logger.error("Error occurred when scaling VNF,error:%s", e.message)
508 logger.error(traceback.format_exc())
509 return Response(data={'error': 'scale expection'}, status='500')
510 return Response(data=resp_data, status=ret[2])
513 nf_healing_url = '/api/v1/nf_m_i/nfs/{vnfInstanceID}/vms/operation'
516 @api_view(http_method_names=['POST'])
517 def heal(request, *args, **kwargs):
518 logger.info("====heal_vnf===")
520 logger.info("request.data = %s", request.data)
521 logger.info("requested_url = %s", request.get_full_path())
522 vnfm_id = ignorcase_get(kwargs, "vnfmid")
523 nf_instance_id = ignorcase_get(kwargs, "vnfInstanceId")
524 ret = get_vnfminfo_from_nslcm(vnfm_id)
526 return Response(data={'error': ret[1]}, status=ret[2])
527 vnfm_info = json.JSONDecoder().decode(ret[1])
529 data['lifecycleoperation'] = 'operate'
530 data['isgrace'] = 'force'
532 logger.info("data = %s", data)
533 ret = restcall.call_req(
534 base_url=ignorcase_get(vnfm_info, "url"),
535 user=ignorcase_get(vnfm_info, "userName"),
536 passwd=ignorcase_get(vnfm_info, "password"),
537 auth_type=restcall.rest_no_auth,
538 resource=nf_healing_url.format(vnfInstanceID=nf_instance_id),
540 content=json.JSONEncoder().encode(data))
541 logger.info("ret=%s", ret)
543 return Response(data={'error': 'heal error'}, status=ret[2])
544 resp_data = json.JSONDecoder().decode(ret[1])
545 # jobId = resp_data["jobid"]
546 logger.info("resp_data=%s", resp_data)
547 except Exception as e:
548 logger.error("Error occurred when healing VNF,error:%s", e.message)
549 logger.error(traceback.format_exc())
550 return Response(data={'error': 'heal expection'}, status='500')
551 return Response(data=resp_data, status=ret[2])
554 def get_vdus(nf_model, aspect_id):
555 associated_group = ''
557 vnf_flavours = nf_model['vnf_flavours']
558 for vnf_flaour in vnf_flavours:
559 scaling_aspects = vnf_flaour['scaling_aspects']
560 for aspect in scaling_aspects:
561 if aspect_id == aspect['id']:
562 associated_group = aspect['associated_group']
564 if not associated_group:
565 logger.error('Cannot find the corresponding element group')
566 raise Exception('Cannot find the corresponding element group')
567 for element_group in nf_model['element_groups']:
568 if element_group['group_id'] == associated_group:
569 members = element_group['members']
571 logger.error('Cannot find the corresponding members')
572 raise Exception('Cannot find the corresponding members')
576 @api_view(http_method_names=['GET'])
577 def samples(request, *args, **kwargs):
578 return Response(data={"status": "ok"})