paramiko模块使用

Posted lincappu

tags:

篇首语:本文由小常识网(cha138.com)小编为大家整理,主要介绍了paramiko模块使用相关的知识,希望对你有一定的参考价值。

 

 


一、paramiko 安装

  paramiko是Python的一个第三方库,所以我们要使用pip安装

1
pip install paramiko

二、什么是paramiko

  SSH是一个协议,paramiko是使用SSHv2协议(底层使用的是cryptography)的一个第三方的库

2.1:paramiko包括两个核心的组件

  SSHClient:它的作用类似于Linux的SSH命令,是对SSH会话的一个类的封装,这个类封装了传输(Transport),通道(Channel)及SFTPClient建立的方法(open_sftp),通过用于执行远程命令。

  SFTPClient:它的作用类似Linux的SFTP命令,是对SFTP客户端的一个类的封装。主要是实现对远程文件的操作,上传,下载,修改文件权限等操作。

2.2:paramiko有几个基础的名词

  Transport:是一种加密的会话,使用时会同步创建一个加密的Tunnels(通道),这个Tunnels叫Channel

  Channel:是一种类的Socket,一种安全的SSH通道

  Session:是client和server保持连接的对象。实现方式是connect ---> start_client ---> start_server 开始会话。

三、SSHClient使用

3.1:常用方法

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
connect()方法:
实现远程服务器的连接认证,对于该方法自由一个hostname是必须传的参数
常用参数:
hostname:连接的目标主机
port:目标主机的端口
username:验证的用户可以为None
password:验证的密码可以为None
pkey:私钥的验证方式可以为None
key_filename:一个文件名或者一个文件列表,指定私钥文件
timeout:TCP连接的超时时间,可以为None
allow_agent:是否允许连接到ssh代理,默认为True
look_for_keys:是否在~/.ssh中搜索秘钥文件,默认为True
compress:是否打开压缩,默认False
 
 
set_missing_host_key_policy()方法:
设置远程服务器没有在know_hosts文件中记录时的应对策略,目前支持三种策略
AutoAddPolicy 自动添加主机名及主机密钥到本地HostKeys对象,不依赖load_system_host_key的配置。即新建立ssh连接时不需要再输入yes或no进行确认
WarningPolicy 用于记录一个未知的主机密钥的python警告。并接受,功能上和AutoAddPolicy类似,但是会提示是新连接
RejectPolicy 自动拒绝未知的主机名和密钥,依赖load_system_host_key的配置。此为默认选项
 
 
 
exec_command()方法:
在远程服务器执行Linux命令的方法
 
open_sftp()方法:
在当前ssh会话的基础上建立一个sftp会话,该方法会返回一个SFTPClient对象
通过这个对象可以实现上传下载的功能

3.2:使用密码连接(一)

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
import paramiko
 
# 实例化SSHClient
client = paramiko.SSHClient()
 
# 自动添加策略,保存服务器的主机名和密钥信息,如果不添加,那么不再本地know_hosts文件中记录的主机将无法连接
client.set_missing.host_key_policy(paramiko.AutoAddPolicy())
 
# 连接SSH服务器,用户名密码认证
client.connect(hostname=‘192.168.163.129‘,port=22,username=‘root‘,password=‘zhujingzhi‘)
 
# 打开一个Chanent并执行命令
stdin,stdout,stderr = client.exec_command(‘df -h‘)
# stdout 为正确输出,stderr为错误输出,同时是有1个变量有值
 
 
# 打印结果
print(stdout.read().decode(‘utf8‘))
 
 
# 关闭连接
client.close()

3.3:使用密码连接(二)transport封装推荐使用

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
import paramiko
 
# 创建一个通道
transport = paramiko.transport((‘192.168.163.129‘22))
transport.connect(username=‘root‘, password=‘zhujingzhi‘)
 
 
# 实例化SSHClient
client = paramiko.SSHClient()
client._transport = transport
 
 
# 打开一个Chanent并执行命令
stdin,stdout,stderr = client.exec_command(‘df -h‘)
# stdout 为正确输出,stderr为错误输出,同时是有1个变量有值
 
 
# 打印结果
print(stdout.read().decode(‘utf8‘))
 
 
# 关闭连接
transport.close()

3.4:使用秘钥连接(一)

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
import paramiko
 
# 配置私人密钥文件位置
private = paramiko.RSAKey.from_private_key_file(‘/Users/zjz/.ssh/id_rsa‘)
  
#实例化SSHClient
client = paramiko.SSHClient()
  
#自动添加策略,保存服务器的主机名和密钥信息,如果不添加,那么不再本地know_hosts文件中记录的主机将无法连接
client.set_missing_host_key_policy(paramiko.AutoAddPolicy())
  
#连接SSH服务端,以用户名和密码进行认证
client.connect(hostname=‘192.168.163.129‘,port=22,username=‘root‘,pkey=private)
 
