Comandi ssh di lunga durata nel modulo paramiko python (e come terminarli)

Question

Voglio eseguire un comando tail -f logfile su una macchina remota usando il modulo paramiko di python. Sto tentando finora nel modo seguente:

interface = paramiko.SSHClient() 
#snip the connection setup portion 
stdin, stdout, stderr = interface.exec_command("tail -f logfile") 
#snip into threaded loop 
print stdout.readline() 

mi piacerebbe il comando da eseguire tutto il tempo necessario, ma ho 2 problemi:

1. Come arresto questo pulito? Ho pensato di creare un canale e quindi di utilizzare il comando shutdown() sul canale quando ho finito con esso- ma ciò sembra disordinato. È possibile fare qualcosa come inviato Ctrl-C allo stdin del canale?
2. readline() blocchi, e potrei evitare i thread se avessi un metodo non bloccante per ottenere output, qualche pensiero?

Answer 1

1) È possibile chiudere il client se lo si desidera. Il server all'altra estremità ucciderà il processo di coda.

2) Se è necessario eseguire questa operazione in modo non bloccante, sarà necessario utilizzare direttamente l'oggetto canale. È quindi possibile guardare sia per stdout sia per stderr con channel.recv_ready() e channel.recv_stderr_ready() oppure utilizzare select.select.

Answer 2

Per chiudere il processo sufficiente eseguire:

interface.close() 

In termini di non bloccante, non è possibile ottenere un bloccante leggere. Il meglio che si sarebbe in grado di analizzare è un "blocco" alla volta, "stdout.read (1)" si bloccherà solo quando non ci sono caratteri rimasti nel buffer.

Answer 3

Invece di chiamare exec_command sul client, ottenere il trasporto e generare il proprio canale. Il channel può essere utilizzato per eseguire un comando, e si può utilizzare in una dichiarazione prescelta per sapere quando i dati possono essere letti:

#!/usr/bin/env python 
import paramiko 
import select 
client = paramiko.SSHClient() 
client.load_system_host_keys() 
client.connect('host.example.com') 
transport = client.get_transport() 
channel = transport.open_session() 
channel.exec_command("tail -f /var/log/everything/current") 
while True: 
    rl, wl, xl = select.select([channel],[],[],0.0) 
    if len(rl) > 0: 
     # Must be stdout 
     print channel.recv(1024) 

L'oggetto canale possono essere letti e scritti, il collegamento con stdout e stdin del comando remoto. È possibile ottenere a stderr chiamando channel.makefile_stderr(...).

Ho impostato il timeout su 0.0 secondi perché è stata richiesta una soluzione non bloccante. A seconda delle esigenze, potresti voler bloccare con un timeout diverso da zero.

Answer 4

Giusto per informazione, c'è una soluzione per farlo usando channel.get_pty(). Prima ulteriori dettagli dare un'occhiata a: https://stackoverflow.com/a/11190727/1480181

Answer 5

Solo un piccolo aggiornamento alla soluzione di Andrew Aylett. Il seguente codice interrompe effettivamente il ciclo e si chiude quando termina il processo esterno:

import paramiko 
import select 

client = paramiko.SSHClient() 
client.load_system_host_keys() 
client.connect('host.example.com') 
channel = client.get_transport().open_session() 
channel.exec_command("tail -f /var/log/everything/current") 
while True: 
    if channel.exit_status_ready(): 
     break 
    rl, wl, xl = select.select([channel], [], [], 0.0) 
    if len(rl) > 0: 
     print channel.recv(1024)