我正在尝试与websockets和asyncio进行自动重新连接,但是我的代码似乎不起作用。有什么改进的建议吗?你知道吗
websocket连接有时会失败。所以我试着用一个例外来捕捉它。你知道吗
import asyncio
import json
import websockets
async def test():
async with websockets.connect('my_websocket_ip') as websvivo:
while True:
response = await websvivo.recv()
response = json.loads(response)
print(response)
if __name__ == "__main__":
try:
asyncio.run(test())
except websockets.exceptions.ConnectionClosedError as e:
asyncio.sleep(2)
asyncio.run(test())
except Exception as e:
print(e)
我收到以下错误消息:
concurrent.futures._base.CancelledError
目前没有回答
相关问题 更多 >
编程相关推荐