两个带有BinancesocketManager的Websocket

Question

我正在尝试打开两个Web插座 - 深度书和用户套接字。

这是我的代码：

async def sockets(client):
    bm = BinanceSocketManager(client)
    ds = bm.depth_socket("BTCUSDT", depth=BinanceSocketManager.WEBSOCKET_DEPTH_5)
    
    print("Started...")

    async with ds as depth_socket:
        while True:
            res = await depth_socket.recv()
            print(res)

    await client.close_connection()

我需要bm.user_socket（）同时打开。

我如何与Binancesocketmanager同时打开其中两个？

Answer 1

我已经修改了您的代码，因为它不起作用。我的感觉是，您对asyncio的工作方式没有很好的了解。我建议您阅读此 tutorial> tutorial> tutorial /代码>事件循环。

您需要的是使用使用使用asyncio's suarsy_future模块，该模块将使您能够 sugch sugch tasks 和运行它们异步。

我们在下面的代码中正在做的是，我们正在为depth_socket和user_socket 创建单独的任务，哪些循环循环但也异常运行，以便他们可以随时返回数据。服务器无需等待其他任务完成。

我认为您遇到的问题是您正在尝试将depth_socket和user_socket 放在同一async coroutine中，因此请与depth_socket 表示您永远无法同时循环浏览user_socket。

我在上面给您的教程链接中有一个关于运行多个Coroutines的部分，这有助于我了解这是如何工作的。

不幸的是，我似乎无法连接到Binance TestNet，因此我无法测试user_socket 任务在发生用户事件时实际上有效，但是当连接时它不会丢弃错误到Livenet。让我知道您是否正在获得贸易活动。

当然，您需要输入API密钥和秘密。

import asyncio
from binance import AsyncClient, BinanceSocketManager

api_key = '...'
api_secret = '...'

async def task_depth_socket():
    client = await AsyncClient.create(api_key, api_secret)
    bm = BinanceSocketManager(client)
    ds = bm.depth_socket("BTCUSDT", depth=BinanceSocketManager.WEBSOCKET_DEPTH_5)

    async with ds as depth_socket:
        while True:
            res = await depth_socket.recv()
            print(res)
    
async def task_user_socket():
    client = await AsyncClient.create(api_key, api_secret)
    bm = BinanceSocketManager(client)
    us = bm.user_socket()
    
    async with us as user_socket:
        while True:
            res = await user_socket.recv()
            print(res)    
 
loop = asyncio.get_event_loop()

try:
    asyncio.ensure_future(task_depth_socket())
    asyncio.ensure_future(task_user_socket())
    loop.run_forever()

except KeyboardInterrupt:
    pass
finally:
    print("Closing Loop")
    loop.close()