Skip to content

H
http-request-component
Commit 956c664c authored by dasharatha.vamshi's avatar dasharatha.vamshi
Browse files
Options

init

parent 98735ef5
Hide whitespace changes
Inline Side-by-side
Showing with 63 additions and 8 deletions
logs/HttpRequestComponent.log
View file @ 956c664c
...@@ -47,3 +47,40 @@ ...@@ -47,3 +47,40 @@
2021-02-19 19:00:00,782 INFO HttpRequestComponent Parsing user requests 2021-02-19 19:00:00,782 INFO HttpRequestComponent Parsing user requests
2021-02-19 19:00:02,815 INFO HttpRequestComponent Receiving data... 2021-02-19 19:00:02,815 INFO HttpRequestComponent Receiving data...
2021-02-19 19:00:02,815 INFO HttpRequestComponent Writing data to response.json file 2021-02-19 19:00:02,815 INFO HttpRequestComponent Writing data to response.json file
2021-02-19 19:31:21,256 INFO HttpRequestComponent Parsing user requests
2021-02-19 19:31:23,301 INFO HttpRequestComponent Receiving data...
2021-02-19 19:31:23,302 INFO HttpRequestComponent Writing data to response.json file
2021-02-22 10:34:38,070 INFO HttpRequestComponent Parsing user requests
2021-02-22 10:35:21,306 INFO HttpRequestComponent Parsing user requests
2021-02-22 10:36:34,134 INFO HttpRequestComponent Parsing user requests
2021-02-22 10:38:32,500 INFO HttpRequestComponent Parsing user requests
2021-02-22 10:38:52,566 INFO HttpRequestComponent Parsing user requests
2021-02-22 10:39:36,816 INFO HttpRequestComponent Parsing user requests
2021-02-22 10:39:59,607 INFO HttpRequestComponent Parsing user requests
2021-02-22 10:40:28,042 INFO HttpRequestComponent Parsing user requests
2021-02-22 10:40:59,762 INFO HttpRequestComponent Parsing user requests
2021-02-22 10:41:41,071 INFO HttpRequestComponent Parsing user requests
2021-02-22 10:41:43,140 INFO HttpRequestComponent Receiving data...
2021-02-22 10:41:43,140 INFO HttpRequestComponent Writing data to response.json file
2021-02-22 10:42:22,480 INFO HttpRequestComponent Parsing user requests
2021-02-22 10:42:24,524 INFO HttpRequestComponent Receiving data...
2021-02-22 10:42:24,525 INFO HttpRequestComponent Writing data to response.json file
2021-02-22 10:43:02,093 INFO HttpRequestComponent Parsing user requests
2021-02-22 10:43:04,139 INFO HttpRequestComponent Receiving data...
2021-02-22 10:43:04,139 INFO HttpRequestComponent Writing data to response.json file
2021-02-22 10:43:37,215 INFO HttpRequestComponent Parsing user requests
2021-02-22 10:43:39,242 INFO HttpRequestComponent Receiving data...
2021-02-22 10:43:39,242 INFO HttpRequestComponent Writing data to response.json file
2021-02-22 10:44:20,100 INFO HttpRequestComponent Parsing user requests
2021-02-22 10:44:22,144 INFO HttpRequestComponent Receiving data...
2021-02-22 10:44:22,145 INFO HttpRequestComponent Writing data to response.json file
2021-02-22 10:44:45,963 INFO HttpRequestComponent Parsing user requests
2021-02-22 10:44:47,992 INFO HttpRequestComponent Receiving data...
2021-02-22 10:44:47,993 INFO HttpRequestComponent Writing data to response.json file
2021-02-22 10:45:11,037 INFO HttpRequestComponent Parsing user requests
2021-02-22 10:45:11,037 INFO HttpRequestComponent Proceeding without authentication
2021-02-22 10:45:13,077 INFO HttpRequestComponent Receiving data...
2021-02-22 10:45:13,077 INFO HttpRequestComponent Writing data to response.json file
2021-02-22 10:45:28,879 INFO HttpRequestComponent Parsing user requests
2021-02-22 10:45:30,913 INFO HttpRequestComponent Receiving data...
2021-02-22 10:45:30,914 INFO HttpRequestComponent Writing data to response.json file
main.py
View file @ 956c664c
...@@ -36,6 +36,17 @@ class RequestComponent: ...@@ -36,6 +36,17 @@ class RequestComponent:
else: else:
request_payload = {} request_payload = {}
# ---------------------- Validating auth -----------------------------------------------------------------------
if RequestConstants.Request_authentication in query.keys():
try:
request_auth = query[RequestConstants.Request_authentication]
self.s.auth = (request_auth[RequestConstants.Request_auth_username],
request_auth[RequestConstants.Request_auth_password])
except Exception as e:
raise Exception(e)
else:
logger.info("Proceeding without authentication")
# ---------------------- Validating Max retries ---------------------------------------------------------------- # ---------------------- Validating Max retries ----------------------------------------------------------------
if RequestConstants.Request_payload in query.keys() and query[RequestConstants.Request_max_retries] != 0: if RequestConstants.Request_payload in query.keys() and query[RequestConstants.Request_max_retries] != 0:
request_max_retries = query[RequestConstants.Request_max_retries] request_max_retries = query[RequestConstants.Request_max_retries]
...@@ -53,6 +64,7 @@ class RequestComponent: ...@@ -53,6 +64,7 @@ class RequestComponent:
# response = requests.request(RequestConstants.Method_get, url=request_url, headers=request_headers, # response = requests.request(RequestConstants.Method_get, url=request_url, headers=request_headers,
# data=request_payload) # data=request_payload)
response = self.s.get(url=request_url, headers=request_headers, data=json.dumps(request_payload)) response = self.s.get(url=request_url, headers=request_headers, data=json.dumps(request_payload))
print(response.request.headers)
if response.status_code == RequestConstants.REQUEST_SUCCESS_CODE: if response.status_code == RequestConstants.REQUEST_SUCCESS_CODE:
logger.info("Receiving data...") logger.info("Receiving data...")
return response.json() return response.json()
...@@ -66,6 +78,7 @@ class RequestComponent: ...@@ -66,6 +78,7 @@ class RequestComponent:
# response = requests.request(RequestConstants.Method_post, url=request_url, headers=request_headers, # response = requests.request(RequestConstants.Method_post, url=request_url, headers=request_headers,
# data=json.dumps(request_payload)) # data=json.dumps(request_payload))
response = self.s.post(url=request_url, headers=request_headers, data=json.dumps(request_payload)) response = self.s.post(url=request_url, headers=request_headers, data=json.dumps(request_payload))
print(response.request.headers)
if response.status_code == RequestConstants.REQUEST_SUCCESS_CODE: if response.status_code == RequestConstants.REQUEST_SUCCESS_CODE:
logger.info("Receiving data...") logger.info("Receiving data...")
return response.json() return response.json()
......
scripts/common/config_parser.py
View file @ 956c664c
...@@ -22,19 +22,21 @@ if not os.path.exists(os.path.join(os.getcwd(), 'logs')): ...@@ -22,19 +22,21 @@ if not os.path.exists(os.path.join(os.getcwd(), 'logs')):
LOG_LEVEL = os.environ.get("LOG_LEVEL", _config.get('SERVICE_CONFIG', {}).get("LOG_LEVEL", "INFO")).upper() LOG_LEVEL = os.environ.get("LOG_LEVEL", _config.get('SERVICE_CONFIG', {}).get("LOG_LEVEL", "INFO")).upper()
LOG_HANDLER_NAME = _config.get('SERVICE_CONFIG', {}).get("LOG_HANDLER_NAME", "HttpRequestComponent") LOG_HANDLER_NAME = _config.get('SERVICE_CONFIG', {}).get("LOG_HANDLER_NAME", "HttpRequestComponent")
# os.environ['shared_volume'] = 'test' os.environ['shared_volume'] = 'test'
# os.environ['method'] = 'POST' os.environ['method'] = 'POST'
# os.environ['url'] = 'http://localhost:5000/get' os.environ['url'] = 'http://localhost:5000/get'
# os.environ['headers'] = '{"content-type":"application/json"}' os.environ['headers'] = '{"content-type":"application/json"}'
# os.environ['payload'] = '{"name": "vamshi", "gender": "male"}' os.environ['payload'] = '{"name": "vamshi", "gender": "male"}'
# os.environ['max_retries'] = '1' os.environ['max_retries'] = '1'
os.environ['authentication'] = '{"username":"vamshi","password":"sai"}'
config = { config = {
"shared_volume": os.environ.get("shared_volume"), "shared_volume": os.environ.get("shared_volume"),
"method": os.environ.get("method", "post"), "method": os.environ.get("method"),
"url": os.environ.get("url"), "url": os.environ.get("url"),
"headers": json.loads(os.environ.get("headers")), "headers": json.loads(os.environ.get("headers")),
"payload": json.loads(os.environ.get("payload")), "payload": json.loads(os.environ.get("payload")),
"max_retries": int(os.environ.get("max_retries")) "max_retries": int(os.environ.get("max_retries")),
"authentication": json.loads(os.environ.get("authentication"))
} }
if not os.path.exists(config['shared_volume']): if not os.path.exists(config['shared_volume']):
sys.stderr.write("Shared path does not exist!") sys.stderr.write("Shared path does not exist!")
......
scripts/common/constants.py
View file @ 956c664c
#!/usr/bin/env python #!/usr/bin/env python
class RequestConstants: class RequestConstants:
Request_auth_username = "username"
Request_auth_password = "password"
Request_authentication = "authentication"
Request_URL = "url" Request_URL = "url"
Request_method = "method" Request_method = "method"
Request_headers = "headers" Request_headers = "headers"
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment