Торнадо: исключение задачи не было получено - PullRequest
Новая
       82

Торнадо: исключение задачи не было получено

1 голос
/ 27 мая 2020

Я получаю исключение на сервере Tornado WebSocket, но оно не дает информации в трассировке, чтобы узнать, из какой строки кода или с какого шага в моей программе оно исходит. Я хотел бы выяснить причину возникновения исключения.

Трассировка ошибки: (Никакого упоминания какой-либо части моих файлов) 

[E 200527 21:07:19 base_events:1608] Task exception was never retrieved
    future: <Task finished coro=<WebSocketProtocol13.write_message.<locals>.wrapper() done, defined at /usr/local/lib/python3.7/site-packages/tornado/websocket.py:1102> exception=WebSocketClosedError()>
    Traceback (most recent call last):
    File "/usr/local/lib/python3.7/site-packages/tornado/websocket.py", line 1104, in wrapper
        await fut
    tornado.iostream.StreamClosedError: Stream is closed

    During handling of the above exception, another exception occurred:

    Traceback (most recent call last):
    File "/usr/local/lib/python3.7/site-packages/tornado/websocket.py", line 1106, in wrapper
        raise WebSocketClosedError()
    tornado.websocket.WebSocketClosedError

[E 200527 21:07:19 base_events:1608] Task exception was never retrieved

Та же самая группа Traceback повторяется более 16 раз.

Вот мой код: 

import tornado.iostream
import tornado.web
import tornado.gen
import tornado.websocket
import asyncio

class SocketHandler(tornado.websocket.WebSocketHandler):
    waiters = set()
    def initialize(self):
        self.client_name = "newly_connected"

    def get_compression_options(self):
        # Non-None enables compression with default options.
        return {}

    def open(self):
        print('connection opened')
        # SocketHandler.waiters.add(self)

    def on_close(self):
        print("CLOSED!", self.client_name)
        try:
            SocketHandler.waiters.remove(self)
        except KeyError:
            print('tried removing new client')

    def check_origin(self, origin):
        # Override the origin check if needed
        return True

    @classmethod
    async def send_updates(cls, message):
        if len(cls.waiters) < 2:
            while True:
                chat = {}
                # Prevent RuntimeError: Set changed size during iteration
                waiters_copy = cls.waiters.copy()
                for waiter in waiters_copy:
                    try:
                        await waiter.write_message(chat)
                    except tornado.websocket.WebSocketClosedError:
                        pass
                    except tornado.iostream.StreamClosedError:
                        pass
                    except Exception as e:
                        print('Exception e:', waiter.client_name)
                        pass

                # sleep a bit
                await asyncio.sleep(0.05)
        else:
            print('broadcast loop already running')

    async def on_message(self, message):
        print("RECEIVED :", message)
        self.client_name = message
        self.first_serve_cache_on_connnect()
        SocketHandler.waiters.add(self)
        await SocketHandler.send_updates(message)

    def first_serve_cache_on_connnect(self):
        print('serving cache on connect')
        temp_calc_results = self.namespace.results
        try:
            self.write_message(temp_calc_results)
        except Exception as e:
            pass

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

1 Ответ

1 голос
/ 28 мая 2020

Сообщение «исключение задачи не было получено» связано не с отсутствием блока try/except, а с отсутствием await. В first_serve_cache_on_connect вы вызываете write_message без await, поэтому first_serve_cache_on_connect больше не работает к моменту возникновения исключения, и ему некуда go, кроме журналов.

Это в основном безвредно, но если вы хотите очистить журналы, вам нужно сделать first_serve_cache_on_connect an async def сопрограмму, вызвать ее с помощью await в on_message и вызвать write_message с await.

...