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

[24.02.20] Missed out log flushing

Browse Source
This commit is contained in:
andrewso 2020-02-24 17:09:10 +00:00
parent 793c8898dc
commit d15c24da2b
1 changed files with 7 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
src/pricing/collector.py
View File

@ -2,6 +2,8 @@
from datetime import datetime, timedelta from datetime import datetime, timedelta
import sys
from time import sleep from time import sleep
from pricing.bitfinex import bitfinexPublicTicker, bitfinexHighLowVol from pricing.bitfinex import bitfinexPublicTicker, bitfinexHighLowVol
@ -47,6 +49,7 @@ def averager(type):
averagePrice = round(averagePrice, 3) averagePrice = round(averagePrice, 3)
print("Price: ", averagePrice) print("Price: ", averagePrice)
sys.stdout.flush()
return averagePrice, timestamp return averagePrice, timestamp
@ -89,7 +92,10 @@ def sendToGateway(c_type, timestamp, av_price, high, low, vol, o_price, c_price)
status, response = send(query) status, response = send(query)
print("Status: ", status) print("Status: ", status)
sys.stdout.flush()
print("Response: ", response) print("Response: ", response)
sys.stdout.flush()
def getOpenClose(type): def getOpenClose(type):
open, close = geminiOpenClose(type) open, close = geminiOpenClose(type)
@ -99,6 +105,7 @@ def getOpenClose(type):
# Dynamically Spin up Child process for each type wanting to track # Dynamically Spin up Child process for each type wanting to track
def collector(c_type): def collector(c_type):
print("Console: ", "== Historical Price Collector ==") print("Console: ", "== Historical Price Collector ==")
sys.stdout.flush()
while True: while True:
av_price, timestamp = averager(c_type) av_price, timestamp = averager(c_type)