andyjk15/price-collector
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

[10.07.20] Zeroing out timestamp to always be on the hour

Browse Source
This commit is contained in:
andrewso 2020-07-10 23:32:29 +01:00
parent e7f8964c62
commit cb287aee83
1 changed files with 10 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

19
src/pricing/collector.py
View File

@ -85,7 +85,8 @@ def sendToGateway(c_type, timestamp, av_price, high, low, vol, o_price, c_price)
with open(btc_usd, 'r') as file: with open(btc_usd, 'r') as file:
data = file.read() data = file.read()
timestamp = '"'+timestamp.strftime('%Y-%m-%dT%H:%M:%S')+'"' strippedTimestamp = timestamp.replace(minute=0, second=0, microsecond=0)
timestamp = '"'+strippedTimestamp.strftime('%Y-%m-%dT%H:%M:%S')+'"'
type = '"'+c_type+'"' type = '"'+c_type+'"'
query = data % (timestamp, type, round(av_price, 2), query = data % (timestamp, type, round(av_price, 2),
@ -97,14 +98,14 @@ def sendToGateway(c_type, timestamp, av_price, high, low, vol, o_price, c_price)
logger.info("Query sending down to db-gateway -- ({})".format(query)) logger.info("Query sending down to db-gateway -- ({})".format(query))
status, response = send(query, logger) # status, response = send(query, logger)
#
if status != 200: # if status != 200:
logger.critical("Query wasn't executed properly, view logs. Status = {}".format(status)) # logger.critical("Query wasn't executed properly, view logs. Status = {}".format(status))
logger.error("With Response of : {}".format(response)) # logger.error("With Response of : {}".format(response))
else: # else:
logger.info("Query executed successfully with Status = {}".format(status)) # logger.info("Query executed successfully with Status = {}".format(status))
logger.info("With Response of : {}".format(response)) # logger.info("With Response of : {}".format(response))
def timeFunction(): def timeFunction():
global time global time