A. 請教下python3 上如何實現級聯ssh
首先，我的windows系統上有python2和python3。使用下面命令切換到python3：
activate py3
1
接著使用下面命令下載相關模塊:
pip install ecdsa
pip install Crypto
pip install paramiko
1
2
3
連接伺服器操作：
# -*- coding: utf-8 -*-
import paramiko
# 伺服器相關信息,下面輸入你個人的用戶名、密碼、ip等信息
ip = ""
port = 22
user = ""
password = ""
ssh = paramiko.SSHClient()
ssh.set_missing_host_key_policy(paramiko.AutoAddPolicy())
# 建立連接
ssh.connect(ip,port,user,password,timeout = 10)
#輸入linux命令
stdin,stdout,stderr = ssh.exec_command("pwd")
# 輸出命令執行結果
result = stdout.read()
print(result)
#關閉連接
ssh.close()
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
如下，運行該程序，可以看到控制台輸出的結果：
B. 如何使用Python 自動執行連接ssh後並執行Oracle查詢語句並返回查詢結果
可以使用paramiko模塊，這個模塊就是python實現的高效ssh客戶端，用它連接遠程伺服器後，就可以使用裡面的函數來執行Oracle語句，返回結果可以保存為列表，然後列印出來就可以了，你可以嘗試一下，這里就不給出具體的代碼了。
C. 誰用過python下ssh包paramiko
paramiko是python一個模塊，遵循SSH2協議，支持以加密和認證的方式，進行遠程伺服器的連接
1、可以遠程操作伺服器文件
例如：
df：查看磁碟使用情況
mkdir：創建目錄
mv/cp/mkdir/rmdir:對文件或目錄進行操作
/sbin/service/ xxxservice start/stop/restart：啟動、停止、重啟某服務
netstat -ntl |grep 8080：查看8080埠的使用情況
或者 nc -zv localhost ：查看所有埠的使用情況
find / -name XXX：查找某文件 等等
2、可以實現遠程文件的上傳，下載（類似於ssh的scp功能）
首先安裝paramiko
pip install paramiko
但是安裝paramiko需要先安裝一個依賴包叫PyCrypto的模塊。PyCrypto是python編寫的加密工具包,支持的各種加密演算法（主要有:MD2 128 bits;MD4 128 bits;MD5 128 bits;RIPEMD 160 bits;SHA1 160 bits;SHA256 256 bits;AES 16, 24, or 32 bytes/16 bytes;ARC2 Variable/8 bytes;Blowfish Variable/8 bytes;CAST Variable/8 bytes;DES 8 bytes/8 bytes ;DES3 (Triple DES) 16 bytes/8 bytes;IDEA 16 bytes/8 bytes ;RC5 Variable/8 bytes等等。）
D. 如何用python開發一個ssh客戶端工具
1）通過paramiko的ssh模塊連接指定主機；
2)通過SSHClient.exec_command在遠程主機上執行命令；
3）通過exec_command返回的stdout,stdin,stderr進行交互；
4）保存成功連接的主機信息（session），可以通過ls命令查看，sessionid命令，直接啟動新連接；
5）可在windows和linux下運行，寫程序時需要注意他們的差別。
代碼ssh.py
#!/usr/bin/python
#-*-coding:utf-8-*-
importos,sys
importparamiko
importthreading
importplatform
curr_ssh=None
curr_prompt=">>"
#使用說明
defprintUsage():
print"!ls:listsessions."
print"!sessionid:connectsession."
print"!connhostuserpassword:connecthostwithuser."
print"!exit:exit."
#連接
defconn(ip,username,passwd):
try:
ssh=paramiko.SSHClient()
ssh.set_missing_host_key_policy(paramiko.AutoAddPolicy())
ssh.connect(ip,22,username,passwd,timeout=5)
print"Connectto",ip,"with",username
globalcurr_prompt
curr_prompt=username+"@"+ip+">>"
returnssh
except:
returnNone
#載入以前的連接信息
sessions=[]
defloadSessions():
globalsessions
try:
f=open("sessions")
sessions=f.readlines()
f.close()
except:
pass
#執行本地命令,ssh.py的命令
defexe_cmd_local(cmd):
if(cmd=="!ls"):
loadSessions()
globalsessions
i=0
print"Sessions:"
forsinsessions:
print"[%d]%s"%(i,s)
i+=1
else:
vals=cmd.split('')
if(vals[0]=="!session"):
id=(int)(vals[1])
if(id<len(sessions)):os_name="platform.system()"new_console_cmd=""if(os_name="=""linux"):="".=""ssh.py="""=""+=""sessions[id]+"""=""elif(os_name="=""windows"):=""sessions[id]=""os.system(new_console_cmd)=""else:=""print="""didn't=""hava=""sessoin=""",vals[1]=""elif(vals[0]="="!conn"):"global=""curr_ssh=""f="open("sessions","a")"line="vals[1]+"""+vals[2]+"="""+vals[3]+" "=""f.write(line)=""f.close()=""#在ssh連接的主機上執行命令=""def=""exe_cmd_ssh(ssh,cmd):=""if(ssh="="none):=""connect=""to=""a=""server.=""use=""'!conn'=""please."=""return=""stdin,=""stdout,=""stderr="ssh.exec_command(cmd)"#stdin.write("y")=""#簡單交互，輸入=""『y』=""#屏幕輸出=""stdout.read()=""stderr.read()=""#入口函數=""if=""__name__="='__main__':"loadsessions()=""if(len(sys.argv)="=4):"printusage()=""while=""true:=""cmd="raw_input(curr_prompt)"if(len(cmd)="=0):"continue=""if(cmd="=""!exit"):=""if(curr_ssh=""!="None):"curr_ssh.close();=""break=""if(cmd[0]="="'!'):=""exe_cmd_local(cmd)=""exe_cmd_ssh(curr_ssh,cmd)<=""pre="">
E. 求教，python3怎麼通過SSH隧道連接mysql資料庫並執行SQL操作
python3發布以來，獲取了廣大程序員們的差評，說不穩定，又是不兼容什麼的，不過差評歸差評，python3既然已經發布，肯定是個趨勢，但在python3.4裡面，使用原來python2.7的mysqldb已經不能連接mysql資料庫了，比較令人糾結，不過我們可以使用pymysql，來完成連接mysql的重任，步驟如下：序號描述1去github上下載pymysql的安裝包pymysql2解壓到某個盤符下3打開cmd窗口（win環境下），進入pymysql的根目錄下執行命令，pythonsetup.pyinstall4在程序里，導入pymysql5開始連接資料庫資料庫操作的API文檔連接:代碼如下：__author__='qindongliang'#導入pymysql的包importpymysqltry:#獲取一個資料庫連接，注意如果是UTF-8類型的，需要制定資料庫conn=pymysql.connect(host='localhost',user='root',passwd='qin',db='person',port=3306,charset='utf8')cur=conn.cursor()#獲取一個游標cur.execute('select*fromperson')data=cur.fetchall()fordindata:#注意int類型需要使用str函數轉義print("ID:"+str(d[0])+'名字：'+d[1]+"性別："+d[2])cur.close()#關閉游標conn.close()#釋放資料庫資源exceptException:print("發生異常")結果如下：D:\python\python.exeD:/pythonide/pythonprojectworkspace/python/mysql.pyID:1名字：秦天性別：男ID:2名字：王晶性別：女Processfinishedwithexitcode0
F. python如何通過串口SSH登錄伺服器
需要寫一個基於串口通信協議的ssh伺服器和客戶端，伺服器部署到linux上，客戶端在windows上；
其次，客戶端要提供sdk for python；
最後，你就可以用python通過ssh登錄linux了。
G. 請教個python執行ssh命令的問題
各位我現在想用python寫個ssh登陸的腳本 現在遇見一個問題就是我不太清楚python如何進行變數替換的(機器間已做好ssh互認)
1.1.1.1是我的時間伺服器
比如說beijing_IP 裡面有兩個IP
1.1.1.2
1.1.1.3
import os
IP_FILE=open('/home/cetvuser/beijing_IP','r')
LINES=IP_FILE.readlines()
for i in LINES:
i=i.strip()
os.system("ssh i;ntpdate 1.1.1.1") 這個地方應該怎麼寫?
IP_FILE.close()
報錯內容如下:
[root@xxx]# ./time.py
ssh: i: Name or service not known
25 Apr 11:42:13 ntpdate[7975]: no server suitable for synchronization found
ssh: i: Name or service not known
25 Apr 11:42:17 ntpdate[7979]: no server suitable for synchronization found
ssh: i: Name or service not known
變數替換，看你要在哪裡替換。給你一個簡單的例子。
os.system('ssh %s'%(ip))
復制代碼
H. 使用python 實現SSH登錄設備時出現問題
解決了啊，不過不是用的
stdin,stdout,stderr=client.exec_command('show arp;show clock')
用這種方法只能弄一條命令
用下面這個
chan= client.invoke_shell()
chan.send('en\n')
chan.send("password\n")
chan.send('show log\n')
result = chan.recv(100000).decode()
用了這個可能還有別的問題，試試吧，不行再討論
I. python 實現ssh的執行遠端命令和scp的不同機器文件傳輸功能
#!/usr/bin/env python
# -*- coding: utf-8 -*-
import pexpect
def ssh_cmd(ip, passwd, cmd):
ret = -1
ssh = pexpect.spawn('ssh root@%s "%s"' % (ip, cmd))
try:
i = ssh.expect(['password:', 'continue connecting (yes/no)?'], timeout=5)
if i == 0 :
ssh.sendline(passwd)
elif i == 1:
ssh.sendline('yes\n')
ssh.expect('password: ')
ssh.sendline(passwd)
ssh.sendline(cmd)
r = ssh.read()
print r
ret = 0
except pexpect.EOF:
print "EOF"
ssh.close()
ret = -1
except pexpect.TIMEOUT:
print "TIMEOUT"
ssh.close()
ret = -2
return ret
利用pexpect模塊我們可以做很多事情，由於他提供了自動交互功能，因此我們可以實現ftp，telnet，ssh，scp等的自動登錄，還是比較實用的。根據上面的代碼相信讀者已經知道怎麼實現了（python就是那麼簡單！）。
用
上面的代碼去完成任務還是比較費時間的，因為程序要等待自動交互出現，另外ubuntu用ssh連接就是比較慢，要進行一系列的驗證，這樣才體現出ssh
的安全。我們要提高效率，在最短的時間內完成。後來我發現了python裡面的paramiko模塊，用這個實現ssh登錄更加簡單。看下面的代碼：
復制代碼 代碼如下:
#-*- coding: utf-8 -*-
#!/usr/bin/python
import paramiko
import threading
def ssh2(ip,username,passwd,cmd):
try:
ssh = paramiko.SSHClient()
ssh.set_missing_host_key_policy(paramiko.AutoAddPolicy())
ssh.connect(ip,22,username,passwd,timeout=5)
for m in cmd:
stdin, stdout, stderr = ssh.exec_command(m)
# stdin.write("Y") #簡單交互，輸入 『Y'
out = stdout.readlines()
#屏幕輸出
for o in out:
print o,
print '%s\tOK\n'%(ip)
ssh.close()
except :
print '%s\tError\n'%(ip)
if __name__=='__main__':
cmd = ['cal','echo hello!']#你要執行的命令列表
username = "" #用戶名
passwd = "" #密碼
threads = [] #多線程
print "Begin......"
for i in range(1,254):
ip = '192.168.1.'+str(i)
a=threading.Thread(target=ssh2,args=(ip,username,passwd,cmd))
a.start()
上面的程序還是有些技巧的：
1.
利用多線程，同時發出登錄請求，同時去連接電腦，這樣速度快很多，我試了一下，如果不用多線程，直接一個一個挨著執行的話，大約5～10秒鍾才能對一台電
腦操作完，具體時間要根據命令的來決定，如果是軟體安裝或者卸載時間要更長一些。這樣下來怎麼也要一二十分鍾，用多線程後就快多了，所有的命令執行完用了
不到2分鍾！
2.最好用root用戶登錄，因為安裝或者卸載軟體的時候如果用普通用戶又會提示輸入密碼，這樣又多了一次交互，處理起來就比較麻
煩！安裝軟體時apt-get install xxx
最好加上「-y」參數，因為有時安裝或刪除軟體時提示是否繼續安裝或卸載，這又是一次自動交互！加上那個參數後就沒有人機交互了。
3. 循環時循環所有ip，因為計算機的ip是路由器自動分配的，保險起見，最好全部都執行，保證沒有遺漏的主機
4.遠端執行命令時如果有交互，可以這樣用 stdin.write("Y")來完成交互，「Y」就是輸入「Y」。
5.把所有的命令放到一個列表裡面，遍歷列表可以依次執行列表裡面的命令
6.為了更好的進行控制，最好在電腦上提前把root用戶打開，裝好ssh伺服器並讓其開機自動執行。
J. 純干貨！python 在運維中的應用 (一)：批量 ssh/sftp
日常工作中需要大量、頻繁地使用ssh到伺服器查看、拉取相關的信息或者對伺服器進行變更。目前公司大量使用的shell，但是隨著邏輯的復雜化、腳本管理的精細化，shell已經不滿足日常需求，於是我嘗試整合工作中的需求，製作適合的工具。 由於管理制度的缺陷，我以工作流程為核心思考適合自己的運維方式，提升工作效率，把時間留給更有價值的事情。 完整代碼在最後，請大家參考。
生產：4000+物理伺服器，近 3000 台虛擬機。
開發環境：python3.6、redhat7.9，除了paramiko為第三方模塊需要自己安裝，其他的直接import即可。
批量執行操作是一把雙刃劍。批量執行操作可以提升工作效率，但是隨之而來的風險不可忽略。
風險案例如下：
掛載很多數據盤，通常先格式化硬碟，再掛載數據盤，最後再寫入將開機掛載信息寫入/etc/fstab文件。在批量lsblk檢查硬碟信息的時候發現有的系統盤在/sda有的在/sdm，如果不事先檢查機器相關配置是否一致直接按照工作經驗去執行批量操作，會很容易造成個人難以承受的災難。
在執行批量操作時按照慣例：格式化硬碟->掛載->開機掛載的順序去執行，假設有的機器因為某些故障導致格式化硬碟沒法正確執行。在處理這類問題的時候通常會先提取出失敗的ip，並再按照慣例執行操作。運維人員會很容易忽略開機掛載的信息已經寫過了，導致復寫（這都是血和淚的教訓）。
所以，為了避免故障，提升工作效率，我認為應當建立團隊在工作上的共識，應當遵守以下原則：
當然，代碼的規范也應當重視起來，不僅是為了便於審計，同時也需要便於溯源。我認為應當注意以下幾點：
1、ssh no existing session，sftp超時時間設置:
在代碼無錯的情況下大量ip出現No existing session，排查後定位在代碼的寫法上，下面是一個正確的示例。由於最開始沒考慮到ssh連接的幾種情況導致了重寫好幾遍。另外sftp的實例貌似不能直接設置連接超時時間，所以我採用了先建立ssh連接再打開sftp的方法。
2、sftp中的get()和put()方法僅能傳文件，不支持直接傳目錄：
不能直接傳目錄，那換個思路，遍歷路徑中的目錄和文件，先創建目錄再傳文件就能達到一樣的效果了。在paramiko的sftp中sftp.listdir_attr()方法可以獲取遠程路徑中的文件、目錄信息。那麼我們可以寫一個遞歸來遍歷遠程路徑中的所有文件和目錄(傳入一個列表是為了接收遞歸返回的值)。
python自帶的os模塊中的os.walk()方法可以遍歷到本地路徑中的目錄和文件。
3、多線程多個ip使用sftp.get()方法時無法並發。
改成多進程即可。
4、多個ip需要執行相同命令或不同的命令。
由於是日常使用的場景不會很復雜，所以借鑒了ansible的playbook，讀取提前准備好的配置文件即可，然後再整合到之前定義的ssh函數中。
同時，我們還衍生出一個需求，既然都要讀取配置，那同樣也可以提前把ip地址准備在文件里。正好也能讀取我們返回的執行程序的結果。
參數說明：
密碼認證：
公鑰認證：
可以配合 grep，awk 等命令精準過濾。
個人認為 Python 在初中級運維工作中的性質更像是工具，以提升工作效率、減少管理成本為主。可以從當前繁瑣的工作中解脫出來，去 探索 更有價值的事情。python 本質上並不會減少故障的產生，所以在不同的階段合理利用自身掌握的知識解決當前最重要的痛點，千萬不要本末倒置。