在龙卷风中使用数据库操作时如何在自定义装饰器中使用协程

Question

我有使用 get 和 post 方法处理请求的处理程序，我想使用我自己的自定义装饰器进行身份验证，而不是龙卷风本身 @tornado.web.authenticated 装饰器。在我的自定义装饰器中，我需要查询数据库以识别用户，但龙卷风中的数据库查询与@gen.coroutine 异步。

我的代码是：

handlers.py;

 @account.utils.authentication
    @gen.coroutine
    def get(self, page):

account/utils.py：

@tornado.gen.coroutine
def authentication(fun):
    def test(self,*args, **kwargs    ):
        print(self)
        db = self.application.settings['db']
        result = yield db.user.find()
        r = yield result.to_list(None)
        print(r)
    return test

但是访问时出现错误：

Traceback (most recent call last): File "/Users/moonmoonbird/Documents/kuolie/lib/python2.7/site-packages/tornado/web.py", line 1443, in _execute result = method(*self.path_args, **self.path_kwargs) TypeError: 'Future' object is not callable

谁能遇到过这个，编写自定义装饰器以使用异步数据库操作进行身份验证的正确方法是什么？提前致谢~

Answer 1

装饰器需要同步；它是 函数，它 returns 是协程。您需要更改：

@tornado.gen.coroutine
def authentication(fun):
    def test(self, *args, **kwargs):
        ...
    return test

收件人：

def authentication(fun):
    @tornado.gen.coroutine  # note
    def test(self, *args, **kwargs):
        ...
    return test

在龙卷风中使用数据库操作时如何在自定义装饰器中使用协程

how to use coroutine in custom decorator when working with db operations in tornado

python

tornado

tornado-motor