Python使用paramiko模块实现远程服务器管理与文件传输

巷口听风

发布时间：2026-10-13| 6人浏览过

原创

本文详细介绍Python中paramiko模块的安装方法及核心用法。涵盖SSHClient类的连接配置、密钥策略及命令执行，以及SFTPClient类的文件上传下载操作。通过完整代码实例演示如何在远程服务器执行命令、获取返回值及进行交互式Shell操作，适用于自动化运维与远程管理场景。

paramiko模块简介与安装

前言

paramiko是一个基于Python实现的SSHv2协议库，旨在提供安全的远程连接服务。它支持在远程服务器上执行命令、上传文件至服务器，以及从指定服务器下载文件等常用功能。

paramiko模块安装方法

paramiko并非Python标准库的一部分，需手动安装。推荐使用pip工具进行自动安装，具体步骤如下：

（1）配置pip命令及镜像源路径。若环境中已配置，可跳过此步骤。

（2）执行命令pip install paramiko进行安装。当终端显示successful字样时，表示安装成功。

SSHClient类核心功能

paramiko常用函数介绍

SSHclient类

（1）建立SSH远程连接，函数格式为：connect(hostname, port=22, username=None, password=None, pkey=None, key_filename=None, timeout=None, ...)。参数说明：hostname为主机IP地址，port为SSH服务端口号（默认22），username和password分别为登录用户名和密码，timeout用于设置连接超时时间。

（2）当远程主机未存储本地主机密钥或无HostKeys对象时，需设置主机密钥策略。函数格式为：set_missing_host_key_policy(policy)。其中policy参数用于定义处理未知主机密钥的策略。

该参数常见取值有以下3种：

AutoAddPolicy：自动将主机名及密钥添加至本地known_hosts文件，不受load_system_host_key配置影响。建立新SSH连接时无需手动输入yes或no确认，使用最为广泛。
WarningPolicy：记录未知主机密钥的Python警告并接受连接。功能与AutoAddPolicy类似，但会提示为新连接。
RejectPolicy：自动拒绝未知主机名和密钥，依赖load_system_host_key配置。此为默认选项。

（3）在远程服务器执行命令，函数格式为：exec_command(command, bufsize=-1, timeout=None, get_pty=False, environment=None）。该命令的标准输入、标准输出及标准错误输出分别对应stdin、stdout和stderr。

（4）在远程服务器生成新的交互式Shell，函数格式为：invoke_shell(term='vt100', width=80, height=24, width_pixels=0, height_pixels=0, environment=None)。

上述仅介绍了SSHClient类常用的几个函数。关于SSHClient类的详细函数说明，请参考官方文档SSHClient。

SFTPClient类文件操作

SFTPClient类

（1）基于已建立的传输通道创建SFTP客户端对象，格式为：from_transport(cls, t)。

（2）将本地文件上传至服务器，格式为：put(localpath, remotepath, callback=None, confirm=True)。

（3）从服务器下载文件至本地，格式为：get(remotepath, localpath, callback=None)。

（4）在服务器上创建目录，格式为：mkdir()。

（5）在服务器上删除目录，格式为：remove()。

（6）在服务器上重命名目录，格式为：rename()。

（7）查看服务器文件状态，格式为：stat()。

（8）列出服务器指定目录下的文件，格式为：listdir()。

常见应用场景与完整代码实例

paramiko常用场景

（1）在远程服务器执行命令，并获取命令执行的输出结果。


import paramiko
ssh = paramiko.SSHClient()
ssh.set_missing_host_key_policy(paramiko.AutoAddPolicy())
ssh.connect(hostname='192.168.0.1', port=22, username='root', password='Aa12345!')
stdin, stdout, stderr = ssh.exec_command('df -k')
print stdout.read()
ssh.close()

（2）在远程服务器执行命令，并获取命令执行的返回码。


import paramiko
ssh = paramiko.SSHClient()
ssh.set_missing_host_key_policy(paramiko.AutoAddPolicy())
ssh.connect(hostname='192.168.0.1', port=22, username='root', password='Aa12345!')
stdin, stdout, stderr = ssh.exec_command('df -k')
channel = stdout.channel
ret = channel.recv_exit_status()
if ret == 0:
  print stdout.read()
else:
  print stderr.read()

（3）在远程服务器执行命令，需生成子进程并进行交互式命令执行。


import paramiko,time
ssh = paramiko.SSHClient()
ssh.set_missing_host_key_policy(paramiko.AutoAddPolicy())
ssh.connect(hostname='192.168.0.1', port=22, username='root', password='Aa12345!')
interact = conn.invoke_shell()
stdin, stdout, stderr = ssh.exec_command('df -k')
interact = conn.invoke_shell()
interact.send("sed -i '/192.168.0.2/d' /root/.ssh/known_hosts" + '\n')
time.sleep(1)
interact.send('ssh root@172.16.128.2' + '\n')
time.sleep(2)
interact.send('yes' + '\n')
time.sleep(2)
interact.send('Aa12345!' + '\n')
time.sleep(2)
interact.send('df -k!' + '\n')
result = interact.recv(65535)
print result

（4）将文件上传至远程服务器。


import paramiko
scp = paramiko.Transport(('192.168.0.1',22))
scp.connect(username='root',password='Aa12345!')
sftp=paramiko.SFTPClient.from_transport(scp)
local_path = "D:\\temp\\cc.txt"
remote_path = "/tmp/cc.txt"
sftp.put(local_path, remote_path)
scp.close()

（5）从远程服务器下载文件。


import paramiko
scp = paramiko.Transport(('192.168.0.1',22))
scp.connect(username='root',password='Aa12345!')
sftp=paramiko.SFTPClient.from_transport(scp)
remote_path = "/tmp/aaaa.txt"
local_path = "D:\\temp\\aaaa.txt"
sftp.get(remote_path, local_path)
scp.close()

paramiko使用完整实例


import paramiko
def ssh_con(ip, username, password):
  try:
    con = paramiko.SSHClient()
    con.set_missing_host_key_policy(paramiko.AutoAddPolicy())
    con.connect(ip=ip, username=username, password=password, timeout=5)
  except:
    return None
  else:
    return con
def exec_cmd(conn, cmd):
  interact = conn.invoke_shell()
  interact.send(cmd)
  result = interact.recv(65535)
  return result  
def exec_cmd2(conn,cmd):
  stdin, stdout, stderr = conn.exec_command(cmd)
  channel = stdout.channel
  ret = channel.recv_exit_status()
  if ret == 0:
    return (ret, stdout.read())
  else:
    return (ret, stderr.read())
if __name__ == '__main__':
  ip = '192.168.0.1'
  user = 'root'
  passwd = 'root'
  con = ssh_con(ip, user, passwd)
  if not con:
    print "Connect %s fail,please check." % (ip,)
  cmd = 'df -k'
  ret, result = exec_cmd2(con,cmd)
  print result

以上就是本文的全部内容，希望对大家的学习有所帮助，也希望大家多多支持本站。