Python websocket подключиться и прослушивать входящие сообщения

Question

Я не могу найти очень простой пример того, как подключиться через веб-сокет в python, и предоставить некоторый обратный вызов on_message, который прослушивает входящие сообщения.

Таким образом, у веб-сокета есть метод create_connection для создания подключения,но я не вижу, где я могу передать функцию обратного вызова, которая будет вызываться каждый раз, когда другая сторона отправляет мне сообщения.

Я создаю простой прокси / ретранслятор веб-сокета Python, поэтому каждый раз, когда клиентподключившись к своему серверу, я хочу создать соединение с другим сервером, а затем прослушать входящие сообщения, чтобы я мог передать их обратно клиенту.

Answer 1

Так что мне удалось сделать это таким образом.Я надеюсь, что это оптимальный способ сделать это.

ws = create_connection(url)
def run(*args):
        while True:
            try:
                message = ws.recv() # This is blocking
            # do what I need to do here
            except WebSocketClosedError:
                break

    thread.start_new_thread(run, ())