请帮助如何获取多个加密的WebSocket数据
import websocket , json
pairs = [ 'fxsusdt', 'bnbusdt', 'btcusdt']
socket = 'wss://stream.binance.com:9443/stream?streams=bnbusdt@kline_1m'
def on_message(ws, message):
# json_message = json.loads(message)
# data = json_message['data']
# candle = data['k']
# candle_closed = candle['x']
# close = candle['c']
# high = candle['h']
# low = candle['l']
# volume = candle['v']
print(message)
def on_error(ws, error):
print(error)
def on_close(ws, close_status_code, close_msg):
print("### closed ###")
def on_open(ws):
print("Opened connection")
ws = websocket.WebSocketApp(socket, on_open=on_open, on_message=on_message,on_error=on_error, on_close=on_close, )
ws.run_forever()
上面的代码给予一个加密的实时数据。如何获取多个crpto的数据。如果有任何参考视频或教程,请张贴
1条答案
按热度按时间5cnsuln71#
要收听单个流,必须使用
wss://stream.binance.com:9443/ws/stream
。在您的情况下,链接将是wss://stream.binance.com:9443/ws/bnbusdt@kline_1m
您使用的url格式用于多个流,正确的用法是
wss://stream.binance.com:9443/stream?streams=stream1/stream2/stream3
,如Vlad所述。您可以使用第二种格式组合合并不同类型的流。