10

我正在使用 python-rq 来管理基于 Redis 的作业，并且我想确定我的工作人员当前正在处理哪些作业。

python-rq 提供了一个 get_current_job 函数来查找连接的“当前作业”，但是：

  1. 我无法让它工作，并且
  2. 我真的想要一个所有作业的列表，这些作业当前由该连接的所有队列上的所有工作人员处理，而不是一个队列中的一项作业。

这是我的代码（总是返回无）：

from rq import Queue, get_current_job
redis_url = os.getenv('REDIS_FOO')
parse.uses_netloc.append('redis')
url = parse.urlparse(redis_url)
conn = Redis(host=url.hostname, port=url.port, db=0, password=url.password)
q = Queue(connection=conn)
get_current_job(connection=conn)

有没有人有任何想法，请让上面的代码工作，但更重要的是，如何从这个连接的所有队列中的所有工作人员那里获取所有当前工作的列表？

4

1 回答 1

18

查看了一些源代码，我认为这是您需要的：

在此处输入图像描述

您还应该注意一件事：正在运行的作业的数量等于 rq worker 的数量。因为工人一次只处理一项工作。

from rq import Queue
from redis import Redis
from rq.registry import StartedJobRegistry

from jobs import count_words_at_url


redis_conn = Redis()
q = Queue('default', connection=redis_conn)

for i in range(5000):
    job = q.enqueue(count_words_at_url, 'http://nvie.com', ttl=43)

registry = StartedJobRegistry('default', connection=redis_conn)

running_job_ids = registry.get_job_ids()  # Jobs which are exactly running. 
expired_job_ids = registry.get_expired_job_ids()
于 2017-08-14T04:29:23.477 回答