# 打开一个Channel并执行命令
stdin, stdout, stderr = client.exec_command(‘df -h ‘)
# stdout 为正确输出,stderr为错误输出,同时是有1个变量有值
  
# 打印执行结果
print(stdout.read().decode(‘utf-8‘))
  
# 关闭SSHClient
client.close()

3.5:使用秘钥连接(二)transport封装推荐使用

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
import paramiko
 
# 配置私人密钥文件位置
private = paramiko.RSAKey.from_private_key_file(‘/Users/zjz/.ssh/id_rsa‘)
  
# 创建一个通道
transport = paramiko.Transport((‘192.168.163.129‘22))
transport.connect(username=‘root‘, pkey=private_key)
 
#实例化SSHClient
client = paramiko.SSHClient()
client._transport = transport
  
# 打开一个Channel并执行命令
stdin, stdout, stderr = client.exec_command(‘df -h ‘)
# stdout 为正确输出,stderr为错误输出,同时是有1个变量有值
  
# 打印执行结果
print(stdout.read().decode(‘utf-8‘))
  
# 关闭SSHClient
transport.close()

四、SFTPClient使用

4.1:常用方法

1
2
3
4
5
6
7
8
9
10
SFTPCLient作为一个sftp的客户端对象,根据ssh传输协议的sftp会话,实现远程文件操作,如上传、下载、权限、状态
  
from_transport(cls,t) 创建一个已连通的SFTP客户端通道
put(localpath, remotepath, callback=None, confirm=True) 将本地文件上传到服务器 参数confirm:是否调用stat()方法检查文件状态,返回ls -l的结果
get(remotepath, localpath, callback=None) 从服务器下载文件到本地
mkdir() 在服务器上创建目录
remove() 在服务器上删除目录
rename() 在服务器上重命名目录
stat() 查看服务器文件状态
listdir() 列出服务器目录下的文件

4.2:上传功能

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
import paramiko
  
# 获取Transport实例
tran = paramiko.Transport((‘192.168.163.129‘22))
  
# 连接SSH服务端,使用password
tran.connect(username="root", password=‘zhujingzhi‘)
# 或使用
# 配置私人密钥文件位置
private = paramiko.RSAKey.from_private_key_file(‘/Users/zjz/.ssh/id_rsa‘)
# 连接SSH服务端,使用pkey指定私钥
tran.connect(username="root", pkey=private)
  
# 获取SFTP实例
sftp = paramiko.SFTPClient.from_transport(tran)
  
# 设置上传的本地/远程文件路径
localpath = "/Users/zjz/Downloads/1.txt"
remotepath = "/tmp/1.txt"
  
# 执行上传动作
sftp.put(localpath, remotepath)
  
# 关闭连接
tran.close()

4.3:下载功能

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
import paramiko
  
# 获取Transport实例
tran = paramiko.Transport((‘192.168.163.129‘22))
  
# 连接SSH服务端,使用password
tran.connect(username="root", password=‘zhujingzhi‘)
# 或使用
# 配置私人密钥文件位置
private = paramiko.RSAKey.from_private_key_file(‘/Users/zjz/.ssh/id_rsa‘)
# 连接SSH服务端,使用pkey指定私钥
tran.connect(username="root", pkey=private)
  
# 获取SFTP实例
sftp = paramiko.SFTPClient.from_transport(tran)
  
# 设置上传的本地/远程文件路径
localpath = "/Users/zjz/Downloads/1.txt"
remotepath = "/tmp/1.txt"
  
# 执行下载动作
sftp.get(remotepath, localpath)
  
# 关闭连接
tran.close() 

五、综合函数实现(复制粘贴即可使用)

 5.1:transport封装函数(推荐使用)

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
import paramiko
 
class ssh(object):
    def __init__(self,hostdata):
        """
        初始化连接信息和ftp方法
        :param hostdata: 连接信息字段
        """
        self.ip = hostdata[‘ip‘]
        self.port = hostdata[‘port‘]
        self.user = hostdata[‘user‘]
        self.passwd = hostdata[‘passwd‘]
        self.transport = paramiko.Transport((self.ip, self.port))
        self.transport.connect (username=self.user, password=self.passwd)
        self.obj = paramiko.SSHClient()
        self.obj._transport = self.transport
        self.objsftp = self.obj.open_sftp ()
 
    def run_cmd(self, cmd):
        """
        执行命令方法
        :param cmd: 需要执行的命令
        :return:
        """
        stdin, stdout, stderr = self.obj.exec_command (cmd)
        return stdout.read ()
 
    def run_cmdlist(self, cmdlist):
        """
        执行命令方法列表
        :param cmdlist: 命令列表
        :return:
        """
        self.resultList = []
        for cmd in cmdlist:
            stdin, stdout, stderr = self.obj.exec_command (cmd)
            self.resultList.append (stdout.read ())
        return self.resultList
 
    def get(self,remotepath,localpath):
        """
        下载文件方法(两个路径都要指定文件名)
        :param remotepath: 服务器路径
        :param localpath:  本地路径
        :return:
        """
        self.objsftp.get(remotepath,localpath)
 
    def put(self,localpath,remotepath):
        """
        上传文件方法(两个路径都要指定文件名)
        :param localpath: 本地路径
        :param remotepath: 服务器路径
        :return:
        """
        self.objsftp.put(localpath,remotepath)
 
    def close(self):
        """
        关闭方法
        :return:
        """
        self.objsftp.close ()
        self.transport.close ()
 
