Python-сообщество

Здравствуйте. Делаю приложение на торнадо. Написал тестовый обработчик

class AdminHandler(BaseHandler):
    @tornado.web.authenticated
    @tornado.web.asynchronous
    @gen.engine
    def get(self):
        response = yield gen.Task(self.acync_func_test, 'my')
        print response
        self.render('admin/index.html')
    def acync_func_test(self, argument, callback):
        for i in xrange(1,59999000):
            i**2+2-12
        callback(argument)

Отредактировано alekseyxxxx (Авг. 30, 2013 09:38:21)

Я не знаю устройства торнады, могу лишь сказать, что если у вас в асинхронной системе выполняется какой-то код и в нём нету никаких точек прерывания, типа того же yield, то этот код будет выполняться без прерываний, весь. Никаких чудес не будет, если функция async_func_test что-то делает долго, то в этом время все будут ждать её. Видимо, в функции надо генерить с помощью yield точки прерывания, наверное так и сделано в торнаде, я не знаю, как ещё по другому можно реализовать такой фунционал в python

alekseyxxxx
Как вызвать функцию асинхронно?

Ну вроде стало понятно.

o7412369815963
Либо запустить ф-ию в другом потоке, но это плохой путь.

class ThreadableMixin:
    def start_worker(self):
        threading.Thread(target=self.worker).start()
    def worker(self):
        try:
            self._worker()
        except tornado.web.HTTPError, e:
            self.set_status(e.status_code)
        except:
            logging.error("_worker problem", exc_info=True)
            self.set_status(500)
        tornado.ioloop.IOLoop.instance().add_callback(self.async_callback(self.results))
    def results(self):
        if self.get_status()!=200:
            self.send_error(self.get_status())
            return
        if hasattr(self, 'res'):
            self.finish(self.res)
            return
        if hasattr(self, 'redir'):
            self.redirect(self.redir)
            return
        self.send_error(500)

class Handler(tornado.web.RequestHandler, ThreadableMixin):
    def _worker(self):
        self.res = self.render_string("template.html",
            title = _("Title"),
			data = self.application.db.query("select ... where object_id=%s", self.object_id)
        )
    @tornado.web.asynchronous
    def get(self, object_id):
	self.object_id = object_id
        self.start_worker(

Отредактировано alekseyxxxx (Сен. 1, 2013 08:51:55)

alekseyxxxx
Получается, что хоть клиенты и не блокируются, но ждут ответа дольше. Или я не так понимаю?)

Просто в разработке есть приложение на tornado на websocket. Все общение идет только через вебсокеты. И интересно сколько способен выдержать tornado. Как я понял, если не писать ‘асинхронным стилем’, то клиенты будут блокироваться. Ну, например, самая простая функция:

def on_message(self, msg):
    user_id = msg['id']
    user = db.query(User).get(id)

Отредактировано alekseyxxxx (Сен. 1, 2013 13:09:43)

alekseyxxxx
И получается, что к примеру 2000 клиентов одновременно отправят запрос, то обработка будет последовательная.

alekseyxxxx
И интересно сколько способен выдержать tornado

alekseyxxxx
Не подскажите, может есть полезные ссылки и ресурсы на которых можно поподробнее почитать.

Ну сейчас на данный момент так и сделано. Т.е. нжинкс балансирует нагрузку на несколько инстансов торнадо. А клиенты с разных инстансов общаются через редис. Вариант с монго привел для примера) Основная база postgres, ну для него тоже есть асинхроная библиотека. Попробую реализовать через нее, и провести нагрузочное тестирование) Спасибо за пояснения)

Не подскажете на эту же тему каким образом лучше реализовать такое. Пользователь заходит на сайт, нажимает кнопочку, запускается действие(настройка свитча по snmp, например), длится оно около минуты и лог этого действия realtime отображается у пользователя. Начал делать через торнадо и вебсокеты, но наткнулся на тоже самое - два пользователя одновременно не могут запустить эту настройку. Как мне сейчас лучше поступить?