如何在数据库中使用 celery result_backend table

Question

我正在通读有关使用事务数据库存储任务结果的文档。我有点不确定如何去做。假设我正在使用 postgresql，我按照文档中的说明配置我的 celery 应用程序：

celery_app = Celery('my_app'
         , broker='amqp://localhost//'
         , backend='db+postgresql://user:password@localhost/db_name',
         , include=['my_app.my_task'])

很好，但我对如何在我的 postgresql 数据库中创建后端 table 感到困惑。 DDL应该是什么样子的？架构名称是什么？ Table名字？ table 中的列+数据类型？我在文档中找不到与这些问题相关的任何内容。请帮忙

Answer 1

如果您决定使用任何 SQLAlchemy 支持的数据库服务器作为结果后端，您需要做的就是为 result_backend[ 提供有效的工作 URL =13=] Celery 配置中的值。 Celery 将自动检测未生成架构并在第一个运行.

时执行此操作

如何在数据库中使用 celery result_backend table

How to use celery result_backend table in a DB

python

postgresql

celery