如何在数据库中使用 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 将自动检测是否未生成模式，并在第一次运行时执行此操作。