flask - 如何在支持的 SQL alchemy 中存储参数,这些参数将传递给 Flask 应用程序中的 celery 任务

标签 flask celery flask-sqlalchemy

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

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

而且我也想在将来取回它们。有什么办法可以将它们存储在我当前的后端。

谢谢

最佳答案

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

result_extended = True

启用扩展任务结果属性(name、args、kwargs、worker、retries、queue、delivery_info)写入后端。

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

关于flask - 如何在支持的 SQL alchemy 中存储参数,这些参数将传递给 Flask 应用程序中的 celery 任务,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/63028750/

相关文章:

python - flask 模板 : nginx cache or serve static assets called in jinja markups

python - flask 中的“全局名称@wraps 未定义”错误

python - 如何让 Celery 工作人员返回任务结果

python - celery 通过对等方重置连接

python - 将 "external' 类模型与 flask sqlalchemy 相关联

python - 使用 SQLalchemy 和 Marshmallow 加载一对多关联属性

flask - SQLAlchemy 一对多查询输出

python - Session.pop 方法的第二个参数在 Python Flask 中有什么作用?

python - 无法在 REST API 的 flask 中返回 json 分页

python - celery vs pyro : is Pyro an alternative to Celery?