根据FastApi文档,我正在使用Databases包装器和Sqlalchemy Core在postgres数据库上执行异步操作。
我遇到了一个问题,在操作过程中连接被关闭。事实证明这是
然而,我没有直接使用asyncpg,而是使用了Database包装器,因为FastAPI推荐使用它。我该如何创建这样的池?
并在数据库包装器中利用它?
我遇到了一个问题,在操作过程中连接被关闭。事实证明这是
asyncpg
的问题,可以通过使用池来解决。然而,我没有直接使用asyncpg,而是使用了Database包装器,因为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')