python学习笔记(paramiko)
时间:2019-02-14
本文章向大家介绍python学习笔记(paramiko)，主要包括python学习笔记(paramiko)使用实例、应用技巧、基本知识点总结和需要注意事项，具有一定的参考价值，需要的朋友可以参考一下。
paramiko是什么?
基于ssh用于连接远程服务器做操作:远程执行命令， 上传文件， 下载文件
远程密码连接
import paramiko
# ssh root@172.25.254.250
# 创建一个ssh对象;
client = paramiko.SSHClient()
# 2. 解决问题:如果之前没有；连接过的ip, 会出现
# Are you sure you want to continue connecting (yes/no)? yes
# 自动选择yes
client.set_missing_host_key_policy(paramiko.AutoAddPolicy())
# 3. 连接服务器
client.connect(
hostname='172.25.254.1',
username='root',
password='westos'
)
# 4. 执行操作
stdin, stdout, stderr = client.exec_command('hostname')
# 5. 获取命令的执行结果;
print(stdout.read().decode('utf-8'))
# 6. 关闭连接
client.close()
批量远程密码连接
from paramiko.ssh_exception import NoValidConnectionsError, AuthenticationException
def connect(cmd, hostname, user, password):
import paramiko
# ssh root@172.25.254.250
# 创建一个ssh对象;
client = paramiko.SSHClient()
# 2. 解决问题:如果之前没有；连接过的ip, 会出现
# Are you sure you want to continue connecting (yes/no)? yes
# 自动选择yes
client.set_missing_host_key_policy(paramiko.AutoAddPolicy())
try:
# 3. 连接服务器
client.connect(
hostname=hostname,
username=user,
password=password
)
except NoValidConnectionsError as e:
return "主机%s连接失败" %(hostname)
except AuthenticationException as e:
return "主机%s密码错误" % (hostname)
except Exception as e:
return "未知错误: ", e
else:
# 4. 执行操作
stdin, stdout, stderr = client.exec_command('hostname')
# 5. 获取命令的执行结果;
res = stdout.read().decode('utf-8')
# 6. 关闭连接
client.close()
return res
if __name__ == '__main__':
with open('doc/hosts.txt') as f:
for line in f:
# 172.25.254.1:root:westos
hostname, username, password = line.split(":")
res = connect('hostname', hostname, username, password )
print(hostname.center(50, '*'))
print("主机名:", res)
写入解析hosts文件中
with open('/etc/hosts', 'a+') as f:
f.write('\n')
for i in range(100):
f.write('172.25.254.%s foundation%s.example.com \n' % (i + 1, i + 1))
基于公钥和私钥连接
目标:
1). 172.25.254.3 - host3
172.25.254.4 - host4
2). host4实现无密码连接host3？
*****host3操作: 生成公钥和私钥， 并发送私钥给host4
993 ssh-keygen
994 cd /root/.ssh/
995 ls
996 ssh-copy-id -i id_rsa.pub root@172.25.254.3
997 scp id_rsa kiosk@172.25.254.4:/home/kiosk/.ssh/
*****host4操作：
a). shell命令检测是否可以成功?
ssh root@172.25.254.3
b). 代码实现:
import paramiko
# ssh root@172.25.254.250
# 创建一个ssh对象;
client = paramiko.SSHClient()
# 实例化一个私钥对象
private_key = paramiko.RSAKey.from_private_key_file('/home/kiosk/.ssh/id_rsa')
# 2. 解决问题:如果之前没有；连接过的ip, 会出现
# Are you sure you want to continue connecting (yes/no)? yes
# 自动选择yes
client.set_missing_host_key_policy(paramiko.AutoAddPolicy())
# 3. 连接服务器
client.connect(
hostname='172.25.254.3',
username='root',
pkey= private_key ,
)
# 4. 执行操作
stdin, stdout, stderr = client.exec_command('hostname')
# 5. 获取命令的执行结果;
print(stdout.read().decode('utf-8'))
# 6. 关闭连接
client.close()
基于用户名和密码上传和下载文件
import paramiko
from paramiko import AuthenticationException, SSHException
import logging
def put(hostname, password, source_name, target_name):
# 类似于sftp命令的功能
try:
# 建立与远程主机的通道；
transport = paramiko.Transport(('172.25.254.4', 22))
# 验证用户名和密码是否正确；
transport.connect(username='root', password='Asimov')
# 根据创建并验证成功的通道， 创建sftp客户端;
sftp = paramiko.SFTPClient.from_transport(transport)
except AuthenticationException as e:
print("密码错误:", e)
except SSHException as e:
print("主机不存在:", e)
except Exception as e:
print("未知错误:", e)
else:
# 上传文件
# sftp.put('/etc/passwd', '/mnt/172.25.254.250')
# 下载文件;
sftp.get('/mnt/172.25.254.250')
finally:
# 关闭两台主机建立的通道;
transport.close()
paramiko的再次封装
ssh远程连接集成了执行命令， 上传文件和下载文件的类;
import os
import sys
import paramiko
from paramiko.ssh_exception import NoValidConnectionsError, AuthenticationException, SSHException
import logging
logging.basicConfig(filename='my.log', level=logging.WARN,
format="%(asctime)s-%(filename)s-%(lineno)d- %(levelname)s: %(message)s ")
class SshRemoteHost(object):
"""
1). 实现类似lftp的功能， 只支持一部分的命令， 输入的命令不存在， 则报错；
"""
def __init__(self, host, user, pwd, cmd, port=22):
self.host = host
self.port = port
self.user = user
self.pwd = pwd
self.cmd = cmd # cmd hostname; cmd ls -l; cmd data +%F
def run(self):
# cmd hostname 类的反射机制
cmd_str = self.cmd.split()[0] # cmd
if hasattr(self, 'do_' + cmd_str): # 判断是否有do_cmd方法
getattr(self, 'do_' + cmd_str)()
else:
logging.error("目前不支持该操作.....目前支持cmd, put, get")
print("目前不支持该操作.....目前支持cmd, put, get")
def do_cmd(self):
print("正在执行命令......")
# ssh root@172.25.254.250
# 创建一个ssh对象;
client = paramiko.SSHClient()
# 2. 解决问题:如果之前没有；连接过的ip, 会出现
# Are you sure you want to continue connecting (yes/no)? yes
# 自动选择yes
client.set_missing_host_key_policy(paramiko.AutoAddPolicy())
try:
# 3. 连接服务器
client.connect(
hostname=self.host,
username=self.user,
password=self.pwd
)
except NoValidConnectionsError as e:
logging.error("主机%s连接失败" % (self.host))
print("主机%s连接失败" % (self.host))
except AuthenticationException as e:
logging.error("主机%s密码错误" % (self.host))
print("主机%s密码错误" % (self.host))
except Exception as e:
logging.error("未知错误: ", e)
print("未知错误: ", e)
else:
# cmd hostname; cmd ls -l; cmd data +%F
# ['cmd', 'ls', '-l']
# ['ls', '-l']
# 'ls -l'
cmd = " ".join(self.cmd.split()[1:])
# 4. 执行操作
stdin, stdout, stderr = client.exec_command(cmd)
# 5. 获取命令的执行结果;
res = stdout.read().decode('utf-8')
logging.debug("%s 主机执行命令%sd的结果: %s" % (
self.host, self.cmd, res))
# 6. 关闭连接
client.close()
print(res)
def do_put(self):
"""
put /etc/passwd /tmp/hello
:return:
"""
print('正在批量上传文件.....')
# 类似于sftp命令的功能
try:
# 建立与远程主机的通道；
transport = paramiko.Transport((self.host, int(self.port)))
# 验证用户名和密码是否正确；
transport.connect(username=self.user, password=self.pwd)
# 根据创建并验证成功的通道， 创建sftp客户端;
except AuthenticationException as e:
logging.error("%s 密码错误" %(self.host),)
print("%s 密码错误:" %(self.host), e)
except SSHException as e:
logging.error("%s未知错误 :" % (self.host))
print('unknown error:', e)
else:
sftp = paramiko.SFTPClient.from_transport(transport)
# 上传文件
# put file1 file2
filenames = self.cmd.split()[1:]
if len(filenames) == 2:
# 如果执行命令: put /etc/passwd /tmp/passwd
# 目标主机上有文件: /tmp/passwd_172.25.254.1
print(filenames[0], filenames[1]+'_'+self.host)
sftp.put(filenames[0], filenames[1] + '_' + self.host)
else:
print("命令错误, 用法: put 源文件名 目标文件名")
# 关闭两台主机建立的通道;
transport.close()
def do_get(self):
print('正在批量下载文件.....')
# 类似于sftp命令的功能
try:
# 建立与远程主机的通道；
transport = paramiko.Transport((self.host, int(self.port)))
# 验证用户名和密码是否正确；
transport.connect(username=self.user, password=self.pwd)
# 根据创建并验证成功的通道， 创建sftp客户端;
except SSHException as e:
logging.error("%s未知错误 :" % (self.host), e)
# print("%s未知错误:" % (self.host), e)
print('unknown error:', e)
else:
sftp = paramiko.SFTPClient.from_transport(transport)
# 上传文件
# put file1 file2
filenames = self.cmd.split()[1:]
if len(filenames) == 2:
# 如果执行命令: put /etc/passwd /tmp/passwd
# 目标主机上有文件: /tmp/passwd_172.25.254.1
print(filenames[0], filenames[1]+'_'+self.host)
sftp.get(filenames[0], filenames[1] + '_' + self.host)
else:
print("命令错误, 用法: put 源文件名 目标文件名")
# 关闭两台主机建立的通道;
transport.close()
def main():
CONFDIR = 'conf'
# 1. 主机组显示:
print("主机组显示:".center(50, '*'))
# 如何获取conf目录中主机的分组(遍历conf目录中的所有以.conf结尾的文件，主机组名需要去掉.conf);
groups = [file.rstrip('.conf') for file in os.listdir(CONFDIR) if file.endswith('.conf')]
for group in groups: print('\t', group)
while True:
choiceGroup = input("请选择操作的主机组名称(eg: web):")
if choiceGroup not in groups:
logging.error("%s不存在" % (choiceGroup))
print("%s不存在" % (choiceGroup))
else:
break
# 2. 根据选择的主机组， 显示包含的主机IP/主机名;
# 1). 打开对应主机的配置文件, eg: conf/mysql.conf
# 2). 依次读取文件的每一行， 获取主机名;
infostr = "%s主机组包含的主机:" % (choiceGroup)
print(infostr.center(50, '*'))
hostinfos = [] # 存储需要操作的主机信息
with open('%s/%s.conf' % (CONFDIR, choiceGroup)) as f:
for line in f:
# 172.25.254.6:22:root:westos
# print(line.split(":")[0])
hostinfos.append(line.strip().split(':'))
hostname, port, user, passwd = line.strip().split(':')
print(hostname)
# 3. 批量执行脚本
print("批量执行脚本".center(50, '*'))
while True:
cmd = input(">>: ")
if cmd:
if cmd in ['exit', 'quit']:
print("执行结束， 退出中.......")
sys.exit(0)
else:
# cmd, put, get
for host in hostinfos:
hostname, port, user, passwd = host
print(hostname.center(50, '*'))
sshObj = SshRemoteHost(hostname, user, passwd, cmd, port)
sshObj.run()
if __name__ == '__main__':
main()
- C#实现微信AES-128-CBC加密数据的解密
- UrlReferrer为空的问题?
- DeepMind发文回顾2017：AlphaGo团队已迎战下一个重大挑战
- [你必须知道的.Net]读书笔记--浅clone与深clone
- Python基础语法学习整理
- 通过部分感知深度卷积网络进行人脸特征点定位
- [你必须知道的.Net]读书笔记--override与new在继承中的区别
- gitlab配置邮件通知功能操作记录
- 微信小程序价值思考：手机端的CS-BS迁移
- Linq2Sql数据实体外部更新时“不能添加其键已在使用中的实体”的解决办法
- 微信小程序：字体保持大小
- 在为知笔记中使用JQuery
- 在为知笔记中使用JQuery
- Python学习笔记（1）：列表元组结构
- JavaScript 教程
- JavaScript 编辑工具
- JavaScript 与HTML
- JavaScript 与Java
- JavaScript 数据结构
- JavaScript 基本数据类型
- JavaScript 特殊数据类型
- JavaScript 运算符
- JavaScript typeof 运算符
- JavaScript 表达式
- JavaScript 类型转换
- JavaScript 基本语法
- JavaScript 注释
- Javascript 基本处理流程
- Javascript 选择结构
- Javascript if 语句
- Javascript if 语句的嵌套
- Javascript switch 语句
- Javascript 循环结构
- Javascript 循环结构实例
- Javascript 跳转语句
- Javascript 控制语句总结
- Javascript 函数介绍
- Javascript 函数的定义
- Javascript 函数调用
- Javascript 几种特殊的函数
- JavaScript 内置函数简介
- Javascript eval() 函数
- Javascript isFinite() 函数
- Javascript isNaN() 函数
- parseInt() 与 parseFloat()
- escape() 与 unescape()
- Javascript 字符串介绍
- Javascript length属性
- javascript 字符串函数
- Javascript 日期对象简介
- Javascript 日期对象用途
- Date 对象属性和方法
- Javascript 数组是什么
- Javascript 创建数组
- Javascript 数组赋值与取值
- Javascript 数组属性和方法
- Python多进程及多线程基础
- Python字符串三种格式化输出
- 你需要知道的Python代码规范性检查（pylint和flake8）
- Linux下安装python环境
- 【5】进大厂必须掌握的面试题-Java面试-spring
- Python 3.7 自动化接口测试简单实例
- 从 0 开始构建一个亿级请求的微服务架构
- ruby+cucumber+watir环境搭建
- Python常用模块os和shutil学习
- Python简单实现批量下载无版权图片
- Pycharm自动添加文件头注释和函数注释参数
- ClickHouse TTL for Columns and Tables
- Sentence-BERT详解
- 分布式文件系统（HDFS和FastDFS）
- Springboot集成JUnit5优雅进行单元测试