Paramiko und exec_command - töten remote-Prozess?

Während nicht die effizienteste Methode, dies sollte funktionieren. Nachdem Sie STRG+C; In die KeyboardInterrupt-handler könnten Sie exec_command("killall -u %s tail" % uname) etwa so:

#!/usr/bin/env python2

import paramiko
import select

import time
ltime = time.time()

# Or use random:
# import random
# ltime = random.randint(0, 500)

uname = "victorhooi"
client = paramiko.SSHClient()
client.load_system_host_keys()
client.connect('someserver', username=uname, password='blahblah')
transport = client.get_transport()
channel = transport.open_session()

channel.exec_command("tail -%df /home/victorhooi/macbeth.txt" % ltime)
while True:
    try:
        rl, wl, xl = select.select([channel],[],[],0.0)
        if len(rl) > 0:
            # Must be stdout
            print channel.recv(1024)
    except KeyboardInterrupt:
        print("Caught control-C")
        channel.close()
        try:
            # open new socket and kill the proc..
            client.get_transport().open_session().exec_command("kill -9 `ps -fu %s | grep 'tail -%df /home/victorhooi/macbeth.txt' | grep -v grep | awk '{print $2}'`" % (uname, ltime))
        except:
            pass
    
        client.close()
        exit(0)

Dies würde die töten, die offenen Prozesse mit dem Namen tail. Das kann Probleme verursachen, wenn Sie tails open, die Sie nicht wollen, um zu schließen, wenn das ist der Fall, Sie könnten grep eine ps haben, erhalten die pid und die kill -9.

Zuerst Schwanz gelesen n Zeilen am Ende der Datei, bevor Sie die folgenden. set n zu einem einzigartigen nuber wie time.time(), da die Rute keine Sorge, wenn diese Zahl größer ist dann die Anzahl der Zeilen in der Datei, die die große Anzahl von time.time()sollte nicht zu Problemen führen und wird einzigartig sein. Dann ist grep für diese eindeutige Nummer im ps:

   client.get_transport().open_session().exec_command("kill -9 `ps -fu %s | grep 'tail -%df /home/victorhooi/macbeth.txt' | grep -v grep | awk '{print $2}'`" % (uname, ltime))

InformationsquelleAutor chown

Gibt es eine Möglichkeit, dies zu tun. Es funktioniert wie auf der shell

ssh -t commandname

Die option-t ist die Eröffnung eines pseudo-pty-Hilfe ssh zu verfolgen, wie lange dieser Prozess dauern soll. das gleiche kann getan werden, über pormiko über

channel.get_pty()

vor execute_command(...). Dies wird nicht öffnen Sie eine shell, wie es mit dem Kanal.invoke_shell(), es fordert eine pseudo-interface zu binden, alle Prozesse zu. Der Effekt kann auch gesehen werden, wenn ps-aux ausgegeben wird auf dem remote-Computer, der Prozess ist jetzt an der sshd mit einem ptxXY-Schnittstelle.

InformationsquelleAutor Sven

Hier ist ein Weg, um die remote-Prozess-ID:

def execute(channel, command):
    command = 'echo $$; exec ' + command
    stdin, stdout, stderr = channel.exec_command(command)
    pid = int(stdout.readline())
    return pid, stdin, stdout, stderr

Und hier ist, wie es zu verwenden (ersetzen ... mit den bits in der ursprünglichen Frage):

pid, _, _, _ = execute(channel, "tail -f /home/victorhooi/macbeth.txt")
while True:
    try:
        # ...
    except KeyboardInterrupt:
        client.exec_command("kill %d" % pid)
        # ...

InformationsquelleAutor Søren Løvborg

Können Sie get_pty wie beschrieben in https://stackoverflow.com/a/38883662/565212.

E. g. Szenario - Wann rufen Sie client/Kanal.close():

Schritt 1: Führen Sie einen remote-Befehl, schreibt in die log-Datei.

Schritt 2: erzeugen Sie einen thread, der führt den tail-Befehl und die Blöcke in die readline loop

Schritt 3: In der main-thread, wenn der Befehl zurückgibt, wissen Sie, es werden keine Protokolle mehr, töten den Schwanz.

InformationsquelleAutor Tapomay