如何用SQLAlchemy正确关闭会话，解决MySQL睡眠连接过多问题？

核心问题原因 #

1. 引擎绑定错误：代码中session.configure(bind=engine())是错误用法，engine是create_engine返回的实例，调用engine()会直接创建临时数据库连接，而非使用配置了连接池参数的Engine。这导致pool_recycle等连接池配置完全失效，连接无法被自动回收。
2. SQL语法错误：text('SELECT employee_name FROM users WHERE status='1';')存在单引号嵌套问题，会触发语法错误，虽不直接导致连接睡眠，但可能引发未预期异常，影响连接正常释放。
3. 连接池回收配置不匹配：即便pool_recycle=30设置正确，若MySQL的wait_timeout（默认3600秒/1小时）大于该值，SQLAlchemy未及时回收的空闲连接会在MySQL端保持睡眠状态，直到超时才被断开，长期积累形成大量睡眠连接。

修正后的代码 #

import pymysql.cursors
from sqlalchemy import create_engine, text
from sqlalchemy.orm import sessionmaker

connect_string = f"mysql+pymysql://{db_user}@/{db_name}?unix_socket=/cloudsql/{cloudsql_instance}"
# 调整pool_recycle为小于MySQL wait_timeout的值，比如3000秒（50分钟）
engine = create_engine(connect_string, echo=False, pool_recycle=3000, pool_size=20, max_overflow=0)

# 正确绑定Engine实例，而非临时连接
Session = sessionmaker(expire_on_commit=True, autoflush=True, autocommit=False)
Session.configure(bind=engine)

# 使用上下文管理器确保session正确关闭
with Session() as session:
    # 修正引号嵌套问题
    all_users = session.execute(text("SELECT employee_name FROM users WHERE status='1';")).fetchall()
    print(all_users)
# 上下文管理器会自动调用session.close()，无需手动执行

额外优化建议 #

• 检查MySQL配置：确认MySQL的wait_timeout和interactive_timeout参数值，确保pool_recycle设置比这两个值小至少30秒，避免SQLAlchemy使用已被MySQL断开的连接。
• 限制连接池大小：根据业务并发量调整pool_size和max_overflow，避免连接池创建过多空闲连接。
• 异常安全处理：若不使用上下文管理器，需在try/finally块中确保session.close()被执行，防止异常导致连接无法释放。

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