Topic: Need help making my first volume monitor bot (Read 750 times)

from requests import Session
from signalr import Connection
import time, json

markets = ['BTC-OMG', 'ETH-OMG', 'USDT-OMG']

def orderPrinter(update):
    orderUnparsed = json.dumps(update)
    JSONOrder = json.loads(orderUnparsed)

    try:
        MarketName = JSONOrder[0]['MarketName']
        Fills = JSONOrder[0]['Fills']
        for order in Fills:
            OrderType = order['OrderType']
            Rate = order['Rate']
            Quantity = order['Quantity']
            Total = Rate * Quantity

            print MarketName, OrderType, Total
    except Exception as e:
        print e
        pass



with Session() as session:
	connection = Connection('http://socket.bittrex.com/signalr', session)

	corehub = connection.register_hub('coreHub')

	#create error handler
	def print_error(error):
		print('error: ', error)


	# debug information, show all data
	def print_raw_data(*args, **kwargs):
		print (args, kwargs)

	def ticker_data(*args, **kwargs):
		print "ticker", (args, kwargs)
	def market_data(*args, **kwargs):
		#print "ticker", (args, kwargs)
            orderPrinter(args)

	connection.error += print_error

	connection.start()
	print "sending subscription request"
	for market in markets:
		corehub.server.invoke('SubscribeToExchangeDeltas', market)

	#corehub.client.on('updateSummaryState', ticker_data)
	corehub.client.on('updateExchangeState', market_data)

	connection.wait(150000)