首页 > 解决方案 > 如何在支持的 SQL alchemy 中存储参数,这些参数传递给烧瓶应用程序中的 celery 任务

问题描述

我正在开发烧瓶应用程序,它使用 celery 在后台启动大量任务,我使用 Redis 作为消息代理队列,使用 SQL alchemy 作为 celery 后端。

默认情况下,我可以看到“结果”存储在 celery_taskmeta 表的“结果”列的后端,但我也想存储传递给任务的参数。

我也想在将来检索它们。有什么办法可以将它们存储在我当前的后端。

谢谢

标签: flaskceleryflask-sqlalchemy

解决方案


您可以在设置中使用此参数 =>

result_extended = True

允许将扩展任务结果属性(name, args, kwargs, worker, retries, queue, delivery_info)写入后端。

查看链接以获得解释:https ://docs.celeryproject.org/en/stable/userguide/configuration.html#result-extended


推荐阅读