如何使用 django-celery 配置 TASK_SERIALIZER

Question

我正在使用 django-celery，我想将 TASK_SERIALIZER 设置为 JSON 而不是 pickle。

从而在每个方法的基础上执行此操作

@task

我可以通过将我的任务装饰器从 更改为

@task(serializer="json")

但我想在全球范围内执行此操作， 。 settings.py 中的设置

TASK_SERIALIZER="json"

不起作用。尝试运行

import celery
celery.conf.TASK_SERIALIZER="json"

（如此处所暗示的那样）会导致

AttributeError: 'module' object has no attribute 'conf'

任何想法如何配置此设置当通过 django 运行 celery 时？

Answer 1

想通了。

在 settings.py 中，您需要设置

CELERY_TASK_SERIALIZER = "json"

文档令人困惑，至少对我而言。

Answer 2

我发现创建一个 celeryconfig 文件（如文档推荐的那样）使事情变得更加清晰。

celeryconfig.py

# Celery configuration file
BROKER_URL = 'amqp://'
CELERY_RESULT_BACKEND = 'amqp://'

CELERY_TASK_SERIALIZER = 'json'
CELERY_RESULT_SERIALIZER = 'json'
CELERY_TIMEZONE = 'America/Los_Angeles'
CELERY_ENABLE_UTC = True

您可以使用此命令发送设置（一旦您调用 Celery）

celery.config_from_object('celeryconfig')

Answer 3

来自 文档：

对于任务消息，您可以设置 CELERY_TASK_SERIALIZER 设置
到“json”或“yaml”而不是pickle。目前没有
任务结果的替代解决方案（但编写自定义结果
使用 JSON 的后端是一个简单的任务）

因此设置 CELERY_RESULT_SERIALIZER = "json" 看起来毫无用处。就我而言，结果仍处于泡菜状态（Celery 3.1.3）。是的。我知道...