python之paramiko模块

矫情吗；* 2022-05-13 00:44 849阅读 0赞

paramiko是一个用于做远程控制的模块，使用该模块可以对远程服务器进行命令或文件操作,paramiko是用python语言写的一个模块，遵循SSH2协议，支持以加密和认证的方式，进行远程服务器的连接。

由于使用的是python这样的能够跨平台运行的语言，所以所有python支持的平台，如Linux, Solaris, BSD, MacOS X, Windows等，paramiko都可以支持，因此，如果需要使用SSH从一个平台连接到另外一个平台，进行一系列的操作时，paramiko是最佳工具之一。

一.paramiko模块的安装

1.pycharm内安装
进入pycharm，执行‘import paramiko‘,发现没有paramiko，此时我们将鼠标放在paramiko上，按‘alt + enter‘，会出现如下图界面，并选择第一个进行安装。
这里写图片描述

等待一会，若出现下面界面，说明安装成功
这里写图片描述
2.外部安装
pycrypto，由于 paramiko 模块内部依赖pycrypto，所以先下载安装pycrypto

yum -y install python-devel
pip3 install pycrypto
pip3 install paramiko

二.应用案例

1.paramiko远程密码连接

  1. import paramiko
  3. ##1.创建一个ssh对象
  4. client = paramiko.SSHClient()
  6. #2.解决问题:如果之前没有，连接过的ip，会出现选择yes或者no的操作，
  7. ##自动选择yes
  8. client.set_missing_host_key_policy(paramiko.AutoAddPolicy())
  10. #3.连接服务器
  11. client.connect(hostname='172.25.254.31',
  12.                port=22,
  13.                username='root',
  14.                password='westos')
  16. #4.执行操作
  17. stdin,stdout, stderr = client.exec_command('hostname')
  19. #5.获取命令执行的结果
  20. result=stdout.read().decode('utf-8')
  21. print(result)
  23. #6.关闭连接
  24. client.close()

这里写图片描述

2.使用sftp上传文件

  1. import paramiko
  2. #获取Transport实例
  3. tran = paramiko.Transport("172.25.254.31",22)
  4. #连接SSH服务端
  5. tran.connect(username = "root", password = "westos")
  6. #获取SFTP实例
  7. sftp = paramiko.SFTPClient.from_transport(tran)
  8. #设置上传的本地/远程文件路径
  9. localpath="passwd.html"   ##本地文件路径
  10. remotepath="/home/kiosk/Desktop/fish"   ##上传对象保存的文件路径
  11. #执行上传动作
  12. sftp.put(localpath,remotepath)
  14. tran.close()

3.使用sftp下载文件

  1. import paramiko
  3. #获取SSHClient实例
  4. client = paramiko.SSHClient()
  5. client.set_missing_host_key_policy(paramiko.AutoAddPolicy())
  6. #连接SSH服务端
  7. client.connect("172.25.254.31",username="root",password="westos")
  8. #获取Transport实例
  9. tran = client.get_transport()
  10. #获取SFTP实例
  11. sftp = paramiko.SFTPClient.from_transport(tran)
  13. remotepath='/home/kiosk/Desktop/fish'
  14. localpath='/home/kiosk/Desktop/fish'
  16. sftp.get(remotepath, localpath)
  18. client.close()

4.批量远程密码连接

  1. from paramiko.ssh_exception import NoValidConnectionsError
  2. from paramiko.ssh_exception import AuthenticationException
  5. def connect(cmd,hostname,port=22,username='root',passwd='westos'):
  6.     import paramiko
  8.     ##1.创建一个ssh对象
  9.     client = paramiko.SSHClient()
  11.     #2.解决问题:如果之前没有，连接过的ip，会出现选择yes或者no的操作，
  12.     ##自动选择yes
  13.     client.set_missing_host_key_policy(paramiko.AutoAddPolicy())
  15.     #3.连接服务器
  16.     try:
  17.         client.connect(hostname=hostname,
  18.                        port=port,
  19.                        username=username,
  20.                        password=passwd)
  21.         print('正在连接主机%s......'%(hostname))
  22.     except NoValidConnectionsError as e:   ###用户不存在时的报错
  23.         print("连接失败")
  24.     except AuthenticationException as t:   ##密码错误的报错
  25.         print('密码错误')
  27.     else:
  28.         #4.执行操作
  29.         stdin,stdout, stderr = client.exec_command(cmd)
  31.         #5.获取命令执行的结果
  32.         result=stdout.read().decode('utf-8')
  33.         print(result)
  35.         #6.关闭连接
  36.     finally:
  37.         client.close()
  39. with open('ip.txt') as f:  #ip.txt为本地局域网内的一些用户信息
  40.     for line in f:
  41.         line = line.strip()   ##去掉换行符
  42.         hostname,port,username,passwd= line.split(':')
  43.         print(hostname.center(50,'*'))
  44.         connect('uname', hostname, port,username,passwd)

