Wie Sie wissen, wenn ein paramiko SSH-Kanal getrennt ist?

Ich bin desinging test Fälle, in denen ich verwenden paramiko für SSH-verbindungen. Testfälle enthalten in der Regel paramiko.exec_command() Anrufe, die ich über ein wrapper für (genannt run_command()). Hier self.ssh ist ein Herzen lag der paramiko.SSHClient(). Ich benutze ein Dekorateur, um zu überprüfen die ssh-Verbindung vor jedem Anruf. (self.get_ssh() verhandelt der Verbindung)

def check_connections(function):
    ''' A decorator to check SSH connections. '''
    def deco(self, *args, **kwargs):
        if self.ssh is None:
            self.ssh = self.get_ssh()
        else:
            ret = getattr(self.ssh.get_transport(), 'is_active', None)
            if ret is None or (ret is not None and not ret()):
                self.ssh = self.get_ssh()
        return function(self, *args, **kwargs)
    return deco

@check_connections
def run_command(self, command):
    ''' Executes command via SSH. '''
    stdin, stdout, stderr = self.ssh.exec_command(command)
    stdin.flush()
    stdin.channel.shutdown_write()
    ret = stdout.read()
    err = stderr.read()
    if ret:
        return ret
    elif err:
        return err
    else:
        return None

Funktioniert es tadellos, bis meine remote-Knoten neu gestartet wird, kann manchmal passieren. Wenn es vorkommt, wird die nächste run_command() Aufruf erzeugt eine socket.error Ausnahme. Das problem ist, dass die paramiko.Transport Objekt zu sein scheint, bleibt im aktiven Zustand bis eine exception geworfen wird:

Python 2.7.3 (default, Mar  7 2013, 14:03:36)
[GCC 4.3.4 [gcc-4_3-branch revision 152973]] on linux2
Type "help", "copyright", "credits" or "license" for more information.
>>> import os
>>> import paramiko
>>> ssh = paramiko.SSHClient()
>>> print ssh
<paramiko.SSHClient object at 0x7f2397b96d50>
>>> print ssh.get_transport()
None
>>> ssh.set_missing_host_key_policy(paramiko.AutoAddPolicy())
>>> ssh.load_host_keys(os.path.expanduser('~') + '/.ssh/known_hosts')
>>> ssh.connect(hostname = '172.31.77.57', username = 'root', password = 'rootroot', timeout = 5.0)
>>> print ssh
<paramiko.SSHClient object at 0x7f2397b96d50>
>>> print ssh.get_transport()
<paramiko.Transport at 0x97537550L (cipher aes128-ctr, 128 bits) (active; 0 open channel(s))>
>>> print ssh.get_transport().is_active()
True
>>> ssh.exec_command('ls')
(<paramiko.ChannelFile from <paramiko.Channel 1 (open) window=2097152 -> <paramiko.Transport at 0x97537550L (cipher aes128-ctr, 128 bits) (active; 1 open channel(s))>>>, <paramiko.ChannelFile from <paramiko.Channel 1 (open) window=2097152 -> <paramiko.Transport at 0x97537550L (cipher aes128-ctr, 128 bits) (active; 1 open channel(s))>>>, <paramiko.ChannelFile from <paramiko.Channel 1 (open) window=2097152 -> <paramiko.Transport at 0x97537550L (cipher aes128-ctr, 128 bits) (active; 1 open channel(s))>>>)
>>> print ssh
<paramiko.SSHClient object at 0x7f2397b96d50>
>>> print ssh.get_transport()
<paramiko.Transport at 0x97537550L (cipher aes128-ctr, 128 bits) (active; 0 open channel(s))>
>>> print ssh.get_transport().is_active()
True
>>> ssh.exec_command('reboot')
(<paramiko.ChannelFile from <paramiko.Channel 2 (open) window=2097152 -> <paramiko.Transport at 0x97537550L (cipher aes128-ctr, 128 bits) (active; 1 open channel(s))>>>, <paramiko.ChannelFile from <paramiko.Channel 2 (open) window=2097152 -> <paramiko.Transport at 0x97537550L (cipher aes128-ctr, 128 bits) (active; 1 open channel(s))>>>, <paramiko.ChannelFile from <paramiko.Channel 2 (open) window=2097152 -> <paramiko.Transport at 0x97537550L (cipher aes128-ctr, 128 bits) (active; 1 open channel(s))>>>)
>>> print ssh
<paramiko.SSHClient object at 0x7f2397b96d50>
>>> print ssh.get_transport()
<paramiko.Transport at 0x97537550L (cipher aes128-ctr, 128 bits) (active; 0 open channel(s))>
>>> print ssh.get_transport().is_active()
True
>>> ssh.exec_command('ls')
No handlers could be found for logger "paramiko.transport"
Traceback (most recent call last):
  File "<stdin>", line 1, in <module>
  File "/home/pytest/lib/python2.7/site-packages/paramiko/client.py", line 370, in exec_command
    chan = self._transport.open_session()
  File "/home/pytest/lib/python2.7/site-packages/paramiko/transport.py", line 662, in open_session
    return self.open_channel('session')
  File "/home/pytest/lib/python2.7/site-packages/paramiko/transport.py", line 764, in open_channel
    raise e
