将结果传递给取决于工作 - python rq

Question

如何将作业的结果传递给依赖它的作业？

我目前所做的是将第一份工作的 id 传递给第二份工作，

first = queue.enqueue(firstJob)
second = queue.enqueue(secondJob, first.id, depends_on=first);

并在 secondJob 中获取第一个作业以获取结果

first = queue.fetch_job(previous_job_id)
print first.result

这是推荐的方式吗？我可以使用任何其他模式将第一份工作的结果直接传递给第二份工作吗？

Answer 1

在我自己的设置中，我使用了两个作业，第二个取决于第一个的结果。它们运行在不同的队列中，如果第一个作业获得成功结果，它会在第二个作业的队列中放置一个作业，并在创建作业时传递必要的数据。它对我来说效果很好。

希望对您有所帮助。

Answer 2

您可以从作业本身访问有关当前作业及其依赖项的信息。这样就无需显式传递第一份工作的 ID。

定义您的工作：

from rq import Queue, get_current_job
from redis import StrictRedis

conn = StrictRedis()
q = Queue('high', connection=conn)

def first_job():
    return 'result of the first job'

def second_job():
    current_job = get_current_job(conn)
    first_job_id = current_job.dependencies[0].id
    first_job_result = q.fetch_job(first_job_id).result
    assert first_job_result == 'result of the first job'

排队您的作业：

first = queue.enqueue(first_job)
second = queue.enqueue(second_job, depends_on=first)

请注意，current_job 可以有多个依赖项，因此 current_job.dependencies 是一个列表。

Answer 3

使用 rq 0.13.0，我们可以通过

获取父作业

current_job = get_current_job(redis_conn)
job = current_job.dependency

将结果传递给取决于工作 - python rq

Passing results to depending on job - python rq

python

python-rq