我有 django 1.11.5 应用程序和 celery 4.1.0，我一直收到：
kombu.exceptions.EncodeError: <User: testuser> is not JSON serializable
我的设置.py：
CELERY_BROKER_URL = 'amqp://localhost'
CELERY_RESULT_BACKEND = 'amqp://localhost'
CELERY_ACCEPT_CONTENT = ['application/json']
CELERY_RESULT_SERIALIZER = 'json'
CELERY_TASK_SERIALIZER = 'json'
CELERY_TIMEZONE = 'Asia/Makassar'
CELERY_BEAT_SCHEDULE = {}
tasks.py
from __future__ import absolute_import, unicode_literals
from celery import task
from django.contrib.auth.models import User
@task(serializer='json')
def task_number_one():
user = User.objects.create(username="testuser", email="[email protected] /cdn-cgi/l/email-protection", password="pass")
return user
我在视图中调用任务：
def form_valid(self, form):
form.instance.user = self.request.user
task_number_one.delay()
return super().form_valid(form)
这是因为您正在使用 JSON 序列化程序进行任务序列化（如设置所示）CELERY_TASK_SERIALIZER = 'json'），但您试图返回一个模型实例（无法序列化为 JSON）。
您有两个选择：
1）不要传递实例，传递实例的主键，然后在任务中查找对象。
2）使用pickle相反，任务序列化器。这将允许您将对象作为参数传递给您的任务并返回它们，但带有它自己的安全问题 http://docs.celeryproject.org/en/latest/userguide/security.html#serializers.
本文内容由网友自发贡献，版权归原作者所有，本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容，请联系:hwhale#tublm.com(使用前将#替换为@)
