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

[09.07.20] Paths

Browse Source
This commit is contained in:
andrewso 2020-07-09 20:14:58 +01:00
parent a3550c61a9
commit 883045beec
1 changed files with 10 additions and 10 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

20
src/pricing/collector.py
View File

@ -13,7 +13,7 @@ from pricing.gemini import geminiPublicTicker, geminiVolAskBid, geminiDailyOpenC
from pricing.bitstamp import bitstampVolAskBid, bitstampHighLow, bitstampOpenClose from pricing.bitstamp import bitstampVolAskBid, bitstampHighLow, bitstampOpenClose
from pricing.kraken import krakenVolAskBid, krakenHighLow, krakenOpenClose from pricing.kraken import krakenVolAskBid, krakenHighLow, krakenOpenClose
from utils.databaseConnect import send from src.utils.databaseConnect import send
import logging as logger import logging as logger
@ -23,7 +23,7 @@ logger.basicConfig(
datefmt='%Y-%m-%d %H:%M:%S' datefmt='%Y-%m-%d %H:%M:%S'
) )
btc_usd="src/resources/queries/V1_INSERT_NEW_PRICE_RECORD_BTC.graphql" btc_usd="/home/price-collector/src/resources/queries/V1_INSERT_NEW_PRICE_RECORD_BTC.graphql"
def averager(type): def averager(type):
@ -95,14 +95,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