Python websockets 服务器和 websockets 客户端在运行这两个任务时使用 asyncio 断言错

Question

>我有3台机器;甲、乙、丙

A正在运行 C 想要连接的 websocket 服务器，但 C 无法直接连接到 A。为了解决这个问题，我想通过机器 B 基本上"代理"websocket。

A充当发布者，每隔几秒钟生成一次我想推送到 C 的新数据包.C 不需要向 A 发送任何内容(尽管将来可能需要(。

我想使用 websockets (https://pypi.org/project/websockets/( 模块实现此代理。我目前正在尝试在 B 上创建一个服务器，该服务器侦听连接并与任何客户端保持 websocket 连接。然后，我想异步运行连接到计算机 A 的 websocket 客户端。这是一个订阅者连接，从 websocket 连接到 A 的任何更新都应推送到 C(或连接到 B 的任何其他客户端(。

这是我当前(最小(发生错误的实现。

sockets = set()
def register(websocket):
sockets.add(websocket)
def unregister(websocket):
sockets.remove(websocket)
async def update_clients(update):
if sockets:
await asyncio.wait([socket.send(update) for socket in sockets])
async def client_server(websocket, path):
register(websocket)
await websocket.send("Welcome!")
async def live_updates():
async with websockets.connect(LIVE_URL) as websocket:
async for update in websocket.recv():
await update_clients(update)
webserver = websockets.serve(client_server, "0.0.0.0", PORT)
loop = asyncio.get_event_loop()
loop.run_until_complete(webserver)
loop.run_until_complete(live_updates)
loop.run_forever()

错误如下

Traceback (most recent call last):
File "/usr/lib/python3.6/asyncio/base_events.py", line 1310, in call_exception_handler
self.default_exception_handler(context)
File "/usr/lib/python3.6/asyncio/base_events.py", line 1282, in default_exception_handler
value = repr(value)
File "/usr/lib/python3.6/asyncio/base_tasks.py", line 15, in _task_repr_info
coro = coroutines._format_coroutine(task._coro)
File "/usr/lib/python3.6/asyncio/coroutines.py", line 276, in _format_coroutine
assert iscoroutine(coro)
AssertionError

Answer 1

当我删除第二个run_until_complete(live_updates)时，代码运行没有错误。所以我删除了第一个run_until_complete，将我的代码与 https://websockets.readthedocs.io/en/stable/intro.html 的示例代码进行了比较，并意识到

run_until_complete(live_updates)应该run_until_complete(live_updates())

我留下这个问题，以防有人遇到同样的错误，因为错误消息对于初学者来说很混乱。