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Она и вызывается асинхронно, суть в том что она блокирующая, вам нужно использовать неблокирующие ф-ии.
Как вызвать функцию асинхронно?
o7412369815963Над этим тоже думал. На хабре есть пример, когда на каждый запрос создаются потоки. http://habrahabr.ru/post/116892/
Либо запустить ф-ию в другом потоке, но это плохой путь.
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Из за GIL питон код будет работать только в одном потоке, т.е. если вы блокируете питон-кодом for in xrange то другие потоки не работают, если вы заблокируете не питон-кодом (io операции, обычно ими блокируют, db.query, urllib.urlopen, time.sleep …) то другой питон-код в других потоках будет работать.
Получается, что хоть клиенты и не блокируются, но ждут ответа дольше. Или я не так понимаю?)
def on_message(self, msg): user_id = msg['id'] user = db.query(User).get(id)
alekseyxxxxДа, для mongodb можете попробовать asyncmongo, не поддерживает весь функционал, но для 99% случаев достаточно. Он асинхронный - не будет блокировать.
И получается, что к примеру 2000 клиентов одновременно отправят запрос, то обработка будет последовательная.
alekseyxxxxЕсли процесс торнадо не будет справляться, то можно запустить их несколько экземпляров (форкнуть), и балансировщиком раскидать нагрузку (пример конфига nginx), таким же образом можно задействовать несколько серверов с кучей процессов торнадо, если нагрузка большая.
И интересно сколько способен выдержать tornado
alekseyxxxxНе знаю, я бы сначала сформулировал задачу, предполагаемые нагрузки, придумал бы несколько вариантов архитектуры, выложил на форуме для обсасывания, потом сделал бы прототип, потом если было б время, сделал бы нагрузочное тестирование.
Не подскажите, может есть полезные ссылки и ресурсы на которых можно поподробнее почитать.