Celery Beat无法自动执行任务，手动触发正常的问题排查求助

核心问题 #

手动调用increment_value.delay()时任务正常执行，但Celery Beat的自动触发功能失效——Redis按时间间隔更新，但任务方法未被调用。Worker和Beat进程均已正常启动，运行环境为WSL2 + Docker。

可能的原因及修复方案 #

1. Celery配置键命名不兼容 #

Celery 4.x及以上版本默认使用小写配置键，你的config.py中使用了大写的CELERY_BEAT_SCHEDULE，会导致Beat无法识别调度规则。同时timedelta未导入，会直接引发运行错误。

修复：
修改config.py内容：

from datetime import timedelta  # 必须导入timedelta

broker_url = f'redis://{REDIS_IP}:6379/0'
result_backend = f'redis://{REDIS_IP}:6379/0'
task_serializer = 'json'
result_serializer = 'json'
accept_content = ['json']
timezone = 'UTC'

# 将大写的CELERY_BEAT_SCHEDULE改为小写的beat_schedule
beat_schedule = {
    'run-every-15-seconds': {
        'task': 'scheduler.increment_value',
        'schedule': timedelta(seconds=15),
    },
}

2. Beat调度存储的持久化问题 #

默认情况下，Beat会将调度状态存在本地文件celerybeat-schedule，但Docker容器内的临时文件会在重启后丢失，且可能因权限问题无法写入，导致调度逻辑异常。

修复：
指定Beat使用Redis作为调度存储（与Broker共用），需要先安装依赖celery-beat-redis，然后修改配置和启动命令：

• 在requirements.txt中添加celery-beat-redis
• 修改config.py添加调度器配置：

  beat_scheduler = 'celerybeatredis.schedulers.RedisScheduler'
  

• 修改start.sh中的Beat启动命令：

  #!/bin/sh
  celery -A scheduler worker --loglevel=info &
  celery -A scheduler beat --loglevel=info --scheduler celerybeatredis.schedulers.RedisScheduler
  

3. Docker进程启动顺序问题 #

start.sh中用&将Worker后台启动后立即启动Beat，可能出现Beat已开始发任务，但Worker尚未完成初始化的情况，导致任务无法被消费。

修复：
在启动Beat前添加短暂延迟，确保Worker就绪：

#!/bin/sh
celery -A scheduler worker --loglevel=info &
sleep 5  # 等待Worker完成启动
celery -A scheduler beat --loglevel=info

4. 时区配置不匹配 #

config.py中时区设为UTC，但WSL2或FastAPI服务可能使用其他时区，导致Beat的调度时间计算偏差，任务未在预期时间触发。

修复：
将时区改为与FastAPI服务一致（例如Asia/Shanghai），同时同步Docker容器时区：

• 修改config.py：

  timezone = 'Asia/Shanghai'
  

• 在Dockerfile中添加时区配置：

  RUN ln -snf /usr/share/zoneinfo/Asia/Shanghai /etc/localtime && echo Asia/Shanghai > /etc/timezone
  

5. 任务路径识别问题 #

Beat可能无法正确解析scheduler.increment_value的任务路径，需确保Celery应用名称与模块名一致。

修复：
在scheduler.py中显式指定Celery应用名称：

from celery import Celery

# 指定应用名称为'scheduler'，与模块名匹配
app = Celery('scheduler')
app.config_from_object('config')

@app.task
def increment_value():
    import requests
    import logging
    response = requests.post(url=f"http://{FASTAPI_IP}:8000/redis/first")
    logging.info("Task Has Been Triggered")
    return response.json()

验证步骤 #

1. 重启Docker容器，查看Beat日志，确认是否输出Scheduler: Sending task scheduler.increment_value
2. 查看Worker日志，确认是否输出Received task: scheduler.increment_value
3. 用redis-cli执行LRANGE celery 0 -1，检查Redis队列中是否有未消费的任务

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