Celery beat 在 Django 中易挂掉因未等待 Django 初始化,需显式调用 django.setup()、用字符串路径引用任务、避免多进程重复启动 scheduler、统一配置时区并重启 beat 进程生效。

为什么 celery beat 在 Django 里容易挂掉
因为 celery beat 默认不感知 Django 的配置加载时机,一启动就去读 settings.py,但此时 Django 的 App 配置、数据库连接、时区设置都还没初始化好。常见现象是报 AppRegistryNotReady: Apps aren't loaded yet,或者定时任务跑着跑着突然不触发了。
实操建议:
- 必须在
celery.py中显式调用django.setup(),且放在Celery实例创建之后、app.conf.beat_schedule设置之前 - 避免在
beat_schedule里直接 import 视图或模型 —— 改用字符串路径,比如'myapp.tasks.send_report'而不是send_report - 如果用了数据库调度(如
DjangoScheduler),注意celery beat进程不能和worker共用同一数据库连接池,否则可能锁表或连接耗尽
django-apscheduler 启动就报 SchedulerAlreadyRunningError
这个错误不是并发问题,而是 Django 多进程启动(比如 runserver 开两个线程、或 gunicorn 多 worker)导致 APScheduler 被重复初始化。它不像 Celery 那样有明确的主控进程概念,每个 worker 都会尝试启动自己的 scheduler。
实操建议:
- 只在单个进程里启用 scheduler:用
if settings.DEBUG:包裹初始化逻辑,生产环境彻底禁用;或者更稳妥地,在manage.py启动时加判断:if os.environ.get('RUN_MAIN') == 'true': - 不要在
apps.py的ready()里启动 scheduler —— 它会被每个 app 加载一次,极易重复 - 数据库 backend 必须配
APSCHEDULER_DATETIME_FORMAT = 'N j, Y, f:s a',否则时间字段写入失败,后续所有 job 都静默失效
时区错乱:celery beat 和 django-apscheduler 都跑在 UTC,但你想按本地时间执行
Django 默认用 TIME_ZONE = 'Asia/Shanghai',但 Celery 默认无视它,APScheduler 更是默认全用系统时区(常为 UTC)。结果你设了 '09:00',实际却在凌晨 1 点执行。
实操建议:
- Celery:在
celery.py里加app.conf.timezone = 'Asia/Shanghai',并确保app.conf.enable_utc = False - APScheduler:初始化时传参
timezone='Asia/Shanghai',别依赖settings.TIME_ZONE自动推导 - 所有 cron 表达式(如
'0 0 * * *')和 datetime 字符串(如datetime(2024, 5, 1, 9, 0))都必须明确带 tzinfo,推荐用pytz.timezone('Asia/Shanghai').localize(...)
任务没进队列、日志也没输出?先查这三处
不是代码写错了,而是最基础的链路断在了看不见的地方。
实操建议:
- 确认
CELERY_BROKER_URL指向的是可用的 Redis/RabbitMQ,而不是本地redis://localhost:6379/0—— Docker 环境下得写宿主机 IP 或 service 名 - 检查
celery -A myproject worker -l info启动时有没有输出Tasks: {'myapp.tasks.xxx'},没有说明 task 没被自动发现,要确认__all__或@shared_task位置是否在可 import 路径下 - 运行
celery -A myproject beat -l info --scheduler django_celery_beat.schedulers:DatabaseScheduler,看有没有打印Writing entries...,没有就说明django-celery-beat的 migrations 没跑完,或者 admin 里没手动添加 PeriodicTask
真正麻烦的从来不是怎么配,而是改完配置后忘了 reload beat 进程,或者以为改了代码就能热更新定时规则 —— 实际上 celery beat 启动后就固化了 schedule,改了 beat_schedule 必须重启它。


















