Docker+Flask+Celery+Redis+Beat定时任务未按每分钟执行排查

核心原因：配置键名不符合Celery 5.x版本规范 #

你使用的是Celery 5.3.4，该版本已弃用带CELERY_前缀的配置键，改用小写无前缀的键名。当前app.py中使用的CELERY_BEAT_SCHEDULE不会被Celery Beat识别，导致调度任务未加载。

具体修正步骤 #

1. 修改app.py中的Celery配置键名 #

将CELERY_BEAT_SCHEDULE替换为beat_schedule，同时建议统一更新其他旧版配置键：

# app.py 中的Celery配置部分
app.config['broker_url'] = 'redis://redis:6379/0'  # 替换原CELERY_BROKER_URL
app.config['result_backend'] = 'redis://redis:6379/0'
app.config['CELERYD_TASK_LOG_SUCCESS'] = False
app.config['beat_schedule'] = {  # 替换原CELERY_BEAT_SCHEDULE
    'delete_old_conversations': {
        'task': 'services.celery.tasks.delete_conversations_and_child_messages_after_.delete_conversations_and_child_messages_after_task',
        'schedule': crontab(minute='*/1'),
    },
}

2. 重启相关容器 #

执行以下命令重启Beat和Worker服务，确保配置生效：

docker-compose restart beat worker

验证修正效果 #

重启后查看Beat日志，若配置加载成功，日志中会显示类似以下的调度任务信息：

docwise-backend-beat-1  | [tasks]
docwise-backend-beat-1  |   . services.celery.tasks.delete_conversations_and_child_messages_after_.delete_conversations_and_child_messages_after_task
docwise-backend-beat-1  | [2023-xx-xx xx:xx:xx,xxx: INFO/MainProcess] Scheduler: Sending due task delete_old_conversations (services.celery.tasks.delete_conversations_and_child_messages_after_.delete_conversations_and_child_messages_after_task)

额外说明 #

• 手动调用任务正常，说明任务路径、Worker与Redis的连接均无问题，仅Beat未加载到调度配置。
• Celery 5.x版本中，所有原CELERY_*前缀的配置键均已对应改为小写无前缀形式，例如CELERY_TIMEZONE改为timezone，建议统一更新以避免后续问题。

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