Python多线程插入MySQL报2055丢失SSL连接问题求助

核心错误根因定位 #

• 全局共享单连接/游标本身不合法：MySQL官方的mysql-connector连接、游标对象完全不支持多线程共享，多线程并发读写同一个连接时会直接破坏TCP报文/SSL会话状态，直接触发2055断开、SSL EOF、 BrokenPipe报错，这是初始方案的核心问题。
• 连接池使用错误导致的报错/连接耗尽：大概率是使用连接池时没有做「用完即归还」、异常回滚、存活检测的逻辑，要么是线程占着连接不释放导致耗尽，要么是拿了已经被MySQL服务端主动断开的空闲连接直接用，触发同类断开错误。

逐点修复方案 #

1. 彻底丢弃全局共享连接的方案，所有数据库操作严格遵循「线程本地获取连接->执行操作->主动归还连接」的逻辑
2. 连接池配置增加存活校验参数，使用mysql-connector连接池时，初始化阶段添加pool_reset_session=True，connection_timeout设置为比MySQL的wait_timeout（默认8小时）更小的值，每次获取连接时先执行pool.get_connection().ping(reconnect=True)校验连接存活
3. 每个线程的数据库操作必须加异常捕获，操作完成（无论成功失败）都要主动调用connection.close()（连接池模式下close不是真的关闭连接，是归还给连接池），如果执行写操作失败要主动执行connection.rollback()避免事务挂起占住连接
4. 针对YOLO实时检测的高吞吐场景，不要每检测一帧就写一次库，先在内存中做批量缓存，攒够10~50条再批量执行插入，减少连接占用频率和TCP交互次数，批量插入可使用executemany接口，性能更高。

最小可用示例参考 #

import mysql.connector
from mysql.connector import pooling
import threading

# 全局仅初始化一次连接池
db_pool = pooling.MySQLConnectionPool(
    pool_name="yolo_detect_pool",
    pool_size=5, # 大小设置为并发写库的线程数+1即可，不要设置过大
    host="192.168.1.131",
    user="你的数据库用户名",
    password="你的数据库密码",
    database="你的业务库名",
    connection_timeout=1800, # 设为半小时，小于MySQL默认的wait_timeout
    pool_reset_session=True,
    ssl_disabled=False # 确认不需要SSL加密时可设为True，避免SSL相关报错
)

# 单个线程的写库逻辑
def insert_detect_result(detect_data_list):
    conn = None
    cursor = None
    try:
        conn = db_pool.get_connection()
        conn.ping(reconnect=True) # 先校验连接是否存活，失效则自动重连
        cursor = conn.cursor()
        # 批量插入逻辑
        sql = "INSERT INTO detect_result (frame_id, class_name, conf, x1, y1, x2, y2) VALUES (%s, %s, %s, %s, %s, %s, %s)"
        cursor.executemany(sql, detect_data_list)
        conn.commit()
    except Exception as e:
        if conn:
            conn.rollback()
        print(f"写库失败: {e}")
    finally:
        # 无论执行成功失败都必须释放资源
        if cursor:
            cursor.close()
        if conn:
            conn.close()

• 附加验证点：如果你的MySQL服务端开启了SSL但证书配置存在异常，也会偶发SSL EOF报错，确认不需要传输加密时可以在连接参数中添加ssl_disabled=True直接关闭SSL连接，排除这部分干扰。

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