socket.error: [Errno 104] Connection reset by peer
>>> print ssh
<paramiko.SSHClient object at 0x7f2397b96d50>
>>> print ssh.get_transport()
<paramiko.Transport at 0x97537550L (unconnected)>
>>> print ssh.get_transport().is_active()
False
>>>

Frage: wie kann ich sicher sein, dass die Verbindung wirklich aktiv ist oder nicht?

InformationsquelleAutor Milo | 2013-11-22

paramiko python

11

In python, es ist einfacher um Vergebung zu bitten, als die Erlaubnis.

Wickeln Sie jeden Anruf zu ssh.exec_command etwa so:
```
try:
    ssh.exec_command('ls')
except socket.error as e:
    # Crap, it's closed. Perhaps reopen and retry?
```
- +1 aber es ist eher ein workaround als eine Lösung für mich... ich denke, paramiko fehlt, was ich brauche...
- hast du eine bessere Lösung zu Paramiko? Ich bin in der exakt gleichen position wie du.
- Nein, aber ich habe nicht getan, keine Forschung auf Sie, vor kurzem. Ich denke, es hat zu sein getan auf diese Weise. (Sorry für die späte Antwort.)
- Hey, was ist, wenn ich bin zwischen einem Befehl, der in 5 Minuten zu beenden, und ich verlor die Verbindung zum server. Wie kann ich prüfen, ob die Verbindung aktiv ist oder nicht ?
- Vielleicht sollten Sie beginnen, eine neue Frage auf, die man...
- ALSO mich gebannt! Ich kann nicht Fragen, neue Frage. Danke!
- Ein heads-up auf dieser socket.error ist ein alias für OSError (docs.python.org/3/library/socket.html#socket.error), das bedeutet zum Beispiel, dass man versehentlich fangen FileNotFoundError welche ausgelöst werden können durch die paramiko.SFTPClient.
InformationsquelleAutor VooDooNOFX

Meine Lösung ist im Grunde das gleiche wie deins, nur anders organisiert:

def connection(self):
    if not self.is_connected():
        self._ssh = paramiko.SSHClient()
        self._ssh.connect(self.server, self.port,
                          username = self.username, password = self.password)

    return self._ssh

def is_connected(self):
    transport = self._ssh.get_transport() if self._ssh else None
    return transport and transport.is_active()

def do_something(self):
    self.connection().exec_command('ls')

InformationsquelleAutor Haroldo_OK

Dies funktioniert:

import paramiko
client = paramiko.SSHClient()
client.set_missing_host_key_policy(paramiko.AutoAddPolicy())        # Setting the missing host policy to auto add it
client.connect('192.168.1.16', port=22, username='admin', password='admin', timeout=3, banner_timeout=2)

channel = client.invoke_shell()                 # Request an interactive shell session on this channel. If the server allows it, the channel will then be directly connected to the stdin, stdout, and stderr of the shell.
print channel.closed          # False
command = 'reboot'
channel.send(command + '\n')
# wait a while
print channel.closed          # True

InformationsquelleAutor Ashutosh Kumar

0

Krank, nur werfen diese hier, da könnte jemand finden es nützlich. Es gibt einen Haken, mit einigen dieser Methoden. Paramiko intern verwendet sockets. Jede neue Verbindung ruft socket dem öffnet sich ein neuer file-Deskriptor. Da die Prozesse beschränkt auf bestimmte Anzahl offener Datei-Deskriptoren, nach einiger Zeit werden Sie laufen, die Folge:

socket.error: [Errno 24] Too many open files.

So ist es besser, explizit zu versuchen, die Verbindung zu schließen, bevor er einen neuen mit SSHClient.close() Methode.

InformationsquelleAutor Majo

Schreibe einen Kommentar

Du musst angemeldet sein, um einen Kommentar abzugeben.