price-collector/src/utils/databaseConnect.py

27 lines
818 B
Python

#!/usr/bin/env python
import requests, os, json, sys
class keys():
def __init__(self):
self.uri = os.getenv("DATABASE_URL")
self.port = os.getenv("DATABASE_PORT")
def send(query, logger):
try:
uri = keys().uri + "/graphql"
headers = {'Content-type': 'application/json'}
response = requests.post(uri, json={'query': query}, headers=headers)
statusCode = response.status_code
response = json.loads(response.text)
return statusCode, response
except requests.exceptions.HTTPError as e:
logger.critical("Unable to send data down to db-gateway: {}".format(e))
sys.exit(1)
except requests.exceptions.RequestException as e:
logger.critical("Unable to send data down to db-gateway: {}".format(e))
sys.exit(1)