Django集成Celery执行后台任务时无法访问Model的问题求助

1. 事务提交延迟导致的查询失败 #

如果在创建Campaign后立刻触发Celery任务，Django的数据库事务可能还未完成提交，此时Celery进程查询不到刚创建的记录。

• 修复方式：使用transaction.on_commit()延迟任务触发，确保事务提交后再执行任务：

  from django.db import transaction
  
  # 创建Campaign的代码后，用以下方式触发任务
  transaction.on_commit(lambda: send_campaign_task.delay(campaign.id))
  

2. Celery数据库配置与主进程不一致 #

Celery进程必须和Django主进程使用相同的数据库配置，否则会连接到错误的数据库实例（比如测试库或其他环境的库）。

• 检查Supervisor中的Celery启动命令，确保指定了正确的Django settings：

  celery -A django_email_marketing worker --loglevel=info --settings=django_email_marketing.settings
  

• 也可以在Supervisor配置中设置环境变量：

  environment=DJANGO_SETTINGS_MODULE=django_email_marketing.settings
  

3. Celery未正确初始化Django环境 #

如果Celery没有加载正确的Django配置，即使使用apps.get_model也无法正确访问模型对应的数据库表。

• 确认项目根目录的celery.py配置正确：

  import os
  from celery import Celery
  
  # 设置Django settings环境变量
  os.environ.setdefault('DJANGO_SETTINGS_MODULE', 'django_email_marketing.settings')
  app = Celery('django_email_marketing')
  # 从Django settings导入Celery配置
  app.config_from_object('django.conf:settings', namespace='CELERY')
  # 自动发现所有app中的任务
  app.autodiscover_tasks()
  

• 可以尝试替换apps.get_model为直接导入模型，测试是否能正常查询：

  from campaigns.models import Campaign
  

4. 确认数据库中目标记录确实存在 #

手动验证数据库中是否存在ID为6的Campaign记录：

• 进入Django shell执行查询：

  python manage.py shell
  >>> from campaigns.models import Campaign
  >>> Campaign.objects.get(pk=6)
  

• 如果查询失败，说明任务触发时传入的ID有误，或者记录已被删除。

5. Supervisor工作目录配置错误 #

如果Supervisor启动Celery时的工作目录不是Django项目根目录，会导致settings加载路径错误，进而连接到错误的数据库。

• 在Supervisor的[program:celery]配置块中添加项目根目录：

  directory=/home/boualam/django_email_marketing
  

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