Python tornado как сделать ответы асинхронными?

Question

[jallvar]

Всем привет, подскажите. Пишу WebSocket сервер на Tornado.
Алгоритм следующий:
-Человек подключается к серверу
-Передает в message - параметры {param1: 1, param2: 2}
-Сервер на основе этих параметров из бд выдает ответы, т.е., что-то вроде live-ленты. Каждые 10 секунд в бесконечном цикле с time.sleep отправляет результаты. И все хорошо, но в таком режиме работает он только с 1 клиентом.
Если, просто, закрыть вкладку, то соединение так и виснет. И сервер не принимает новых сообщений

class capitalizationHandler(Handler.WebSocketHandler): #Наследую от измененного Handler'a Tornado (Ничего там интересного, просто, уменьшил код
    @tornado.web.asynchronous
    def on_message(self, message):

        while True:
            response = requests.get(url) #Через reuquests, да-да, простите меня

            if response.status_code != 200:
                self.write_message(u"bad parameters #3")
                print(url)
                break

            self.write_message(response.content)

            time.sleep(Config.script2Pause) #Config.script2Pause = 10 сек

if __name__ == '__main__':
    ws_app = Application()
    server = tornado.httpserver.HTTPServer(ws_app)
    server.listen(8808)
    tornado.ioloop.IOLoop.instance().start()

Answer 1

[Сергей Горностаев]

time.sleep() - это блокирующаяся операция. Нельзя блокировать асинхронный код. Используйте yield gen.sleep(Config.script2Pause).

Comments

[jallvar]

Pavel Denisov, можете дать помер?

[Сергей Горностаев]

jallvar, чего дать? Кто помер?

[jallvar]

Pavel Denisov, пример, т9 :) извиняюсь

[Сергей Горностаев]

jallvar, грубый, но рабочий вариант:

from tornado import gen
from tornado.httpclient import AsyncHTTPClient

class capitalizationHandler(Handler.WebSocketHandler):
    http_client = AsyncHTTPClient()

    @gen.coroutine
    def on_message(self, message):

        while True:
            response = yield self.http_client.fetch(url)

            if response.error:
                self.write_message(u"bad parameters #3")
                print(url)
                break

            self.write_message(response.body)

            yield gen.sleep(Config.script2Pause)

Лучше, конечно, вместо цикла и sleep использовать периодическую асинхронную задачу, которая будет при срабатывании отправлять данные в подключенные соединения.

[Владимир]

почему не выделить блок с получением данных в отдельную корутину которая будет работать через очереди? тогда on_message будет просто добавлять задачки для парсинга в очередь или команды по остановке корутины. также завершение сессии будет приводить к остановке корутины.
и да, таки все клиентов по присоединении надо добавлять в set и удалять из него при отсоединении.
вот так реализован чат посмотрите как идет работа с waiters в ChatSocketHandler

[Сергей Горностаев]

Владимир, потому, что я стараюсь показать предельно простой вариант с минимально необходимым для работы отличием от оригинала. Тем более, что Pavel Denisov уже дал эту ссылку, нет нужды перепечатывать в ответ её содержимое.

[Владимир]

Сергей Горностаев, к сожалению самый простой вариант не будет самым правильным.
это ассинхронное программирование и оно несколько другое. нельзя делать циклы в функции которая отвечает за прием сообщений. ее задача просто принять сообщение и все. а вот уже работа с БД или же с ассинхронными запросами к вэбу должна идти в отдельной сопрограмме и уже от нее отдаваться должен ответ подписчику

[Сергей Горностаев]

Владимир,

это ассинхронное программирование и оно несколько другое

Ага, я в курсе, уже 14 лет этим на хлеб зарабатываю :) Ещё со времён голых селектов, первой версии Twisted и второй Netty.

нельзя делать циклы в функции которая отвечает за прием сообщений

Нежелательно, но технически можно. Надо только не блокировать итерацию надолго и уступать управление циклу событий в конце итерации.

[Владимир]

Сергей Горностаев, даже и не знаю что сказать. против такого опыта конечно не попрешь, что там мои 22 года опыта, просто пыль. а так да, все аргументировано, спасибо

[Сергей Горностаев]

Владимир, хорошо, что на Тостере становится больше опытных специалистов, станет больше хороших ответов.