python中使用paramiko模塊并實(shí)現(xiàn)遠(yuǎn)程連接服務(wù)器執(zhí)行上傳下載功能
paramiko模塊
paramiko是一個(gè)用于做遠(yuǎn)程控制的模塊,使用該模塊可以對(duì)遠(yuǎn)程服務(wù)器進(jìn)行命令或文件操作,paramiko是用python語(yǔ)言寫(xiě)的一個(gè)模塊,遵循SSH2協(xié)議,支持以加密和認(rèn)證的方式,進(jìn)行遠(yuǎn)程服務(wù)器的連接。
由于使用的是python這樣的能夠跨平臺(tái)運(yùn)行的語(yǔ)言,所以所有python支持的平臺(tái),如Linux, Solaris, BSD, MacOS X, Windows等,paramiko都可以支持,因此,如果需要使用SSH從一個(gè)平臺(tái)連接到另外一個(gè)平臺(tái),進(jìn)行一系列的操作時(shí),paramiko是最佳工具之一。
因此,如果需要使用SSH從一個(gè)平臺(tái)連接到另外一個(gè)平臺(tái),進(jìn)行一系列的操作時(shí),paramiko是最佳工具之一。
通過(guò)ssh鏈接服務(wù)器并執(zhí)行想要的命令,類(lèi)似于XShell
ansible(遠(yuǎn)程批量管理服務(wù)器)底層源碼其實(shí)就是paramiko模塊實(shí)現(xiàn)的
安裝
pip3 install paramiko
使用
前提須知:paramiko模塊即支持用戶(hù)名密碼的方式,也支持公鑰私鑰的方式操作服務(wù)器
1.用戶(hù)名密碼的方式:
# 執(zhí)行命令
import paramiko
# 創(chuàng)建鏈接對(duì)象
ssh = paramiko.SSHClient()
# 允許鏈接不在know_hosts文件中的主機(jī)
ssh.set_missing_host_key_policy(paramiko.AutoAddPolicy())
# 鏈接服務(wù)器
ssh.connect(hostname='服務(wù)器ip地址',port='端口號(hào)',username='用戶(hù)名',password='密碼')
# 執(zhí)行命令
stdin, stdout, stderr = ssh.exec_command('ip a')
"""
stdin 是用來(lái)輸入額外的參數(shù)的 -y
stdout 命令的返回結(jié)果
stderr 錯(cuò)誤的結(jié)果
"""
# 獲取命令執(zhí)行的結(jié)果
res = stdout.read()
print(res.decode('utf-8'))
# 關(guān)閉鏈接
ssh.close()
2.公鑰私鑰的方式
首先在windows上產(chǎn)生公鑰私鑰對(duì)
可以用openssl工具產(chǎn)生,也可以用Git Bash工具產(chǎn)生(需要安裝git)
1.打開(kāi) Git Bash工具 輸入命令 ssh-keygen
2.輸入完命令一直按回車(chē)即可
3.在 c/user/用戶(hù)名下的文件/.ssh 的目錄中生成了兩個(gè)密鑰文件。id_rsa 為私鑰,id_rsa.pub 為公鑰
4.將公鑰內(nèi)容復(fù)制到你的linux服務(wù)器下的 /root/.ssh/authorized_keys文件中即可
復(fù)制私鑰文件到項(xiàng)目根目錄下,我這里重命名為a.txt
import paramiko
# 讀取本地私鑰
private_key = paramiko.RSAKey.from_private_key_file('a.txt')
# 創(chuàng)建SSH對(duì)象
ssh = paramiko.SSHClient()
# 允許連接不在know_hosts文件中的主機(jī)
ssh.set_missing_host_key_policy(paramiko.AutoAddPolicy())
# 連接服務(wù)器
ssh.connect(hostname='服務(wù)器ip地址', port=22, username='用戶(hù)名', pkey=private_key)
# 執(zhí)行命令
stdin, stdout, stderr = ssh.exec_command('ls /')
# 獲取命令結(jié)果
result = stdout.read()
print(result.decode('utf-8'))
# 關(guān)閉連接
ssh.close()
實(shí)現(xiàn)上傳下載文件
1.用戶(hù)名和密碼的方式:
import paramiko
# 用戶(hù)名和密碼
transport = paramiko.Transport(('服務(wù)器ip地址', 22))
transport.connect(username='用戶(hù)名', password='密碼')
sftp = paramiko.SFTPClient.from_transport(transport)
# 上傳文件
# sftp.put("a.txt", '/data/tmp.txt') # 注意上傳文件到遠(yuǎn)程某個(gè)文件下 文件必須存在
# 下載文件
sftp.get('/data/tmp.txt', 'hahaha.txt') # 將遠(yuǎn)程文件下載到本地并重新命令
transport.close()
2.公鑰和私鑰的方式:
import paramiko
private_key = paramiko.RSAKey.from_private_key_file('a.txt')
transport = paramiko.Transport(('服務(wù)器地址', 22))
transport.connect(username='用戶(hù)名', pkey=private_key)
sftp = paramiko.SFTPClient.from_transport(transport)
# 將location.py 上傳至服務(wù)器 /tmp/test.py
sftp.put('manage.py', '/data/test.py')
# 將remove_path 下載到本地 local_path
sftp.get('remove_path', 'local_path')
transport.close()
下面將執(zhí)行命令和上傳下載文件 封裝到一個(gè)類(lèi)里面
SSHProxy類(lèi)的封裝
假如我想鏈接服務(wù)器執(zhí)行三條命令,并且上傳一個(gè)文件內(nèi)容
大部分都會(huì)操作幾次就鏈接幾次服務(wù)器,效率較低,代碼冗余
我們想實(shí)現(xiàn)一個(gè)類(lèi)里面包含了執(zhí)行命令和上傳下載文件的操作
# 類(lèi)的代碼無(wú)需掌握 只需要會(huì)拷貝使用即可
import paramiko
class SSHProxy(object):
# 這里的參數(shù) 你可以再加公鑰私鑰的形式
def __init__(self, hostname, port, username, password):
self.hostname = hostname
self.port = port
self.username = username
self.password = password
self.transport = None
def open(self): # 給對(duì)象賦值一個(gè)上傳下載文件對(duì)象連接
self.transport = paramiko.Transport((self.hostname, self.port))
self.transport.connect(username=self.username, password=self.password)
def command(self, cmd): # 正常執(zhí)行命令的連接 至此對(duì)象內(nèi)容就既有執(zhí)行命令的連接又有上傳下載鏈接
ssh = paramiko.SSHClient()
ssh._transport = self.transport
stdin, stdout, stderr = ssh.exec_command(cmd)
result = stdout.read()
return result
def upload(self, local_path, remote_path):
sftp = paramiko.SFTPClient.from_transport(self.transport)
sftp.put(local_path, remote_path)
sftp.close()
def close(self):
self.transport.close()
def __enter__(self): # 對(duì)象執(zhí)行with上下文會(huì)自動(dòng)觸發(fā)
self.open()
return self # 這里發(fā)揮上面with語(yǔ)法內(nèi)的as后面拿到的就是什么
def __exit__(self, exc_type, exc_val, exc_tb): # with執(zhí)行結(jié)束自動(dòng)觸發(fā)
self.close()
使用流程
"""
上述的封裝操作在使用的使用 必須按照下面的順序
obj = SSHProxy(...)
obj.open() # 產(chǎn)生的對(duì)象必須要先執(zhí)行open方法
obj.command('ls /')
obj.command('cat /data/tmp.txt')
obj.upload(...)
obj.upload(...)
obj.close()
利用文件操作的特性
f = open()
f.close()
嫌上述操作麻煩 利用with上下文做處理了
with open() as f:
pass
as后面的值由__enter__方法返回值決定 返回什么就是什么
# 一旦對(duì)象被執(zhí)行with會(huì)自動(dòng)觸發(fā)對(duì)象內(nèi)部的__enter__方法 with結(jié)束之后還會(huì)自動(dòng)觸發(fā)__exit__方法
obj = SSHProxy(1,2,3,4)
with obj as f:
pass
封裝之后按照下面的方式使用即可
with SSHProxy(....) as obj:
obj.command()
obj.command()
obj.upload()
obj.upload()
obj.command()
"""
拓展: __enter__ 和 __exit__ 的使用
class Foo(object):
def __enter__(self):
print('他進(jìn)來(lái)了')
return 123
def __exit__(self, exc_type, exc_val, exc_tb):
print('他就這么出去了')
obj = Foo()
with obj as f:
print(f)
"""
執(zhí)行結(jié)果:
他進(jìn)來(lái)了
123
他就這么出去了
"""
總結(jié):as后面的值由 __enter__ 方法返回值決定 返回什么就是什么,
一旦對(duì)象被執(zhí)行with會(huì)自動(dòng)觸發(fā)對(duì)象內(nèi)部的 __enter__ 方法 with結(jié)束之后還會(huì)自動(dòng)觸發(fā) __exit__ 方法
面試題
# 面試題"""
請(qǐng)?jiān)贑ontext類(lèi)中添加代碼完成該類(lèi)的實(shí)現(xiàn)(意思是怎么樣修改才能實(shí)現(xiàn)以下代碼并不會(huì)報(bào)錯(cuò))
"""
class Context:
pass
with Context() as ctx:
ctx.do_something()
# 答案
class Context:
def __enter__(self):
return self
def __exit__(self,*args,**kwargs):
pass
def do_something(self):
pass
到此這篇關(guān)于python中使用paramiko模塊并實(shí)現(xiàn)遠(yuǎn)程連接服務(wù)器執(zhí)行上傳下載功能的文章就介紹到這了,更多相關(guān)python paramiko模塊內(nèi)容請(qǐng)搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家!
- python使用paramiko模塊實(shí)現(xiàn)ssh遠(yuǎn)程登陸上傳文件并執(zhí)行
- Python2.x利用commands模塊執(zhí)行Linux shell命令
- python通過(guò)getopt模塊如何獲取執(zhí)行的命令參數(shù)詳解
- python SSH模塊登錄,遠(yuǎn)程機(jī)執(zhí)行shell命令實(shí)例解析
- 使用Python paramiko模塊利用多線程實(shí)現(xiàn)ssh并發(fā)執(zhí)行操作
- 執(zhí)行Python程序時(shí)模塊報(bào)錯(cuò)問(wèn)題
- Python-jenkins模塊獲取jobs的執(zhí)行狀態(tài)操作
- Python代碼執(zhí)行時(shí)間測(cè)量模塊timeit用法解析
- 解決Python paramiko 模塊遠(yuǎn)程執(zhí)行ssh 命令 nohup 不生效的問(wèn)題
- Python實(shí)現(xiàn)以主程序的形式執(zhí)行模塊
相關(guān)文章
運(yùn)行django項(xiàng)目指定IP和端口的方法
今天小編就為大家分享一篇運(yùn)行django項(xiàng)目指定IP和端口的方法。具有很好的參考價(jià)值,希望對(duì)大家有所幫助。一起跟隨小編過(guò)來(lái)看看吧2018-05-05
Pandas實(shí)現(xiàn)(pivot_table函數(shù))數(shù)據(jù)透視表方式
pandas的pivot_table()函數(shù)非常強(qiáng)大,主要用于創(chuàng)建數(shù)據(jù)透視表,重要參數(shù)包括index、values、columns和aggfunc,index用于設(shè)置行索引,類(lèi)似于SQL中的group by,values用于進(jìn)行聚合計(jì)算的數(shù)據(jù)選擇,columns參數(shù)可設(shè)置列層次,非必須2024-09-09
PyTorch+LSTM實(shí)現(xiàn)單變量時(shí)間序列預(yù)測(cè)
時(shí)間序列是指在一段時(shí)間內(nèi)發(fā)生的任何可量化的度量或事件。這篇文章主要為大家介紹了PyTorch+LSTM實(shí)現(xiàn)單變量時(shí)間序列預(yù)測(cè)的相關(guān)資料,需要的可以參考一下2023-02-02
Python使用pymysql模塊操作mysql增刪改查實(shí)例分析
這篇文章主要介紹了Python使用pymsql模塊操作mysql增刪改查,結(jié)合實(shí)例形式分析了Python使用pymsql模塊針對(duì)mysql進(jìn)行增刪改查操作的相關(guān)實(shí)現(xiàn)方法與操作注意事項(xiàng),需要的朋友可以參考下2019-12-12
PyQt實(shí)現(xiàn)界面翻轉(zhuǎn)切換效果
這篇文章主要為大家詳細(xì)介紹了PyQt實(shí)現(xiàn)界面翻轉(zhuǎn)切換效果,具有一定的參考價(jià)值,感興趣的小伙伴們可以參考一下2018-04-04
Pandas之?dāng)?shù)據(jù)追加df.append方式
這篇文章主要介紹了Pandas之?dāng)?shù)據(jù)追加df.append方式,具有很好的參考價(jià)值,希望對(duì)大家有所幫助,如有錯(cuò)誤或未考慮完全的地方,望不吝賜教2023-08-08
TensorFlow實(shí)現(xiàn)自定義Op方式
今天小編就為大家分享一篇TensorFlow實(shí)現(xiàn)自定義Op方式,具有很好的參考價(jià)值,希望對(duì)大家有所幫助。一起跟隨小編過(guò)來(lái)看看吧2020-02-02

