我试图连接到Binance流,但当我运行代码时,它会输出:"closed connection“。我能做些什么来加入这个流呢?
import websocket
import json
socket = 'wss://fstream.binance.com/ws'
def on_open(ws):
subscribe_message = {"method": "SUBSCRIBE", "params":["btcusdt@trade"],"id": 1}
ws.send(json.dumps(subscribe_message))
def on_message(ws, message):
print("received a message")
print(json.loads(message))
def on_close(ws):
print("closed connection")
ws = websocket.WebSocketApp(socket, on_open=on_open, on_message=on_message, on_close=on_close)
ws.run_forever()
发布于 2021-03-25 14:22:43
欢迎使用stackoverflow
。
通过查看wss://fstream.binance.com/ws
,我可以看到您正在尝试连接到Futures API
。
它在API文档中清楚地说明,任何原始流都可以在/ws/<streamName>
访问。
您没有在url中指定streamName
,这就是错误的原因。
只需更改url以连接到正确的流&相同的代码应该适用于您:
ws = websocket.WebSocketApp(socket + '/btcusdt@trade', on_open=on_open, on_message=on_message, on_close=on_close)
如果有帮助,请将答案标记为已接受。
https://stackoverflow.com/questions/66788212
复制相似问题