Python如何通过SSH连接MySQL数据库？-杰瑞科技汇

Python 连接 MySQL（通过 SSH 隧道）终极指南：从零到精通，附代码与排错

Meta 描述：

本文详细讲解如何使用 Python 通过 SSH 隧道安全地连接到远程 MySQL 数据库，提供完整代码示例、Paramiko 与 Pymysql 的结合使用、常见问题（如端口转发失败、连接超时）的解决方案，以及最佳安全实践，助你轻松实现数据库远程访问。

引言：为什么你需要 SSH 隧道连接 MySQL？

作为一名开发者,你很可能遇到过这样的场景：你的应用部署在云服务器上，而 MySQL 数据库运行在另一台隔离的内网服务器上，无法直接从公网访问，直接开放数据库的 3306 端口不仅存在巨大的安全风险，还可能违反公司的安全策略。

SSH 隧道（SSH Tunneling） 就是为解决这个痛点而生的“银弹”，它就像在你的本地机器和远程数据库服务器之间建立了一条加密的“秘密通道”，所有通过这条通道的 MySQL 数据流量都被 SSH 协议加密，不仅安全，还能绕过防火墙限制。

本文将手把手教你如何用 Python 这把“瑞士军刀”，结合 paramiko（用于建立 SSH 连接）和 pymysql（用于操作 MySQL），轻松实现这一功能。

核心概念：SSH 隧道是如何工作的？

在敲代码之前,理解其背后的原理至关重要。

本地端口转发 (Local Port Forwarding)：这是最常用的模式。
- 目标：让本地的一台机器（你的开发机）能够访问远程服务器（B）上的一个服务（MySQL）。
- 过程：
  - 你的本地机器（A）与跳板机/SSH 服务器（C）建立一个 SSH 连接。
  - 你告诉 SSH：“请在我的本地机器（A）上打开一个端口（33070），并将所有发送到这个端口的流量，通过 SSH 连道转发到远程服务器（C），再由它转发到目标数据库服务器（B）的 3306 端口。”
- 结果：在你的本地机器上，localhost:33070 就成了远程 MySQL 数据库的一个“代理入口”，你的 Python 应用只需要连接这个本地端口，数据就会安全地通过 SSH 通道直达数据库。
远程端口转发 (Remote Port Forwarding)：较少用，用于反向场景，本文重点讲解本地端口转发。

准备工作：你需要什么？

在开始编码前,请确保你拥有以下信息：

SSH 服务器信息：SSH 服务器的 IP 地址（或域名）和端口号（默认为 22）。
SSH 登录凭据：你的 SSH 用户名和密码，或者更安全的 SSH 密钥对。
MySQL 服务器信息：数据库服务器的 IP 地址（通常是 0.0.1 或 localhost，因为 SSH 服务器通常和 MySQL 在同一内网）和数据库名。
MySQL 登录凭据：数据库的用户名和密码。
Python 环境：确保你的 Python 环境已安装以下库：
```
pip install paramiko pymysql
```

实战演练：Python 代码实现

我们将分步实现：首先建立 SSH 隧道，然后通过隧道连接 MySQL。

步骤 1：使用 Paramiko 建立 SSH 隧道

paramiko 是 Python 中最强大的 SSH 库，我们将用它来创建一个端口转发。

import paramiko
import time
import socket
# --- 配置信息 ---
SSH_HOST = 'your_ssh_server_ip'      # SSH服务器的公网IP
SSH_PORT = 22                        # SSH端口
SSH_USER = 'your_ssh_username'      # SSH用户名
SSH_PASSWORD = 'your_ssh_password'  # SSH密码 或 使用密钥
# MySQL服务器信息（相对于SSH服务器）
MYSQL_HOST = '127.0.0.1'             # SSH服务器内网的MySQL地址，通常是localhost
MYSQL_PORT = 3306                    # MySQL端口
# 本地转发端口
LOCAL_PORT = 33070                   # 本地机器上开放的端口
# --- 创建SSH客户端 ---
ssh_client = paramiko.SSHClient()
# 自动添加主机密钥（首次连接时提示确认，生产环境建议更安全的处理方式）
ssh_client.set_missing_host_key_policy(paramiko.AutoAddPolicy())
try:
    # --- 建立SSH连接 ---
    print(f"正在连接到SSH服务器 {SSH_HOST}...")
    ssh_client.connect(hostname=SSH_HOST, port=SSH_PORT, 
                       username=SSH_USER, password=SSH_PASSWORD)
    print("SSH连接成功！")
    # --- 建立端口转发通道 ---
    # transport 对象包含了底层的SSH连接
    transport = ssh_client.get_transport()
    # request_port_forward 是建立转发的方法
    # LOCAL_PORT 是本地端口
    # '' 表示绑定到所有网络接口
    transport.request_port_forward('', LOCAL_PORT)
    # 创建一个socket来监听本地端口
    # 这个socket会接收所有发往LOCAL_PORT的连接
    local_socket = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
    local_socket.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEADDR, 1)
    local_socket.bind(('', LOCAL_PORT))
    local_socket.listen(1)
    print(f"SSH隧道已建立！本地端口 {LOCAL_PORT} 已转发到远程MySQL {MYSQL_HOST}:{MYSQL_PORT}")
    print("现在你可以使用 pymysql 连接到 'localhost:{LOCAL_PORT}' 了。")
    # 保持隧道开启，直到手动中断
    # 在实际应用中，这个连接会一直保持
    while True:
        # 这里只是一个示例，实际应用中你不会用死循环来等待
        # 你的主程序会通过这个隧道去连接MySQL
        time.sleep(60)
