使用psycopg2通过端口转发连接PostgreSQL时遇连接故障

你遇到的connection reset by peer错误属于端口转发层面的网络问题，而非Python数据库连接库的问题（这也是换库后问题依旧的原因）。以下是具体的排查和解决步骤：

一、先确认PostgreSQL Pod本身是否正常 #

• 检查Pod状态：

  kubectl get pods
  

  确保目标Pod处于Running状态，且RESTARTS次数无异常增长。
• 查看Pod日志，确认PostgreSQL服务正常启动：

  kubectl logs <你的Pod名称/ID>
  

  重点看是否有PostgreSQL init process complete; ready for start up.或类似启动成功的日志，同时排查是否有端口绑定失败、权限不足等错误。
• 直接在Pod内部验证数据库可用性：

  kubectl exec -it <你的Pod名称/ID> -- psql -U postgres -d consumer -c "SELECT version();"
  

  如果这条命令能正常返回结果，说明数据库本身没有问题，问题出在端口转发环节。

二、排查端口转发配置与本地环境 #

• 确认端口转发命令正确性：
  确保你执行的转发命令是：

  kubectl port-forward <你的Pod名称/ID> 5555:5432
  

  检查Pod名称/ID是否正确，端口映射本地端口:Pod端口是否写反。
• 更换本地端口测试：
  避免本地5555端口被其他进程占用，尝试换一个端口：

  kubectl port-forward <你的Pod名称/ID> 6666:5432
  

  同时修改Python脚本中的port='6666'，重新测试连接。
• 检查本地端口占用：
  Linux/macOS执行：

  lsof -i :5555
  

  Windows执行：

  netstat -ano | findstr :5555
  

  如果有其他进程占用5555端口，关闭该进程后重新启动转发。
• 临时关闭本地防火墙/安全软件：
  部分防火墙会拦截本地端口转发的连接，关闭后测试是否恢复正常。

三、优化端口转发参数 #

• 增加超时时间并允许全局绑定：
  执行转发命令时添加参数，延长超时时间并允许所有地址访问：

  kubectl port-forward --address 0.0.0.0 --timeout 3600s <你的Pod名称/ID> 5555:5432
  

  --address 0.0.0.0可以避免仅绑定localhost导致的潜在连接问题，--timeout防止转发因闲置被自动断开。

四、优化Python连接脚本（非根源，但避免额外问题） #

你的当前脚本在全局初始化数据库连接，如果端口转发还未完全建立就会提前触发连接失败。建议将连接逻辑移到函数内部：

import psycopg2

def check_postgres_connection():
    postgres_conn = None
    postgres_cursor = None
    try:
        postgres_conn = psycopg2.connect(
            dbname='consumer',
            user='postgres',
            password='postgres',
            host='localhost',
            port='5555'
        )
        postgres_cursor = postgres_conn.cursor()
        postgres_cursor.execute("SELECT version();")
        result = postgres_cursor.fetchone()
        print(f"PostgreSQL Connection Successful. Sample Query Result: {result}")
    except Exception as e:
        print(f"PostgreSQL Connection Failed. Error: {e}")
    finally:
        if postgres_cursor:
            postgres_cursor.close()
        if postgres_conn:
            postgres_conn.close()

if __name__ == "__main__":
    print("\n")
    check_postgres_connection()

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