# 函数的使用
if __name__ == ‘__main__‘:
    hostdata = {
        ‘ip‘:‘192.168.163.129‘,
        ‘port‘:22,
        ‘user‘:‘root‘,
        ‘passwd‘:‘zhujingzhi‘,
    }
    host = ssh (hostdata)                                      # 实例化远程函数给数据库里面的IP 端口 用户名 密码信息
    = host.run_cmd (‘df -h‘)                                 # 执行单个命令
    vstr = v.decode (encoding=‘utf-8‘, errors=‘strict‘)        # bytes转字符串
    v1 = host.run_cmdlist ([‘ls‘‘df‘])                       # 执行命令列表
    print(hostdata[‘ip‘])
    print(vstr)
    = host.get(‘/root/anaconda-ks.cfg‘,‘D:\\采集\\a.cfg‘)     # 下载文件
    = host.put(‘D:\\采集\\a.cfg‘,‘/opt/a.cfg‘)                # 上传文件
    host.close() 

5.1:普通方式

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
import paramiko
 
class ssh(object):
    def __init__(self,hostdata):
        """
        初始化连接信息和ftp方法
        :param hostdata: 连接信息字段
        """
        self.ip = hostdata[‘ip‘]
        self.port = hostdata[‘port‘]
        self.user = hostdata[‘user‘]
        self.passwd = hostdata[‘passwd‘]
        self.obj = paramiko.SSHClient()
        self.obj.set_missing_host_key_policy(paramiko.AutoAddPolicy ())
        self.obj.connect (self.ip, self.port, self.user, self.passwd)
        self.objsftp = self.obj.open_sftp ()
 
    def run_cmd(self, cmd):
        """
        执行命令方法
        :param cmd: 需要执行的命令
        :return:
        """
        stdin, stdout, stderr = self.obj.exec_command (cmd)
        return stdout.read ()
 
    def run_cmdlist(self, cmdlist):
        """
        执行命令方法列表
        :param cmdlist: 命令列表
        :return:
        """
        self.resultList = []
        for cmd in cmdlist:
            stdin, stdout, stderr = self.obj.exec_command (cmd)
            self.resultList.append (stdout.read ())
        return self.resultList
 
    def get(self,remotepath,localpath):
        """
        下载文件方法(两个路径都要指定文件名)
        :param remotepath: 服务器路径
        :param localpath:  本地路径
        :return:
        """
        self.objsftp.get(remotepath,localpath)
 
    def put(self,localpath,remotepath):
        """
        上传文件方法(两个路径都要指定文件名)
        :param localpath: 本地路径
        :param remotepath: 服务器路径
        :return:
        """
        self.objsftp.put(localpath,remotepath)
 
    def close(self):
        """
        关闭方法
        :return:
        """
        self.objsftp.close ()
        self.obj.close ()
 
# 函数的使用
if __name__ == ‘__main__‘:
    hostdata = {
        ‘ip‘:‘192.168.163.129‘,
        ‘port‘:22,
        ‘user‘:‘root‘,
        ‘passwd‘:‘zhujingzhi‘,
    }
    host = ssh (hostdata)                                      # 实例化远程函数给数据库里面的IP 端口 用户名 密码信息
    = host.run_cmd (‘df -h‘)                                 # 执行单个命令
    vstr = v.decode (encoding=‘utf-8‘, errors=‘strict‘)        # bytes转字符串
    v1 = host.run_cmdlist ([‘ls‘‘df‘])                       # 执行命令列表
    print(hostdata[‘ip‘])
    print(vstr)
    = host.get(‘/root/anaconda-ks.cfg‘,‘D:\\采集\\a.cfg‘)     # 下载文件
    = host.put(‘D:\\采集\\a.cfg‘,‘/opt/a.cfg‘)                # 上传文件
    host.close()
 

以上是关于paramiko模块使用的主要内容,如果未能解决你的问题,请参考以下文章

Python模块学习 - Paramiko

Python模块学习 - Paramiko

python 使用paramiko模块上传本地文件到ssh

使用python的paramiko模块对多台机器更新密码

Python 3.x--paramiko模块详解

paramiko模块,线程,进程