Aşağıdaki kod SSH aracılığıyla bir makinede grep çalışır Paramiko

Question

kullanarak aynı anda birden SSH bağlantıları oluşturma ve sonuçları yazdırır: Bilmiyorum ki

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() 

nasıl (tek seferde beş makineleri grep edebilirsiniz herşeyi beş değişkene koymak ve hepsini basmaktan ziyade büyük gecikme var.

Answer 1

Aramaları ayrı iş parçacıklarına (veya işlemlere, ancak bu aşırıya kaçmayacak şekilde) eklemeniz gerekir, bu da kodun bir işlevde olmasını gerektirir (yine de iyi bir fikirdir: önemli kod yoktur) bir modülün üst seviyesinde). Örneğin

:

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() 

birçok fazla beş ana olsaydı, ben bir "iş parçacığı havuzu" mimari ve iş birimlerinin bir kuyruk yerine kullanarak öneriyoruz. Ancak, sadece beş için, "özel iş parçacığı" modeline bağlı kalmak daha kolay (özellikle standart kitaplıkta iş parçacığı havuzu olmadığından, threadpool gibi bir üçüncü taraf paketine veya bir sürü ince özelliğe ihtiyacın var. Kendi kodunuzun kodu ;-).

Answer 2

Her şeyi for döngüsünde çalıştırın ve sonraki iterasyona geçmeden önce stdin'i kapatmayı unutmayın. Ben 1 makineyi ortadan stdin.close()