Source code
Revision control
Copy as Markdown
Other Tools
#!/usr/bin/env python
import asyncio
import signal
import websockets
async def client():
async with websockets.connect(uri) as websocket:
# Close the connection when receiving SIGTERM.
loop = asyncio.get_running_loop()
loop.add_signal_handler(
signal.SIGTERM, loop.create_task, websocket.close())
# Process messages received on the connection.
async for message in websocket:
...
asyncio.run(client())