如何在数据库中使用芹菜result_backend表

Question

我正在阅读有关使用事务数据库存储任务结果的文档。我有点不确定该怎么做。假设我正在使用 postgresql，我按照文档中的规定配置我的芹菜应用程序：

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

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

Answer 1

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