Я хочу запустить команду 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()
Я бы хотел, чтобы команда выполнялась столько, сколько необходимо, но у меня есть две проблемы:
shutdown() на канале, когда я закончил с ним, но это кажется беспорядочным. Возможно ли сделать что-то вроде отправки Ctrl-C на канал stdin?readline(), и я мог бы избежать потоков, если бы у меня был неблокирующий метод получения вывода - любые мысли?1) Вы можете просто закрыть клиента, если хотите. Сервер с другого конца убьет хвостовой процесс.
2) Если вам нужно сделать это неблокирующим способом, вам придется напрямую использовать объект канала. Затем вы можете смотреть как stdout, так и stderr с каналами .recv_ready() и channel.recv_stderr_ready() или использовать select.select.
Вместо вызова 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)
Объект канала можно считывать и записывать, подключаясь к stdout и stdin удаленной команды. Вы можете получить stderr, вызвав channel.makefile_stderr(...).
Я установил таймаут на 0.0 секунды, потому что было запрошено неблокирующее решение. В зависимости от ваших потребностей вы можете блокировать с ненулевым тайм-аутом.
Просто небольшое обновление для решения Эндрю Айлетта. Следующий код фактически прерывает цикл и завершает работу, когда внешний процесс завершается:
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)
Чтобы закрыть процесс, просто запустите:
interface.close()
В терминах неблокирования вы не можете получить неблокирующее чтение. Лучшее, что вы могли бы сделать, - разобрать на нем один "блок" за раз, "stdout.read(1)" будет блокироваться только тогда, когда в буфере нет символов.
Просто для информации есть решение сделать это с помощью channel.get_pty(). Более подробная информация приведена ниже: fooobar.com/info/241655/...