Coinbase DataStream

class src.boatwright.Data.Collection.Live.CoinbaseDataStream.CoinbaseDataStream(symbol, granularity='1-min', broker_name='COINBASE', api_key=None, api_secret=None, quote_symbol='USD', debug=False)

boatwright interface to the coinbase websocket client

Parameters:

• granularity (str)

• broker_name (str)

• api_key (str)

• api_secret (str)

• quote_symbol (str)

• debug (bool)

async handle_msg(message)

converts message collected from a websocket subscription to boatwright compatabile format

Parameters:

msg – message recieved from websocket

async run(queue)

launch websocket