Real-time Coinbase orders and trades

coinbase.py

# -*- coding: utf-8 -*-
"""
    coinbase
    ~~~~~~~~

    Real time Coinbase trades and orders using their Websocket Feed
    https://docs.exchange.coinbase.com/?python#overview
"""

import asyncio
import json
import websockets

COINBASE_FEED_URL = "wss://ws-feed.exchange.coinbase.com"


@asyncio.coroutine
def coinbase_feed():
    websocket = yield from websockets.connect(COINBASE_FEED_URL)
    yield from websocket.send(json.dumps({
        "type": "subscribe",
        "product_id": "BTC-USD"
    }))
    while True:
        message = yield from websocket.recv()
        print(message)


def main():
    asyncio.get_event_loop().run_until_complete(coinbase_feed())


if __name__ == '__main__':
    main()