Celery worker 启动后任务不自动执行，因其仅为被动消费者，只消费消息代理中的任务；要实现定时自动执行，必须配合 celery beat 调度器（如每天8点发邮件），它独立运行、按 beat_schedule 配置向 broker 投递任务消息，worker 再执行。
直接说结论：Celery 本身不自动“调度”任务，它只负责分发和执行；真正实现“自动化任务队列处理”，必须配合 celery beat（周期性调度器）或外部触发机制（如 Webhook、文件监听、数据库轮询），且需明确区分「定时任务」和「事件驱动型异步任务」两类场景。
为什么 celery worker 启动后任务不自动跑？
Celery worker 只是被动消费者——它不会主动拉取或触发任务，只等消息中间件（如 Redis、RabbitMQ）里有任务就执行。常见误解是“启动 worker 就等于启动自动化”，结果发现写了 @app.task 却没反应。
- 确认你是否真的发出了任务：用
my_task.delay()或my_task.apply_async()显式调用，而不是只定义函数 - 检查 broker 连接是否通：worker 启动日志里有没有
Connected to redis://...或连接失败警告 - 确保 task 名在 worker 和 producer 端一致（尤其跨项目时容易因模块导入路径不同导致注册名不一致）
- 别忽略序列化问题：默认用
pickle，但若 worker 和 producer Python 版本或依赖不一致，会静默失败；建议显式设task_serializer='json'
如何让任务按固定时间自动执行（比如每天 8 点发邮件）？
必须启用 celery beat，它是一个独立进程，负责按配置生成定时任务并推送到 broker。仅靠 worker 是做不到的。
- 在 Celery 实例中配置
beat_schedule，键名任意，但值必须含task（字符串全路径）和schedule（crontab或timedelta） - 示例：
app.conf.beat_schedule = { 'send-daily-report': { 'task': 'tasks.send_report', 'schedule': crontab(hour=8, minute=0), } } - 启动命令要分开：一个终端跑
celery -A tasks worker --loglevel=info，另一个跑celery -A tasks beat --loglevel=info - 注意时区：
crontab默认用系统本地时区，若部署在 Docker 或 UTC 服务器上，务必设timezone = 'Asia/Shanghai'并配enable_utc = False
怎样避免任务重复执行或丢失？
这取决于 broker 类型和任务配置，不是 Celery 单方面能保证的。
立即学习“Python免费学习笔记（深入）”；
- Redis 作 broker 时，默认不持久化任务，worker 崩溃且未 ack 的任务会丢失；加
task_acks_late = True+worker_prefetch_multiplier = 1可提升可靠性（但降低吞吐） - RabbitMQ 更适合生产环境：启用
durable队列 +delivery_mode=2（消息持久化）+ 手动 ack - 幂等性必须由业务代码保障：比如任务参数带唯一
run_id，执行前查 DB 是否已存在该记录 - 别依赖
retry解决根本问题：设置autoretry_for=(Exception,)很方便，但如果失败原因是数据库连接超时，重试 3 次可能全失败，不如先做健康检查
最常被忽略的一点：Celery 的「自动化」本质是「可编程的触发 + 可靠的投递」，而不是黑盒调度器。从定义 task 到配置 beat、选型 broker、处理失败重试，每一步都要主动决策，没有开箱即用的“全自动”。