ip.txt 文件内容
这里写图片描述
连接后结果
这里写图片描述
5.paramiko基于公钥密钥连接

  1. import  paramiko
  3. from paramiko.ssh_exception import NoValidConnectionsError, AuthenticationException
  6. def connect(cmd, hostname, port=22, user='root'):
  8.     client = paramiko.SSHClient()  
  10.     private_key = paramiko.RSAKey.from_private_key_file('id_rsa')
  11.      ###id_rsa为本地局域网密钥文件
  13.     client.set_missing_host_key_policy(paramiko.AutoAddPolicy())
  14.     try:
  15.         client.connect(hostname=hostname,
  16.                        port=port,
  17.                        username=user,
  18.                        pkey=private_key
  19.                       )
  21.         stdin, stdout, stderr = client.exec_command(cmd)
  22.     except NoValidConnectionsError as e:
  23.         print("连接失败")
  24.     except AuthenticationException as e:
  25.         print("密码错误")
  26.     else:
  28.         result = stdout.read().decode('utf-8')
  29.         print(result)
  30.     finally:
  32.         client.close()
  33. for count in range(254):
  34.     host = '172.25.254.%s' %(count+1)
  35.     print(host.center(50, '*'))
  36.     connect('uname', host)

6.基于密钥的上传和下载

  1. import paramiko
  2. private_key = paramiko.RSAKey.from_private_key_file('id_rsa')
  3. tran = paramiko.Transport('172.25.254.31',22)
  4. tran.connect(username='root',password='westos')
  5. #获取SFTP实例
  6. sftp = paramiko.SFTPClient.from_transport(tran)
  7. remotepath='/home/kiosk/Desktop/fish8'
  8. localpath='/home/kiosk/Desktop/fish1'
  9. sftp.put(localpath,remotepath)
  10. sftp.get(remotepath, localpath)

