Python运维之远程登录----paramiko
paramiko是一个用于做远程控制的模块，使用该模块可以对远程服务器进行命令或文件操作,paramiko是用python语言写的一个模块，遵循SSH2协议，支持以加密和认证的方式，进行远程服务器的连接。
paramiko包含两个核心组件，一个为SSHClient类，另一个为SFTPClient类。
SSHClient类是SSH服务会话的高级表示，该类封装了传输(transport)、通道(channel)及SFTPClient的校验、建立的方法，通常用于执行远程命令。
SFTPClient作为一个SFTP客户端对象，根据SSH传输协议的sftp会话，实现远程文件操作，比如文件上传、下载、权限、状态等操作。需要注意的是，put和get方法需要指定文件名，不能省略。
安装paramiko Module：
py -m pip install paramiko远程连接：
# paramiko是用python语言写的一个模块，遵循SSH2协议，支持以加密和认证的方式，进行远程服务器的连接。#!/bin/python#coding:utf-8import paramikoimport systransport = paramiko.Transport(('20.85.223.**', 22))#公钥连接'''私钥链接private_key = paramiko.RSAKey.from_private_key_file('/root/.ssh/id_rsa')transport = paramiko.Transport(('192.168.1.**', 22))transport.connect(username='root', pkey=private_key)'''try: transport.connect(username='****', password='*****')except Exception as err: print("connection failure") print(err) sys.exit()ssh = paramiko.SSHClient()ssh._transport = transportstdin, stdout, stderr = ssh.exec_command('kubectl get node')print (stdout.read())transport.close()sftp上传和下载文件：
#!/bin/pythonimport os,sysimport paramikot = paramiko.Transport(('20.85.223.**',22))try: t.connect(username='*****',password='*****')except Exception as err: print("connection failure") print(err) sys.exit()sftp = paramiko.SFTPClient.from_transport(t)#将error.jpg上传到服务器20.85.223.12的/home/junwang目录sftp.put('C:/Users/Daisy/python/test/system_infor.py','/home/junwang/systeminfo.py')#将sftp.txt下载到本机#sftp.get('/home/junwang/test.py','C:/Users/Daisy/python/test/test.py')t.close()check server端：
check 本地：
连接多台服务器：
#导入paramiko，（导入前需要先在环境里安装该模块）import paramikoimport 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为键,值为服务器的用户密码端口定义的字典 "20.85.223.12": { "username": "junwang", "password": "QAZwsx123456!", "port": 22, }, "20.232.176.247": { "username": "junwang", "password": "QAZwsx123456!", "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") )远程连接到多个server上传文件：
'''批量通过ssh协议在服务器上传文件时间：2022-04-09localfile:本地文件名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为键,值为服务器的用户密码端口定义的字典 "20.232.176.247": { "username": "******", "password": "******", "port": 22, }, "20.85.221.160": { "username": "******", "password": "******", "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 )结果:
