Python?Paramiko上傳下載sftp文件及遠(yuǎn)程執(zhí)行命令詳解
一、簡(jiǎn)介
Paramiko模塊是基于Python實(shí)現(xiàn)的SSH遠(yuǎn)程安全連接,用于SSH遠(yuǎn)程執(zhí)行命令、文件傳輸?shù)裙δ堋?/p>
安裝模塊
默認(rèn)Python沒有自帶,需要手動(dòng)安裝:
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: 主機(jī)名
:param user: 用戶名
:param password: 密碼
:param server_path: 遠(yuǎn)程路徑,比如:/home/sdn/tmp.txt
:param local_path: 本地路徑,比如:D:/text.txt
:param timeout: 超時(shí)時(shí)間(默認(rèn)),必須是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測(cè)試一下上傳,完整代碼如下:
#!/usr/bin/env python3
# coding: utf-8
import paramiko
def sftp_upload_file(host, user, password, server_path, local_path, timeout=10):
"""
上傳文件,注意:不支持文件夾
:param host: 主機(jī)名
:param user: 用戶名
:param password: 密碼
:param server_path: 遠(yuǎn)程路徑,比如:/home/sdn/tmp.txt
:param local_path: 本地路徑,比如:D:/text.txt
:param timeout: 超時(shí)時(shí)間(默認(rèn)),必須是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)執(zhí)行輸出:
上傳文件: D:/text.txt 成功
三、下載文件
def sftp_down_file(host,user,password,server_path, local_path,timeout=10):
"""
下載文件,注意:不支持文件夾
:param host: 主機(jī)名
:param user: 用戶名
:param password: 密碼
:param server_path: 遠(yuǎn)程路徑,比如:/home/sdn/tmp.txt
:param local_path: 本地路徑,比如:D:/text.txt
:param timeout: 超時(shí)時(shí)間(默認(rèn)),必須是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測(cè)試一下,下載文件功能,完整代碼如下:
#!/usr/bin/env python3
# coding: utf-8
import paramiko
def sftp_down_file(host,user,password,server_path, local_path,timeout=10):
"""
下載文件,注意:不支持文件夾
:param host: 主機(jī)名
:param user: 用戶名
:param password: 密碼
:param server_path: 遠(yuǎn)程路徑,比如:/home/sdn/tmp.txt
:param local_path: 本地路徑,比如:D:/text.txt
:param timeout: 超時(shí)時(shí)間(默認(rèn)),必須是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)執(zhí)行輸出:
下載文件: /tmp/tmp.txt 成功
四、遠(yuǎn)程執(zhí)行命令
def ssh_exec_command(host,user,password, cmd,timeout=10):
"""
使用ssh連接遠(yuǎn)程服務(wù)器執(zhí)行命令
:param host: 主機(jī)名
:param user: 用戶名
:param password: 密碼
:param cmd: 執(zhí)行的命令
:param seconds: 超時(shí)時(shí)間(默認(rèn)),必須是int類型
:return: dict
"""
result = {'status': 1, 'data': None} # 返回結(jié)果
try:
ssh = paramiko.SSHClient() # 創(chuàng)建一個(gè)新的SSHClient實(shí)例
ssh.banner_timeout = timeout
# 設(shè)置host key,如果在"known_hosts"中沒有保存相關(guān)的信息, SSHClient 默認(rèn)行為是拒絕連接, 會(huì)提示yes/no
ssh.set_missing_host_key_policy(paramiko.AutoAddPolicy())
ssh.connect(host, 22, user, password, timeout=timeout) # 連接遠(yuǎn)程服務(wù)器,超時(shí)時(shí)間1秒
stdin, stdout, stderr = ssh.exec_command(cmd,get_pty=True,timeout=timeout) # 執(zhí)行命令
out = stdout.readlines() # 執(zhí)行結(jié)果,readlines會(huì)返回列表
# 執(zhí)行狀態(tài),0表示成功,1表示失敗
channel = stdout.channel
status = channel.recv_exit_status()
ssh.close() # 關(guān)閉ssh連接
# 修改返回結(jié)果
result['status'] = status
result['data'] = out
return result
except Exception as e:
print(e)
print("錯(cuò)誤, 登錄服務(wù)器或者執(zhí)行命令超時(shí)!!! ip: {} 命令: {}".format(ip,cmd))return False測(cè)試一下,遠(yuǎn)程執(zhí)行命令功能,完整代碼如下:
#!/usr/bin/env python3
# coding: utf-8
import paramiko
def ssh_exec_command(host,user,password, cmd,timeout=10):
"""
使用ssh連接遠(yuǎn)程服務(wù)器執(zhí)行命令
:param host: 主機(jī)名
:param user: 用戶名
:param password: 密碼
:param cmd: 執(zhí)行的命令
:param seconds: 超時(shí)時(shí)間(默認(rèn)),必須是int類型
:return: dict
"""
result = {'status': 1, 'data': None} # 返回結(jié)果
try:
ssh = paramiko.SSHClient() # 創(chuàng)建一個(gè)新的SSHClient實(shí)例
ssh.banner_timeout = timeout
# 設(shè)置host key,如果在"known_hosts"中沒有保存相關(guān)的信息, SSHClient 默認(rèn)行為是拒絕連接, 會(huì)提示yes/no
ssh.set_missing_host_key_policy(paramiko.AutoAddPolicy())
ssh.connect(host, 22, user, password, timeout=timeout) # 連接遠(yuǎn)程服務(wù)器,超時(shí)時(shí)間1秒
stdin, stdout, stderr = ssh.exec_command(cmd,get_pty=True,timeout=timeout) # 執(zhí)行命令
out = stdout.readlines() # 執(zhí)行結(jié)果,readlines會(huì)返回列表
# 執(zhí)行狀態(tài),0表示成功,1表示失敗
channel = stdout.channel
status = channel.recv_exit_status()
ssh.close() # 關(guān)閉ssh連接
# 修改返回結(jié)果
result['status'] = status
result['data'] = out
return result
except Exception as e:
print(e)
print("錯(cuò)誤, 登錄服務(wù)器或者執(zhí)行命令超時(shí)!!! 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("錯(cuò)誤, ip: {} 執(zhí)行命令: {} 失敗".format(host, cmd), "red")
exit()
value = res['data'][0].strip() # 獲取實(shí)際值
print("操作系統(tǒng)為: %s"%value)執(zhí)行輸出:
操作系統(tǒng)為: Ubuntu 16.04.2 LTS
五、錯(cuò)誤集錦
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,就不會(huì)報(bào)錯(cuò)了。
pip uninstall cryptography pip install cryptography==2.4.2
本文參考鏈接:http://www.dhdzp.com/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
要解決這個(gè)問題, 需要將paramiko的響應(yīng)等待時(shí)間調(diào)長(zhǎng)。 修改paramiko/transport.py文件中的
self.banner_timeout
值, 將其設(shè)為300或者其他較長(zhǎng)的值即可解決這個(gè)問題。
以上就是Python Paramiko上傳下載sftp文件及遠(yuǎn)程執(zhí)行命令示例的詳細(xì)內(nèi)容,更多關(guān)于Python Paramiko上傳下載sftp的資料請(qǐng)關(guān)注腳本之家其它相關(guān)文章!
相關(guān)文章
python中Requests發(fā)送json格式的post請(qǐng)求方法
這篇文章主要介紹了python中Requests發(fā)送json格式的post請(qǐng)求方法,文章圍繞主題展開詳細(xì)的內(nèi)容介紹,具有一定的參考價(jià)值,感興趣的朋友可以參考一下2022-09-09
Python利用AI接口實(shí)現(xiàn)摳圖并改圖片底色
時(shí)候我們的證件照需要換底色,又來不及去照相館拍照,用ps也不好摳圖,所以今天給你們分享一下如何用python來摳圖,并換底色,需要的可以參考一下2022-09-09
利用Python統(tǒng)計(jì)Jira數(shù)據(jù)并可視化
目前公司使用 Jira 作為項(xiàng)目管理工具,在每一次迭代完成后的復(fù)盤會(huì)上,我們都需要針對(duì)本次迭代的 Bug 進(jìn)行數(shù)據(jù)統(tǒng)計(jì),以幫助管理層能更直觀的了解研發(fā)的代碼質(zhì)量。本篇文章將介紹如何利用統(tǒng)計(jì) Jira 數(shù)據(jù),并進(jìn)行可視化,需要的可以參考一下2022-07-07
Python3 Tkinkter + SQLite實(shí)現(xiàn)登錄和注冊(cè)界面
這篇文章主要為大家詳細(xì)介紹了Python3 Tkinkter + SQLite實(shí)現(xiàn)登錄和注冊(cè)界面,文中示例代碼介紹的非常詳細(xì),具有一定的參考價(jià)值,感興趣的小伙伴們可以參考一下2019-11-11
Python SMTP發(fā)送郵件遇到的一些問題及解決辦法
今天小編就為大家分享一篇關(guān)于Python SMTP發(fā)送郵件遇到的一些問題及解決辦法,小編覺得內(nèi)容挺不錯(cuò)的,現(xiàn)在分享給大家,具有很好的參考價(jià)值,需要的朋友一起跟隨小編來看看吧2018-10-10
Tensorflow2.1 完成權(quán)重或模型的保存和加載
這篇文章主要為大家介紹了Tensorflow2.1 完成權(quán)重或模型的保存和加載,有需要的朋友可以借鑒參考下,希望能夠有所幫助,祝大家多多進(jìn)步,早日升職加薪2022-11-11

