'X-FromAppId': 'VFC-CATALOG',
'X-TransactionId': str(uuid.uuid1())
}
-
return restcall.call_req(AAI_BASE_URL,
AAI_USER,
AAI_PASSWD,
if ret[0] != 0:
logger.error("Status code is %s, detail is %s.", ret[2], ret[1])
raise CatalogException("Failed to query vims from extsys.")
-
# convert vim_info_aai to internal vim_info
vims_aai = json.JSONDecoder().decode(ret[1])
vims_aai = ignore_case_get(vims_aai, "cloud-region")
if ret[0] != 0:
logger.error("Status code is %s, detail is %s.", ret[2], ret[1])
raise CatalogException("Failed to query vim(%s) from extsys." % vim_id)
-
# convert vim_info_aai to internal vim_info
vim_info_aai = json.JSONDecoder().decode(ret[1])
vim_info = convert_vim_info(vim_info_aai)
if ret[0] != 0:
logger.error("Failed to query sdn ontroller(%s) from extsys. detail is %s.", sdn_ontroller_id, ret[1])
raise CatalogException("Failed to query sdn ontroller(%s) from extsys." % sdn_ontroller_id)
-
# convert vim_info_aai to internal vim_info
sdnc_info_aai = json.JSONDecoder().decode(ret[1])
sdnc_info = convert_sdnc_info(sdnc_info_aai)
def get_vnfm_by_id(vnfm_inst_id):
- uri = '/external-system/esr-vnfm-list/esr-vnfm/%s?depth=all' % vnfm_inst_id
+ uri = "/external-system/esr-vnfm-list/esr-vnfm/%s?depth=all" % vnfm_inst_id
ret = call_aai(uri, "GET")
if ret[0] > 0:
logger.error('Send get VNFM information request to extsys failed.')
def select_vnfm(vnfm_type, vim_id):
- uri = '/external-system/esr-vnfm-list?depth=all'
+ uri = "/external-system/esr-vnfm-list?depth=all"
ret = call_aai(uri, "GET")
if ret[0] > 0:
logger.error("Failed to call %s: %s", uri, ret[1])
def call_lcm(resource, method, content=''):
return restcall.call_req(base_url=NFVOLCM_BASE_URL,
- user=NFVOLCM_USER,
- passwd=NFVOLCM_PASSWD,
+ user="",
+ passwd="",
auth_type=restcall.rest_no_auth,
resource=resource,
method=method,
content=content)
+
def get_nsInstances(csarid):
ret=call_lcm("/nslcm/v1/ns?nsPackageId=%s"% csarid,"get")
if ret[0] != 0:
raise CatalogException("Failed to query NS Instances(%s) from NSLCM." % csarid)
return json.JSONDecoder().decode(ret[1])
+
def get_vnfInstances(csarid):
ret=call_lcm("/nslcm/v1/vnfs?vnfPackageId=%s"% csarid,"get")
if ret[0] != 0:
raise CatalogException("Failed to query VNF Instances(%s) from NSLCM." % csarid)
return json.JSONDecoder().decode(ret[1])
+
# Mock code because the REST API from nfvolcm to delete ns instance is not implemented
def delete_ns_inst_mock():
return [0,'success']
+
# Mock code because the REST API from nfvolcm to delete nf instance is not implemented
def delete_nf_inst_mock():
return [0,'success']
+
def delete_ns(asset_type):
resource = "/nfvolcm/v1/ns/"
resource = resource.format(assetType=asset_type)
raise CatalogException("Failed to query artifacts(%s) from sdc." % asset_type)
return json.JSONDecoder().decode(ret[1])
+
def getNsInsts_mock():
return [
{
"nsInstanceName": "vnf2"
}]
+
def getNfInsts_mock():
return [
{
{
"vnfInstanceId": 2,
"vnfInstanceName": "vnf2"
- }]
\ No newline at end of file
+ }]