python - 如何在 RQ python 中通过 id 获取作业？

Question

所以，基本上我想构建一个在 heroku 上使用 RQ 的长轮询应用程序。我看过这个问题Flask: passing around background worker job (rq, redis)但它没有帮助。

这基本上就是我正在做的。

@app.route('/do_something', methods=['POST'])
def get_keywords():
    data_json = json.loads(request.data)
    text = urllib.unquote(data_json["sentence"])

    job = q.enqueue(keyword_extraction.extract, text)
    return job.key

@app.route('/do_something/<job_id>', methods=['GET'])
def get_keywords_results(job_id):
    job = Job().fetch(job_id)

    if(not job.is_finished):
        return "Not yet", 202
    else:
        return str(job.result)

没有什么花哨的，所以当POST请求到来时，它会将作业排队并立即将job_id返回给用户，然后用户将使用 key 不断轮询结果。但是，我似乎无法让它工作，因为这行 Job().fetch(job_id) 返回

NoRedisConnectionException:无法解析 Redis 连接。

任何帮助将不胜感激。

Answer 1

我已经发现了这一点，以防有人感兴趣。必须是这个。

Job.fetch(job_id, connection=conn)