Python-binance期货用户数据websocket答案

【问题标题】：Python-binance futures user data websocketPython-binance期货用户数据websocket
【发布时间】：2021-02-12 07:17:12
【问题描述】：

由于包无法正常工作，我需要有关代码的帮助，以使 binance 期货用户数据流运行。

我尝试对代码进行以下更改，但未能说明来自 Binance 的 APIERROR(code=0) Invalid Jason 错误消息。我为订阅期货用户数据流所做的调整如下：

在我的脚本中：

bm = BinanceSocketManager(client)
def processmessage(msg):
    print(msg)
    conn_keys = bm.start_user_socket(processmsg)
    bm.start()

在websockets.py 在def start_socket: 中我将stream_url 替换为fstream_url

在client.py 在def create_api_uri: 中我将api_url 替换为futures_url

我需要币安期货的用户数据流 websockets。

【问题讨论】：

“代码帮助”。什么代码？如果您需要帮助，您需要向我们展示您的代码。如果您没有向我们展示您正在做的事情是什么，我们怎么可能知道为什么您正在做的事情不起作用？
我尝试在代码中进行更改，但未能说明来自 Binance 的 APIERROR(code=0) Invalid Jason 错误消息。我为订阅期货用户数据流所做的调整如下： 1-在我的脚本中 bm = BinanceSocketManager(client) def processmessage(msg): print(msg) conn_keys = bm.start_user_socket(processmsg) bm.start() 2 在 websockets 中。 py in def start_socket: 我用 fstream_url 替换了 def create_api_uri 中 client.py 中的 stream_url 3: 我用 futures_url 替换了 api_url 我需要币安期货的用户数据流 websockets....请帮忙谢谢....
我猜任何使用python-binance模块的人都知道它没有未来的userdatasream websockets......因此我没有代码问......
我将您的 cmets 移到了问题本身，这些添加项所属的位置。
解决方案的其余部分在哪里？你在说什么代码websockets.py 和client.py？您是否期望我们知道您开始和修改的一些示例？我们不知道那个例子是什么，因为你没有告诉我们。此外，您不应该只参考一个示例。您应该包含问题中直接涉及的所有代码。请尝试提供Minimal, Complete, and Verifiable Example。

标签： python binance

【解决方案1】：

我也和你一样使用包。

你需要重新编写process_data逻辑来获取数据，然后我们的代码如下：

bm.start_futures_socket(process_data)

bm.start()

【讨论】：

【解决方案2】：

我也试图这样做。我无法让 python-binance 工作，所以我切换到了unicorn_binance_websocket_api。

快速示例：

from unicorn_binance_websocket_api.unicorn_binance_websocket_api_manager import BinanceWebSocketApiManager

binance_websocket_api_manager = BinanceWebSocketApiManager(exchange="binance.com-futures")
binance_websocket_api_manager.create_stream('arr', '!userData', api_key=<Your API key>, api_secret=<Your secret API key>, output="UnicornFy")
while True:
    data = binance_websocket_api_manager.pop_stream_data_from_stream_buffer()
    if data:
        #do something with that data
        pass

也许有帮助。

【讨论】：

【解决方案3】：

这是我的代码：

binance = await AsyncClient.create(config.API_KEY, config.API_SECRET)
bsm = BinanceSocketManager(binance)
async with bsm.futures_multiplex_socket(streams) as ms:
    while True:
        msg = await ms.recv()
        ...

【讨论】：