1 # Copyright (C) 2019 ZTE. All Rights Reserved.
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 drf_yasg.utils import swagger_auto_schema
19 from rest_framework import status
20 from rest_framework.response import Response
21 from rest_framework.views import APIView
23 from lcm.nf.serializers.scale_vnf_request import ScaleVnfRequestSerializer
24 from lcm.nf.serializers.response import ProblemDetailsSerializer
25 from lcm.pub.exceptions import NFLCMException, NFLCMExceptionNotFound, NFLCMExceptionConflict
26 from lcm.pub.utils.jobutil import JobUtil
27 from lcm.pub.database.models import NfInstModel
28 from lcm.nf.const import VNF_STATUS
29 from lcm.nf.biz.scale_vnf import ScaleVnf
31 logger = logging.getLogger(__name__)
34 class ScaleVnfView(APIView):
36 request_body=ScaleVnfRequestSerializer(),
38 status.HTTP_202_ACCEPTED: "Success",
39 status.HTTP_404_NOT_FOUND: ProblemDetailsSerializer(),
40 status.HTTP_409_CONFLICT: ProblemDetailsSerializer(),
41 status.HTTP_500_INTERNAL_SERVER_ERROR: "Internal error"
44 def post(self, request, instanceid):
45 logger.debug("ScaleVnf--post::> %s" % request.data)
47 scale_vnf_request_serializer = ScaleVnfRequestSerializer(data=request.data)
48 if not scale_vnf_request_serializer.is_valid():
49 raise NFLCMException(scale_vnf_request_serializer.errors)
51 job_id = JobUtil.create_job('NF', 'SCALE', instanceid)
52 JobUtil.add_job_status(job_id, 0, "SCALE_VNF_READY")
53 self.scale_pre_check(instanceid, job_id)
55 ScaleVnf(scale_vnf_request_serializer.data, instanceid, job_id).start()
57 response = Response(data={"jobId": job_id}, status=status.HTTP_202_ACCEPTED)
59 except NFLCMExceptionNotFound as e:
60 probDetail = ProblemDetailsSerializer(data={"status": status.HTTP_404_NOT_FOUND, "detail": "VNF Instance not found"})
61 resp_isvalid = probDetail.is_valid()
63 raise NFLCMException(probDetail.errors)
64 return Response(data=probDetail.data, status=status.HTTP_404_NOT_FOUND)
65 except NFLCMExceptionConflict as e:
66 probDetail = ProblemDetailsSerializer(data={"status": status.HTTP_409_CONFLICT, "detail": "VNF Instance not in Instantiated State"})
67 resp_isvalid = probDetail.is_valid()
69 raise NFLCMException(probDetail.errors)
70 return Response(data=probDetail.data, status=status.HTTP_409_CONFLICT)
71 except NFLCMException as e:
72 logger.error(e.message)
73 return Response(data={'error': '%s' % e.message}, status=status.HTTP_500_INTERNAL_SERVER_ERROR)
74 except Exception as e:
75 logger.error(e.message)
76 logger.error(traceback.format_exc())
77 return Response(data={'error': 'unexpected exception'}, status=status.HTTP_500_INTERNAL_SERVER_ERROR)
79 def scale_pre_check(self, nf_inst_id, job_id):
80 vnf_insts = NfInstModel.objects.filter(nfinstid=nf_inst_id)
81 if not vnf_insts.exists():
82 raise NFLCMExceptionNotFound("VNF nf_inst_id does not exist.")
84 NfInstModel.objects.filter(nfinstid=nf_inst_id).update(status=VNF_STATUS.SCALING)
85 JobUtil.add_job_status(job_id, 15, 'Nf scaling pre-check finish')
86 logger.info("Nf scaling pre-check finish")