python - 如何在数据库中使用 celery result_backend 表

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 数据库中创建后端表感到困惑。 DDL应该是什么样子的？架构名称是什么？表名？表中的列+数据类型？我在文档中找不到与这些问题相关的任何内容。请帮忙

Answer 1

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