从 python-rq 获取所有当前工作

Question

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

python-rq 提供了一个 get_current_job 函数来查找 'the current job' 连接但是：

我无法让它工作，并且
我真的想要一份 all 工作的列表，这些工作目前正在由 all 工作人员在 all 上处理 此连接的队列，而不是来自一个队列的一个作业。

这是我的代码（总是 returns None）：

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)

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

Answer 1

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

还有一件事你应该注意：运行作业的数量等于 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()

从 python-rq 获取*所有*当前工作

Get *all* current jobs from python-rq

python

python-rq

从 python-rq 获取所有当前工作

Get all current jobs from python-rq