Flask使用原生SQLAlchemy时请求后会话未释放导致数据库连接过多报错

你当前代码的核心问题是每次Web请求都会重新创建独立的SQLAlchemy引擎实例，而非全局复用同一个引擎，导致连接泄漏无法通过scoped_session.remove()回收：

• 每次before_request触发时，都会实例化新的PostgreSQL对象，对应新建一个engine和专属连接池
• scoped_session.remove()仅会将当前线程绑定的会话归还到对应引擎的连接池，不会销毁旧引擎持有的连接池资源
• 多次请求累计的废弃引擎连接池会占满数据库角色的最大连接数配额，触发报错。

方案1：适配现有代码的快速修复 #

也就是你已经定位到的解决方法，在teardown_request中新增引擎资源释放逻辑即可，修改后代码如下：

@app.teardown_request
def teardown(response):
    database.session.remove()
    database.engine.dispose() # 新增行，销毁当前引擎持有的所有连接资源

该方案可以直接解决连接泄漏问题，但每次请求都创建、销毁引擎会产生额外性能开销，仅适合临时修复场景。

方案2：生产环境推荐的优化实现 #

SQLAlchemy的引擎和scoped_session本身就是设计为全局单例使用的，不需要每次请求重新初始化，修改后可以在避免连接泄漏的同时保证性能：

1. 将数据库实例初始化逻辑从请求钩子中移除，调整为应用启动时全局初始化一次
2. 仅保留teardown_request中的session.remove()逻辑回收当前会话即可

修改后的代码示例：

app.py调整后代码 #

# 应用启动阶段全局初始化，仅执行一次
database = PostgreSQL()

# 移除before_request中的数据库初始化逻辑
@app.teardown_request
def teardown(response):
    database.session.remove()

可选优化：限制连接池大小 #

在初始化引擎时添加连接池参数，限制单应用的最大连接数，避免异常场景打满数据库连接：

# PostgreSQL.py中create_engine调用调整
self.engine = create_engine(
    self.database_url, 
    echo=False,
    pool_size=10, # 常驻连接数
    max_overflow=20 # 峰值可额外创建的临时连接数
)

• scoped_session.remove()：将当前线程绑定的会话归还到连接池，连接会被复用不会被销毁
• engine.dispose()：关闭当前引擎持有的所有空闲连接，直接销毁整个连接池，仅适合清理废弃引擎的场景

内容的提问来源于stack exchange，提问作者William May