1 # Copyright 2017 ZTE Corporation.
\r
3 # Licensed under the Apache License, Version 2.0 (the "License");
\r
4 # you may not use this file except in compliance with the License.
\r
5 # You may obtain a copy of the License at
\r
7 # http://www.apache.org/licenses/LICENSE-2.0
\r
9 # Unless required by applicable law or agreed to in writing, software
\r
10 # distributed under the License is distributed on an "AS IS" BASIS,
\r
11 # WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
\r
12 # See the License for the specific language governing permissions and
\r
13 # limitations under the License.
\r
17 from lcm.pub.config.config import AAI_BASE_URL, AAI_USER, AAI_PASSWORD
\r
18 from lcm.pub.exceptions import NFLCMException
\r
19 from lcm.pub.utils.restcall import call_req_aai, rest_no_auth
\r
21 logger = logging.getLogger(__name__)
\r
23 def call_aai(resource, method, data=''):
\r
24 return call_req_aai(AAI_BASE_URL, AAI_USER, AAI_PASSWORD, rest_no_auth, resource, method, data)
\r
26 def create_ns(global_customer_id, service_type, service_instance_id, data):
\r
27 resource = "/business/customers/customer/%s/service-subscriptions/service-subscription/" \
\r
28 "%s/service-instances/service-instance/%s" % \
\r
29 (global_customer_id, service_type, service_instance_id)
\r
30 ret = call_aai(resource, "PUT", data)
\r
31 # ret = call_req_aai(AAI_BASE_URL, AAI_USER, AAI_PASSWORD, rest_no_auth, resource, "PUT", data)
\r
33 logger.error("Status code is %s, detail is %s.", ret[2], ret[1])
\r
34 raise NFLCMException("Ns instance creation exception in AAI")
\r
35 return json.JSONDecoder().decode(ret[1])
\r
37 def delete_ns(global_customer_id, service_type, service_instance_id, data):
\r
38 resource = "/business/customers/customer/%s/service-subscriptions/service-subscription/" \
\r
39 "%s/service-instances/service-instance/%s" % \
\r
40 (global_customer_id, service_type, service_instance_id)
\r
41 ret = call_aai(resource, "DELETE", data)
\r
42 # ret = call_req_aai(AAI_BASE_URL, AAI_USER, AAI_PASSWORD, rest_no_auth, resource, "DELETE", data)
\r
44 logger.error("Status code is %s, detail is %s.", ret[2], ret[1])
\r
45 raise NFLCMException("Ns instance delete exception in AAI")
\r
46 return json.JSONDecoder().decode(ret[1])
\r
48 def query_ns(global_customer_id, service_type, service_instance_id, data):
\r
49 resource = "/business/customers/customer/%s/service-subscriptions/service-subscription/" \
\r
50 "%s/service-instances/service-instance/%s" % \
\r
51 (global_customer_id, service_type, service_instance_id)
\r
52 ret = call_aai(resource, "GET", data)
\r
53 # ret = call_req_aai(AAI_BASE_URL, AAI_USER, AAI_PASSWORD, rest_no_auth, resource, "GET", data)
\r
55 logger.error("Status code is %s, detail is %s.", ret[2], ret[1])
\r
56 raise NFLCMException("Ns instance query exception in AAI")
\r
57 return json.JSONDecoder().decode(ret[1])
\r
60 def create_vnf(vnf_id, data):
\r
61 resource = "/network/generic-vnfs/generic-vnf/%s" % vnf_id
\r
62 ret = call_aai(resource, "PUT", data)
\r
63 # ret = call_req_aai(AAI_BASE_URL, AAI_USER, AAI_PASSWORD, rest_no_auth, resource, "PUT", data)
\r
65 logger.error("Status code is %s, detail is %s.", ret[2], ret[1])
\r
66 raise NFLCMException("Vnf instance creation exception in AAI")
\r
67 return json.JSONDecoder().decode(ret[1])
\r
69 def delete_vnf(vnf_id, data=[]):
\r
70 resource = "/network/generic-vnfs/generic-vnf/%s" % vnf_id
\r
71 ret = call_aai(resource, "DELETE", data)
\r
72 # ret = call_req_aai(AAI_BASE_URL, AAI_USER, AAI_PASSWORD, rest_no_auth, resource, "DELETE", data)
\r
74 logger.error("Status code is %s, detail is %s.", ret[2], ret[1])
\r
75 raise NFLCMException("Vnf instance delete exception in AAI")
\r
76 return json.JSONDecoder().decode(ret[1])
\r
78 def query_vnf(vnf_id, data):
\r
79 resource = "/network/generic-vnfs/generic-vnf/%s" % vnf_id
\r
80 ret = call_aai(resource, "GET", data)
\r
81 # ret = call_req_aai(AAI_BASE_URL, AAI_USER, AAI_PASSWORD, rest_no_auth, resource, "GET", data)
\r
83 logger.error("Status code is %s, detail is %s.", ret[2], ret[1])
\r
84 raise NFLCMException("Vnf instance query exception in AAI")
\r
85 return json.JSONDecoder().decode(ret[1])
\r
88 def create_vserver(cloud_owner, cloud_region_id, tenant_id, vserver_id, data):
\r
89 resource = "/cloud-infrastructure/cloud-regions/cloud-region/%s/" \
\r
90 "%s/tenants/tenant/%s/vservers/vserver/%s" % \
\r
91 (cloud_owner, cloud_region_id, tenant_id, vserver_id)
\r
92 ret = call_aai(resource, "PUT", data)
\r
93 # ret = call_req_aai(AAI_BASE_URL, AAI_USER, AAI_PASSWORD, rest_no_auth, resource, "PUT", data)
\r
95 logger.error("Status code is %s, detail is %s.", ret[2], ret[1])
\r
96 raise NFLCMException("Vserver creation exception in AAI")
\r
97 return json.JSONDecoder().decode(ret[1])
\r
99 def delete_vserver(cloud_owner, cloud_region_id, tenant_id, vserver_id, data):
\r
100 resource = "/cloud-infrastructure/cloud-regions/cloud-region/%s/" \
\r
101 "%s/tenants/tenant/%s/vservers/vserver/%s" % \
\r
102 (cloud_owner, cloud_region_id, tenant_id, vserver_id)
\r
103 ret = call_aai(resource, "DELETE", data)
\r
104 # ret = call_req_aai(AAI_BASE_URL, AAI_USER, AAI_PASSWORD, rest_no_auth, resource, "DELETE", data)
\r
106 logger.error("Status code is %s, detail is %s.", ret[2], ret[1])
\r
107 raise NFLCMException("Vserver delete exception in AAI")
\r
108 return json.JSONDecoder().decode(ret[1])
\r
110 def query_vserver(cloud_owner, cloud_region_id, tenant_id, vserver_id, data):
\r
111 resource = "/cloud-infrastructure/cloud-regions/cloud-region/%s/" \
\r
112 "%s/tenants/tenant/%s/vservers/vserver/%s" % \
\r
113 (cloud_owner, cloud_region_id, tenant_id, vserver_id)
\r
114 ret = call_aai(resource, "GET", data)
\r
115 # ret = call_req_aai(AAI_BASE_URL, AAI_USER, AAI_PASSWORD, rest_no_auth, resource, "GET", data)
\r
117 logger.error("Status code is %s, detail is %s.", ret[2], ret[1])
\r
118 raise NFLCMException("Vserver query exception in AAI")
\r
119 return json.JSONDecoder().decode(ret[1])
\r
122 def put_vserver_relationship(cloud_owner, cloud_region_id, tenant_id, vserver_id, data):
\r
123 resource = "/cloud-infrastructure/cloud-regions/cloud-region/%s/" \
\r
124 "%s/tenants/tenant/%s/vservers/vserver/%s/relationship-list/relationship" % \
\r
125 (cloud_owner, cloud_region_id, tenant_id, vserver_id)
\r
126 ret = call_aai(resource, "PUT", data)
\r
127 # ret = call_req_aai(AAI_BASE_URL, AAI_USER, AAI_PASSWORD, rest_no_auth, resource, "PUT", data)
\r
129 logger.error("Status code is %s, detail is %s.", ret[2], ret[1])
\r
130 raise NFLCMException("Put or update vserver relationship exception in AAI")
\r
131 return json.JSONDecoder().decode(ret[1])
\r
133 def delete_vserver_relationship(cloud_owner, cloud_region_id, tenant_id, vserver_id, data):
\r
134 resource = "/cloud-infrastructure/cloud-regions/cloud-region/%s/" \
\r
135 "%s/tenants/tenant/%s/vservers/vserver/%s/relationship-list/relationship" % \
\r
136 (cloud_owner, cloud_region_id, tenant_id, vserver_id)
\r
137 ret = call_aai(resource, "DELETE", data)
\r
138 # ret = call_req_aai(AAI_BASE_URL, AAI_USER, AAI_PASSWORD, rest_no_auth, resource, "DELETE", data)
\r
140 logger.error("Status code is %s, detail is %s.", ret[2], ret[1])
\r
141 raise NFLCMException("Delete vserver relationship exception in AAI")
\r
142 return json.JSONDecoder().decode(ret[1])
\r
145 def put_vnf_relationship(vnf_id, data):
\r
146 resource = "/network/generic-vnfs/generic-vnf/%s/relationship-list/relationship" % vnf_id
\r
147 ret = call_aai(resource, "PUT", data)
\r
148 # ret = call_req_aai(AAI_BASE_URL, AAI_USER, AAI_PASSWORD, rest_no_auth, resource, "PUT", data)
\r
150 logger.error("Status code is %s, detail is %s.", ret[2], ret[1])
\r
151 raise NFLCMException("Put or update vnf instance relationship exception in AAI")
\r
152 return json.JSONDecoder().decode(ret[1])
\r
154 def delete_vnf_relationship(vnf_id, data):
\r
155 resource = "/network/generic-vnfs/generic-vnf/%s/relationship-list/relationship" % vnf_id
\r
156 ret = call_aai(resource, "DELETE", data)
\r
157 # ret = call_req_aai(AAI_BASE_URL, AAI_USER, AAI_PASSWORD, rest_no_auth, resource, "DELETE", data)
\r
159 logger.error("Status code is %s, detail is %s.", ret[2], ret[1])
\r
160 raise NFLCMException("Delete vnf instance relationship exception in AAI")
\r
161 return json.JSONDecoder().decode(ret[1])
\r
164 def put_ns_relationship(global_customer_id, service_type, service_instance_id, data):
\r
165 resource = "/business/customers/customer/%s/service-subscriptions/service-subscription/" \
\r
166 "%s/service-instances/service-instance/%s/relationship-list/relationship" % \
\r
167 (global_customer_id, service_type, service_instance_id)
\r
168 ret = call_aai(resource, "PUT", data)
\r
169 # ret = call_req_aai(AAI_BASE_URL, AAI_USER, AAI_PASSWORD, rest_no_auth, resource, "PUT", data)
\r
171 logger.error("Status code is %s, detail is %s.", ret[2], ret[1])
\r
172 raise NFLCMException("Put or update ns instance relationship exception in AAI")
\r
173 return json.JSONDecoder().decode(ret[1])
\r
175 def delete_ns_relationship(global_customer_id, service_type, service_instance_id, data):
\r
176 resource = "/business/customers/customer/%s/service-subscriptions/service-subscription/" \
\r
177 "%s/service-instances/service-instance/%s/relationship-list/relationship" % \
\r
178 (global_customer_id, service_type, service_instance_id)
\r
179 ret = call_aai(resource, "DELETE", data)
\r
180 # ret = call_req_aai(AAI_BASE_URL, AAI_USER, AAI_PASSWORD, rest_no_auth, resource, "DELETE", data)
\r
182 logger.error("Status code is %s, detail is %s.", ret[2], ret[1])
\r
183 raise NFLCMException("Delete ns instance relationship exception in AAI")
\r
184 return json.JSONDecoder().decode(ret[1])
\r