0

我在我的项目中使用django-rq。

我想要实现的目标： 我有一个加载模板的第一个视图，该模板从网络摄像头获取图像并保存在我的电脑上。然后，视图调用第二个视图，其中处理图像的异步任务使用 rq 排队。最后，在 20 秒延迟后，调用第三个视图。在后一种观点中，我想检索异步任务的结果。

问题：作业对象已正确创建，但队列始终为空，因此无法使用queue.fetch_job(job_id). 读到这里，我设法在 FinishedJobRegistry 中找到了这份工作，但我无法访问它，因为注册表不可迭代。

from django_rq import job
import django_rq
from rq import Queue
from redis import Redis
from rq.registry import FinishedJobRegistry

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

def wait(request): #second view, starts the job
    template = loader.get_template('pepper/wait.html')
    job = q.enqueue(processImage)
    print(q.is_empty()) # this is always True!
    last_job_id = job.id # this is the expected job id
    return  HttpResponse(template.render({},request))

def ceremony(request): #third view, retrieves the result
    template = loader.get_template('pepper/ceremony.html')
    print(q.is_empty()) # True
    registry = FinishedJobRegistry('default', connection=redis_conn)
    finished_job_ids = registry.get_job_ids() #here I have the correct id (last_job_id)
    return HttpResponse(template.render({},request))

问题：如何从已完成的作业注册表中检索异步作业的结果？或者，更好的是，我怎样才能正确地将工作排入队列？

4

1 回答 1

0

我找到了另一种方法：我只是使用一个全局作业列表，我正在视图中对其进行修改。无论如何，我想知道这样做的正确方法......

于 2018-01-04T15:59:31.663 回答