Python中paramiko模块的基础操作与排错问题

河源大盗

关于

1. python的ssh库操作需要引入一个远程控制的模块——paramiko，可用于对远程服务器进行命令或文件操作。

复制代码

应用

1. 登陆服务器，问题排查。可用于编写脚本，在服务器上做一些繁琐的重复操作。

复制代码

安装

1. 打开cmd，输入命令[code]python -m pip install paramiko

复制代码

[/code]
示例


1.秘钥登陆

1. 配置免密登录，linux上信任了windows的公钥，然后脚本在windows上跑，使用windows的私钥就可以直接不要密码登录linux

复制代码

1. 注意

复制代码

：提供秘钥的

1. paramiko.RSAKey.from_private_key_file('文件')

复制代码

，这里面的"文件"是你本机上的秘钥，不是指你被控机上的公钥哦！

1. import paramiko
   
2. 
   
3. key = paramiko.RSAKey.from_private_key_file("C:\\Users\\liyansheng\\.ssh\\id_rsa")
   
4. ssh = paramiko.SSHClient()
   
5. ssh.set_missing_host_key_policy(paramiko.AutoAddPolicy())
   
6. print("connecting")
   
7. ssh.connect(hostname="192.168.220.128", username="root", pkey=key)
   
8. print("connected")
   
9. commands = "uname -a"
   
10. stdin, stdout, stderr = ssh.exec_command(commands)
    
11. stdin.close()
    
12. res, err = stdout.read(), stderr.read()
    
13. result = res if res else err
    
14. print(result)
    
15. ssh.close()
    
16. 
    
17. if __name__ == '__main__':
    
18.     print()

复制代码

2.单个命令执行

1. 创建一个[code].py

复制代码

文件，引入

1. paramiko

复制代码

模块[/code]

1. import paramiko

复制代码

1. <ol start="2"><li>建立[code]SSHClient

复制代码

对象
[/code]

1. ssh = paramiko.SSHClient()

复制代码

1. <ol start="3"><li>设置可信任，将主机加到[code]host_allow

复制代码

列表
[/code]

1. ssh.set_missing_host_key_policy(paramiko.AutoAddPolicy())

复制代码

1. <ol start="4"><li>创建连接</li></ol>

复制代码

1. ssh.connect("150.158.16.123", 22, "wuyanping", "2022")

复制代码

1. <ol start="5"><li>创建命令，发送并获取响应结果</li></ol>

复制代码

1. stdin, stdout, stderr = ssh.exec_command("ls /home")
   
2.     print(stdout.read().decode("utf-8"))

复制代码

1. <ol start="6"><li>关闭连接</li></ol>

复制代码

1. ssh.close()

复制代码

3.执行多个命令

1. # 执行多条命令,注意传入的参数有个list
   
2. def execMultiCmd(host, user, psw, cmds: list, port=22) -> (str, str):
   
3.     with paramiko.SSHClient() as ssh_client:
   
4.         ssh_client.set_missing_host_key_policy(paramiko.AutoAddPolicy())
   
5.         ssh_client.connect(hostname=host, port=port, username=user, password=psw)
   
6.         cmd = ";".join(cmds)
   
7.         _, stdout, stderr = ssh_client.exec_command(cmd, get_pty=True)
   
8.         result = stdout.read().decode('utf-8')
   
9.         err = stderr.read().decode('utf-8')
   
10.     return result, err
    
11. 
    
12. 
    
13. if __name__ == '__main__':
    
14.     cmdList = ["cd /home", "ls"]
    
15.     print(execMultiCmd("192.168.220.128", "root", "root", cmdList))

复制代码

4.SFTPClient下载文件

方法封装：

1. def down_file(host, user, psw, local_file, remote_file, port=22):
   
2.     with paramiko.Transport((host, port)) as transport:
   
3.         # 连接服务
   
4.         transport.connect(username=user, password=psw)
   
5.         # 获取SFTP示例
   
6.         sftp = paramiko.SFTPClient.from_transport(transport)
   
7.         # 下载
   
8.         sftp.get(remote_file, local_file)
   
9.         transport.close()

复制代码

问题：（错误)

1. if __name__ == '__main__':
   
2.     down_file(my_linux.host, my_linux.user, my_linux.psw, "D:\\ssh_download", "/home/test.txt")

复制代码

1. Traceback (most recent call last):
   
2.   File "D:\MyCode2\py-1\ssh\download.py", line 17, in <module>
   
3.     down_file("192.168.220.128", "root", "root", "D:\\ssh_download", "/home/test.txt")
   
4.   File "D:\MyCode2\py-1\ssh\download.py", line 11, in down_file
   
5.     sftp.get(remote_file, local_file)
   
6.   File "D:\MyCode2\py-1\venv\lib\site-packages\paramiko\sftp_client.py", line 810, in get
   
7.     with open(localpath, "wb") as fl:
   
8. PermissionError: [Errno 13] Permission denied: 'D:\\ssh_download'

复制代码

正确使用

1. 要指定下载的文件名，不能只是一个目录

复制代码

1. if __name__ == '__main__':
   
2.     down_file(my_linux.host, my_linux.user, my_linux.psw, "D:\\ssh_download\\test.txt", "/home/test.txt")

