Flask SQlAlchemy 单个请求中的多个数据库事务答案

【问题标题】：Flask SQl-Alchemy multiple DB transactions in single requestFlask SQlAlchemy 单个请求中的多个数据库事务
【发布时间】：2021-01-03 00:33:44
【问题描述】：

我正在尝试制作一个单路由 Flask Web 应用程序，其中用户向客户端提交 URL，从 URL 中提取的一些数据在服务器端提取并附加到 Postgres DB。接下来，对从 URL 中提取的数据进行进一步处理，并更新 DB 中 URL 的数据条目。所有这些处理都是使用 celery 作为后台任务完成的。工作流程如下所示：

@app.route
def app_route(url):
    chain(task1(url) | task2(url))

@celery.task
def task1(url):
   out1 = some_long_task(url)
   append url,out1 to db

@celery.task
def task2(url):
   out2 = some_other_long_task(url)
   update url row in db with out2

我们这样做的原因是，这两个任务是长任务，用户应该可以在客户端看到任务的状态。因此，我们首先更新数据库中的 out1 以便用户知道状态，然后使用 out2 更新用户可以知道最终状态。在任何时候，用户都可以访问显示当前数据库中的 URL 及其数据的主页。

这会引发一个错误：psycopg2.OperationalError) SSL 错误：解密失败或错误记录 mac

带有 out1 的 url 正确附加到数据库中，没有问题。但是当我们第二次尝试更新我们在前一个任务中附加的行时，它会抛出上述错误。我猜烧瓶 sqlalchemy 只允许在一个请求中对数据库进行单个会话，因此会出现错误。我该怎么做才能解决这个问题？

【问题讨论】：

标签： postgresql flask sqlalchemy flask-sqlalchemy

【解决方案1】：

我解决了这个错误。从 flask-sqlalchemy 切换到 sqlalchemy 以连接到数据库，因为它提供了更多的可见性。将应用连接到数据库后调用engine.dispose()释放引擎对象，错误消失。

【讨论】：