websockets.exceptions.ConnectionClosedOK:代码=1000(OK)，没有原因

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='nn')
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='nn')
counter+=1

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