python - RQ worker 抛出 "ValueError"

Question

我正在尝试让 RQ/RQ-Worker 在我的 Flask 应用程序上运行。我试图将其简化为一个非常简单的测试用例。这是总体思路:

1. 用户访问/test页。这会触发作业排队并返回排队作业的 job_key
2. 工作人员 ( worker.py ) 处理排队的作业。
3. 然后用户可以访问 /retrieve/<job_key>检索结果的页面。 [未显示。]

目前的工作只是加2 + 2。

这是应用程序代码:

from rq import Queue
from rq.job import Job

# import conn from worker.py
from worker import conn

app = Flask(__name__)

q = Queue(connection=conn)

def add():
  return 2+2

@app.route('/test')
def test():
  job = q.enqueue_call(func="add", args=None, result_ttl=5000)
  return job.get_id()

if __name__ == "__main__":
  app.run()

worker.py源代码如下所示:

from redis import StrictRedis
from rq import Worker, Queue, Connection

listen = ['default']
redis_url = 'redis://localhost:6379'
conn = StrictRedis.from_url(redis_url)
if __name__ == "__main__":
  with Connection(conn):
    worker = Worker(list(map(Queue, listen)))
    worker.work()

据我所知，应用程序代码不是问题所在。我可以访问/test将作业排队的页面。但是，一旦我运行 worker，就会出现以下错误:

Traceback (most recent call last):
  File "/home/<>/dev/sched/venv/lib/python3.5/site-packages/rq/worker.py", line 588, in perform_job
    rv = job.perform()
  File "/home/<>/dev/sched/venv/lib/python3.5/site-packages/rq/job.py", line 498, in perform
    self._result = self.func(*self.args, **self.kwargs)
  File "/home/<>/dev/sched/venv/lib/python3.5/site-packages/rq/job.py", line 206, in func
    return import_attribute(self.func_name)
  File "/home/<>/dev/sched/venv/lib/python3.5/site-packages/rq/utils.py", line 149, in import_attribute
    module_name, attribute = name.rsplit('.', 1)
ValueError: not enough values to unpack (expected 2, got 1)

我觉得行:

worker = Worker(list(map(Queue, listen)))

问题只是错误性质的 b/c，但我不知道如何解决它。特别是 b/c I've seen other projects似乎使用完全相同的 worker 源代码。

我的技术栈是:

1. flask (0.11.1)
2. Redis (2.10.5)
3. 请求质量 (0.6.0)
4. RQ-Worker (0.0.1)

编辑:

开始认为这是一个错误。在 RQ 的来源中查看此问题单:issue #531 .

Answer 1

对我来说，问题是由 RQ 无法解析我的工作模块引起的。

解决方案是为 enqueue 提供“限定”名称，例如:

job = q.enqueue("app.worker.add", data)