執行二進制文件在Python腳本

Question

編輯： 使用片斷下面我遇到的幾個問題

import paramiko, threading 

ssh=paramiko.SSHClient() 
ssh.set_missing_host_key_policy(paramiko.AutoAddPolicy()) 

def connectAndCMD(command): 
    ssh.connect('127.0.0.1',22,'MY_USER','MY_SSH_PASS') 
    stdin, stdout, stderr = ssh.exec_command(command) 
    print stdout.read() 

commandList=[ 
    "pwd", 
    "whoami", 
    "ls", 
    "echo hello", 
    "ping google.com", 
    "ifconfig | grep Bcast | awk {'print $2'}" 
] 
for command in commandList: 
    print '[',command, '] command thread started' 
    t=threading.Thread(target=connectAndCMD,args=(command,)) 
    t.start() 

在控制檯中我看到： SSHException：不存在會話 奇怪的是，當我減少列表的大小隻是一些命令，減少了線程數量，我能夠看到隨機線程的某個ssh命令的輸出，但是腳本無限期地掛起。什麼是問題，我該如何解決這個問題？

這是樣機，但在我實際的程序我正在做的線程來運行只是不同的參數/選項

Answer 1

的問題是，您試圖重新驗證每個命令的ssh連接相同的命令。 SSH使用單個傳輸連接（通常是TCP，但理論上是其他的）來複用多個ssh級別的通道，這些通道運行命令，管道和外殼等。 SSHClient.connect將打開傳輸連接，驗證服務器（注意丟失的主機密鑰策略 - 您使用了一個相當不安全的策略）並驗證客戶端（在您的情況下爲密碼）。

之後，客戶端可以打開任意數量的ssh級別的通道來完成工作。每個exec_command打開一個通道，在服務器上啓動一個shell，運行一個命令並關閉該通道。但由於這些通道是多路複用的，它們可以並行運行，並且是多線程的好選擇。

import paramiko, threading 

ssh=paramiko.SSHClient() 
ssh.set_missing_host_key_policy(paramiko.AutoAddPolicy()) 
ssh.connect('127.0.0.1',22,'MY_USER','MY_SSH_PASS') 

def connectAndCMD(command): 
    stdin, stdout, stderr = ssh.exec_command(command) 
    print stdout.read() 

commandList=[ 
    "pwd", 
    "whoami", 
    "ls", 
    "echo hello", 
    "ping google.com", 
    "ifconfig | grep Bcast | awk {'print $2'}" 
] 
for command in commandList: 
    print '[',command, '] command thread started' 
    t=threading.Thread(target=connectAndCMD,args=(command,)) 
    t.start() 

UPDATE

由於SSH服務器會限制你可以使用一個線程池，以確保您保持在限制下同時命令的數量。

import paramiko 
import multiprocessing.pool 

ssh=paramiko.SSHClient() 
ssh.set_missing_host_key_policy(paramiko.AutoAddPolicy()) 
ssh.connect('127.0.0.1',22,'MY_USER','MY_SSH_PASS') 

def connectAndCMD(command): 
    stdin, stdout, stderr = ssh.exec_command(command) 
    return command, stdout.read(), stderr.read() 

commandList=[ 
    "pwd", 
    "whoami", 
    "ls", 
    "echo hello", 
    "ping google.com", 
    "ifconfig | grep Bcast | awk {'print $2'}" 
] 

pool = multiprocessing.pool.ThreadPool(min(10, len(commandList)) 
for command, out, err in pool.map(connectAndCMD, commandList, chunksize=1): 
    print((command, out, err)) 
pool.close() 
pool.join()