Python基於模塊Paramiko實現SSHv2協議

ssh是一個協議，OpenSSH是其中一個開源實現，paramiko是Python的一個庫，實現了SSHv2協議(底層使用cryptography)。

有了Paramiko以後，我們就可以在Python代碼中直接使用SSH協議對遠程服務器執行操作，而不是通過ssh命令對遠程服務器進行操作。

由於paramiko屬於第三方庫，所以需要使用如下命令先行安裝 ：pip install paramiko

paramiko包含兩個核心組件：SSHClient和SFTPClient。



SSHClient的作用類似於Linux的ssh命令，是對SSH會話的封裝，該類封裝了傳輸(Transport)，通道(Channel)及SFTPClient建立的方法(open_sftp)，通常用於執行遠程命令。



SFTPClient的作用類似與Linux的sftp命令，是對SFTP客戶端的封裝，用以實現遠程文件操作，如文件上傳、下載、修改文件權限等操作。

# Paramiko中的幾個基礎名詞：

1、Channel：是一種類Socket，一種安全的SSH傳輸通道；

2、Transport：是一種加密的會話，使用時會同步創建了一個加密的Tunnels(通道)，這個Tunnels叫做Channel；

3、Session：是client與Server保持連接的對象，用connect()/start_client()/start_server()開始會話。



SSHClient常用的方法介紹



connect()：實現遠程服務器的連接與認證，對於該方法只有hostname是必傳參數。

常用參數



hostname 連接的目標主機

port=SSH_PORT 指定端口

username=None 驗證的用戶名

password=None 驗證的用戶密碼

pkey=None 私鑰方式用於身份驗證

key_filename=None 一個文件名或文件列表，指定私鑰文件

timeout=None 可選的tcp連接超時時間

allow_agent=True, 是否允許連接到ssh代理，默認為True 允許

look_for_keys=True 是否在~/.ssh中搜索私鑰文件，默認為True 允許

compress=False, 是否打開壓縮



set_missing_host_key_policy()：設置遠程服務器沒有在know_hosts文件中記錄時的應對策略。目前支持三種策略：

設置連接的遠程主機沒有本地主機密鑰或HostKeys對象時的策略，目前支持三種：



AutoAddPolicy 自動添加主機名及主機密鑰到本地HostKeys對象，不依賴load_system_host_key的配置。即新建立ssh連接時不需要再輸入yes或no進行確認



WarningPolicy 用於記錄一個未知的主機密鑰的python警告。並接受，功能上和AutoAddPolicy類似，但是會提示是新連接

RejectPolicy 自動拒絕未知的主機名和密鑰，依賴load_system_host_key的配置。此為默認選項



exec_command()：在遠程服務器執行Linux命令的方法。

open_sftp()：在當前ssh會話的基礎上創建一個sftp會話。該方法會返回一個SFTPClient對象。

# 利用SSHClient對象的open_sftp()方法，可以直接返回一個基於當前連接的sftp對象，可以進行文件的上傳等操作.

sftp = client.open_sftp()

sftp.put('test.txt','text.txt')

SSHClient常用的方法舉例

1.基於用戶名和密碼登入方式

import paramiko class param(): def param_iko(self): #實例化SSHClient client = paramiko.SSHClient() #自動添加策略，保存服務器的主機名和密鑰信息，如果不添加，那麼不再本地know_hosts文件中記錄的主機將無法連接 client.set_missing_host_key_policy(paramiko.AutoAddPolicy()) #連接SSH服務端，以用戶名和密碼進行認證 client.connect(hostname='192.168.1.200', port=22, username='root', password='a123') #打開一個Channel並執行命令 stdin, stdout, stderr = client.exec_command('df -h ') #打印執行結果 print(stdout.read().decode('utf-8')) #關閉SSHClient client.close() if __name__=='__main__': param().param_iko()

通過公鑰連接，前提是兩臺Linux可以互相連接

兩臺服務器需要ssh免祕鑰登入

import paramiko class param_my(): def param_miyao(self): #配置私人密鑰文件位置 private = paramiko.RSAKey.from_private_key_file('/root/.ssh/id_rsa') #實例化SSHClient client = paramiko.SSHClient() #自動添加策略，保存服務器的主機名和密鑰信息，如果不添加，那麼不再本地know_hosts文件中記錄的主機將無法連接 client.set_missing_host_key_policy(paramiko.AutoAddPolicy()) #連接SSH服務端，以用戶名和密碼進行認證 client.connect(hostname='192.168.1.250',port=22,username='root',pkey=private) #打開一個Channel並執行命令 stdin, stdout, stderr = client.exec_command('df -h ') #打印執行結果 print(stdout.read().decode('utf-8')) #關閉SSHClient client.close() if __name__=='__main__': param_my().param_miyao() [root@master test]# python3 a.py 文件系統 容量 已用 可用 已用% 掛載點 /dev/mapper/rhel-root 27G 21G 6.8G 75% / devtmpfs 977M 0 977M 0% /dev tmpfs 993M 0 993M 0% /dev/shm tmpfs 993M 9.1M 984M 1% /run tmpfs 993M 0 993M 0% /sys/fs/cgroup /dev/sr0 3.8G 3.8G 0 100% /mnt/cdrom /dev/sda1 1014M 161M 854M 16% /boot tmpfs 199M 0 199M 0% /run/user/0 tmpfs 199M 12K 199M 1% /run/user/42

跨服務器上傳和下載文件

import os,sys import paramiko class get_putclass(): def get_put(self): t = paramiko.Transport(('192.168.1.250',22)) t.connect(username='root',password='a123') sftp = paramiko.SFTPClient.from_transport(t) #前面部分是192.168.1.250 遠程機器上的文件，後半部分是取到本地的路徑和文件名 sftp.get('/root/file/test.txt','/home/python/tmp/test/test.txt') #前面部分是本機器上的文件，後半部分是遠程機器上的文件路徑和文件名 sftp.put('/home/python/tmp/test/a.py','/root/file/a.py') t.close() if __name__=='__main__': get_putclass().get_put()

通過祕鑰來上傳下載文件

import os,sys import paramiko class get_put_myao(): def get_put_miyao(self): pravie_key_path = '/root/.ssh/id_rsa' key = paramiko.RSAKey.from_private_key_file(pravie_key_path) t = paramiko.Transport(('192.168.1.250',22)) t.connect(username='root',pkey=key) sftp = paramiko.SFTPClient.from_transport(t) sftp.put('/home/python/tmp/test/b.py','/root/file/b.py') sftp.get('/root/file/test.txt','/home/python/tmp/test/test.txt') t.close() if __name__=='__main__': get_put_myao().get_put_miyao()