python - 使用 websocket.send(msg) 一段时间后出现 "got Future attached to a different loop"错误

Question

我正在使用 websocket 在 python 中发送和接收消息。我使用“websocket.send(msg)”以这些形式发送消息:

await ws.send(message)

和

asyncio.run(ws.send(message))

在 while 循环中，我首先检查连接是否处于事件状态，然后使用这些命令发送消息。在所有这些中，如果发送次数较少，没有问题，但是当发送次数增加时，我会收到发送消息的异常

Task <Task pending coro=<RunSocket() running at <ipython-input-1-b17eaf75a3de>:182> cb=[_run_until_complete_cb() at D:\Anaconda\InstallationFolder\lib\asyncio\base_events.py:158]> got Future <Future pending> attached to a different loop

“请注意，RunSocket 是我的函数名称之一”

然后我收到此错误:

got Future <Future pending> attached to a different loop

我也尝试了这段代码:

asyncio.ensure_future(await ws.send(message))

但它没有发送任何消息。谁能帮我解决这个错误？任何帮助将不胜感激。

Answer 1

got Future attached to a different loop

当您创建一些异步对象时，它会附加到 current事件循环(主线程默认有一个)。当相同的事件循环处于当前状态时，预计将使用异步对象。asyncio.run 创建新的事件循环并将其设置为当前事件循环。结果是 - 您已将异步对象附加到一个事件循环，但尝试将其与另一个事件循环一起使用。这就是错误的来源。

为了避免这种情况，您应该在 asyncio.run 创建新事件循环后创建异步对象:

async def main():
    ws = ...  # create object after asyncio.run is started
    res = ws.send(message)
    return res

asyncio.run(main())