复制代码

5.上传文件

1. def upload_file(host, user, psw, local_file, remote_file, port=22):
   
2.     with paramiko.Transport((host, port)) as transport:
   
3.         # 连接服务
   
4.         transport.connect(username=user, password=psw)
   
5.         # 获取SFTP示例
   
6.         sftp = paramiko.SFTPClient.from_transport(transport)
   
7.         sftp.put(local_file, remote_file)
   
8.         transport.close()

复制代码

测试同下载，

1. 特别要注意路径问题

复制代码

。如

1. if __name__ == '__main__':
   
2.     upload_file(my_linux.host, my_linux.user, my_linux.psw, "D:\\ssh_download\\test123.txt", "/home/test/test123.txt")

复制代码

6.ssh工具封装

1. import os
   
2. 
   
3. import paramiko
   
4. 
   
5. 
   
6. class SSHTool():
   
7.     def __init__(self, ip, port, user, psw):
   
8.         """
   
9.         初始化
   
10.         :param ip:
    
11.         :param port:
    
12.         :param user:
    
13.         :param psw:
    
14.         """
    
15.         self.ip = ip
    
16.         self.port = port
    
17.         self.user = user
    
18.         self.psw = psw
    
19. 
    
20.     def connect_ssh(self):
    
21.         """
    
22.         创建连接
    
23.         :return:
    
24.         """
    
25.         try:
    
26.             self.ssh = paramiko.SSHClient()
    
27.             self.ssh.set_missing_host_key_policy(paramiko.AutoAddPolicy())
    
28.             self.ssh.connect(
    
29.                 hostname=self.ip,
    
30.                 port=self.port,
    
31.                 username=self.user,
    
32.                 password=self.psw
    
33.             )
    
34.         except Exception as e:
    
35.             print(e)
    
36.         return self.ssh
    
37. 
    
38.     def close_ssh(self):
    
39.         """
    
40.         关闭连接
    
41.         :return:
    
42.         """
    
43.         try:
    
44.             self.ssh.close()
    
45.         except Exception as e:
    
46.             print(e)
    
47. 
    
48.     def exec_shell(self, shell):
    
49.         ssh = self.connect_ssh()
    
50.         try:
    
51.             stdin, stdout, stderr = ssh.exec_command(shell)
    
52.             return stdin, stdout, stderr
    
53.         except Exception as e:
    
54.             print(e)
    
55. 
    
56.     def sftp_put_file(self, file, local_dir, remote_dir):
    
57.         try:
    
58.             t = paramiko.Transport((self.ip, self.port))
    
59.             t.connect(username=self.user, password=self.psw)
    
60.             sftp = paramiko.SFTPClient.from_transport(t)
    
61.             sftp.put(os.path.join(local_dir, file), remote_dir)
    
62.             t.close()
    
63.         except Exception:
    
64.             print("connect error!")
    
65. 
    
66.     def sftp_get_file(self, file, local_dir, remote_dir):
    
67.         try:
    
68.             t = paramiko.Transport((self.ip, self.port))
    
69.             t.connect(username=self.user, password=self.psw)
    
70.             sftp = paramiko.SFTPClient.from_transport(t)
    
71.             sftp.get(remote_dir, os.path.join(local_dir, file))
    
72.             t.close()
    
73.         except Exception:
    
74.             print("connect error!")

复制代码

补充

获取当前文件路径：os.getcwd()

1. import os
   
2. 
   
3. if __name__ == '__main__':
   
4.     print(os.getcwd())  # D:\MyCode2\py-1\ssh

复制代码

python函数返回多个参数

1. def get_strs() -> (str, str):
   
2.     return "hello", "word"
   
3. if __name__ == '__main__':
   
4.     # 返回值为元祖的形式
   
5.     print(get_strs())  # ('hello', 'word')
   
6.     # 获取元祖的个数
   
7.     print(len(get_strs()))  # 2
   
8.     # 通过下标获取元祖的某一个值
   
9.     print(get_strs().__getitem__(1))  # word
   
10.     # 通过元祖的某个元素定位对应的下标
    
11.     print(get_strs().index("hello"))  # 0

复制代码

with … as …使用

1. 为了更好地避免此类问题，不同的编程语言都引入了不同的机制。在 Python 中，对应的解决方式是使用 with as 语句操作上下文管理器（context manager），它能够帮助我们自动分配并且释放资源。简单的理解，同时包含 <strong>enter</strong>() 和 <strong>exit</strong>() 方法的对象就是上下文管理器。

复制代码

格式：

1. with 表达式 [as target]：
   
2.     代码块

复制代码

学习参考

• Python]远程SSH库Paramiko简介_alwaysrun的博客-CSDN博客_python ssh库
  
• Python with as用法详解 (biancheng.net)
  
• Python中的with-as用法 - 简书 (jianshu.com)
  

到此这篇关于Python学习之paramiko模块的基础操作与排错的文章就介绍到这了,更多相关Python paramiko模块内容请搜索晓枫资讯以前的文章或继续浏览下面的相关文章希望大家以后多多支持晓枫资讯！

免责声明：如果侵犯了您的权益，请联系站长，我们会及时删除侵权内容，谢谢合作！