Python Paramiko上传下载sftp文件及远程执行命令详解
作者：py3study 发布时间：2021-06-20 16:35:09
标签：Python,Paramiko,上传下载,sftp,远程
一、简介
Paramiko模块是基于Python实现的SSH远程安全连接，用于SSH远程执行命令、文件传输等功能。
安装模块
默认Python没有自带，需要手动安装：
pip3 install paramiko
二、上传文件
#!/usr/bin/env python3
# coding: utf-8
import paramiko
def sftp_upload_file(host,user,password,server_path, local_path,timeout=10):
"""
上传文件，注意：不支持文件夹
:param host: 主机名
:param user: 用户名
:param password: 密码
:param server_path: 远程路径，比如：/home/sdn/tmp.txt
:param local_path: 本地路径，比如：D:/text.txt
:param timeout: 超时时间(默认)，必须是int类型
:return: bool
"""
try:
t = paramiko.Transport((host, 22))
t.banner_timeout = timeout
t.connect(username=user, password=password)
sftp = paramiko.SFTPClient.from_transport(t)
sftp.put(local_path, server_path)
t.close()
return True
except Exception as e:
print(e)
return False
测试一下上传，完整代码如下：
#!/usr/bin/env python3
# coding: utf-8
import paramiko
def sftp_upload_file(host, user, password, server_path, local_path, timeout=10):
"""
上传文件，注意：不支持文件夹
:param host: 主机名
:param user: 用户名
:param password: 密码
:param server_path: 远程路径，比如：/home/sdn/tmp.txt
:param local_path: 本地路径，比如：D:/text.txt
:param timeout: 超时时间(默认)，必须是int类型
:return: bool
"""
try:
t = paramiko.Transport((host, 22))
t.banner_timeout = timeout
t.connect(username=user, password=password)
sftp = paramiko.SFTPClient.from_transport(t)
sftp.put(local_path, server_path)
t.close()
return True
except Exception as e:
print(e)
return False
if __name__ == '__main__':
host = '192.168.10.1'
user = 'xiao'
password = 'xiao@1234'
server_path = '/tmp/tmp.txt'
local_path = 'D:/text.txt'
res = sftp_upload_file(host, user, password, server_path, local_path)
if not res:
print("上传文件: ％s 失败"％local_path)
else:
print("上传文件: ％s 成功" ％ local_path)
执行输出：
上传文件: D:/text.txt 成功
三、下载文件
def sftp_down_file(host,user,password,server_path, local_path,timeout=10):
"""
下载文件，注意：不支持文件夹
:param host: 主机名
:param user: 用户名
:param password: 密码
:param server_path: 远程路径，比如：/home/sdn/tmp.txt
:param local_path: 本地路径，比如：D:/text.txt
:param timeout: 超时时间(默认)，必须是int类型
:return: bool
"""
try:
t = paramiko.Transport((host,22))
t.banner_timeout = timeout
t.connect(username=user,password=password)
sftp = paramiko.SFTPClient.from_transport(t)
sftp.get(server_path, local_path)
t.close()
return True
except Exception as e:
print(e)
return False
测试一下，下载文件功能，完整代码如下：
#!/usr/bin/env python3
# coding: utf-8
import paramiko
def sftp_down_file(host,user,password,server_path, local_path,timeout=10):
"""
下载文件，注意：不支持文件夹
:param host: 主机名
:param user: 用户名
:param password: 密码
:param server_path: 远程路径，比如：/home/sdn/tmp.txt
:param local_path: 本地路径，比如：D:/text.txt
:param timeout: 超时时间(默认)，必须是int类型
:return: bool
"""
try:
t = paramiko.Transport((host,22))
t.banner_timeout = timeout
t.connect(username=user,password=password)
sftp = paramiko.SFTPClient.from_transport(t)
sftp.get(server_path, local_path)
t.close()
return True
except Exception as e:
print(e)
return False
if __name__ == '__main__':
host = '192.168.10.1'
user = 'xiao'
password = 'xiao@1234'
server_path = '/tmp/tmp.txt'
local_path = 'D:/text.txt'
res = sftp_down_file(host, user, password, server_path, local_path)
if not res:
print("下载文件: ％s 失败"％server_path)
else:
print("下载文件: ％s 成功" ％ server_path)
执行输出：
下载文件: /tmp/tmp.txt 成功
四、远程执行命令
def ssh_exec_command(host,user,password, cmd,timeout=10):
"""
使用ssh连接远程服务器执行命令
:param host: 主机名
:param user: 用户名
:param password: 密码
:param cmd: 执行的命令
:param seconds: 超时时间(默认)，必须是int类型
:return: dict
"""
result = {'status': 1, 'data': None} # 返回结果
try:
ssh = paramiko.SSHClient() # 创建一个新的SSHClient实例
ssh.banner_timeout = timeout
# 设置host key,如果在"known_hosts"中没有保存相关的信息, SSHClient 默认行为是拒绝连接, 会提示yes/no
ssh.set_missing_host_key_policy(paramiko.AutoAddPolicy())
ssh.connect(host, 22, user, password, timeout=timeout) # 连接远程服务器,超时时间1秒
stdin, stdout, stderr = ssh.exec_command(cmd,get_pty=True,timeout=timeout) # 执行命令
out = stdout.readlines() # 执行结果,readlines会返回列表
# 执行状态,0表示成功，1表示失败
channel = stdout.channel
status = channel.recv_exit_status()
ssh.close() # 关闭ssh连接
# 修改返回结果
result['status'] = status
result['data'] = out
return result
except Exception as e:
print(e)
print("错误, 登录服务器或者执行命令超时!!! ip: {} 命令: {}".format(ip,cmd))return False
测试一下，远程执行命令功能，完整代码如下：
#!/usr/bin/env python3
# coding: utf-8
import paramiko
def ssh_exec_command(host,user,password, cmd,timeout=10):
"""
使用ssh连接远程服务器执行命令
:param host: 主机名
:param user: 用户名
:param password: 密码
:param cmd: 执行的命令
:param seconds: 超时时间(默认)，必须是int类型
:return: dict
"""
result = {'status': 1, 'data': None} # 返回结果
try:
ssh = paramiko.SSHClient() # 创建一个新的SSHClient实例
ssh.banner_timeout = timeout
# 设置host key,如果在"known_hosts"中没有保存相关的信息, SSHClient 默认行为是拒绝连接, 会提示yes/no
ssh.set_missing_host_key_policy(paramiko.AutoAddPolicy())
ssh.connect(host, 22, user, password, timeout=timeout) # 连接远程服务器,超时时间1秒
stdin, stdout, stderr = ssh.exec_command(cmd,get_pty=True,timeout=timeout) # 执行命令
out = stdout.readlines() # 执行结果,readlines会返回列表
# 执行状态,0表示成功，1表示失败
channel = stdout.channel
status = channel.recv_exit_status()
ssh.close() # 关闭ssh连接
# 修改返回结果
result['status'] = status
result['data'] = out
return result
except Exception as e:
print(e)
print("错误, 登录服务器或者执行命令超时!!! ip: {} 命令: {}".format(ip,cmd))
return False
if __name__ == '__main__':
host = '192.168.10.1'
user = 'xiao'
password = 'xiao@1234'
cmd = "cat /etc/issue | awk '{print $1,$2,$3}'"
res = ssh_exec_command(host, user, password, cmd)
# print(res)
if not res or not res['data'] or res['status'] != 0:
print("错误, ip: {} 执行命令: {} 失败".format(host, cmd), "red")
exit()
value = res['data'][0].strip() # 获取实际值
print("操作系统为: ％s"％value)
执行输出：
操作系统为: Ubuntu 16.04.2 LTS
五、错误集锦
1. EllipticCurvePublicKey.public_bytes
Please use EllipticCurvePublicKey.public_bytes to obtain both compressed and uncompressed point encoding.
原因
paramiko 2.4.2 依赖 cryptography，而最新的cryptography==2.5里有一些弃用的API。
解决
删掉cryptography，安装2.4.2，就不会报错了。
pip uninstall cryptography
pip install cryptography==2.4.2
本文参考链接：https://www.jb51.net/article/257218.htm
2. Error reading SSH protocol banner
Traceback (most recent call last):
File "/python3/lib/python3.5/site-packages/paramiko/transport.py", line 1966, in run
self._check_banner()
File "/python3/lib/python3.5/site-packages/paramiko/transport.py", line 2143, in _check_banner
"Error reading SSH protocol banner" + str(e)
paramiko.ssh_exception.SSHException: Error reading SSH protocol banner
Error reading SSH protocol banner
要解决这个问题， 需要将paramiko的响应等待时间调长。 修改paramiko/transport.py文件中的
self.banner_timeout
值， 将其设为300或者其他较长的值即可解决这个问题。
来源：https://cloud.tencent.com/developer/article/1592375
0
投稿猜你喜欢
- 客户/服务器体系结构图形化的用户界面，使系统的管理更加直观和简单。丰富的编程接口，为用户进行应用程序设计提供了更大的选择余地。与Window
- 一、利用ASP和ADO实现数据库操作的工作流程ASP内嵌了五个对象Resquest、Response、Server、Seesion、Appl
- 从今天开始起，基督山将和大家一起进入ASP.net 诸多程序的学习中，老实说，.net到底是法宝还是垃圾，我们拭目以待。有任何问题，联络基督
- Access保留字&变量名列表，建表时应避免使用这些词汇和符号。Access 2002/2003-A &nbs
利用Python处理数据时，处理完成后输出结果为二维的列表，如果我们想把这个列表输出到Excel中形成格式化的数据，其实和输出到TXT文件大- 一、什么是进程进程是执行中的程序，是资源分配的最小单位：操作系统以进程为单位分配存储空间，进程拥有独立地址空间、内存、数据栈等操作系统管理所
- WordPress可以改造成twitter一样的微博网站，但是有一个坏处就是你要么用来做博客要么用来做微博，功能难兼得。相信大家在访问一些知
- 一、 for 循环根据变量赋值的次数进行循环for item in ["tom","bob",&qu
- python如何跳过异常继续执行下面有两种解决方法第一种是类似if…else…；另外一种是使用语
- 下载了一个小型的记帐软件，发现这个软件数据库用的是access，很想看看它的数据库结构怎样，结果人家加密了。access的解密小case了，
- 一、os函数目录1 os.access(path, mode) 检验权限模式2 os.chdir(path) 改变当前工
- 1、运动速率上节中，实现了一辆汽车在马路上由下到上行驶，并使用了pygame.time.delay(200)来进行时间延迟。看了很多参考材料
- 这篇文章主要介绍了wxpython自定义下拉列表框过程图解,文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值,需要
- 最近接了个项目，其中有需求是要实现摇一摇红包功能，在网上搜了好久，都没有找到源码，没办法，只有自动写了，下面小编把我的劳动成果分享给大家供大
- Python实现12306火车票抢票系统效果图如下所示：具体代码如下所示：import urllib.request as request
- 如何在网站上提供音乐下载？为用户提供歌曲下载，一般有两种方式，一是直接通过Http，浏览器下载，二是通过ftp协议下载。我们来用Http和浏
- 前言大家都知道Python的优点是开发效率高，使用方便，C++则是运行效率高，这两者可以相辅相成，不管是在Python项目中嵌入C++代码，
- 类的参数定义将conda环境设置为ai，conda activate ai这个文件的由来：由于在yolov1的pytorch实现的损失函数中
- 本文实例为大家分享了python实现双色球随机选号的具体代码，供大家参考，具体内容如下双色球随机选号实现代码from random impo
- 本文实例讲述了Python实现网络端口转发和重定向的方法。分享给大家供大家参考，具体如下：【任务】需要将某个网络端口转发到另一个主机（for
