如何为 asyncpg 保留连接池并在数据库包装器中使用它？

如何解决如何为 asyncpg 保留连接池并在数据库包装器中使用它？

根据 FastApi 文档，我使用 Databases 包装器和 sqlalchemy Core 在 postgres 数据库上执行异步操作。

我遇到了连接在操作过程中关闭的问题。事实证明，它是一个带有 asyncpg 的 issue，可以通过使用池来解析。

但是我没有直接使用 asyncpg，而是使用 FastAPI 推荐的数据库包装器。如何创建这样的池：

await asyncpg.create_pool(database="dbname",user="username",password="dbpw",max_inactive_connection_lifetime=3)

并在数据库包装器中使用它？

import databases
from sqlalchemy import MetaData

db = databases.Database(settings.sqlALCHEMY_DATABASE_URI)
Metadata = MetaData(schema='main')

解决方法

在幕后 database.connect 使用 asyncpg.create_pool，您的 SQLALCHEMY_DATABASE_URI 已经有连接变量，您还可以添加其他连接选项：

db = databases.Database(settings.SQLALCHEMY_DATABASE_URI,max_inactive_connection_lifetime=3)

它们将在连接时传递给 asyncpg.create_pool。