Erstellen mehrerer SSH-Verbindungen zu einer Zeit mit paramiko

Question

Der folgende Code läuft grep in einer Maschine über SSH und druckt die Ergebnisse:

import sys, os, string 
import paramiko 

cmd = "grep -h 'king' /opt/data/horror_20100810*" 

ssh = paramiko.SSHClient() 
ssh.set_missing_host_key_policy(paramiko.AutoAddPolicy()) 
ssh.connect('10.10.3.10', username='xy', password='xy') 
stdin, stdout, stderr = ssh.exec_command(cmd) 
stdin.write('xy\n') 
stdin.flush() 

print stdout.readlines() 

Wie kann ich grep fünf Maschinen auf einmal (so, dass ich nicht tun haben Sie große Verzögerung), dann setzen Sie all das in fünf Variablen und drucken sie alle aus.

Answer 1

Sie müssen die Aufrufe in separate Threads (oder Prozesse, aber das wäre Overkill) setzen, was wiederum erfordert, dass der Code in einer Funktion (was eine gute Idee ist sowieso: haben Sie keinen wesentlichen Code auf der obersten Ebene eines Moduls).

Zum Beispiel:

import sys, os, string, threading 
import paramiko 

cmd = "grep -h 'king' /opt/data/horror_20100810*" 

outlock = threading.Lock() 

def workon(host): 

    ssh = paramiko.SSHClient() 
    ssh.set_missing_host_key_policy(paramiko.AutoAddPolicy()) 
    ssh.connect(host, username='xy', password='xy') 
    stdin, stdout, stderr = ssh.exec_command(cmd) 
    stdin.write('xy\n') 
    stdin.flush() 

    with outlock: 
     print stdout.readlines() 

def main(): 
    hosts = ['10.10.3.10', '10.10.4.12', '10.10.2.15', ] # etc 
    threads = [] 
    for h in hosts: 
     t = threading.Thread(target=workon, args=(h,)) 
     t.start() 
     threads.append(t) 
    for t in threads: 
     t.join() 

main() 

Wenn Sie viel mehr als fünf Hosts hätten, würde ich anstelle eine „Thread-Pool“ Architektur und eine Warteschlange von Arbeitseinheiten empfehlen. Aber für nur fünf ist es einfacher, beim "dedicated thread" -Modell zu bleiben (besonders, da es keinen Thread-Pool in der Standard-Bibliothek gibt, so dass Sie ein Paket von Drittanbietern wie threadpool ... oder eine Menge subtiler Custom benötigen eigener Code natürlich ;-).

Answer 2

Führen Sie einfach alles in einer for-Schleife aus, und vergessen Sie nicht, stdin zu schließen, bevor Sie mit der nächsten Iteration fortfahren. Das heißt, nach Zeile stdin.flush() Zeile hinzufügen stdin.close()