Wykonywanie poleceń przez ssh za pomocą Pythona

Lub możesz po prostu użyć poleceń.getstatusoutput :

   commands.getstatusoutput("ssh machine 1 'your script'")

Używałem go intensywnie i działa świetnie.

W Pythonie 2.6+, użyj subprocess.check_output.

Czy widziałeś tkaniny ? Pozwala na wykonywanie wszelkiego rodzaju zdalnych rzeczy przez SSH przy użyciu Pythona.

Uznałem, że paramiko jest trochę za niskopoziomowe, a Fabric nie nadaje się specjalnie do wykorzystania jako biblioteka, więc stworzyłem własną bibliotekę o nazwie spur , która używa paramiko do implementacji nieco ładniejszego interfejsu:

import spur

shell = spur.SshShell(hostname="localhost", username="bob", password="password1")
result = shell.run(["echo", "-n", "hello"])
print result.output # prints hello

Jeśli trzeba uruchomić wewnątrz powłoki:

shell.run(["sh", "-c", "echo -n hello"])

Wszyscy już stwierdzili (zalecane) Użycie paramiko i właśnie udostępniam kod Pythona (można powiedzieć API), który pozwoli Ci wykonać wiele poleceń za jednym zamachem.

Aby wykonywać polecenia na różnych węzłach użyj : Commands().run_cmd(host_ip, list_of_commands)

Zobaczysz jedno TODO, które zatrzymałem, aby zatrzymać wykonywanie, jeśli któreś z poleceń nie wykona, Nie wiem, jak to zrobić. podziel się swoją wiedzą

#!/usr/bin/python

import os
import sys
import select
import paramiko
import time


class Commands:
    def __init__(self, retry_time=0):
        self.retry_time = retry_time
        pass

    def run_cmd(self, host_ip, cmd_list):
        i = 0
        while True:
        # print("Trying to connect to %s (%i/%i)" % (self.host, i, self.retry_time))
        try:
            ssh = paramiko.SSHClient()
            ssh.set_missing_host_key_policy(paramiko.AutoAddPolicy())
            ssh.connect(host_ip)
            break
        except paramiko.AuthenticationException:
            print("Authentication failed when connecting to %s" % host_ip)
            sys.exit(1)
        except:
            print("Could not SSH to %s, waiting for it to start" % host_ip)
            i += 1
            time.sleep(2)

        # If we could not connect within time limit
        if i >= self.retry_time:
            print("Could not connect to %s. Giving up" % host_ip)
            sys.exit(1)
        # After connection is successful
        # Send the command
        for command in cmd_list:
            # print command
            print "> " + command
            # execute commands
            stdin, stdout, stderr = ssh.exec_command(command)
            # TODO() : if an error is thrown, stop further rules and revert back changes
            # Wait for the command to terminate
            while not stdout.channel.exit_status_ready():
                # Only print data if there is data to read in the channel
                if stdout.channel.recv_ready():
                    rl, wl, xl = select.select([ stdout.channel ], [ ], [ ], 0.0)
                    if len(rl) > 0:
                        tmp = stdout.channel.recv(1024)
                        output = tmp.decode()
                        print output

        # Close SSH connection
        ssh.close()
        return

def main(args=None):
    if args is None:
        print "arguments expected"
    else:
        # args = {'<ip_address>', <list_of_commands>}
        mytest = Commands()
        mytest.run_cmd(host_ip=args[0], cmd_list=args[1])
    return


if __name__ == "__main__":
    main(sys.argv[1:])

Użyłem paramiko kilka (ładne) i pxssh (również ładne). Polecam. Działają nieco inaczej, ale mają stosunkowo duże nakładanie się w użyciu.

Przyjrzyjmy się spurplus, owijce, którą stworzyliśmy wokół spur, która zawiera adnotacje o typach i kilka drobnych sztuczek (ponowne łączenie SFTP, md5 itd.): https://pypi.org/project/spurplus/