如何解决带有PostgreSQL的celery result_backend-任务表中某些字段的null
我正在将芹菜用于POC。我的目标是在整个分布式系统上创建工作流程。
出于POC的目的,我创建了几个Docker容器,每个容器的工作人员均以queue选项开头。我从另一个容器启动了一条链。链在容器之间成功执行。现在,我决定启用result_backend
来存储每个执行任务的结果。
我使用schema选项将result_backend
设置为postgresql
。现在执行了链后,我确实看到了在postgres中创建的表。但是task_meta
表中的某些列为null(例如,worker,queue。)task_id
和状态已正确填充。
有人遇到过类似的问题吗?任何帮助表示赞赏。
解决方法
我知道您问这个问题已经很长时间了,但我希望它能帮助其他人。
默认情况下,Celery 不会将所有任务结果属性写入后端。
您必须通过将 result_extended
设置为 True
来配置它,如下所述:https://docs.celeryproject.org/en/stable/userguide/configuration.html#result-extended
因此,如果您从 python 配置应用程序,则必须执行以下操作:
import celery
app = Celery(
broker=broker_url,backend=postgresq_url,)
app.conf.update(result_extended=True)
版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。