Python运维自动化之paramiko模块应用实例

目录
  • 运维自动化Python
  • 一、模块介绍
  • 二、模块应用
    • 1.使用paramiko模块,通过ssh协议连接服务器
    • 2.解决首次连接known_hosts问题
    • 3、执行命令exec_command方法
    • 扩展:
      • 使用try异常捕获
    • 4、多台服务器执行命令
    • 5、从服务器上传下载文件–SFTPClient方法
    • 6、多台服务器上传下载文件
    • 扩展-文件操作
  • 可扩展练习
  • 总结

运维自动化Python

paramiko模块

一、模块介绍

模块:paramiko

模块作用:

1、通过ssh协议远程执行命令

2、文件上传下载

安装模块:

pip install paramiko

二、模块应用

1.使用paramiko模块,通过ssh协议连接服务器

#导入paramiko,(导入前需要先在环境里安装该模块)
import paramiko

#定义函数ssh,把操作内容写到函数里
def sshExeCMD():
    #定义一个变量ssh_clint
    ssh_client=paramiko.SSHClient()
    #使用cnnect类来连接服务器
    ssh_client.connect(hostname="192.168.1.110", port="22", username="songxk", password="123123")

#通过判断模块名运行上边函数
if __name__ == '__main__':
    sshExeCMD()

这时会报错,提示在服务器的known_hosts中没有,这个就是连接服务器的时候那个首次连接需要输入一个yes保存证书。

2.解决首次连接known_hosts问题

通过这个set_missing_host_key_policy方法用于实现登录是需要确认输入yes,否则保存

#导入paramiko,(导入前需要先在环境里安装该模块)
import paramiko

#定义函数ssh,把操作内容写到函数里
def sshExeCMD():
    #定义一个变量ssh_clint
    ssh_client=paramiko.SSHClient()
    #通过这个set_missing_host_key_policy方法用于实现登录是需要确认输入yes,否则保存
    ssh_client.set_missing_host_key_policy(paramiko.AutoAddPolicy())
    #使用cnnect类来连接服务器
    ssh_client.connect(hostname="192.168.1.110", port="22", username="songxk", password="123123")

#通过判断模块名运行上边函数
if __name__ == '__main__':
    sshExeCMD()

连接成功, 没有报错:

3、执行命令exec_command方法

使用exec_command执行命令会返回三个信息:

1、标准输入内容(用于实现交互式命令)

2、标准输出(保存命令的正常执行结果)

3、标准错误输出(保存命令的错误信息)

可以通过三个变量来接受,然后使用print输出到屏幕查看

#导入paramiko,(导入前需要先在环境里安装该模块)
import paramiko

#定义函数ssh,把操作内容写到函数里
def sshExeCMD():
    #定义一个变量ssh_clint使用SSHClient类用来后边调用
    ssh_client=paramiko.SSHClient()
    #通过这个set_missing_host_key_policy方法用于实现登录是需要确认输入yes,否则保存
    ssh_client.set_missing_host_key_policy(paramiko.AutoAddPolicy())
    #使用cnnect类来连接服务器
    ssh_client.connect(hostname="192.168.1.110", port="22", username="songxk", password="123123")
    #使用exec_command方法执行命令,并使用变量接收命令的返回值并用print输出
    stdin, stdout, stderr = ssh_client.exec_command("hostname")
    print(stdout.read())
#通过判断模块名运行上边函数
if __name__ == '__main__':
    sshExeCMD()

展示内容以python的格式b’内容\n’的格式展示,如果后边需要对回显处理,可以直接用str把内容输出为字符串格式如下:

print(str(stdout.read()))

扩展:

使用try异常捕获

