Pythonのparamikoモジュールで長時間実行されるsshコマンド（および終了方法）

Question

tail -f logfileコマンドを、pythonのparamikoモジュールを使用してリモートマシン上で実行したいとします。私は、次の方法で、これまでにそれをしようとしてきた：

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

私は必要な限り実行するコマンドをたいが、私は2つの問題を抱えて：私はこれをどのように

1. を停止しますきれいに？私はチャンネルを作ってから、チャンネルでshutdown()コマンドを使ってみることを考えましたが、それは面倒です。チャンネルの標準入力にCtrl-Cというような送信を行うことはできますか？
2. readline()ブロックをブロックすることができます。出力を取得するノンブロッキングの方法があれば、スレッドを避けることができます。

Answer 1

1）ご希望の場合は、クライアントを閉じることができます。もう一方の端にあるサーバーは、テールプロセスを停止します。

2）これをノンブロッキングで行う必要がある場合は、チャネルオブジェクトを直接使用する必要があります。次に、channel.recv_ready（）およびchannel.recv_stderr_ready（）を使用してstdoutとstderrの両方を監視するか、select.selectを使用します。

Answer 2

単に実行するプロセスを閉じるには：ノンブロッキングの面では

interface.close() 

を、あなたはノンブロッキングの読み取りを取得することはできません。一度に1つの "ブロック"を解析すると、バッファに文字が残っていないと "stdout.read（1）"がブロックされません。

Answer 3

クライアントでexec_commandを呼び出す代わりに、トランスポートを取得して独自のチャネルを生成します。 channelは、コマンドを実行するために使用することができ、あなたがデータを読み取ることができたときに調べるためにselect文でそれを使用することができます。

#!/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) 

チャネルオブジェクトから読み書きすることができ、標準出力と接続し、リモートコマンドのstdin。 channel.makefile_stderr(...)を呼び出すことで、stderrにアクセスできます。

ノンブロッキングソリューションが要求されたため、タイムアウトを0.0秒に設定しました。必要に応じて、ゼロ以外のタイムアウトでブロックすることができます。

Answer 4

ちょうど情報のために、channel.get_pty（）を使用してこれを行う解決策があります。詳細は次のURLをご覧ください。https://stackoverflow.com/a/11190727/1480181

Answer 5

Andrew Aylettのソリューションに対するちょっとした更新。次のコードは実際にループを壊して、外部プロセスが終了すると終了します。

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)