except Exception as e:
    print(f"SSH连接或隧道建立失败: {e}")
finally:
    if 'local_socket' in locals():
        local_socket.close()
    if ssh_client:
        ssh_client.close()
        print("SSH连接已关闭。")

代码解释：

paramiko.SSHClient()：创建一个 SSH 客户端实例。
set_missing_host_key_policy：用于处理首次连接时服务器密钥未知的情况。AutoAddPolicy 会自动接受，但在生产环境中，你应该先手动获取服务器的公钥并使用 SSHClient.load_host_keys() 来加载。
connect()：使用提供的凭据建立 SSH 连接。
get_transport()：获取底层的传输通道对象，这是进行高级操作（如端口转发）所必需的。
request_port_forward()：这是核心方法，它请求 SSH 服务器在指定的本地端口上设置转发。
socket.bind() 和 listen()：我们在本地机器上创建一个真正的 socket 来“监听”我们指定的端口，准备接收客户端连接。

步骤 2：通过 SSH 隧道连接 MySQL

现在隧道已经建立,你的 Python 应用（比如一个 Flask 或 Django 服务）连接数据库的代码就变得非常简单了，你只需要连接本地端口，pymysql 会自动通过这个端口将数据发送到 SSH 隧道中。

import pymysql
# --- MySQL连接配置（现在连接的是本地端口！）---
DB_CONFIG = {
    'host': '127.0.0.1',  # 连接到本地转发的端口
    'port': LOCAL_PORT,    # 我们在SSH中转发的本地端口
    'user': 'your_mysql_user',
    'password': 'your_mysql_password',
    'database': 'your_database_name',
    'charset': 'utf8mb4'
}
try:
    # --- 建立MySQL连接 ---
    print(f"正在通过SSH隧道连接到MySQL (localhost:{LOCAL_PORT})...")
    connection = pymysql.connect(**DB_CONFIG)
    with connection.cursor() as cursor:
        # --- 执行查询 ---
        sql = "SELECT VERSION()"
        cursor.execute(sql)
        result = cursor.fetchone()
        print(f"MySQL 服务器版本: {result[0]}")
        # --- 执行插入操作 ---
        insert_sql = "INSERT INTO your_table (name, email) VALUES (%s, %s)"
        cursor.execute(insert_sql, ('John Doe', 'john.doe@example.com'))
        connection.commit() # 提交事务
        print("数据插入成功！")
except pymysql.MySQLError as e:
    print(f"MySQL操作失败: {e}")
finally:
    if 'connection' in locals() and connection.open:
        connection.close()
        print("MySQL连接已关闭。")

关键点：

host 和 port：这里的 host 必须是 0.0.1 或 localhost，port 必须是你在 SSH 隧道中设置的 LOCAL_PORT。
pymysql 对 SSH 隧道是无感知的：它只知道自己连接了一个在本地运行的数据库服务，这个“服务”实际上是 SSH 隧道在背后默默工作的结果。

高级用法：使用 SSH 密钥进行认证

使用密码认证虽然方便,但存在安全风险，推荐使用 SSH 密钥对进行认证。

# 在 SSH 连接部分修改如下
private_key_path = '/path/to/your/private_key' # 你的私钥文件路径
# 使用私钥文件
private_key = paramiko.RSAKey.from_private_key_file(private_key_path)
ssh_client.connect(hostname=SSH_HOST, port=SSH_PORT, 
                   username=SSH_USER, pkey=private_key)
# 如果你设置了密码保护的私钥，可以使用 from_private_key_file 的 password 参数
# private_key = paramiko.RSAKey.from_private_key_file(private_key_path, password='your_key_password')

常见问题与排错指南

遇到问题不要慌,这是程序员成长的必经之路。

问题 1：`OSError: [Errno 22] Invalid argument` 或端口绑定失败

原因：通常是因为你指定的 LOCAL_PORT 已经被其他程序占用。
解决方案：
1. 更换一个不常用的端口号（33071, 33072）。
2. 使用 netstat -an | grep :33070 (Linux/macOS) 或 netstat -ano | findstr :33070 (Windows) 命令检查端口占用情况。
3. 在代码中,确保 local_socket 在 bind() 之前被正确关闭。

问题 2：`pymysql.err.OperationalError: (2003, "Can't connect to MySQL server on 'localhost:33070'")`

