Django1.11.5+Celery4.1.0遇kombu编码错误：用户对象无法JSON序列化

嘿，这个问题我之前踩过坑！本质原因很直白：你把Django的User模型实例直接传给Celery任务了，但你配置的JSON序列化器根本处理不了这种复杂的类对象——JSON只能序列化字符串、数字、列表、字典这类原生数据类型，而User是带一堆属性和方法的模型实例，自然会触发序列化错误。

下面给你两个实用的解决方案，按推荐程度排序：

方案一：传递用户ID而非整个对象（最稳妥） #

这是业内最常用的做法，既避开了复杂对象序列化的麻烦，还能减少任务队列的数据传输量。

修改任务代码 #

把任务参数从user改成user_id，在任务内部通过ID重新获取User实例：

from __future__ import absolute_import, unicode_literals
from celery import shared_task
from django.contrib.auth.models import User

@shared_task
def your_task_name(user_id):
    # 通过ID获取用户实例，同时处理用户不存在的异常
    try:
        user = User.objects.get(id=user_id)
    except User.DoesNotExist:
        # 这里可以加日志记录或者直接终止任务
        return
    # 继续你的业务逻辑
    print(f"正在处理用户：{user.username}")

调用任务时传ID而非User对象 #

比如在视图或其他代码里调用任务：

# 错误写法：直接传User实例
# your_task_name.delay(request.user)

# 正确写法：传递用户ID
your_task_name.delay(request.user.id)

方案二：自定义JSON序列化器（适合特殊场景） #

如果你确实需要传递模型实例（不推荐，除非有特殊需求），可以自定义一个能处理Django模型的JSON序列化器，让Celery用它来序列化数据。

1. 创建自定义序列化器 #

在项目目录下新建celery_serializers.py文件：

import json
from django.core.serializers.json import DjangoJSONEncoder
from django.db import models
from kombu.serialization import register

class DjangoModelJSONEncoder(DjangoJSONEncoder):
    def default(self, obj):
        # 处理Django模型实例，这里返回ID，你也可以用model_to_dict返回所有字段
        if isinstance(obj, models.Model):
            return obj.id
        # 其他类型交给父类处理
        return super().default(obj)

# 定义序列化和反序列化方法
def django_model_json_dumps(obj):
    return json.dumps(obj, cls=DjangoModelJSONEncoder)

def django_model_json_loads(obj):
    return json.loads(obj)

# 注册自定义序列化器到Celery
register(
    'django-json',
    django_model_json_dumps,
    django_model_json_loads,
    content_type='application/json',
    content_encoding='utf-8'
)

2. 更新Celery配置 #

在settings.py里修改序列化相关配置：

CELERY_TASK_SERIALIZER = 'django-json'
CELERY_RESULT_SERIALIZER = 'django-json'
CELERY_ACCEPT_CONTENT = ['django-json', 'application/json']

注意事项 #

• 这个方案序列化后得到的是用户ID（或你定义的字段字典），反序列化时不会自动还原成User实例——如果任务需要完整模型，还是得自己通过ID查询。
• 如果选择序列化整个模型字典，要注意外键、ManyToMany字段的处理，避免冗余数据或序列化错误。

为什么你的现有配置没用？ #

虽然你设置了CELERY_TASK_SERIALIZER = 'json'，但默认的JSON序列化器不认识Django模型实例，它只能处理Python原生的可序列化类型。所以只要传模型实例，默认配置就会报错。

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