python-rq worker 未读取队列中的作业
python-rq worker not reading jobs in queue
我在设置 python-rq 时遇到了一个基本问题 - rqworker
似乎无法识别推送到它正在侦听的队列的作业。
virtualenv
里面的一切都是运行
我有以下代码:
from redis import Redis
from rq import Queue
from rq.registry import FinishedJobRegistry
from videogen import videogen
import time
redis_conn = Redis(port=5001)
videoq = Queue('medium', connection=redis_conn)
fin_registry = FinishedJobRegistry(connection=redis_conn, name='medium')
jobid = 1024
job = videoq.enqueue(videogen, jobid)
while not job.is_finished:
time.sleep(2)
print job.result
这里 videogen
是一个简单的函数,它立即 returns 它接收到的整数参数。
在 运行 宁 rqworker medium
并启动应用程序,没有打印结果。除此之外,rqworker 没有额外的痕迹:
14:41:29 RQ worker started, version 0.5.0
14:41:29
14:41:29 *** Listening on medium...
redis 实例可以从我 运行 rqworker 所在的同一个 shell 访问,甚至显示更新的密钥:
127.0.0.1:5001> keys *
1) "rq:queues"
2) "rq:queue:medium"
3) "rq:job:9a46f9c5-03e1-4b08-946b-61ad2c3815b1"
那么这里可能缺少什么?
愚蠢的错误 - 必须向 rqworker
提供 redis 连接 url
rqworker --url redis://localhost:5001 medium
我在设置 python-rq 时遇到了一个基本问题 - rqworker
似乎无法识别推送到它正在侦听的队列的作业。
virtualenv
里面的一切都是运行
我有以下代码:
from redis import Redis
from rq import Queue
from rq.registry import FinishedJobRegistry
from videogen import videogen
import time
redis_conn = Redis(port=5001)
videoq = Queue('medium', connection=redis_conn)
fin_registry = FinishedJobRegistry(connection=redis_conn, name='medium')
jobid = 1024
job = videoq.enqueue(videogen, jobid)
while not job.is_finished:
time.sleep(2)
print job.result
这里 videogen
是一个简单的函数,它立即 returns 它接收到的整数参数。
在 运行 宁 rqworker medium
并启动应用程序,没有打印结果。除此之外,rqworker 没有额外的痕迹:
14:41:29 RQ worker started, version 0.5.0
14:41:29
14:41:29 *** Listening on medium...
redis 实例可以从我 运行 rqworker 所在的同一个 shell 访问,甚至显示更新的密钥:
127.0.0.1:5001> keys *
1) "rq:queues"
2) "rq:queue:medium"
3) "rq:job:9a46f9c5-03e1-4b08-946b-61ad2c3815b1"
那么这里可能缺少什么?
愚蠢的错误 - 必须向 rqworker
提供 redis 连接 url
rqworker --url redis://localhost:5001 medium