How to manually close a websocket

python python-3.x websocket django-channels
David542 picture David542 · Oct 7, 2018 · Viewed 7.4k times · Source

If I'm not using a context for a websocket, how would I manually close it? When I try running conn.close() I get an event loop is closed error. Here is what I have so far:

from asgiref.sync import async_to_sync
import websockets

# connect -- works OK
conn = async_to_sync(websockets.connect)("ws://localhost:8000/ws/registration/123/")

# send message -- works OK
async_to_sync(conn.send)("hello")

# disconnect -- doesn't work
async_to_sync(conn.close)()

What should the last part of this be?

Answer

madjaoue picture madjaoue · Oct 8, 2018

You can use websocket-client library, it's already sync and pretty straightforward.

Install

pip install websocket-client

Usage

from websocket import create_connection
ws = create_connection(someWsUrl)  # open socket
ws.send(someMessage)  # send to socket
ws.recv(nBytes)  # receive from socket
ws.close()  # close socket

Related questions

Python - how to run multiple coroutines concurrently using asyncio?

I'm using the websockets library to create a websocket server in Python 3.4. Here's a simple echo server: import asyncio import websockets @asyncio.coroutine def connection_handler(websocket, path): while True: msg = yield from websocket.recv() if msg is None: # connection …

Read More
How can I implement asyncio websockets in a class?

I would like to connect to a websocket via asyncio and websockets, with a format as shown below. How would I be able to accomplish this? from websockets import connect class EchoWebsocket: def __init__(self): self.websocket = self._connect() def _…

Read More
Convert bytes to a string

I'm using this code to get standard output from an external program: >>> from subprocess import * >>> command_stdout = Popen(['ls', '-l'], stdout=PIPE).communicate()[0] The communicate() method returns an array of bytes: >>> …

Read More