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将作业排队的页面。但是，一旦我运行工作程序，我就会收到以下错误：

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)

我感觉就像那条线：

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)

问题只是错误性质的问题，但我不知道如何解决它。特别是 b/c我见过其他项目似乎使用完全相同的工作源代码。

我的技术栈是：

1. 烧瓶 (0.11.1)
2. Redis (2.10.5)
3. 需求量 (0.6.0)
4. RQ-工人 (0.0.1)

编辑：

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

Answer 1

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

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

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