summaryrefslogtreecommitdiffstats
path: root/windriver/titanium_cloud/vesagent/event_domain
diff options
context:
space:
mode:
authorBin Yang <bin.yang@windriver.com>2018-05-15 07:15:12 +0000
committerBin Yang <bin.yang@windriver.com>2018-05-15 07:15:12 +0000
commitf8dd18b31de4ea5d90a3eacb4af2cc2f382aadd8 (patch)
tree884a16a43a8cde12abd2e766148a5f04c88a20ed /windriver/titanium_cloud/vesagent/event_domain
parent1651f1627110c5ad87371c3646fcaf4a1b0a058a (diff)
Resolve tenant name to id and server name to id
Change-Id: I8ba7ca6a7e06ce24c3485a2c719df4c8e31f8b34 Issue-ID: MULTICLOUD-230 Signed-off-by: Bin Yang <bin.yang@windriver.com>
Diffstat (limited to 'windriver/titanium_cloud/vesagent/event_domain')
-rw-r--r--windriver/titanium_cloud/vesagent/event_domain/fault_vm.py42
1 files changed, 39 insertions, 3 deletions
diff --git a/windriver/titanium_cloud/vesagent/event_domain/fault_vm.py b/windriver/titanium_cloud/vesagent/event_domain/fault_vm.py
index b0baac55..314847c0 100644
--- a/windriver/titanium_cloud/vesagent/event_domain/fault_vm.py
+++ b/windriver/titanium_cloud/vesagent/event_domain/fault_vm.py
@@ -18,6 +18,8 @@ import logging
import json
import uuid
+from django.conf import settings
+from common.utils.restcall import _call_req
logger = logging.getLogger(__name__)
@@ -44,11 +46,45 @@ def buildBacklog_fault_vm(vimid, backlog_input):
return None
# get token
- #TBD resolve tenant_name to tenant_id
+ # resolve tenant_name to tenant_id
+ auth_api_url_format = "/{f_vim_id}/identity/v2.0/tokens"
+ auth_api_url = auth_api_url_format.format(f_vim_id=vimid)
+ auth_api_data = { "auth":{"tenantName": tenant_name} }
+ base_url = settings.MULTICLOUD_PREFIX
+ extra_headers = ''
+ ret = _call_req(base_url, "", "", 0, auth_api_url, "POST", extra_headers, json.dumps(auth_api_data))
+ if ret[0] > 0 or ret[1] is None:
+ logger.critical("call url %s failed with status %s" % (auth_api_url, ret[0]))
+ return None
+
+ token_resp = json.JSONDecoder().decode(ret[1])
+ token = token_resp["access"]["token"]["id"]
+ tenant_id = token_resp["access"]["token"]["tenant"]["id"]
if server_id is None:
- #TBD resolve server_name to server_id
- pass
+ # resolve server_name to server_id
+ vserver_api_url_format \
+ = "/{f_vim_id}/compute/v2.1/{f_tenant_id}/servers?name={f_server_name}"
+ vserver_api_url = vserver_api_url_format.format(f_vim_id=vimid,
+ f_tenant_id=tenant_id,
+ f_server_name=server_name)
+ base_url = settings.MULTICLOUD_PREFIX
+ extra_headers = {'X-Auth-Token': token}
+ ret = _call_req(base_url, "", "", 0, vserver_api_url, "GET", extra_headers, "")
+ if ret[0] > 0 or ret[1] is None:
+ logger.critical("call url %s failed with status %s" % (vserver_api_url, ret[0]))
+ return None
+
+ server_resp = json.JSONDecoder().decode(ret[1])
+ # find out the server wanted
+ for s in server_resp.get("servers", []):
+ if s["name"] == server_name:
+ server_id = s["id"]
+ break
+ if server_id is None:
+ logger.warn("source %s cannot be found under tenant id %s "
+ % (server_name, tenant_id))
+ return None
#m.c. proxied OpenStack API
api_url_fmt = "/{f_vim_id}/compute/v2.1/{f_tenant_id}/servers/{f_server_id}"