如何解决Celery中接收未注册任务的报错问题

我之前也碰到过一模一样的问题，核心原因其实很简单：你的Celery Worker启动时没有加载到任务定义模块，所以它识别不了Beat发送过来的任务名。下面是具体的解决步骤和代码调整建议：

1. 修正Beat任务调度的配置格式 #

先看你的beat_schedule配置，原来的写法有个小问题：任务的键名应该是自定义的任务标识（比如'daily-facebook-api-job'），而不是'task'；另外crontab的参数也需要调整——如果你想指定每周的执行天数，要用day_of_week而非day（day指的是每月日期）。修正后的配置如下：

app.conf.beat_schedule = {
    'daily-facebook-api-job': {  # 给任务起一个唯一的标识名
        'task': 'facebook-call.facebook_api',
        'schedule': crontab(hour=0, minute=0, day_of_week='0-6'),
    },
}

2. 让Worker启动时自动加载任务 #

Celery Worker默认不会自动发现所有任务，你需要在Celery实例初始化时显式指定要加载的任务模块。修改你的Celery初始化代码，加上include参数：

from celery import Celery
from celery.schedules import crontab

# 加上include参数，指定包含任务的模块名（即你的Python文件名，不带.py后缀）
app = Celery('facebook-call', broker='amqp://localhost//', include=['FacebookAPICall'])

@app.task
def facebook_api():
    # 你的函数逻辑
    print("Executing Facebook API task...")

app.conf.beat_schedule = {
    'daily-facebook-api-job': {
        'task': 'facebook-call.facebook_api',
        'schedule': crontab(hour=0, minute=0, day_of_week='0-6'),
    },
}

3. 确保启动命令的工作目录正确 #

假设你的代码文件名叫FacebookAPICall.py，请先切换到该文件所在的目录，再执行启动命令：

# 启动Beat进程
celery -A FacebookAPICall beat --loglevel=info
# 启动Worker进程
celery -A FacebookAPICall worker --loglevel=info

如果你的文件在子目录中，可以通过设置PYTHONPATH让Worker找到模块，比如：

PYTHONPATH=/path/to/your/project celery -A FacebookAPICall worker --loglevel=info

错误原因补充 #

Beat进程只负责按照调度规则把任务消息发送到RabbitMQ，但Worker需要知道任务的具体定义（比如函数逻辑）才能执行。如果Worker启动时没有加载到你的facebook_api任务，它就会判定这个任务未注册，直接丢弃消息。

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