Docker部署Django+Celery时任务无法写入数据库并报错

数据老陈

2026-8-11

问题分析与解决办法

你的问题核心可能出在数据库访问一致性和Celery结果后端的依赖配置上，结合你的配置和报错信息，以下是具体排查和解决步骤：

1. 排查SQLite导致的多容器数据不一致（关键）

从你的docker-compose配置看，没有单独的数据库服务，推测你用的是SQLite文件型数据库。这种情况下，web容器和Celery容器的数据库文件是独立的（除非共享了包含数据库文件的卷）：

web容器中创建的mymodel数据，Celery容器根本看不到，所以执行任务时会报DoesNotExist
django-db需要的结果表（django_celery_results_taskresult等）只在web容器的数据库中创建，Celery容器没有这些表，导致任务结果无法写入

解决办法：

方案A：改用PostgreSQL/MySQL替代SQLite（推荐）

添加数据库服务到docker-compose，修改Django的数据库配置指向这个服务：

更新docker-compose.yml，添加db服务：

services:
  # 新增db服务
  db:
    image: postgres:15-alpine
    volumes:
      - postgres_data:/var/lib/postgresql/data/
    environment:
      - POSTGRES_USER=your_user
      - POSTGRES_PASSWORD=your_password
      - POSTGRES_DB=your_db_name
    networks:
      - braythonweb-network

  # 修改braythonweb和celery服务，添加数据库依赖
  braythonweb:
    # ... 原有配置
    depends_on:
      - db
      - redis

  celery:
    # ... 原有配置
    depends_on:
      - db
      - redis

volumes:
  postgres_data:

在Django的settings.py中修改数据库配置：

DATABASES = {
    'default': {
        'ENGINE': 'django.db.backends.postgresql',
        'NAME': os.environ.get('POSTGRES_DB'),
        'USER': os.environ.get('POSTGRES_USER'),
        'PASSWORD': os.environ.get('POSTGRES_PASSWORD'),
        'HOST': 'db',
        'PORT': 5432,
    }
}

方案B：共享SQLite文件卷（仅测试用，不推荐生产）

如果只是测试，需要把SQLite文件所在的目录挂载到两个容器：

假设你的SQLite文件在项目根目录的db.sqlite3，修改web和celery服务的volumes：

braythonweb:
  volumes:
    - .:/code
    # 确保数据库文件所在目录被共享
    - ./:/code/
celery:
  volumes:
    - .:/code
    - ./:/code/

注意：SQLite不支持多进程/多容器并发写，生产环境绝对不能用这种方式。

2. 确保Celery容器能访问到django_celery_results的表

CELERY_RESULT_BACKEND = 'django-db'依赖django_celery_results库的数据库表，你需要：

确保已经安装django-celery-results，并添加到INSTALLED_APPS：

INSTALLED_APPS = [
    # ... 其他app
    'django_celery_results',
]

确保Celery容器启动前，数据库迁移已完成。可以修改Celery的command，先等待数据库就绪再启动worker：

celery:
  command: >
    sh -c "python manage.py migrate &&
           celery -A braython worker -l info"

（如果需要等待数据库服务启动，可自行实现wait_for_db管理命令，或使用第三方库如django-wait-for-db）

3. 检查任务参数传递方式

Celery用json序列化任务参数，无法直接传递Django模型对象，必须传递主键：

错误写法：

# 任务调用时传递对象
my_task.delay(mymodel_instance)

正确写法：

# 传递主键，任务内部查询模型
my_task.delay(mymodel_instance.id)

# 任务定义
@app.task
def my_task(model_id):
    my_instance = MyModel.objects.get(id=model_id)
    # 执行任务逻辑

4. 验证Celery容器的数据库连接

在Celery容器中执行命令，测试是否能连接到数据库并查询模型：

# 进入Celery容器
docker exec -it cl01 bash
# 进入Django shell
python manage.py shell
# 尝试查询模型
from myapp.models import mymodel
mymodel.objects.all()

如果查询不到数据，说明数据库连接或数据一致性有问题，回到第一步排查。

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

Docker部署Django+Celery时任务无法写入数据库并报错

1. 排查SQLite导致的多容器数据不一致（关键） #

解决办法： #