summaryrefslogtreecommitdiffstats
path: root/policyhandler/deploy_handler.py
diff options
context:
space:
mode:
Diffstat (limited to 'policyhandler/deploy_handler.py')
-rw-r--r--policyhandler/deploy_handler.py19
1 files changed, 13 insertions, 6 deletions
diff --git a/policyhandler/deploy_handler.py b/policyhandler/deploy_handler.py
index 3d299f3..6d258f2 100644
--- a/policyhandler/deploy_handler.py
+++ b/policyhandler/deploy_handler.py
@@ -150,6 +150,7 @@ class DeployHandler(object):
_url = None
_url_policy = None
_max_msg_length_mb = 10
+ _query = {}
_target_entity = None
_custom_kwargs = None
_server_instance_uuid = None
@@ -186,12 +187,16 @@ class DeployHandler(object):
# "deploy_handler" : {
# "target_entity" : "deployment_handler",
# "url" : "http://deployment_handler:8188",
- # "max_msg_length_mb" : 100
+ # "max_msg_length_mb" : 10,
+ # "query" : {
+ # "cfy_tenant_name" : "default_tenant"
+ # }
# }
DeployHandler._target_entity = config_dh.get("target_entity", "deployment_handler")
DeployHandler._url = config_dh.get("url")
DeployHandler._max_msg_length_mb = config_dh.get("max_msg_length_mb",
DeployHandler._max_msg_length_mb)
+ DeployHandler._query = deepcopy(config_dh.get("query", {}))
DeployHandler._logger.info("dns based routing to %s: url(%s)",
DeployHandler._target_entity, DeployHandler._url)
@@ -256,8 +261,8 @@ class DeployHandler(object):
log_action = "put to {0} at {1}".format(
DeployHandler._target_entity, DeployHandler._url_policy)
- log_data = " msg={0} headers={1}".format(json.dumps(message),
- json.dumps(headers))
+ log_data = " msg={} headers={}, params={}".format(json.dumps(message), json.dumps(headers),
+ json.dumps(DeployHandler._query))
log_line = log_action + log_data
DeployHandler._logger.info(log_line)
metrics.metrics_start(log_line)
@@ -273,7 +278,8 @@ class DeployHandler(object):
res = None
try:
res = DeployHandler._requests_session.put(
- DeployHandler._url_policy, json=message, headers=headers,
+ DeployHandler._url_policy, json=message,
+ headers=headers, params=DeployHandler._query,
**DeployHandler._custom_kwargs
)
except Exception as ex:
@@ -316,7 +322,8 @@ class DeployHandler(object):
headers = {REQUEST_X_ECOMP_REQUESTID : metrics.request_id}
log_action = "get {0}: {1}".format(DeployHandler._target_entity, DeployHandler._url_policy)
- log_data = " headers={}".format(json.dumps(headers))
+ log_data = " headers={}, params={}".format(json.dumps(headers),
+ json.dumps(DeployHandler._query))
log_line = log_action + log_data
DeployHandler._logger.info(log_line)
metrics.metrics_start(log_line)
@@ -332,7 +339,7 @@ class DeployHandler(object):
res = None
try:
res = DeployHandler._requests_session.get(
- DeployHandler._url_policy, headers=headers,
+ DeployHandler._url_policy, headers=headers, params=DeployHandler._query,
**DeployHandler._custom_kwargs
)
except Exception as ex: