Flower - 任务元数据和结果仅对 Celery 的周期性任务可见

编程问答 2022-05-14

问题描述

我有一个问题，当通过 Celery 的 period_task 功能调用任务时，元数据和任务结果仅在 Flower 中可见。

我的代码

from task_queue.celery import app
from tasks.warehouse.warehouse_tasks import synchronize_all_warehouses


@app.on_after_finalize.connect
def setup_periodic_tasks(sender,**kwargs):
    sender.add_periodic_task(3600,synchronize_all_warehouses.s(),name="synchronize_all_warehouses")


# Start task immediately after deploy so you do not have to wait 1h for results
result = synchronize_all_warehouses.apply_async()

定期芹菜任务：

enter image description here

同样的任务，通过 .apply_async() 调用

enter image description here

我试图研究如何保存任务结果，但找不到答案。 至于为什么我需要这个解决方案：我想在部署时立即看到正在运行的任务，而不是等到周期性任务开始，在我的情况下是 1 小时后。

这些任务在Kubernetes集群上运行，但在本地设置问题是一样的。

解决方法

暂无找到可以解决该程序问题的有效方法，小编努力寻找整理中！

如果你已经找到好的解决方法，欢迎将解决方案带上本链接一起发送给小编。

小编邮箱:dio#foxmail.com (将#修改为@）

celerydockerdockerflowerkubernetespython