import paramiko
import sys
#定义函数ssh,把操作内容写到函数里
def sshExeCMD():
    #定义一个变量ssh_clint使用SSHClient类用来后边调用
    ssh_client=paramiko.SSHClient()
    #通过这个set_missing_host_key_policy方法用于实现登录是需要确认输入yes,否则保存
    ssh_client.set_missing_host_key_policy(paramiko.AutoAddPolicy())
    #使用try做异常捕获
    try:
    #使用cnnect类来连接服务器
        ssh_client.connect(hostname="192.168.1.110", port="22", username="songx1k", password="123123")
    #如果上边命令报错吧报错信息定义到err变量,并输出。
    except Exception as err:
        print("服务器链接失败!!!")
        print(err)
        #如果报错使用sys的exit退出脚本
        sys.exit()
    #使用exec_command方法执行命令,并使用变量接收命令的返回值并用print输出
    stdin, stdout, stderr = ssh_client.exec_command("df -hT")
    print(str(stdout.read()))
#通过判断模块名运行上边函数
if __name__ == '__main__':
    sshExeCMD()

4、多台服务器执行命令

注意:给函数传参,需要在函数括号里写上接收的参数

#导入paramiko,(导入前需要先在环境里安装该模块)
import paramiko
import sys
#定义函数ssh,把操作内容写到函数里,函数里接收参数(写在括号里),其中port=是设置一个默认值如果没传就用默认
def sshExeCMD(ip, username, password, port=22):
    #定义一个变量ssh_clint使用SSHClient类用来后边调用
    ssh_client=paramiko.SSHClient()
    #通过这个set_missing_host_key_policy方法用于实现登录是需要确认输入yes,否则保存
    ssh_client.set_missing_host_key_policy(paramiko.AutoAddPolicy())
    #使用try做异常捕获
    try:
    #使用cnnect类来连接服务器
        ssh_client.connect(hostname=ip, port=port, username=username, password=password)
    #如果上边命令报错吧报错信息定义到err变量,并输出。
    except Exception as err:
        print("服务器链接失败!!!"% ip)
        print(err)
        #如果报错使用sys的exit退出脚本
        sys.exit()
    #使用exec_command方法执行命令,并使用变量接收命令的返回值并用print输出
    #这里也可以把命令做成参数传进来
    stdin, stdout, stderr = ssh_client.exec_command("hostname")
    #使用decode方法可以指定编码
    print(stdout.read().decode("utf-8"))
#通过判断模块名运行上边函数
if __name__ == '__main__':
    #定义一个字典,写服务器信息
    servers = {
        #以服务器IP为键,值为服务器的用户密码端口定义的字典
        "192.168.1.110": {
            "username": "songxk",
            "password": "123123",
            "port": 22,
        },
        "192.168.1.123": {
            "username": "root",
            "password": "123123",
            "port": 22,
        },
    }
    #使用items方法遍历,使用ip 和info把字典里的键和值遍历赋值,传给函数sshExeCMD
    for ip, info in servers.items():
        # 这里的info也就是上边定义的ip对应值的字典,使用get获取这个字典里对应username键对应的值,赋值给变量username传给函数中使用
        sshExeCMD(
            ip=ip,
            username=info.get("username"),
            password=info.get("password"),
            port=info.get("port")
        )

5、从服务器上传下载文件–SFTPClient方法

'''
通过ssh协议在服务器上传下载文
时间:2022-04-09
'''
import paramiko

def sshfileftp():
    #与服务器创建ssh连接,transport方法建立通道,以元组的方式歇服务器信息
    ssh_conn = paramiko.Transport(("192.168.1.110", 60317))
    ssh_conn.connect(username="songxk", password="123123")

    #创建连接后,使用sftpclient类和from_transport(括号里写上边创建的Transport通道)基于上边ssh连接创建一个sftp连接,定义成ftp_client变量后边方便引用
    ftp_client = paramiko.SFTPClient.from_transport(ssh_conn)
    #下载文件
    #ftp_client.get("目标文件", r"保存位置,写到文件名")
    ftp_client.get("/etc/fstab", r"C:\Users\Administrator.USER-CH3G0KO3MG\Desktop\test\fstab")
    '''
    上传文件
    ftp_client.put(r"C:\Users\Administrator.USER-CH3G0KO3MG\Desktop\test\fstab", "/etc/fstab")
    '''

    #关闭ssh连接
    ssh_conn.close()

