Flask SQl-Alchemy在单个请求中进行多个DB事务

如何解决Flask SQl-Alchemy在单个请求中进行多个DB事务

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

@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仅在一个请求中允许到数据库的单个会话，因此出现错误。我该怎么办才能解决这个问题？

解决方法

我解决了错误。从flask-sqlalchemy切换到sqlalchemy以连接到数据库，因为它提供了更多的可见性。将应用程序连接到数据库后，应该通过调用engine.dispose（）来处理引擎对象，并且错误消失。