Python中paramiko模块的基础操作与排错问题
作者:程序员-小李 发布时间:2023-06-21 04:45:33
关于
python的ssh库操作需要引入一个远程控制的模块——paramiko,可用于对远程服务器进行命令或文件操作。
应用
登陆服务器,问题排查。可用于编写脚本,在服务器上做一些繁琐的重复操作。
安装
打开cmd,输入命令
python -m pip install paramiko
示例
1.秘钥登陆
配置免密登录,linux上信任了windows的公钥,然后脚本在windows上跑,使用windows的私钥就可以直接不要密码登录linux
注意
:提供秘钥的paramiko.RSAKey.from_private_key_file('文件')
,这里面的"文件"是你本机上的秘钥,不是指你被控机上的公钥哦!
import paramiko
key = paramiko.RSAKey.from_private_key_file("C:\\Users\\liyansheng\\.ssh\\id_rsa")
ssh = paramiko.SSHClient()
ssh.set_missing_host_key_policy(paramiko.AutoAddPolicy())
print("connecting")
ssh.connect(hostname="192.168.220.128", username="root", pkey=key)
print("connected")
commands = "uname -a"
stdin, stdout, stderr = ssh.exec_command(commands)
stdin.close()
res, err = stdout.read(), stderr.read()
result = res if res else err
print(result)
ssh.close()
if __name__ == '__main__':
print()
2.单个命令执行
1.创建一个.py
文件,引入 paramiko
模块
import paramiko
2.建立SSHClient
对象
ssh = paramiko.SSHClient()
3.设置可信任,将主机加到host_allow
列表
ssh.set_missing_host_key_policy(paramiko.AutoAddPolicy())
4.创建连接
ssh.connect("150.158.16.123", 22, "wuyanping", "2022")
5.创建命令,发送并获取响应结果
stdin, stdout, stderr = ssh.exec_command("ls /home")
print(stdout.read().decode("utf-8"))
6.关闭连接
ssh.close()
3.执行多个命令
# 执行多条命令,注意传入的参数有个list
def execMultiCmd(host, user, psw, cmds: list, port=22) -> (str, str):
with paramiko.SSHClient() as ssh_client:
ssh_client.set_missing_host_key_policy(paramiko.AutoAddPolicy())
ssh_client.connect(hostname=host, port=port, username=user, password=psw)
cmd = ";".join(cmds)
_, stdout, stderr = ssh_client.exec_command(cmd, get_pty=True)
result = stdout.read().decode('utf-8')
err = stderr.read().decode('utf-8')
return result, err
if __name__ == '__main__':
cmdList = ["cd /home", "ls"]
print(execMultiCmd("192.168.220.128", "root", "root", cmdList))
4.SFTPClient下载文件
方法封装:
def down_file(host, user, psw, local_file, remote_file, port=22):
with paramiko.Transport((host, port)) as transport:
# 连接服务
transport.connect(username=user, password=psw)
# 获取SFTP示例
sftp = paramiko.SFTPClient.from_transport(transport)
# 下载
sftp.get(remote_file, local_file)
transport.close()
问题:(错误)
if __name__ == '__main__':
down_file(my_linux.host, my_linux.user, my_linux.psw, "D:\\ssh_download", "/home/test.txt")
Traceback (most recent call last):
File "D:\MyCode2\py-1\ssh\download.py", line 17, in <module>
down_file("192.168.220.128", "root", "root", "D:\\ssh_download", "/home/test.txt")
File "D:\MyCode2\py-1\ssh\download.py", line 11, in down_file
sftp.get(remote_file, local_file)
File "D:\MyCode2\py-1\venv\lib\site-packages\paramiko\sftp_client.py", line 810, in get
with open(localpath, "wb") as fl:
PermissionError: [Errno 13] Permission denied: 'D:\\ssh_download'
正确使用
要指定下载的文件名,不能只是一个目录
if __name__ == '__main__':
down_file(my_linux.host, my_linux.user, my_linux.psw, "D:\\ssh_download\\test.txt", "/home/test.txt")
5.上传文件
def upload_file(host, user, psw, local_file, remote_file, port=22):
with paramiko.Transport((host, port)) as transport:
# 连接服务
transport.connect(username=user, password=psw)
# 获取SFTP示例
sftp = paramiko.SFTPClient.from_transport(transport)
sftp.put(local_file, remote_file)
transport.close()
测试同下载,特别要注意路径问题
。如
if __name__ == '__main__':
upload_file(my_linux.host, my_linux.user, my_linux.psw, "D:\\ssh_download\\test123.txt", "/home/test/test123.txt")
6.ssh工具封装
import os
import paramiko
class SSHTool():
def __init__(self, ip, port, user, psw):
"""
初始化
:param ip:
:param port:
:param user:
:param psw:
"""
self.ip = ip
self.port = port
self.user = user
self.psw = psw
def connect_ssh(self):
"""
创建连接
:return:
"""
try:
self.ssh = paramiko.SSHClient()
self.ssh.set_missing_host_key_policy(paramiko.AutoAddPolicy())
self.ssh.connect(
hostname=self.ip,
port=self.port,
username=self.user,
password=self.psw
)
except Exception as e:
print(e)
return self.ssh
def close_ssh(self):
"""
关闭连接
:return:
"""
try:
self.ssh.close()
except Exception as e:
print(e)
def exec_shell(self, shell):
ssh = self.connect_ssh()
try:
stdin, stdout, stderr = ssh.exec_command(shell)
return stdin, stdout, stderr
except Exception as e:
print(e)
def sftp_put_file(self, file, local_dir, remote_dir):
try:
t = paramiko.Transport((self.ip, self.port))
t.connect(username=self.user, password=self.psw)
sftp = paramiko.SFTPClient.from_transport(t)
sftp.put(os.path.join(local_dir, file), remote_dir)
t.close()
except Exception:
print("connect error!")
def sftp_get_file(self, file, local_dir, remote_dir):
try:
t = paramiko.Transport((self.ip, self.port))
t.connect(username=self.user, password=self.psw)
sftp = paramiko.SFTPClient.from_transport(t)
sftp.get(remote_dir, os.path.join(local_dir, file))
t.close()
except Exception:
print("connect error!")
补充
获取当前文件路径:os.getcwd()
import os
if __name__ == '__main__':
print(os.getcwd()) # D:\MyCode2\py-1\ssh
python函数返回多个参数
def get_strs() -> (str, str):
return "hello", "word"
if __name__ == '__main__':
# 返回值为元祖的形式
print(get_strs()) # ('hello', 'word')
# 获取元祖的个数
print(len(get_strs())) # 2
# 通过下标获取元祖的某一个值
print(get_strs().__getitem__(1)) # word
# 通过元祖的某个元素定位对应的下标
print(get_strs().index("hello")) # 0
with … as …使用
为了更好地避免此类问题,不同的编程语言都引入了不同的机制。在 Python 中,对应的解决方式是使用 with as 语句操作上下文管理器(context manager),它能够帮助我们自动分配并且释放资源。简单的理解,同时包含 enter() 和 exit() 方法的对象就是上下文管理器。
格式:
with 表达式 [as target]:
代码块
学习参考
Python]远程SSH库Paramiko简介_alwaysrun的博客-CSDN博客_python ssh库
Python with as用法详解 (biancheng.net)
Python中的with-as用法 - 简书 (jianshu.com)
来源:https://blog.csdn.net/weixin_44107140/article/details/126729548
猜你喜欢
- 传统行业里,缺做互联网资深的人;互联网行业里,缺玩传统业务资深的人。于是会造成很多问题,比如两边难沟通,在传统行业者心目中,网络营销e-Ma
- 关于 WARNING: Ignoring invalid distribution -pencv-python … 警
- 活在当下的程序员应该都听过“面向对象编程”一词,也经常有人问能不能用一句话解释下什么是“面向对象编程”,我们先来看看比较正式的说法。把一组数
- *注意:本文的内容涉及到修改NTFS磁盘权限和设置安全策略,请务必在确认您了解操作可能的后果之后再动手进行任何的修改。文中提及的权限都是在原
- 修改字符串本身是不可能的,因为字符串是不可变类型,只能是通过某些方法来产生它的副本。再把副本赋值给原字符串,达到类似替换的作用。这里介绍几种
- 本文实例讲述了Python使用minidom读写xml的方法。分享给大家供大家参考。具体分析如下:一 python提供的xml支持2种工业标
- 生成Fiboncci Fn数有Θ(1),Θ(n)甚至指数级的算法,不过有Θ(log n)的吗?告诉你,有。首先,关于Fibonacci数,有
- 查询效率分析:子查询为确保消除重复值,必须为外部查询的每个结果都处理嵌套查询。在这种情况下可以考虑用联接查询来取代。如果要用子查询,那就用E
- 题目:1. 利用拉格朗日乘子法#导入sympy包,用于求导,方程组求解等等from sympy import * #设置变量x1 = sym
- 随着网络的发展,网速和机器速度的提高,越来越多的网站用到了丰富客户端技术。而现在Ajax则是最为流行的一种方式。JavaScript是一种解
- 我发现有的网站利用了SQL SERVER提供的通过EXCHANGE或OUTLOOK收发邮件的扩展存储过程来完成收发和自动处理邮件(这句话太长
- 通过 register_shutdown_function 方法,可以让我们设置一个当执行关闭时可以被调用的另一个函数。也就是说,当我们的脚
- 如下所示:matplotlib.pyplot.plot(*args, **kwargs)绘制线条或标记的轴。参数是一个可变长度参数,允许多个
- 另外,我们在 控制结构比较两个数值是否一直的时候,也应该尽量使用 === 来代替 ==(当然,这个也根据具体的业务逻辑选用比较合适的)。 小
- 环境Python 3.7.4pymysql8.0.11 MySQL Community Server读取图片以二进制格式读取图片with o
- 在上一篇文章中 ,我说到:强硬的把CSS和HTML塞到PHP里面可以防止代码太枯燥(DRY)并最终导致代码臃肿,因为的CSS和HTML需要比
- 新闻系统,相册系统可以用用哦,简单实用,有兴趣的可以自己扩充!^_^相册截图:<?xml version="1.0"
- 1. auth介绍Django 自带一个用户验证系统。它负责处理用户账号、组、权限和基于cookie的用户会话。认证系统由以下部分
- 如下所示:# 创建一个空的 DataFramedf_empty = pd.DataFrame()#或者df_empty = pd.DataF
- MaxDB和MySQL是独立的数据库管理服务器。系统间的协同性是可能的,通过相应的方式,系统能够彼此交换数据。要想在MaxDB和MySQL之