Tornado 异步处理程序

发布于 2024-10-16 15:33:11 字数 679 浏览 8 评论 0原文

我正在尝试在 Tornado 的 RequestHandler 中实现 get_current_user，但我需要在等待对数据库的异步调用时阻止该调用。使用 @tornado.web.asynchronous 修饰调用将不起作用，因为无论哪种方式， get_current_user 方法都会在异步查询完成并执行查询回调之前返回。

例如：

class MyHandler(BaseHandler):
  @tornado.web.asynchronous
  @tornado.web.authenticated
  def get(self):
    self.write('example')
    self.finish()

class BaseHandler(tornado.web.RequestHandler):
  def get_current_user(self):
    def query_cb(self, doc):
      return doc or None

    database.get(username='test', password='t3st', callback=query_cb)

@tornado.web.authenticated 调用 get_current_user，但始终收到“None”，因为 BaseHandler 没有时间响应。有没有一种方法，使用龙卷风，暂时阻止像上面这样的呼叫？

原文

I am attempting to implement get_current_user in the RequestHandler for Tornado, but I need the call to block while waiting on the asynchronous call to my database. Decorating the call with @tornado.web.asynchronous will not work because either way the get_current_user method returns before the async query completes and the query callback is executed.

For example:

class MyHandler(BaseHandler):
  @tornado.web.asynchronous
  @tornado.web.authenticated
  def get(self):
    self.write('example')
    self.finish()

class BaseHandler(tornado.web.RequestHandler):
  def get_current_user(self):
    def query_cb(self, doc):
      return doc or None

    database.get(username='test', password='t3st', callback=query_cb)

@tornado.web.authenticated calls get_current_user, but always receives "None" because the BaseHandler does not have time to respond. Is there a way, using tornado, to temporarily block for a call such as the one above?

分享到QQ

分享到微博

如果你对这篇内容有疑问，欢迎到本站社区发帖提问参与讨论，获取更多帮助，或者扫码二维码加入 Web 技术交流群。

发布评论

需要登录才能够评论，你可以免费注册一个本站的账号。

心碎的声音 2024-10-23 15:33:11

执行阻塞数据库操作，而不是上述非阻塞操作（tornado 附带有一个阻塞 mysql 库）。

来自 Tornado wiki 页面有关线程和并发的信息：
“同步执行并阻止 IOLoop。这最适合内存缓存和数据库查询之类的事情，这些查询在您的控制之下，并且应该始终保持快速。如果速度不快，可以通过向数据库添加适当的索引等来加快速度。 ”

https://github.com/facebook/tornado/wiki/Threading-and-concurrency

回复收藏 0 原文

江湖正好 2024-10-23 15:33:11

当数据库返回异步响应时，让 get_current_user 返回一个 Future 信号怎么样？

class BaseHandler(tornado.web.RequestHandler):
    def get_current_user(self):
        future = Future()
        def query_cb(user):
            future.set_result(user or None)
        database.get(username='test', password='t3st', callback=query_cb)
        return future


class MainHandler(BaseHandler):
    @gen.coroutine
    def get(self):
        user = yield self.get_current_user()
        self.write('user: ' + user)
        # ... actual request processing

How about having get_current_user return a Future that you signal when the asynchronous response from your database is returned?

class BaseHandler(tornado.web.RequestHandler):
    def get_current_user(self):
        future = Future()
        def query_cb(user):
            future.set_result(user or None)
        database.get(username='test', password='t3st', callback=query_cb)
        return future


class MainHandler(BaseHandler):
    @gen.coroutine
    def get(self):
        user = yield self.get_current_user()
        self.write('user: ' + user)
        # ... actual request processing

回复收藏 0 原文