Celery未注册任务问题求助：已遵循教程仍遇异常

看起来你已经完成了基础配置，但未注册任务的问题大多和Worker无法正确定位到你的Celery App或任务模块有关。结合你的项目结构和代码，我整理了几个最可能的解决方向：

1. 确保Worker启动时指定了正确的App路径 #

你的项目结构是：

|-module
  |-tasks
    |-__init__.py
    |-tasks.py

Worker启动时必须能找到module.tasks.tasks里的app实例。如果你的终端当前目录是module的父目录（即能看到module文件夹的目录），正确的启动命令应该是：

celery -A module.tasks.tasks worker --loglevel=info

如果你的终端在module目录下，命令则改为：

celery -A tasks.tasks worker --loglevel=info

要是省略了-A参数或者路径指定错误，Worker根本找不到你的任务定义，自然会提示未注册。

2. 优化__init__.py的内容 #

虽然你的__init__.py是空的，但可以通过它简化App的引用路径。在module/tasks/__init__.py中添加以下代码：

from .tasks import app

之后启动Worker时就能用更简洁的路径：

celery -A module.tasks worker --loglevel=info

这能避免因路径层级问题导致的模块识别失败。

3. 排查模块命名冲突 #

你的任务文件名叫tasks.py，和所在目录名tasks完全一致，虽然Celery 4.1.0通常能处理这种情况，但偶尔会出现导入混淆。可以尝试把tasks.py重命名为my_tasks.py，然后调整代码：

# my_tasks.py
from celery import Celery
app = Celery("tasks", broker="redis://localhost:6379/0", backend="redis://localhost:6379/0")

@app.task
def add(x, y):
    return x + y

同时更新__init__.py：

from .my_tasks import app

再用新路径启动Worker：

celery -A module.tasks worker --loglevel=info

4. 验证任务是否被成功注册 #

启动Worker后，你可以在Worker的日志里查看已注册的任务列表。如果日志里没有出现add任务，说明Worker确实没加载到它，回到前面的步骤检查路径和导入逻辑。

另外，调用任务时也要确保引用正确的模块路径，比如在调用端应该这样导入：

from module.tasks.tasks import add
# 或者优化__init__.py后，用 from module.tasks import add
add.delay(1, 2)

内容的提问来源于stack exchange，提问作者Callum Osborn