if __name__ == '__main__':
    sshfileftp()

6、多台服务器上传下载文件

和批量对服务器执行命令原理一样,使用字典写服务器信息,通过for循环处理把变量分别传给写好的上传函数。

'''
批量通过ssh协议在服务器上传文件
时间:2022-04-09
localfile:本地文件名
remotedir:服务器目录名
'''

import paramiko
#后续需要用到os模块的方法
import os

#定义函数并且接收变量
def sshPutfile(ip, port, username, password, localfile, remotedir):
    #获取源文件的文件名,把进来的localfile变量的值处理只剩文件名
    file_name = os.path.basename(localfile)

    #处理服务器目录名,如果输入的目录名没有带后边的/(不是以/结尾)则添加一个,方便后边拼接文件名
    if not remotedir.endswith("/"):
        remotedir = remotedir + "/"
    dest_file_name = remotedir + file_name

    #创建ssh连接
    ssh_conn = paramiko.Transport((ip, port))
    ssh_conn.connect(username=username, password=password)
    #创建ftp工具(变量)
    ftp_client = paramiko.SFTPClient.from_transport(ssh_conn)
    #上传文件
    ftp_client.put(localfile, dest_file_name)
    # 关闭ssh连接
    ssh_conn.close()

if __name__ == '__main__':
    #定义一个字典,写服务器的信息
    servers = {
        #以服务器IP为键,值为服务器的用户密码端口定义的字典
        "192.168.1.110": {
            "username": "songxk",
            "password": "123123",
            "port": 60317,
        },
        "192.168.106.71": {
            "username": "root",
            "password": "123123",
            "port": 22,
        },
    }
    source_file = input("请输入源文件路径(绝对路径):")
    remote_dir = input("服务器路径(绝对路径):")
    for ip, info in servers.items():
        sshPutfile(
            ip=ip,
            port=info.get("port"),
            username=info.get("username"),
            password=info.get("password"),
            localfile=source_file,
            remotedir=remote_dir
        )

效果:

扩展-文件操作

对文件的操作除了上传下载还有其他很多操作

可扩展练习

1、 输入的文件是否存在

2、服务器目录是否存在

3、上传后文件是否完整(利用md5判断,本地文件的md5和Linux命令md5sum)

总结

到此这篇关于Python运维自动化之paramiko模块应用的文章就介绍到这了,更多相关Python自动化paramiko模块内容请搜索我们以前的文章或继续浏览下面的相关文章希望大家以后多多支持我们!

(0)

