Python连接PostgreSQL持续出现SSL SYSCALL error: EOF detected求助

从你提供的日志和代码来看，问题根源集中在连接重试逻辑缺陷、Patroni集群的连接限制以及SSL配置不匹配这几个方面，以下是针对性修复方案：

1. 修复代码中的连接重试与资源管理问题 #

你的execute方法重连逻辑存在两个关键问题：重连时未复用保活配置、异常处理后无二次错误捕获，容易触发集群连接拒绝机制。修改后代码如下：

首先在__init__中把保活参数设为实例变量：

elif self._connection_type == 'POSTGRES':
    self._engin = db.create_engine(self.connectionInfo.url)
    # 调整保活参数，缩短空闲触发时间避免连接被回收
    self.keepalive_kwargs = {
        "keepalives": 1,
        "keepalives_idle": 30,
        "keepalives_interval": 5,
        "keepalives_count": 3
    }
    self.postgres_con = psycopg2.connect(
        database=self.connectionInfo.database,
        user=self.connectionInfo.user,
        password=self.connectionInfo.password,
        host=self.connectionInfo.host,
        port=self.connectionInfo.port,
        **self.keepalive_kwargs
    )
    self.post_cursor = self.postgres_con.cursor()

然后修改execute方法，限制重试次数并复用保活配置：

def execute(self, query_string, param=None):
    if self._connection_type == 'POSTGRES':
        success = False
        retry_count = 0
        max_retries = 2  # 限制重试次数，避免触发Patroni阈值
        while not success and retry_count < max_retries:
            try:
                if param:
                    self.post_cursor.execute(query_string, param)
                else:
                    self.post_cursor.execute(query_string)
                success = True
            except Exception as ex:
                retry_count += 1
                # 清理失效连接
                try:
                    if not self.postgres_con.closed:
                        self.post_cursor.close()
                        self.postgres_con.close()
                except Exception:
                    pass
                # 重连时带上保活参数
                self.postgres_con = psycopg2.connect(
                    database=self.connectionInfo.database,
                    user=self.connectionInfo.user,
                    password=self.connectionInfo.password,
                    host=self.connectionInfo.host,
                    port=self.connectionInfo.port,
                    **self.keepalive_kwargs
                )
                self.post_cursor = self.postgres_con.cursor()
        if not success:
            raise Exception(f"查询执行失败，已重试{max_retries}次")
        
        result = self.post_cursor.fetchall()
        return [result, self.post_cursor.description]

2. 适配Patroni集群的连接限制 #

日志显示Too many retry attempts和rejecting connections，说明代码重试次数超过了Patroni的防护阈值：

• 严格限制代码中的重试次数（如上设置max_retries=2），避免触发集群的连接拒绝机制
• 检查Patroni配置，确认max_connections参数是否足够，或当前节点是否处于主从切换过程中

3. 强制匹配SSL连接配置 #

既然Datagrip能正常连接，说明本地SSL配置有效，但Python代码未明确指定SSL参数，导致协商失败。在psycopg2.connect中添加对应SSL参数（参考Datagrip的连接配置）：

self.postgres_con = psycopg2.connect(
    database=self.connectionInfo.database,
    user=self.connectionInfo.user,
    password=self.connectionInfo.password,
    host=self.connectionInfo.host,
    port=self.connectionInfo.port,
    sslmode='require',  # 对应Datagrip的SSL模式，如verify-full、require等
    sslrootcert='/path/to/root.crt',  # 若需证书验证，指定CA证书路径
    **self.keepalive_kwargs
)

4. 统一使用SQLAlchemy原生连接管理 #

代码同时维护SQLAlchemy引擎和psycopg2原生连接，易导致资源冲突。建议统一用SQLAlchemy处理连接，自动管理连接池、重连和资源释放：

def execute(self, query_string, param=None):
    if self._connection_type == 'POSTGRES':
        with self._engin.connect() as conn:
            result = conn.execute(db.text(query_string), param)
            return [result.fetchall(), result.keys()]

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