bybit_websocket_realtime_fill_data.py

################ bybit WebSocket example. 


import asyncio 
import websockets
import json

async def my_loop_WebSocket_bybit():
    # 2021.09.04 error websockets version 9.1 only available version 8.1 async with websockets.client.Connect("wss://stream.bybit.com/realtime") as websocket:
    async with websockets.connect("wss://stream.bybit.com/realtime") as websocket:# OK websockets version 9.1
        print("Connected to bybit WebSocket");
        await websocket.send('{"op":"subscribe","args":["trade.BTCUSD"]}');
        data_rcv_response = await websocket.recv(); 
        print("response for subscribe req. : " + data_rcv_response);

        while True:
            data_rcv_strjson = await websocket.recv(); 
            data_rcv_dict = json.loads(data_rcv_strjson); # convert to Pyhton type dict 
            data_trade_list = data_rcv_dict.get('data',0); 
            if data_trade_list == 0:
                continue
            num_data_trade_list = len(data_trade_list); 
            print("Num List : " + str(num_data_trade_list));
            for data_trade_dict in data_trade_list : ## variable number of element(dictionary) in List per one packet. 
                print("timestamp : " + data_trade_dict.get('timestamp',0) 
                        + ", price : " + str(data_trade_dict.get('price',0))   
                        + ", size : " + str(data_trade_dict.get('size',0)) 
                        );
            

##### main exec 
my_loop = asyncio.get_event_loop();  
my_loop.run_until_complete(my_loop_WebSocket_bybit()); # loop for connect to WebSocket and receive data. 
my_loop.close(); 

https://igotit.tistory.com/2490