2

在 django shell 中运行此脚本：

import processors.topics.tasks as t
t.test.delay()

给出这个错误：

NotRegistered: 'processors.topics.tasks.test'

奇怪的是 chorus.processors.topics.tasks.test在我运行时肯定包含在 [Tasks] 打印输出中

python celeryd --verbosity=2 --loglevel=INFO --purge

为什么我会收到错误消息？

4

1 回答 1

1

它与您导入任务的方式有关，例如，您从项目而不是应用程序导入任务，chorus.processors.topics任务而不是processors.topics.tasks. 这会给 Celery 带来问题，因为客户端和服务器中的名称会有所不同。

以下是与以下问题相关的文档

于 2011-11-04T06:18:45.927 回答