SQLAlchemy 1.4.25 QueuePool连接池超限超时问题求助

1. 核查Session的实际生命周期 #

你虽然用了with管理Session，但要确保每个数据库操作方法里的Session是每次调用都正确创建、并在with块结束后自动释放连接。比如cadastrar_candidato的标准结构应该是：

def cadastrar_candidato(dados):
    with Session() as session:
        with session.begin():
            novo_candidato = Candidato(**dados)
            session.add(novo_candidato)

如果方法里存在手动调用session.commit()后未让with块接管关闭逻辑，或者嵌套了额外的事务操作，可能导致连接未及时归还连接池。

2. 调整连接池配置参数 #

默认的pool_size=5和max_overflow=10在循环批量调用场景下容量不足，可在创建Engine时针对性调整：

from sqlalchemy import create_engine
from sqlalchemy.orm import sessionmaker

engine = create_engine(
    "你的数据库连接URL",
    pool_size=15,  # 增大基础常驻连接数
    max_overflow=20,  # 增大临时溢出连接数
    pool_recycle=300,  # 自动回收闲置超5分钟的连接（避免数据库主动断开）
    pool_pre_ping=True  # 获取连接前自动检查有效性
)
Session = sessionmaker(bind=engine)

注意：参数值不要超过数据库本身的最大连接数限制（比如MySQL默认是151）。

3. 路由循环内复用Session #

在/chamadas-subsequentes路由的循环中，不要每次调用数据库方法都新建Session，而是在路由层面创建一个Session，循环内复用，减少连接创建销毁的开销：

@app.route('/chamadas-subsequentes')
def chamadas_subsequentes():
    with Session() as session:
        with session.begin():
            for item in 你的循环数据集:
                # 所有数据库方法都传入同一个session
                cadastrar_candidato(session, item.dados)
                # 其他数据库操作同理

对应的数据库方法需要修改为接受外部Session：

def cadastrar_candidato(session, dados):
    novo_candidato = Candidato(**dados)
    session.add(novo_candidato)

这样整个循环只会占用一个连接，不会耗尽连接池。

4. 排查隐性连接泄漏 #

• 检查是否存在session.query()后未完整迭代结果集的情况（比如只取了第一条结果但未关闭游标），导致连接被持续占用。
• 用连接池状态监控确认连接使用情况：

print(engine.pool.status())

该命令会输出当前连接池的活跃、闲置连接数，帮助定位是否有连接未被归还。

• 确认异常场景下Session的处理：虽然with块会自动处理异常时的连接关闭，但如果有自定义异常捕获逻辑，要确保执行了session.rollback()。

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