在Django中使用Celery Beat创建PeriodicTask后任务未执行的问题

1. 核心问题：celery-beat未使用数据库调度器 #

默认celery-beat使用文件存储任务调度信息，不会读取django_celery_beat存在数据库中的PeriodicTask记录。必须启动beat时指定数据库调度器：

celery -A helpdesk beat -l INFO --scheduler django_celery_beat.schedulers:DatabaseScheduler

2. 检查django_celery_beat配置完整性 #

• 确保django_celery_beat已添加到settings.py的INSTALLED_APPS：

  INSTALLED_APPS = [
      # ... 其他已安装应用
      'django_celery_beat',
  ]
  

• 执行数据库迁移，创建django_celery_beat所需表：

  python manage.py migrate
  

3. 参数传递验证 #

你的代码中args=json.dumps((instance.id,))格式正确，celery会自动解析该JSON字符串为任务参数，任务函数create会收到instance.id作为data参数，这部分无需修改。

4. 日志排查 #

启动beat时增加日志级别到DEBUG，确认是否加载到目标任务：

celery -A helpdesk beat -l DEBUG --scheduler django_celery_beat.schedulers:DatabaseScheduler

如果日志中出现notification_xxx相关任务的加载记录，说明beat已正确读取数据库配置。

5. 基础环境检查 #

• 确认Redis服务正常运行，worker和beat都能连接到CELERY_BROKER_URL指定的地址。
• 确保worker和beat使用同一套Django配置。

内容的提问来源于stack exchange，提问作者Алексей Шаков