paramiko模块, 基于SSH用于连接远程服务器并执行相关操作
SSHClient: 用于连接远程服务器并执行基本命令
1 import paramiko 2 3 # private_key = paramiko.RSAKey.from_private_key_file("/root/.ssh/id.rsa") # 密钥文件 4 5 ssh = paramiko.SSHClient() # 创建SSH对象 6 7 ssh.set_missing_host_key_policy(paramiko.AutoAddPolicy()) # 对没有连接过的地址自动添加到know_host中 8 9 ssh.connect(hostname="120.24.218.137",port=30122, username="root",password="[email protected]") # 通用密码连接 10 # ssh.connect(hostname="120.24.218.137",port=30122, username="root",pkey=private_key) # 通过私钥连接 11 12 stdin,stdout,stderr = ssh.exec_command("scp /root/test /tmp/") # ssh执行的命令,会有3个返回值 13 14 res,err = stdout.read(),stderr.read() # 标准输出,错误输出 15 16 result = res if res else err # 只有两个命令都出错的时候才会输出err,一个命令出错res中还有另一个命令的数据 17 18 print(result.decode()) 19 20 ssh.close() # 关闭连接
1 import paramiko 2 3 # private_key = paramiko.RSAKey.from_private_key_file("/root/.ssh/id.rsa") # 密钥文件 4 5 transport = paramiko.Transport(("10.10.10.1",22)) 6 7 transport.connect(username="root",password="123") 8 # transport.connect(username="root",pkey=private_key) # 密钥认证 9 10 ssh = paramiko.SSHClient() 11 12 ssh._transport = transport # 封装transport到SSHClient对象里 13 14 stdin,stdout,stderr = ssh.exec_command("df -h") 15 16 print(stdout.read().decode()) 17 18 transport.close()
SFTPClient: 用于连接远程服务器并执行上传下载
1 import paramiko 2 3 # private_key = paramiko.RSAKey.from_private_key_file("/root/.ssh/id.rsa") # 密钥文件 4 5 transport = paramiko.Transport(("120.24.218.137",30122)) # 创建transport对象 6 7 transport.connect(username="root",password="[email protected]") # 基于用户名密码建transport连接 8 # transport.connect(username="root",pkey=private_key) # 基于密钥建transport连接 9 10 11 sftp = paramiko.SFTP.from_transport(transport) # 创建一个已连接的sftp客户端通道 12 13 sftp.get("/root/test","./test") # 下载文件,本地路径要写到文件名 14 15 sftp.put("paramiko模块.py","/root/paramiko模块.py") #上传文件,远程路径写到文件名 16 17 transport.close()
from_transport:创建一个已连通的sftp客户端通道
put:上传本地文件到远程服务器
get:从远程服务器上下载文件到本地
StringIO模块
当密钥不是文件而是字符串
1 import paramiko 2 from io import StringIO 3 4 key_str = """-----BEGIN RSA PRIVATE KEY----- 5 MIIEpQIBAAKCAQEAq7gLsqYArAFco02/55IgNg0r7NXOtEM3qXpb/dabJ5Uyky/8 6 NEHhFiQ7deHIRIuTW5Zb0kD6h6EBbVlUMBmwJrC2oSzySLU1w+ZNfH0PE6W6fans 7 H80whhuc/YgP+fjiO+VR/gFcqib8Rll5UfYzf5H8uuOnDeIXGCVgyHQSmt8if1+e 8 7hn1MVO1Lrm9Fco8ABI7dyv8/ZEwoSfh2C9rGYgA58LT1FkBRkOePbHD43xNfAYC 9 tfLvz6LErMnwdOW4sNMEWWAWv1fsTB35PAm5CazfKzmam9n5IQXhmUNcNvmaZtvP 10 c4f4g59mdsaWNtNaY96UjOfx83Om86gmdkKcnwIDAQABAoIBAQCnDBGFJuv8aA7A 11 ZkBLe+GN815JtOyye7lIS1n2I7En3oImoUWNaJEYwwJ8+LmjxMwDCtAkR0XwbvY+ 12 c+nsKPEtkjb3sAu6I148RmwWsGncSRqUaJrljOypaW9dS+GO4Ujjz3/lw1lrxSUh 13 IqVc0E7kyRW8kP3QCaNBwArYteHreZFFp6XmtKMtXaEA3saJYILxaaXlYkoRi4k8 14 S2/K8aw3ZMR4tDCOfB4o47JaeiA/e185RK3A+mLn9xTDhTdZqTQpv17/YRPcgmwz 15 zu30fhVXQT/SuI0sO+bzCO4YGoEwoBX718AWhdLJFoFq1B7k2ZEzXTAtjEXQEWm6 16 01ndU/jhAasdfasdasdfasdfa3eraszxqwefasdfadasdffsFIfAsjQb4HdkmHuC 17 OeJrJOd+CYvdEeqJJNnF6AbHyYHIECkj0Qq1kEfLOEsqzd5nDbtkKBte6M1trbjl 18 HtJ2Yb8w6o/q/6Sbj7wf/cW3LIYEdeVCjScozVcQ9R83ea05J+QOAr4nAoGBAMaq 19 UzLJfLNWZ5Qosmir2oHStFlZpxspax/ln7DlWLW4wPB4YJalSVovF2Buo8hr8X65 20 lnPiE41M+G0Z7icEXiFyDBFDCtzx0x/RmaBokLathrFtI81UCx4gQPLaSVNMlvQA 21 539GsubSrO4LpHRNGg/weZ6EqQOXvHvkUkm2bDDJAoGATytFNxen6GtC0ZT3SRQM 22 WYfasdf3xbtuykmnluiofasd2sfmjnljkt7khghmghdasSDFGQfgaFoKfaawoYeH 23 C2XasVUsVviBn8kPSLSVBPX4JUfQmA6h8HsajeVahxN1U9e0nYJ0sYDQFUMTS2t8 24 RT57+WK/0ONwTWHdu+KnaJECgYEAid/ta8LQC3p82iNAZkpWlGDSD2yb/8rH8NQg 25 9tjEryFwrbMtfX9qn+8srx06B796U3OjifstjJQNmVI0qNlsJpQK8fPwVxRxbJS/ 26 pMbNICrf3sUa4sZgDOFfkeuSlgACh4cVIozDXlR59Z8Y3CoiW0uObEgvMDIfenAj 27 98pl3ZkCgYEAj/UCSni0dwX4pnKNPm6LUgiS7QvIgM3H9piyt8aipQuzBi5LUKWw 28 DlQC4Zb73nHgdREtQYYXTu7p27Bl0Gizz1sW2eSgxFU8eTh+ucfVwOXKAXKU5SeI 29 +MbuBfUYQ4if2N/BXn47+/ecf3A4KgB37Le5SbLDddwCNxGlBzbpBa0= 30 -----END RSA PRIVATE KEY-----""" 31 32 # print(StringIO(key_str).read()) # 读取key_str内容,StringIO可以用来作字符串缓存 33 34 private_key = paramiko.RSAKey(file_obj=StringIO(key_str)) # 密钥 35 36 transport = paramiko.Transport(("10.10.10.1",22)) 37 38 transport.connect(username="root",pkey=private_key) 39 40 ssh = paramiko.SSHClient() 41 42 ssh._transport = transport 43 44 stdin, stdout, stderr = ssh.exec_command("df") 45 46 transport.close() 47 48 print(stdout.read().decode())
StringIO经常被用来作字符串的缓存,因为StringIO的一些接口和文件操作是一致的,也就是说同样的代码,可以同时当成文件操作或者StringIO操作
1 read用法: 2 s.read([n]):参数n用于限定读取的长度,类型为int,默认为从当前位置读取对象s中所有的数据。读取结束后,位置被移动。 3 4 readline用法: 5 s.readline([length]):length用于限定读取的结束位置,类型为int,缺省为None,即从当前位置读取至下一个以‘\n‘为结束符的当前行。读位置被移动。 6 7 readlines用法: 8 s.readlines():读取所有行,生成一个列表 9 10 write用法: 11 s.write(s):从读写位置将参数s写入到对象s。参数为str或unicode类型,读写位置的指针被移动 12 s.write("alex") 13 s.seek(0) # 指针回到原来位置,不执行这语句时,指针会跑到4的位置 14 print("tell:",s.tell()) # 读取指针位置 15 16 writeline用法: 17 s.writeline(s):从读写位置将list写入给对象s。参数list为一个列表,列表的成员为str或unicode类型。读写位置被移动,同上面的s.write()指针移动位置一样 18 19 getvalue用法: 20 s.getvalue():返回对象s中的所有数据 21 22 truncate用法: 23 s.truncate([size]):从读写位置起切断数据,参数size限定裁剪长度,默认为None 24 25 tell用法: 26 s.tell() #返回当前读写位置 27 28 seek用法: 29 s.seek(pos[,mode]):移动当前读写位置至pos处,可选参数mode为0时将读写位置移动到pos处,为1时将读写位置从当前位置移动pos个长度,为2时读写位置置于末尾处再向后移动pos个长度。默认为0 30 31 close用法: 32 s.close():释放缓冲区,执行此函数后,数据将被释放,也不可再进行操作。 33 34 isatty用法: 35 s.isatty():此函数总是返回0。不论StringIO对象是否已被close。 36 print(s.isatty()) # False 37 38 flush用法: 39 s.flush():刷新缓冲区。