我已将 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)
我是否遗漏了一些可能未记录的内容。
最佳答案
问题是 celery 正在接受 json 并在发送任务时将其发送内容作为 pickle 因此出现错误。
如前所述here在调用时你必须指定序列化器(从 celery 4.0 开始默认为 json )
add.apply_async((10, 10), serializer='json')
关于python - 强制 celery 使用 json 代替 pickle，我们在Stack Overflow上找到一个类似的问题： https://stackoverflow.com/questions/36919065/