websockets.exceptions.ConnectionClosedOK：代码= 1000（好的），没有原因

Question

• 我正在尝试从使用 websocket 的网站接收数据。其行为如下： websocket 握手

这是捕获数据的代码：

async def hello(symb_id: int):
    async with websockets.connect("wss://ws.bitpin.ir/", extra_headers = request_header, timeout=15) as websocket:
        await websocket.send('{"method":"sub_to_price_info"}')
        recv_msg = await websocket.recv()
        if recv_msg == '{"message": "sub to price info"}':
            await websocket.send(json.dumps({"method":"sub_to_market","id":symb_id}))
            recv_msg = await websocket.recv()
            counter = 1 

            while(1):
                msg = await websocket.recv()
                print(counter, msg[:100], end='\n\n')
                counter+=1

asyncio.run(hello(1))

• 收到大约 100 条消息后，我面临以下错误：

websockets.exceptions.ConnectionClosedOK: code = 1000 (OK), no reason

• 我尝试设置timeout，request headers但这些没有帮助

Answer 1

我通过创建发送任务解决了这个错误PING。

async def hello(symb_id: int):
    async with websockets.connect("wss://ws.bitpin.ir/", extra_headers = request_header, timeout=10, ping_interval=None) as websocket:
        await websocket.send('{"method":"sub_to_price_info"}')
        recv_msg = await websocket.recv()
        if recv_msg == '{"message": "sub to price info"}':
            await websocket.send(json.dumps({"method":"sub_to_market","id":symb_id}))
            recv_msg = await websocket.recv()
            counter = 1 

            task = asyncio.create_task(ping(websocket))
            while True:
                msg = await websocket.recv()
                await return_func(msg)
                print(counter, msg[:100], end='\n\n')
                counter+=1


async def ping(websocket):
    while True:
        await websocket.send('{"message":"PING"}')
        print('------ ping')
        await asyncio.sleep(5)