python - 强制 celery 使用 json 代替 pickle

Question

我已将 celery 配置为以下列方式使用 json:

CELERY_ACCEPT_CONTENT = ['json']
CELERY_TASK_SERIALIZER = 'json'
CELERY_RESULT_SERIALIZER = 'json'

但是，当工作人员收到任务时，它会生成以下错误:

ContentDisallowed: Refusing to deserialize untrusted content of type pickle (application/x-python-serialize)

我是否遗漏了一些可能未记录的内容。

Answer 1

问题是 celery 正在接受 json 并在发送任务时将其发送内容作为 pickle 因此出现错误。

如前所述here在调用时你必须指定序列化器(从 celery 4.0 开始默认为 json )

add.apply_async((10, 10), serializer='json')