dennisthiessen/stock-arbitrage-bot
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Now with time performance output

Browse Source
This commit is contained in:
Dennis Thiessen
2017-10-11 13:33:49 +02:00
parent a226033d21
commit 942e6081b2
1 changed files with 43 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

48
bot/market_data_crawler.py
View File

@@ -15,8 +15,10 @@ def update_market_data_for_basecoin(basecoin):
@gen.coroutine @gen.coroutine
def call_market_data(url, response_handler): def call_market_data(url, response_handler):
start_time5 = time.time()
http_client = tornado.httpclient.AsyncHTTPClient() http_client = tornado.httpclient.AsyncHTTPClient()
response = yield http_client.fetch(url) response = yield http_client.fetch(url)
print("Data received for url {0}. Responsetime: {1:.2f}ms".format(url[0:15], (time.time() - start_time5)*100))
return response_handler(response) return response_handler(response)
""" """
@@ -28,14 +30,17 @@ def update_market_data_for_basecoin(basecoin):
return False return False
else: else:
print("Response received from Bittrex - handling now!") start_time1 = time.time()
response_data = tornado.escape.json_decode(response.body) response_data = tornado.escape.json_decode(response.body)
for market in response_data["result"]: for market in response_data["result"]:
base, target = market["MarketName"].split("-") base, target = market["MarketName"].split("-")
if base == basecoin: if base == basecoin:
market_data[target].append({"Bittrex": market["Last"]}) market_data[target].append({"Bittrex": market["Last"]})
elif target == basecoin:
market_data[base].append({"Bittrex": market["Last"]})
print("Handling bitr finished in {:.3f}ms".format((time.time() - start_time1)*100))
return True return True
market_requests.append( market_requests.append(
@@ -52,15 +57,17 @@ def update_market_data_for_basecoin(basecoin):
return False return False
else: else:
print("Response received from Poloniex - handling now!") start_time2 = time.time()
response_data = tornado.escape.json_decode(response.body) response_data = tornado.escape.json_decode(response.body)
for market in response_data: for market in response_data:
base, target = market.split("_") base, target = market.split("_")
if base == basecoin: if base == basecoin:
market_data[target].append({"Poloniex": response_data[market]["last"]}) market_data[target].append({"Poloniex": response_data[market]["last"]})
elif target == basecoin:
market_data[base].append({"Poloniex": response_data[market]["last"]})
print("Handling pol finished in {:.3f}ms".format((time.time() - start_time2)*100))
return True return True
market_requests.append( market_requests.append(
@@ -77,7 +84,7 @@ def update_market_data_for_basecoin(basecoin):
return False return False
else: else:
print("Response received from Kraken - handling now!") start_time3 = time.time()
response_data = tornado.escape.json_decode(response.body) response_data = tornado.escape.json_decode(response.body)
import re import re
@@ -85,9 +92,13 @@ def update_market_data_for_basecoin(basecoin):
base = "ETH" base = "ETH"
target = re.findall('XBT|EOS|GNO|ETC|ICN|REP|MLN', market, re.DOTALL) target = re.findall('XBT|EOS|GNO|ETC|ICN|REP|MLN', market, re.DOTALL)
if target[0] == "XBT":
target[0] = "BTC"
if base == basecoin: if base == basecoin:
market_data[target[0]].append({"Kraken": response_data["result"][market]["c"][0]}) market_data[target[0]].append({"Kraken": response_data["result"][market]["c"][0]})
print("Handling kra finished in {:.3f}ms".format((time.time() - start_time3)*100))
return True return True
market_requests.append( market_requests.append(
@@ -95,9 +106,36 @@ def update_market_data_for_basecoin(basecoin):
"https://api.kraken.com/0/public/Ticker?pair=ETHXBT,EOSETH,GNOETH,ETCETH,ICNETH,REPETH,MLNETH", "https://api.kraken.com/0/public/Ticker?pair=ETHXBT,EOSETH,GNOETH,ETCETH,ICNETH,REPETH,MLNETH",
handle_response_kraken)) handle_response_kraken))
"""
Bitfinex
"""
def handle_response_bitfinex(response):
if response.error:
print("Error: %s" % response.error)
return False
else:
start_time4 = time.time()
response_data = tornado.escape.json_decode(response.body)
import re
for market in response_data:
base = "ETH"
target = re.findall('BTC|IOT|EOS|SAN|OMG|QTM|AVT|ETP|NEO|BCH', market[0], re.DOTALL)
if base == basecoin:
market_data[target[0]].append({"Bitfinex": market[7]})
print("Handling bitf finished in {:.3f}ms".format((time.time() - start_time4)*100))
return True
market_requests.append(
call_market_data(
"https://api.bitfinex.com/v2/tickers?symbols=tETHBTC,tIOTETH,tEOSETH,tSANETH,tOMGETH,tQTMETH,tAVTETH,tETPETH,tNEOETH,tBCHETH",
handle_response_bitfinex))
print("--- Retrieve market data now ---") print("--- Retrieve market data now ---")
start_time = time.time() start_time = time.time()
response_dict = yield market_requests response_dict = yield market_requests
print("--- Marked data updated in {0} seconds. Responses: {1} ---".format(time.time() - start_time, response_dict)) print("--- Marked data updated in {0:.3f}s. Responses: {1} ---".format(time.time() - start_time, response_dict))