diff options
author | 2017-09-30 11:00:47 +0800 | |
---|---|---|
committer | 2017-09-30 11:00:47 +0800 | |
commit | 47fd33356d8ae5d709fdb1759a3fcfdb3a8c06a2 (patch) | |
tree | 4386f2b941c73d40b2b7d32728f19ac82514586e /zte/vmanager/driver/interfaces/views.py | |
parent | 910d4b904de77e9be7beb64bebc7b4cf99f97050 (diff) |
Fix vfc-svnfm-ztedriver pep8 issues
Change-Id: Iaa7f1293f036652f9825a40e41b58da0794e85d7
Issue-ID: VFC-478
Signed-off-by: ying.yunlong <ying.yunlong@zte.com.cn>
Diffstat (limited to 'zte/vmanager/driver/interfaces/views.py')
-rw-r--r-- | zte/vmanager/driver/interfaces/views.py | 37 |
1 files changed, 23 insertions, 14 deletions
diff --git a/zte/vmanager/driver/interfaces/views.py b/zte/vmanager/driver/interfaces/views.py index 3f4a4baf..a9a430d2 100644 --- a/zte/vmanager/driver/interfaces/views.py +++ b/zte/vmanager/driver/interfaces/views.py @@ -55,21 +55,25 @@ query_vnfd_url = "api/nslcm/v1/vnfpackage/%s" query_vnfm_url = "api/extsys/v1/vnfms/%s" query_package_url = "api/nslcm/v1/vnfpackage/%s" -#Query vnfm_info from nslcm + +# Query vnfm_info from nslcm def get_vnfminfo_from_nslcm(vnfmid): ret = req_by_msb("api/nslcm/v1/vnfms/%s" % vnfmid, "GET") return ret + # Query vnfm_info from esr def vnfm_get(vnfmid): ret = call_aai("api/aai-esr-server/v1/vnfms/%s" % vnfmid, "GET") return ret + # Query vnfd_info from nslcm def vnfd_get(vnfpackageid): ret = req_by_msb("api/nslcm/v1/vnfpackage/%s" % vnfpackageid, "GET") return ret + # Query vnfpackage_info from nslcm def vnfpackage_get(csarid): ret = req_by_msb("api/nslcm/v1/vnfpackage/%s" % csarid, "GET") @@ -91,7 +95,8 @@ create_vnf_param_mapping = { "additionalParam": ""} create_vnf_resp_mapping = { "VNFInstanceID": "vnfInstanceId", - "JobId": "jobid",} + "JobId": "jobid" +} @api_view(http_method_names=['POST']) @@ -214,7 +219,8 @@ def terminate_vnf(request, *args, **kwargs): vnf_detail_url = "v1/vnfs/%s" vnf_detail_resp_mapping = { - "VNFInstanseStatus": "status",} + "VNFInstanseStatus": "status" +} @api_view(http_method_names=['GET']) @@ -258,7 +264,8 @@ operation_status_resp_map = { "ErrorCode": "errorCode", "ResponseId": "responseId", "ResponseHistoryList": "responseHistoryList", - "ResponseDescriptor": "responseDescriptor",} + "ResponseDescriptor": "responseDescriptor" +} @api_view(http_method_names=['GET']) @@ -366,7 +373,8 @@ notify_param_map = { "VMFlavor": "", "VMNumber": "", "VMIDlist": "", - "VMUUID": "",} + "VMUUID": "" +} @api_view(http_method_names=['POST']) @@ -447,14 +455,14 @@ def scale(request, *args, **kwargs): scale_type = ignorcase_get(request.data, "type") aspect_id = ignorcase_get(request.data, "aspectId") number_of_steps = ignorcase_get(request.data, "numberOfSteps") - extension = ignorcase_get(request.data, "additionalParam") - vnfd_model = ignorcase_get(extension, "vnfdModel") + # extension = ignorcase_get(request.data, "additionalParam") + # vnfd_model = ignorcase_get(extension, "vnfdModel") data = { 'vnfmid': vnfm_id, 'nfvoid': 1, 'scaletype': '0' if scale_type == 'SCALE_OUT' else '1', - 'vmlist': [{'VMNumber':number_of_steps,'VMFlavor':aspect_id}], - 'extension':'' + 'vmlist': [{'VMNumber': number_of_steps, 'VMFlavor': aspect_id}], + 'extension': '' } ''' for vdu_id in get_vdus(vnfd_model, aspect_id): @@ -474,19 +482,20 @@ def scale(request, *args, **kwargs): content=json.JSONEncoder().encode(data)) logger.info("ret=%s", ret) if ret[0] != 0: - return Response(data={'error':'scale error'}, status=ret[2]) + return Response(data={'error': 'scale error'}, status=ret[2]) resp_data = json.JSONDecoder().decode(ret[1]) # jobId = resp_data["jobid"] logger.info("resp_data=%s", resp_data) except Exception as e: - logger.error("Error occurred when scaling VNF") + logger.error("Error occurred when scaling VNF,error:%s", e.message) logger.error(traceback.format_exc()) - return Response(data={'error':'scale expection'}, status='500') + return Response(data={'error': 'scale expection'}, status='500') return Response(data=resp_data, status=ret[2]) nf_healing_url = '/api/v1/nf_m_i/nfs/{vnfInstanceID}/vms/operation' + @api_view(http_method_names=['POST']) def heal(request, *args, **kwargs): logger.info("====heal_vnf===") @@ -519,12 +528,12 @@ def heal(request, *args, **kwargs): # jobId = resp_data["jobid"] logger.info("resp_data=%s", resp_data) except Exception as e: - logger.error("Error occurred when healing VNF") + logger.error("Error occurred when healing VNF,error:%s", e.message) logger.error(traceback.format_exc()) return Response(data={'error': 'heal expection'}, status='500') return Response(data=resp_data, status=ret[2]) -#@staticmethod + def get_vdus(nf_model, aspect_id): associated_group = '' members = [] |