7.paramiko的再封装

  1. import os
  2. import paramiko
  3. from paramiko.ssh_exception import NoValidConnectionsError, AuthenticationException, SSHException
  6. class SshRemoteHost(object):
  7.     def __init__(self, hostname, port, user, passwd, cmd):
  8.         self.hostname  = hostname
  9.         self.port = port
  10.         self.user = user
  11.         self.passwd = passwd
  12.         self.cmd = cmd
  13.     def run(self):
  14.         """默认调用的内容"""
  15.         # cmd hostname
  16.         # put
  17.         # get
  18.         cmd_str =  self.cmd.split()[0] # cmd
  19.         # 类的反射，判断类里面是否可以支持该操作
  20.         if hasattr(self, 'do_'+ cmd_str):  # do_cmd
  21.             getattr(self, 'do_'+cmd_str)()
  22.         else:
  23.             print("目前不支持该功能")
  25.     def do_cmd(self):
  26.         client = paramiko.SSHClient()
  28.         client.set_missing_host_key_policy(paramiko.AutoAddPolicy())
  30.         try:
  32.             client.connect(hostname=self.hostname,
  33.                            port=self.port,
  34.                            username=self.user,
  35.                            password=self.passwd)
  37.             print("正在连接%s......." % (self.hostname))
  38.         except NoValidConnectionsError as e:
  39.             print("连接失败")
  40.         except AuthenticationException as e:
  41.             print("密码错误")
  42.         else:
  43.             # 4. 执行操作
  44.             cmd = ''.join(self.cmd.split()[1:])  ##将输入的后面的取出，作为
  45.             stdin, stdout, stderr = client.exec_command(cmd)
  47.             # 5.获取命令执行的结果
  48.             result = stdout.read().decode('utf-8')
  49.             print(result)
  50.         finally:
  51.             # 6.关闭连接
  52.             client.close()
  54.     def do_put(self):
  55.         ###put /tmp/passwd ###将本地的/tmp/passwd上传到远端/tmp/passwd
  56.         print('正在上传...')
  57.         try:
  58.             #获取Transport实例
  59.             tran = paramiko.Transport(self.hostname,int(self.port))  ##由于端口为整形，而我们用split方法得到的是str
  60.             #连接SSH服务端
  61.             tran.connect(username = self.user, password = self.passwd)
  62.         except SSHException as e:
  63.             print('连接失败')
  64.         else:
  65.             #获取SFTP实例
  66.             sftp = paramiko.SFTPClient.from_transport(tran)
  67.             newCmd = self.cmd.split()[1:]
  68.             if len(newCmd) == 2:
  70.                 #设置上传的本地/远程文件路径
  71.                 localpath=newCmd[0]
  72.                 remotepath=newCmd[1]
  73.                 #执行上传动作
  74.                 sftp.put(localpath,remotepath)
  75.                 print('%s文件上传到%s主机的%s文件成功' %(localpath,self.hostname,remotepath))
  76.             else:
  77.                 print('上传文件信息错误')
  79.                 tran.close()
  82.     def do_get(self):
  84.         print('正在下载...')
  85.         try:
  86.             # 获取Transport实例
  87.             tran = paramiko.Transport(self.hostname, int(self.port))  ##由于端口为整形，而我们用split方法得到的是str
  88.             # 连接SSH服务端
  89.             tran.connect(username=self.user, password=self.passwd)
  90.         except SSHException as e:
  91.             print('连接失败')
  92.         else:
  93.             # 获取SFTP实例
  94.             sftp = paramiko.SFTPClient.from_transport(tran)
  95.             newCmd = self.cmd.split()[1:]
  96.             if len(newCmd) == 2:
  98.                 # 设置下载的本地/远程文件路径
  99.                 localpath = newCmd[1]
  100.                 remotepath = newCmd[0]
  101.                 # 执行上传动作
  102.                 sftp.get( remotepath,localpath)
  103.                 print('%s主机的%s文件下载到%s文件成功' % (self.hostname,remotepath,localpath))
  104.             else:
  105.                 print('上传文件信息错误')
  107.                 tran.close()
  110. import paramiko
  111. import os
  112. # 1.选择操作的主机组:eg:mysql,web,ftp
  113. groups=[file.rstrip('.conf') for  file in os.listdir('conf')]
  114. print("主机组显示：".center(50,'*'))
  115. for group in groups:
  116.     print('\t',group)
  117. choiceGroup = input("选择批量操作的主机组(eg:mysql):")
  120. ##2.根据选择的主机组，显示包含的主机IP/主机名
  121. # 1).打开文件conf/choiceGroup.conf
  122. # 2).依次读取文件每一行
  123. # 3).只拿出
  124. print("主机组包含的主机：".center(50,'*'))
  125. with open('conf/%s.conf' %(choiceGroup)) as f:
  126.     for line in f:
  127.         print(line.split(':')[0])
  128.     f.seek(0,0)  ##把指针移动到文件最开始
  129.     hostinfos = [line.strip() for line in f.readlines()]
  131. ###3.让用户确认信息，选择需要批量执行的命令；
  132. ## -cmd shell 命令
  133. ## -put 本地文件 远程文件
  134. ## -get 远程文件 本地文件
  135. print("批量执行脚本".center(50,"*"))
  136. while True:
  137.     cmd = input('>>:').strip()
  138.     if cmd :
  139.         if cmd == 'exit' or cmd == "quit":
  140.             print("执行完毕，正在退出")
  141.             break
  142.         for info in hostinfos:
  143.             host,port,user,passwd = info.split(':')
  144.             clientObj = SshRemoteHost(host,port,user,passwd,cmd)
  145.             clientObj.run()

这里写图片描述
这里写图片描述

发表评论

表情：
评论列表 （有 0 条评论，849人围观）

还没有评论，来说两句吧...

相关阅读

    相关 python模块之 paramiko

    paramiko模块提供了ssh及sft进行远程登录服务器执行命令和上传下载文件的功能。这是一个第三方的软件包，使用之前需要安装。 1 基于用户名和密码的 sshclient

    以你之姓@以你之姓@/ 0 赞/ 317 阅读

    相关 python之paramiko模块

    paramiko是一个用于做远程控制的模块，使用该模块可以对远程服务器进行命令或文件操作,paramiko是用python语言写的一个模块，遵循SSH2协议，支持以加密和认证的

    矫情吗；*矫情吗；*/ 0 赞/ 850 阅读