Lệnh ssh chạy dài trong mô-đun paramiko python (và cách kết thúc chúng)

Question

Tôi muốn chạy lệnh tail -f logfile trên máy từ xa bằng mô-đun paramiko của python. Tôi đã cố gắng nó cho đến nay trong thời trang sau:

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

Tôi muốn các lệnh để chạy miễn là cần thiết, nhưng tôi có 2 vấn đề:

1. Làm thế nào để ngăn chặn điều này sạch? Tôi đã nghĩ đến việc tạo một Kênh và sau đó sử dụng lệnh shutdown() trên kênh khi tôi kết nối với nó - nhưng điều đó có vẻ lộn xộn. Có thể thực hiện điều gì đó như đã gửi Ctrl-C tới kênh chuẩn của kênh không?
2. readline() khối và tôi có thể tránh các chuỗi nếu tôi có phương pháp không chặn đầu ra - bất kỳ suy nghĩ nào?

Answer 1

1) Bạn chỉ có thể đóng ứng dụng nếu muốn. Máy chủ ở đầu kia sẽ giết quá trình đuôi.

2) Nếu bạn cần thực hiện điều này theo cách không chặn, bạn sẽ phải trực tiếp sử dụng đối tượng kênh. Sau đó, bạn có thể xem cả stdout và stderr với channel.recv_ready() và channel.recv_stderr_ready() hoặc sử dụng select.select.

Answer 2

Để đóng quá trình này chỉ cần chạy:

interface.close() 

Về nonblocking, bạn có thể không nhận được một nonblocking đọc. Tốt nhất bạn có thể sẽ phân tích nó thành một "khối" tại một thời điểm, "stdout.read (1)" sẽ chỉ chặn khi không còn ký tự nào trong bộ đệm.

Answer 3

Thay vì gọi exec_command trên máy khách, hãy giữ vận chuyển và tạo kênh của riêng bạn. Các channel có thể được sử dụng để thực thi một lệnh, và bạn có thể sử dụng nó trong một tuyên bố chọn để tìm hiểu khi dữ liệu có thể được đọc:

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

Đối tượng kênh có thể được đọc từ và ghi vào, kết nối với thiết bị xuất chuẩn và stdin của lệnh từ xa. Bạn có thể nhận được stderr bằng cách gọi channel.makefile_stderr(...).

Tôi đã đặt thời gian chờ thành 0.0 giây vì giải pháp không chặn được yêu cầu. Tùy thuộc vào nhu cầu của bạn, bạn có thể muốn chặn với thời gian chờ khác không.

Answer 4

Chỉ để biết thông tin, có giải pháp để thực hiện việc này bằng cách sử dụng channel.get_pty(). Để biết thêm chi tiết, hãy xem: https://stackoverflow.com/a/11190727/1480181

Answer 5

Chỉ cần cập nhật nhỏ cho giải pháp của Andrew Aylett. Đoạn mã sau thực sự phá vỡ vòng lặp và thoát khi quá trình bên ngoài kết thúc:

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)