Я подключаюсь к клиенту websocket и подписываюсь на несколько потоков. Но я продолжаю получать эту ошибку
"'WebSocket connection is closed: code = 1006 (connection closed abnormally [internal]), no reason'"
Я не знаю причину. Погуглил проблему, но без помощи.
Я использую пакет websockets. Ниже мой код.
async def streaming_data(url):
headers = await gives_auth(auth_url)
print(headers)
try:
async with websockets.client.connect(url,extra_headers=headers) as websocket:
response = await websocket.recv()
print(response)
except websockets.exceptions.InvalidHandshake:
print('Exception raised when a handshake request or response is invalid.')
except websockets.exceptions.InvalidURI:
print('Exception raised when an URI isn’t a valid websocket URI.')
except websockets.exceptions.InvalidStatusCode:
print('Handshake responce status code is invalid')
except Exception as e:
print('Error in making the Websocket Connection!!')
print(e.args)
loop = asyncio.new_event_loop()
stream_url=""
streams = [loop.create_task(streaming_data(stream_url))]
loop.run_until_complete(asyncio.wait(streams))
Я довольно новичок в этом. Спасибо за помощь.