Django+Celery结果无法存入django-db后端，疑与CockroachDB有关

问题背景 #

使用Django 4.1 + CockroachDB（兼容Postgres）+ Redis（Heroku部署），Celery Worker能正常识别并执行任务，但结果无法存入django-db后端，无报错信息。已完成以下操作仍未解决：

• 将django_celery_results加入INSTALLED_APPS
• 设置CELERY_RESULT_BACKEND='django-db'
• 用celery -A kmaofny worker --loglevel=info -E启动Worker
• 验证任务结果对象的后端为django_celery_results.backends.database.DatabaseBackend

排查与解决方案 #

1. 确认django_celery_results迁移适配CockroachDB #

执行迁移并验证表结构：

python manage.py migrate django_celery_results

检查数据库中django_celery_results_taskresult表：

• 确认task_id字段长度为191（匹配DJANGO_CELERY_RESULTS_TASK_ID_MAX_LENGTH=191配置）
• 确认字段类型兼容CockroachDB（如JSON、UUID类型的支持是否与PostgreSQL一致）

2. 确保任务有明确返回值 #

检查任务函数是否包含return语句，示例：

from celery import shared_task

@shared_task
def add_numbers(a, b):
    # 必须明确返回结果，无返回值时结果为None（理论上仍会存储，但需验证）
    return a + b

3. 开启Worker debug日志排查静默错误 #

将日志级别调至debug，查看结果存储阶段的细节：

celery -A kmaofny worker --loglevel=debug -E

重点关注含result、database、save的日志条目，排查是否存在数据库写入失败的静默异常（如权限不足、字段约束冲突）。

4. 手动测试数据库写入能力 #

在Django Shell中直接创建TaskResult对象，验证数据库存储功能：

from django_celery_results.models import TaskResult
from celery.utils.time import timezone

test_result = TaskResult(
    task_id="test-task-001",
    status="SUCCESS",
    result=6,
    date_done=timezone.now()
)
try:
    test_result.save()
    print("结果存储成功")
except Exception as e:
    print(f"存储失败，错误：{str(e)}")

若报错，可直接定位数据库层面问题（如CockroachDB不支持的字段类型、索引冲突）。

5. 验证Worker进程的数据库连接 #

在任务中添加数据库连接测试代码，确认Worker能正常访问数据库：

from celery import shared_task
from django.db import connection

@shared_task
def add_numbers(a, b):
    with connection.cursor() as cursor:
        cursor.execute("SELECT 1")
        print("数据库连接正常：", cursor.fetchone())
    return a + b

查看Worker日志是否输出数据库连接正常：(1,)，排除Worker进程无法连接数据库的可能。

6. 确认Celery配置加载正确 #

查看Worker启动日志，确认result_backend条目输出为django-db，避免配置被其他逻辑覆盖。

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