Tornado 异步请求中的多个数据库调用

Question

我目前正在使用 Tornado 和 asyncmongo 创建一个访问 mongodb 的网站。一切都工作得很好，除了当我需要在对处理程序的单个请求中向 mongodb 发出多个请求时。我想保持所有数据库调用异步，这样服务器上就不会阻塞。

我怎样才能做到这一点？在某些情况下，我需要从多个集合中检索不同的文档。有时我还需要在第二个查询中使用从第一个查询中检索到的数据，例如外键。当我渲染模板时，我还需要来自两个请求的数据。

谢谢！

Answer 1

每个请求是否都会触发不同的回调？

例如（我没有测试这个，而且我不熟悉 asyncmongo，所以它可能包含错误）：

import asyncmongo
import tornado.web

class Handler(tornado.web.RequestHandler):

    @tornado.web.asynchronous
    def get(self, id):
        self.id = id
        self.db = asyncmongo.Client(pool_id='mypool', host='localhost', 
            port=27107, dbname='mydb')

        self.db.users.find_one({'username': self.current_user}, 
            callback=self.on_user)

    def on_user(self, response, error):
        if error:
            raise tornado.web.HTTPError(500)
        self.user = response
        self.db.documents.find_one({'id': self.id, 'user': self.user}, 
            callback=self.on_document)

    def on_document(self, response, error):
        if error:
            raise tornado.web.HTTPError(500)
        self.render('template', first_name=self.user['first_name'],
            document=response)