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.
17 from lcm.pub.database.models import NfInstModel, StorageInstModel, VLInstModel, NetworkInstModel, VNFCInstModel, \
19 from lcm.pub.exceptions import NFLCMException
21 logger = logging.getLogger(__name__)
25 def __init__(self, data, instanceid=''):
26 self.vnf_inst_id = instanceid
29 def query_single_vnf(self):
30 vnf_inst = NfInstModel.objects.filter(nfinstid=self.vnf_inst_id)
31 if not vnf_inst.exists():
32 raise NFLCMException('VnfInst(%s) does not exist.' % self.vnf_inst_id)
33 resp_data = self.fill_resp_data(vnf_inst[0])
36 def query_multi_vnf(self):
37 vnf_insts = NfInstModel.objects.all()
39 raise NFLCMException('VnfInsts does not exist.')
41 for vnf_inst in vnf_insts:
42 resp_data.append(self.fill_resp_data(vnf_inst))
45 def fill_resp_data(self, vnf):
46 logger.info('Get storages')
47 storage_inst = StorageInstModel.objects.filter(instid=vnf.nfinstid)
49 for s in storage_inst:
53 "vimConnectionId": s.vimid,
54 "resourceId": s.resourceid
58 logger.info('Get networks')
59 vl_inst = VLInstModel.objects.filter(ownerid=vnf.nfinstid)
62 net = NetworkInstModel.objects.filter(networkid=v.relatednetworkid)
64 raise NFLCMException('NetworkInst(%s) does not exist.' % v.relatednetworkid)
67 "virtualLinkDescId": v.vldid,
69 "vimConnectionId": net[0].vimid,
70 "resourceId": net[0].resourceid
74 logger.info('Get vnfcs')
75 vnfc_insts = VNFCInstModel.objects.filter(instid=vnf.nfinstid)
77 for vnfc in vnfc_insts:
78 vm = VmInstModel.objects.filter(vmid=vnfc.vmid)
80 raise NFLCMException('VmInst(%s) does not exist.' % vnfc.vmid)
81 if vm[0].volume_array:
82 storage = StorageInstModel.objects.filter(resourceid__in=vm[0].volume_array)
86 "id": vnfc.vnfcinstanceid,
89 "vimConnectionId": vm[0].vimid,
90 "resourceId": vm[0].resourceid
92 "storageResourceIds": [s.storageid for s in storage]
94 vnfc_arr.append(vnfc_dic)
95 logger.info('Get vms')
99 "vnfInstanceName": vnf.nf_name,
100 "vnfPkgId": vnf.package_id,
101 "vnfdVersion": vnf.version,
102 "vnfProvider": vnf.vendor,
103 "instantiationState": vnf.status,
104 "instantiatedVnfInfo": {
105 "flavourId": vnf.flavour_id,
106 "vnfState": "STARTED",
109 "extVirtualLinkInfo": [],
110 "monitoringParameters": {},
111 "vnfcResourceInfo": vnfc_arr,
112 "vnfVirtualLinkResourceInfo": vl_arr,
113 "virtualStorageResourceInfo": arr