PyMySQL连接失败主因是认证插件不兼容、网络不通或驱动版本低;SQLAlchemy需配pool_pre_ping、pool_recycle防stale连接;连接池大小与事务管理不当易致连接泄露或超限。

PyMySQL直连MySQL,连不上先看这三件事
PyMySQL连接失败,八成卡在认证、网络或驱动版本上。它不依赖系统 MySQL 客户端,但对 mysql_native_password 插件和 TLS 配置很敏感。
- 确认 MySQL 服务已启动且允许远程连接:
SELECT host, user FROM mysql.user;看是否有%或对应 IP 的用户 - 检查用户认证插件:5.7+ 默认可能用
caching_sha2_password,PyMySQL 1.0+ 才原生支持;旧版建议执行ALTER USER 'user'@'%' IDENTIFIED WITH mysql_native_password BY 'pwd'; - 防火墙和云厂商安全组必须放行
3306端口,本地测试可先用telnet host 3306验证通路
SQLAlchemy + PyMySQL 配置连接池,别只写 engine = create_engine(...)
默认不启用连接池复用,短时高频请求会反复建连,超时或报 Too many connections。关键在参数组合,不是加个 pool_size 就完事。
-
pool_pre_ping=True必开:每次取连接前发SELECT 1检活,避免拿到被服务端断掉的 stale 连接 -
pool_recycle=3600推荐设:强制连接每小时重连一次,防止 MySQL 的wait_timeout(默认 8 小时)导致中间断连 - 慎用
pool_timeout:设太小(如 5)会让等待连接的请求直接抛TimeoutError;设太大(如 30)又拖慢故障感知;一般 10–20 足够 - 示例连接串:
mysql+pymysql://user:pwd@host:3306/db?charset=utf8mb4,注意charset参数影响 emoji 存储
连接池满、查询卡住?查清是应用层阻塞还是数据库瓶颈
现象是请求 hang 住、日志停在 acquiring connection from pool,但不一定是池子太小——可能是连接没归还,或 DB 已扛不住。
- 先看 SQLAlchemy 日志:加
echo=True和logging.basicConfig(level=logging.INFO),观察是否所有connection.execute()都有对应connection.close()或上下文退出 - 查 MySQL 当前连接:
SHOW PROCESSLIST;,重点看State是Sleep还是Locked或Sending data;大量Sleep说明连接没释放 - PyMySQL 默认不自动 commit,
engine.execute()执行 DML 后必须conn.commit()或用session,否则连接一直被事务占用 - 连接池大小不是越大越好:
pool_size=10+max_overflow=20是较稳配置;盲目调到 50 容易打爆 MySQL 的max_connections
PyMySQL 和 SQLAlchemy 一起用,cursor 和 session 别混着关
PyMySQL 的 cursor 和 SQLAlchemy 的 Connection / Session 生命周期不同,手动关错对象会导致连接泄露或重复关闭异常。
立即学习“Python免费学习笔记(深入)”;
- 用
engine.connect()得到Connection对象,必须显式调.close()或用with语句;它不等同于 PyMySQL 的cursor - 不要对 SQLAlchemy 的
Connection调.cursor()再手动关 cursor——这是底层封装,交由 SQLAlchemy 管理 - ORM 模式下用
session,务必配session.close()或with Session() as s:;session.rollback()不会自动 close,得再 call 一次 close - 调试时可在
engine.dispose()后立刻SHOW STATUS LIKE 'Threads_connected';看连接数是否回落,验证释放逻辑










