websockets sample code

websockets-sample.py

import asyncio
import json
import websockets
​
async def subscribe_to_exchange():
    async with websockets.connect('wss://ws-feed.gdax.com') as websocket:
        subscribe = {
            "type": "subscribe",
            "product_ids": ["BTC-USD"],
            "channels": ["full"]
        }
        await websocket.send(json.dumps(subscribe))
        print("> {}".format(subscribe))
​
        while True:
            event = await websocket.recv()
            print(event)
​
asyncio.get_event_loop().run_until_complete(subscribe_to_exchange())