Python paramiko模块

Python paramiko模块

一、paramiko简介

paramiko是用Python语言写的一个模块，遵循SSH2协议，支持加密和认证的方式，进行远程服务器的连接。由于使用的是Python这样的能够跨平台的语言，所以paramiko支持所有Python支持的平台(如：Linux，Solaris，BSD，MacOS X，Windows等)。因此，如果需要使用SSH从一个平台连接到另外一个平台，进行操作时paramiko是最佳工具之一。
举个常见的例子，现在有如下需求：需要使用windows客户端，远程登陆到Linux服务器，常看上面的日志。我们通常会用到的方法是：

• 1.用telnet；
• 2.用putty；
• 3.用winscp；
• 4.用xmanager；
  ......

如果现在需求又增加一条，需要从服务器上下载文件，该怎么办呢？那么常用的方法可能是：

• 1.Linux上安装FTP并配置；
• 2.Linux上安装Sambe并配置；
  ......

我们会发现，常见的解决办法都会需要对远程服务器进行必要的配置，如果远程服务器只有一两台还好说，如果有N台，还需要逐台进行配置，或者需要使用代码进行以上操作时，上面的办法就太不方便了。
使用paramiko可以很好的解决以上问题，比起前面的方法，它仅需要在本地安装相应的软件(Python和paramiko)，对远程服务器没有配置要求，对于链接多台服务器，进行复杂的连接操作特别有帮助。

二、安装

使用pip安装，命令如下：

pip install paramiko

下图说明安装成功

三、使用paramiko

SSHClient
远程连接分为两种：(1)基于用户名密码连接；(2)基于公钥密钥连接；
通过paramiko远程操作，其实本质也分为两种：(1)只用SSHClient；(2)自己创建Transport；
1.基于用户名和密码的连接

import paramiko

# 创建SSH对象
ssh = paramiko.SSHClient()
# 允许连接不在known_hosts文件中的主机
ssh.set_missing_host_key_policy(paramiko.AutoAddPolicy)
# 连接服务器
ssh.connect(hostname="172.18.0.99", port=22, username="远程服务器/虚拟机名字", password="远程服务器/虚拟机密码")


# 执行命令
stdin, stdout, stderr = ssh.exec_command("ls")
# 获取命令结果
result = stdout.read()
print(str(result, encoding="utf-8"))    # 打印输出结果

# 关闭连接
ssh.close()

SSHClient封装Transport

import paramiko
transport = paramiko.Transport(("172.18.0.99", 22))     # 使用IP + 端口
transport.connect(username="xh", password="123456")     # 使用用户名 + 密码

ssh = paramiko.SSHClient()
ssh._transport = transport
# print(dir(ssh))

stdin, stdout, stderr = ssh.exec_command("ls")
print(str(stdout.read(), encoding="utf-8"))

transport.close()       # 关闭连接

2.基于公钥密钥连接

import paramiko
private_key = paramiko.RSAKey.from_private_key_file("/home/auto/.ssh/id_rsa")
# 创建SSH对象
ssh = paramiko.SSHClient()
# 允许连接不在known_hosts文件中的主机
ssh.set_missing_host_key_policy(paramiko.AutoAddPolicy())
# 连接服务器
ssh.connect(hostname="172.18.0.99", port=22, username="xh", pkey=private_key)

# 执行命令
stdin, stdout, stderr = ssh.exec_command("ifconfig")
# 获取命令结果
result = stdout.read()
print(str(result, encoding="utf-8"))    # 打印输出结果

# 关闭连接
ssh.close()

SSHClient封装Transport

import paramiko

private_key = paramiko.RSAKey.from_private_key_file("/home/auto/.ssh/id_rsa")
transport = paramiko.Transport(("172.18.0.99", 22))
transport.connect(username="xh", pkey=private_key)
ssh = paramiko.SSHClient()
ssh._transport = transport
stdin, stdout, stderr = ssh.exec_command("ifconfig")
result = stdout.read()
print(str(result, encoding="utf-8"))
transport.close()

SFTPClient
用于连接远程服务器并进行上传下载功能。
1.基于用户名密码的上传下载

import paramiko

transport = paramiko.Transport(("172.18.0.99", 22))
transport.connect(username="xh", password="123456")

sftp = paramiko.SFTPClient.from_transport(transport)
# 将paramiko_ssh.py 上传至服务器 /tmp/test.py 文件
sftp.put("paramiko_ssh.py", "/tmp/test.py")
# 将/home/xh/core 下载到本地 local_path 文件
sftp.get("/home/xh/core", "local_path")

transport.close()

2.基于公钥密钥上传下载

import paramiko

private_key = paramiko.RSAKey.from_private_key_file("/home/auto/.ssh/id_rsa")

transport = paramiko.Transport(("172.18.0.99", 22))
transport.connect(username="xh", pkey=private_key)

sftp = paramiko.SFTPClient.from_transport(transport)
# 将paramiko_ssh.py 上传至服务器 /tmp/test.py 文件
sftp.put("paramiko_ssh.py", "/tmp/test.py")
# 将/home/xh/core 下载到本地 local_path 文件
sftp.get("/home/xh/core", "local_path")

transport.close()

Demo：远程命令执行和文件上传

import paramiko


class SSHConnection:
    def __init__(self, host=None, port=22, username=None, passwd=None):
        self.host = host
        self.port = port
        self.username = username
        self.passwd = passwd
        self__k = None

    def run(self):
        self.connect()              # 连接远程服务器
        self.upload("db.py", "/tmp/1.py")       # 将本地的db.py文件上传到远程服务器的/tmp/目录下并改名为1.py
        self.cmd("ifconfig")        # 执行ifconfig命令
        self.close()        # 关闭连接

    def connect(self):
        transport = paramiko.Transport((self.host, self.port))
        transport.connect(username=self.username, password=self.passwd)
        self.__transport = transport

    def close(self):
        self.__transport.close()

    def upload(self, local_path, remote_path):
        sftp = paramiko.SFTPClient.from_transport(self.__transport)
        sftp.put(local_path, remote_path)

    def cmd(self, command):
        ssh = paramiko.SSHClient()
        ssh._transport = self.__transport
        # 执行命令
        stdin, stdout, stderr = ssh.exec_command(command)
        # 获取命令结果
        result = stdout.read()
        # print(str(result, encoding="utf-8"))
        return result


ssh_obj = SSHConnection(host="172.18.0.99", username="xh", passwd="123456")
ssh_obj.run()