diff options
author | SudhakarReddy <Sudhakar.Reddy@amdocs.com> | 2018-09-06 12:37:26 +0300 |
---|---|---|
committer | SudhakarReddy <Sudhakar.Reddy@amdocs.com> | 2018-09-06 12:54:35 +0300 |
commit | e212f4fcb3d6f7d2853c6a80144f193b6cc266bf (patch) | |
tree | 3c49cb66dea9b1cfee90bb185c8c8969915dca69 /azure/multicloud_azure/middleware.py | |
parent | 98609ecffcaef619e31044ac40b71b4fa8858357 (diff) |
Added V0 Registry API
Change-Id: Iac61b136485ddb06b76d8b701ab51e8e18439e94
Issue-ID: MULTICLOUD-354
Signed-off-by: SudhakarReddy <Sudhakar.Reddy@amdocs.com>
Diffstat (limited to 'azure/multicloud_azure/middleware.py')
-rw-r--r-- | azure/multicloud_azure/middleware.py | 59 |
1 files changed, 59 insertions, 0 deletions
diff --git a/azure/multicloud_azure/middleware.py b/azure/multicloud_azure/middleware.py new file mode 100644 index 0000000..5b99e9a --- /dev/null +++ b/azure/multicloud_azure/middleware.py @@ -0,0 +1,59 @@ +# Copyright (c) 2018 Amdocs +# +# Licensed under the Apache License, Version 2.0 (the "License"); +# you may not use this file except in compliance with the License. +# You may obtain a copy of the License at: +# +# http://www.apache.org/licenses/LICENSE-2.0 +# +# Unless required by applicable law or agreed to in writing, software +# distributed under the License is distributed on an "AS IS" BASIS, +# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + + +import uuid +from onaplogging.mdcContext import MDC +from multicloud_azure.pub.config.config import SERVICE_NAME +from multicloud_azure.pub.config.config import FORWARDED_FOR_FIELDS + + +class LogContextMiddleware(object): + + # the last IP behind multiple proxies, if no exist proxies + # get local host ip. + def _getLastIp(self, request): + + ip = "" + try: + for field in FORWARDED_FOR_FIELDS: + if field in request.META: + if ',' in request.META[field]: + parts = request.META[field].split(',') + ip = parts[-1].strip().split(":")[0] + else: + ip = request.META[field].split(":")[0] + + if ip == "": + ip = request.META.get("HTTP_HOST").split(":")[0] + + except Exception: + pass + + return ip + + def process_request(self, request): + + ReqeustID = request.META.get("HTTP_X_TRANSACTIONID", None) + if ReqeustID is None: + ReqeustID = str(uuid.uuid3(uuid.NAMESPACE_URL, SERVICE_NAME)) + MDC.put("requestID", ReqeustID) + InovocationID = str(uuid.uuid4()) + MDC.put("invocationID", InovocationID) + MDC.put("serviceName", SERVICE_NAME) + MDC.put("serviceIP", self._getLastIp(request)) + return None + + def process_response(self, request, response): + + MDC.clear() + return response |