python-3.x - 是否可以以异步/等待方式将任务发送到 pyRQ redis 队列？

Question

pyRQ是否可以以异步/等待方式将任务发送到redis 队列？

我正在使用tornado支持新 python await/async功能的框架。

看这个例子：

@job(`default`, connection=redis_conn)
def add(a: int, b: int):
    logger.info('Dummy adding task for {} and {}'.format(a, b))
    import time
    time.sleep(1)
    return a + b

现在，在我的RequestHandler我可以这样做：

add.delay(2, 3)

由于与 Redis 的连接过程，上面的行会产生 I/O 块。有谁知道如何将@job装饰器更改为async版本，然后有这样的行：

await add.delay(2, 3)

标签： python-3.xredispython-asyncio