Untitled

 avatar
unknown
plain_text
2 years ago
910 B
6
Indexable
import requests
import websocket
import json


symbol_container = []
spot_ws = f'wss://fstream.binance.com/stream?streams=btcusdt@bookTicker/'
print(spot_ws)
def on_message(ws,message):
    json_msg = json.loads(message)
    symbol = json_msg['data']['s']
    bid = json_msg['data']['b']
    symbol_container.append(symbol)
    #print(json_msg)

def on_ping(ws, message):
    print("### on_ping ###")
    print("ping message: %s", message)

def on_pong(ws, message):
    print("### on_pong ###")
    print("pong message: %s", message)

def on_error(ws, error):
    print(error)

def on_close(ws):
    print('connection end')
ws = websocket.WebSocketApp(spot_ws,
	on_message=on_message,
    on_ping=on_ping,
    on_pong=on_pong,
	on_close=on_close,
	on_error=on_error)
ws.run_forever(ping_interval=2, ping_timeout=1)

symbol_container = set(symbol_container)
print(symbol_container)
print(len(symbol_container))
Editor is loading...