相关推荐

  • Python使用Paramiko模块编写脚本进行远程服务器操作

    简介: paramiko是python(2.2或更高)的模块,遵循SSH2协议实现了安全(加密和认证)连接远程机器. 安装所需软件包: http://ftp.dlitz.net/pub/dlitz/crypto/pycrypto/pycrypto-2.5.tar.gz http://www.lag.net/paramiko/download/paramiko-1.7.7.1.tar.gz tar zxvf pycrypto-2.5.tar.gz cd pycrypto-2.5 python se

  • Python paramiko模块使用解析(实现ssh)

    开发堡垒机之前,先来学习Python的paramiko模块,该模块基于SSH用于连接远程服务器并执行相关操作 安装paramiko模块 pip3 install paramiko 基于用户密码方式 import paramiko # 创建SSH对象 ssh = paramiko.SSHClient() # 允许连接不在know_hosts文件中的主机 ssh.set_missing_host_key_policy(paramiko.AutoAddPolicy()) # 连接服务器 ssh.con

  • Python Paramiko模块的使用实际案例

    本文研究的主要是Python Paramiko模块的使用的实例,具体如下. Windows下有很多非常好的SSH客户端,比如Putty.在python的世界里,你可以使用原始套接字和一些加密函数创建自己的SSH客户端或服务端,但如果有现成的模块,为什么还要自己实现呢.使用Paramiko库中的PyCrypto能够让你轻松使用SSH2协议. Paramiko的安装方法网上有很多这样的帖子,这里就不描述了.这里主要讲如何使用它.Paramiko实现SSH2不外乎从两个角度实现:SSH客户端与服务端.

  • python下paramiko模块实现ssh连接登录Linux服务器

    本文实例讲述了python下paramiko模块实现ssh连接登录Linux服务器的方法.分享给大家供大家参考.具体分析如下: python下有个paramiko模块,这个模块可以实现ssh登录linux服务器,下面贴出代码,注意,我在centos5.6下,python2.6.5,paramiko-1.7的版本下测试成功. #!/usr/bin/env python import paramiko hostname='172.28.102.249' username='root' passwor

  • Python Paramiko模块的安装与使用详解

    一.前言 常见的解决方法都会需要对远程服务器必要的配置,如果远程服务器只有一两台还好说,如果有N台,还需要逐台进行配置,或者需要使用代码进行以上操作时,上面的办法就不太方便了.而使用paramiko可以很好的解决以上问题,比起前面的方法,它仅需要在本地上安装相应的软件(python以及PyCrypto),对远程服务器没有配置要求,对于连接多台服务器,进行复杂的连接操作特别有帮助.下面本文就来详细的介绍Python Paramiko模块的安装与使用,一起学习学习吧.. 二.安装 安装paramik

  • python paramiko模块学习分享

    paramiko是用python语言写的一个模块,遵循SSH2协议,支持以加密和认证的方式,进行远程服务器的连接.paramiko支持Linux, Solaris, BSD, MacOS X, Windows等平台通过SSH从一个平台连接到另外一个平台.利用该模块,可以方便的进行ssh连接和sftp协议进行sftp文件传输. 首先让我们理清以下几个名词: SSHClient:包装了Channel.Transport.SFTPClient Channel:是一种类Socket,一种安全的SSH传输

  • python使用paramiko模块实现ssh远程登陆上传文件并执行

    程序执行时需要读取两个文件command.txt和ipandpass.txt.格式如下: 复制代码 代码如下: command.txt:ThreadNum:1port:22local_dir:hello_mkdirremote_dir:hello_mkdiralter_auth:chmod 755 hello_mkdirexec_program:./hello_mkdir ipandpass.txt:ip username password 程序中的队列操作是修改的别的程序,写的确实不错.该程序

  • Python paramiko模块的使用示例

    paramiko模块提供了ssh及sft进行远程登录服务器执行命令和上传下载文件的功能.这是一个第三方的软件包,使用之前需要安装. 1 基于用户名和密码的 sshclient 方式登录 # 建立一个sshclient对象 ssh = paramiko.SSHClient() # 允许将信任的主机自动加入到host_allow 列表,此方法必须放在connect方法的前面 ssh.set_missing_host_key_policy(paramiko.AutoAddPolicy()) # 调用c

  • Python运维自动化之paramiko模块应用实例

    目录 运维自动化Python 一.模块介绍 二.模块应用 1.使用paramiko模块,通过ssh协议连接服务器 2.解决首次连接known_hosts问题 3.执行命令exec_command方法 扩展: 使用try异常捕获 4.多台服务器执行命令 5.从服务器上传下载文件–SFTPClient方法 6.多台服务器上传下载文件 扩展-文件操作 可扩展练习 总结 运维自动化Python paramiko模块 一.模块介绍 模块:paramiko 模块作用: 1.通过ssh协议远程执行命令 2.文

  • Python运维自动化之nginx配置文件对比操作示例

    本文实例讲述了Python运维自动化之nginx配置文件对比操作.分享给大家供大家参考,具体如下: 文件差异对比diff.py #!/usr/bin/env python # import difflib import sys try: textfile1=sys.argv[1] textfile2=sys.argv[2] except exception,e: print "Error:"+str(2) print "Usge: difflib.py file1 file2

  • Python运维之获取系统CPU信息的实现方法

    使用Python进行运维工作的时候有时候需要获取CPU的信息,这在psutil模块库的帮助下非常容易实现. 常见的CPU信息有以下几种: 1,用户时间以及百分比: 2,系统时间以及百分比: 3,空闲时间以及百分比: 4,CPU的硬件信息: 前3个中的时间可以采用cpu_times方法获取,百分比可以使用cpu_times_pcercent获得. 简单的示范如下: In [9]: importpsutil In [10]:psutil.cpu_times() Out[10]: scputimes(

  • Python用于学习重要算法的模块pygorithm实例浅析

    本文实例讲述了Python用于学习重要算法的模块pygorithm.分享给大家供大家参考,具体如下: 这是一个能够随时学习重要算法的Python模块,纯粹是为了教学使用. 特点 易于使用 容易理解的文档 快速获取算法的源代码 随时获取时间复杂度 安装 仅需在终端中执行以下命令: pip3 install pygorithm *如果你使用的是Python 2.7,请使用pip来安装.如果存在用户权限的限制,你可能需要使用pip install --user pygorithm这个命令来安装. 或者

  • 20个常用Python运维库和模块

    1.psutil是一个跨平台库(https://github.com/giampaolo/psutil) 能够实现获取系统运行的进程和系统利用率(内存,CPU,磁盘,网络等),主要用于系统监控,分析和系统资源及进程的管理. 2.IPy(http://github.com/haypo/python-ipy),辅助IP规划. 3.dnspython(http://dnspython.org)Python实现的一个DNS工具包. 4.difflib:difflib作为Python的标准模块,无需安装,

  • 集群运维自动化工具ansible的安装与使用(包括模块与playbook使用)第1/2页

    我使用过puppet与salt,但这2个软件都需要安装客户端,并且更新很快,每次更新都是令人蛋疼的事,尤其是salt,喜欢他的命令功能,但bug太多,不敢在公司线上使用,puppet虽然稳定,但弄命令执行的时候,需要mco配置,非常麻烦,我公司由于跟多家公司合作,很多业务没办法安装客户端,所以没办法使用puppet与salt(虽然salt有ssh,但不太好使),最后找到了ansible,他既有命令执行也有配置管理,关键开发它的语言是python,paramiko进行ssh连接,跟我之前开发的自动

  • Python运维开发之psutil库的使用详解

    介绍 psutil能够轻松实现获取系统运行的进程和系统利用率. 导入模块 import psutils 获取系统性能信息 CPU信息 使用cpu_times()方法获取CPU的完整信息: >>> psutil.cpu_times() 获取单项数据,例如用户user的CPU时间比: >>> psutil.cpu_times().user 获取CPU的个数: >>> psutil.cpu_count() # 默认logical=True,获取逻辑个数 &g

  • 集群运维自动化工具ansible之使用playbook安装zabbix客户端

    之前介绍了关于ansible的安装与使用(包括模块与playbook使用,地址是http://www.jb51.net/article/52154.htm),今天介绍一下如何使用playbook来部署zabbix客户端. ansible服务端的环境为centos 6.5 x86_64系统 ansible客户端环境为centos 6.3 x86_64系统 目前我的playbook只允许centos或redhat 6系列系统来安装zabbix客户端,并且客户端的版本是2.0.6. 下面是playbo

  • 集群运维自动化工具ansible使用playbook安装mysql

    上次介绍了如何使用ansible playbook安装zabbix客户端(http://www.jb51.net/article/52158.htm),这次介绍一下如何使用playbook安装mysql. 下面是安装mysql的信息: mysql_basedir: /data/mysql/basedir 源码目录 mysql_datadir: /data/mysql/datadir 数据目录 mysql_user: mysql mysql用户 mysql_database_user: root

  • python中使用smtplib和email模块发送邮件实例

    SMTP模块 这么多已定义的类中,我们最常用的的还是smtplib.SMTP类,就具体看看该类的用法:smtp实例封装一个smtp连接,它支持所有的SMTP和ESMTP操作指令,如果host和port参数被定义,则smtp会在初始化期间自动调用connect()方法,如果connect()方法失败,则会触发SMTPConnectError异常,timeout参数设置了超时时间.在一般的调用过程中,应该遵connetc().sendmail().quit()步骤. SMTP模块主要方法 下面我们来

随机推荐