原因：
1. SSH 隧道未成功建立：你的 Python MySQL 连接代码在 SSH 隧道建立成功之前就尝试连接了。
2. SSH 服务器配置问题：SSH 服务器可能不允许端口转发，检查 SSH 服务的配置文件（通常是 /etc/ssh/sshd_config），确保 AllowTcpForwarding 设置为 yes。
3. 防火墙阻止：本地机器的防火墙可能阻止了 LOCAL_PORT 的连接。
解决方案：
1. 确保顺序：先运行并保持 SSH 隧道脚本在后台运行，再运行你的 Python MySQL 脚本。
2. 检查 SSH 服务器配置：登录到 SSH 服务器，确认 AllowTcpForwarding yes。
3. 检查防火墙：临时关闭本地防火墙进行测试，或添加入站规则允许 LOCAL_PORT。

问题 3：`paramiko.ssh_exception.AuthenticationException`

原因：SSH 用户名或密码/密钥错误。
解决方案：仔细核对你的 SSH 登录凭据，如果使用密钥，确保私钥文件路径正确且权限设置恰当（chmod 600）。

最佳实践与安全建议

使用 SSH 密钥：永远优先使用 SSH 密钥对进行认证，而不是密码。
限制 SSH 访问：为专门用于数据库跳板的 SSH 用户创建一个独立的、权限受限的账户，这个账户甚至可以禁止登录 Shell，只允许端口转发，在 /etc/ssh/sshd_config 中使用 Match 指令和 ForceCommand 可以实现。
使用配置文件：不要将敏感信息（如密码）硬编码在脚本中，使用 .env 文件或 configparser 来管理配置。
优雅地关闭连接：使用 try...finally 或 with 语句确保 SSH 和 MySQL 连接在使用完毕后被正确关闭，避免资源泄漏。
封装成工具类：将 SSH 隧道和 MySQL 连接的逻辑封装成一个可复用的 Python 类，方便在项目中调用。

通过 SSH 隧道使用 Python 连接远程 MySQL 数据库，是现代云原生应用开发中一项至关重要的技能，它巧妙地结合了 paramiko 的网络穿透能力和 pymysql 的数据库操作能力，在保证数据传输安全性的同时，实现了对内网服务的便捷访问。

本文从原理到实践,再到排错和最佳实践，为你提供了一个完整的行动指南，你已经具备了将这项技术应用到你的项目中的所有知识，快去尝试一下吧，你会发现它比你想象的要简单得多！

你觉得这篇文章对你有帮助吗？欢迎在评论区分享你的使用经验或遇到的问题！

Python如何通过SSH连接MySQL数据库？

Python 连接 MySQL（通过 SSH 隧道）终极指南：从零到精通，附代码与排错

Meta 描述：

引言：为什么你需要 SSH 隧道连接 MySQL？

核心概念：SSH 隧道是如何工作的？

准备工作：你需要什么？

实战演练：Python 代码实现

步骤 1：使用 Paramiko 建立 SSH 隧道

步骤 2：通过 SSH 隧道连接 MySQL

高级用法：使用 SSH 密钥进行认证

常见问题与排错指南

问题 1：`OSError: [Errno 22] Invalid argument` 或端口绑定失败

问题 2：`pymysql.err.OperationalError: (2003, "Can't connect to MySQL server on 'localhost:33070'")`

问题 3：`paramiko.ssh_exception.AuthenticationException`

最佳实践与安全建议

99ANYc3cd6

WebLogic Java内存溢出如何排查？

Java exec在Linux中如何正确执行命令？

java的setvisible

iPhone5如何越狱？教程步骤详解

Java如何接收FormData数据？

Java Socket编程实例具体怎么实现？

ActionScript 3.0教程如何快速入门？

Photoshop教程从哪开始学？新手必看技巧有哪些？

Visual Basic教程PDF哪里找？

Python dist packages是什么？如何管理？

Java基础篇第八版课后答案哪里找？

Java接口与类的核心区别是什么？

AutoCAD Electrical教程如何快速上手？

Java用OpenOffice操作Word，如何实现？

webservice rest java

Python UDP如何实现keepalive心跳机制？

Python如何通过SSH连接MySQL数据库？

Python 连接 MySQL（通过 SSH 隧道）终极指南：从零到精通，附代码与排错

Meta 描述：

引言：为什么你需要 SSH 隧道连接 MySQL？

核心概念：SSH 隧道是如何工作的？

准备工作：你需要什么？

实战演练：Python 代码实现

步骤 1：使用 Paramiko 建立 SSH 隧道

步骤 2：通过 SSH 隧道连接 MySQL

高级用法：使用 SSH 密钥进行认证

常见问题与排错指南

问题 1：OSError: [Errno 22] Invalid argument 或端口绑定失败

问题 2：pymysql.err.OperationalError: (2003, "Can't connect to MySQL server on 'localhost:33070'")

问题 3：paramiko.ssh_exception.AuthenticationException

最佳实践与安全建议

相关推荐

Java Socket编程实例具体怎么实现？

问题 1：`OSError: [Errno 22] Invalid argument` 或端口绑定失败

问题 2：`pymysql.err.OperationalError: (2003, "Can't connect to MySQL server on 'localhost:33070'")`

问题 3：`paramiko.ssh_exception.AuthenticationException`