async def main():
async with websockets.connect(URL) as websocket:
await websocket.send(json.dumps({"type":"init", "id":"server"}))
loop = asyncio.get_running_loop()
loop.add_signal_handler(
signal.SIGTERM, loop.create_task, websocket.close())
async for message in websocket:
logger.info(message)
if __name__ == '__main__':
asyncio.run(main())
error:
File "D:\miniconda3\envs\monitor\Lib\asyncio\runners.py", line 118, in run
return self._loop.run_until_complete(task)
^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
File "D:\miniconda3\envs\monitor\Lib\asyncio\base_events.py", line 653, in run_until_complete
return future.result()
^^^^^^^^^^^^^^^
File "E:\video_stream_workspace\monitor\services.py", line 15, in main
loop.add_signal_handler(
File "D:\miniconda3\envs\monitor\Lib\asyncio\events.py", line 574, in add_signal_handler
raise NotImplementedError
NotImplementedError
sys:1: RuntimeWarning: coroutine 'WebSocketCommonProtocol.close' was never awaited
when i run the code:
error:
File "D:\miniconda3\envs\monitor\Lib\asyncio\runners.py", line 118, in run return self._loop.run_until_complete(task) ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ File "D:\miniconda3\envs\monitor\Lib\asyncio\base_events.py", line 653, in run_until_complete return future.result() ^^^^^^^^^^^^^^^ File "E:\video_stream_workspace\monitor\services.py", line 15, in main loop.add_signal_handler( File "D:\miniconda3\envs\monitor\Lib\asyncio\events.py", line 574, in add_signal_handler raise NotImplementedError NotImplementedError sys:1: RuntimeWarning: coroutine 'WebSocketCommonProtocol.close' was never awaited