自定义装饰器中的龙卷风异步操作

Question

我正在尝试使用redis和龙卷风库为我的龙卷风路由处理程序构建一个缓存装饰器。这是我到目前为止所拥有的：

def rediscache(route):
    def decorator(func):
        @wraps(func)
        def wrapper(*args, **kwargs):
            result = yield redis.call("GET", "latest_info")
            print(result)
            func(*args, **kwargs)
        return wrapper
    return decorator

在我的路由处理程序中，我像这样使用它：

class MainHandler(tornado.web.RequestHandler):
    def initialize(self, db, redis):
        self.db = db
        self.quakes = self.db.quakes
        self.redis = redis
    @gen.coroutine
    @rediscache('route_is_here')
    def get(self):
        ''' ... handler logic here ... '''

问题是，如果我使用我的装饰器，我将停止看到我的处理程序到 Web 的输出。如果代替...

result = yield redis.call("GET", "latest_info")

我愿意。。。

result = redis.call("GET", "latest_info")

然后我开始再次在浏览器中看到输出，但这是正确的方法吗？这仍然是异步的吗？如果不是，那么道具的方法是什么？谢谢！

Answer 1

如果要

yield协程，则应gen.coroutine装饰器中的包装器：

def rediscache(route):
    def decorator(func):
        @tornado.gen.coroutine
        @wraps(func)
        def wrapper(*args, **kwargs):
            result = yield redis.call("GET", "latest_info")
            print(result)
            if not result:
                new = yield func(*args, **kwargs)
                # save to
        return wrapper
    return decorator

您还需要将装饰器的顺序更改为：

@rediscache('route_is_here')
@gen.coroutine
def get(self):
    ''' ... handler logic here ... '''

编辑

装饰器订单说明

@second
@first
def my_func():
    pass

与

my_func = second(first(my_func))

因此，如果您想在装饰器中等待（生成）原始get，则必须传递协程，因此它必须在rediscache之前。

有关装饰器的更多信息 - https://wiki.python.org/moin/PythonDecorators