python - redis redis.client rq Queue job.result # => None

Question

我正在尝试使用 Redis 找出 rq 队列。我有一个简单的 test_job 函数，我想在队列中使用它。

def test_job():
    return "OK"

脚本主要取自 rq 文档:

#!/usr/bin/env python

import redis.client
from rq import Queue
import time

from helpers import test_job

def main():

    q = Queue(connection=redis.client.Redis('localhost',6379)) 

    job = q.enqueue(test_job)
    print job.result   # => None

    while not job.result:
        time.sleep(2)
        print job.result   # => None

if __name__ == "__main__":
    main()

问题是我不会离开 while 循环。 job.result 仍然是 None。但是，根据日志，redis 连接似乎可以正常工作:

[1279] 30 Dec 12:08:20.041 - 0 clients connected (0 slaves), 612560 bytes in use
[1279] 30 Dec 12:08:21.371 - Accepted 127.0.0.1:58541
[1279] 30 Dec 12:08:25.337 - DB 0: 23 keys (0 volatile) in 32 slots HT.
[1279] 30 Dec 12:08:25.337 - 1 clients connected (0 slaves), 633664 bytes in use

Answer 1

您是否启动了一个 worker 来处理该任务？

看起来没有工作人员在运行(因为只有您的客户端连接到 Redis)。从项目的根目录运行 rqworker。