linux批量管理推送工具mussh和pssh介绍

Usage: mussh [OPTIONS] <-h host.. | -H hostfile> [-c cmd] [-C scriptfile]

mussh --help        for full help text

Send a command or list of commands to multiple hosts.

OPTIONS:

        --help          This text.

        -d [n]          Verbose debug.  Prints each action, all hosts

                        and commands to be executed to STDERR.  'n' can

                        be from 0 to 2.

        -v [n]          Ssh debug levels.  Can be from 0 to 3.

        -m [n]          Run concurrently on 'n' hosts at a time (asynchronous).

                        Use '0' (zero) for infinite. (default if -m)

        -q              No output unless necessary.

        -i <identity> [identity ..]

                        Load an identity file.  May be used

                        more than once.

        -o <ssh-args>   Args to pass to ssh with -o option.

        -a              Force loading ssh-agent.

        -A              Do NOT load ssh-agent.

        -b              Print each hosts' output in a block without mingling

                        with other hosts' output.

        -B              Allow hosts' output to mingle. (default)

        -u              Unique.  Eliminate duplicate hosts. (default)

        -U              Do NOT make host list unique.

        -P              Do NOT fall back to passwords on any host.  This will

                        skip hosts where keys fail.

    -l <login>      Use 'login' when no other is specified with hostname.

    -L <login>      Force use of 'login' name on all hosts.

        -s <shell>      Path to shell on remote host. (Default: bash)

        -t <secs>       Timeout setting for each session.

                        (requires openssh 3.8 or newer)

        -V              Print version info and exit.

PROXY ARGS:

        -p [user@]<host>

                        Host to use as proxy.  (Must have mussh installed)

        -po <ssh-args>        Args to pass to ssh on proxy with -o option.

HOST ARGS:

        -h [user@]<host> [[user@]<host> ..]

                        Add a host to list of hosts.  May be

                        used more than once.

        -H <file> [file ..]

                        Add contents of file(s) to list of hosts.

                        Files should have one host per line.  Use

                        "#" for comments.

COMMAND ARGS:

If neither is specified, commands will be read from standard input.

        -c <command>    Add a command or quoted list of commands and

                        args to list of commands to be executed on

                        each host.  May be used more than once.

        -C <file> [file ..]

                        Add file contents to list of commands to be

                        executed on each host.  May be used more

                        than once.

At least one host is required.  Arguments are in no particular order.

EXAMPLES:

mussh -H ./linuxhosts -C spfiles/testscript.sh

mussh -c "cat /etc/hosts" -h myhost.mydomain.com

Comments and Bug Reports: [email protected]

[1] 10:13:10 [SUCCESS] 10.154.252.46

 10:13:10 up 62 days, 19:29,  2 users,  load average: 0.00, 0.00, 0.01

[2] 10:13:10 [SUCCESS] 10.154.252.47

 10:13:10 up 62 days, 20:02,  0 users,  load average: 0.01, 0.04, 0.00

[3] 10:13:10 [SUCCESS] 10.154.252.49

 10:13:10 up 62 days, 19:33,  1 user,  load average: 0.00, 0.00, 0.00

[4] 10:13:10 [SUCCESS] 10.154.252.48

 10:13:10 up 62 days, 20:52,  1 user,  load average: 0.06, 0.04, 0.00

real    0m3.175s

user    0m0.101s

sys     0m0.038s

         signal.signal(signal.SIGCHLD, signal.SIG_DFL)

     def set_sigchld_handler(self):

         # TODO: find out whether set_wakeup_fd still works if the default

         # signal handler is used (I'm pretty sure it doesn't work if the

         # signal is ignored).

         signal.signal(signal.SIGCHLD, self.handle_sigchld)

         # This should keep reads and writes from getting EINTR.

         if hasattr(signal, 'siginterrupt'):

             signal.siginterrupt(signal.SIGCHLD, False)

     def handle_sigchld(self, number, frame):

         """Apparently we need a sigchld handler to make set_wakeup_fd work."""

         # Write to the signal pipe (only for Python <2.5, where the

         # set_wakeup_fd method doesn't exist).

         if self.iomap.wakeup_writefd:

             os.write(self.iomap.wakeup_writefd, '')

         for task in self.running:

             if task.proc:

                 task.proc.poll()

         # Apparently some UNIX systems automatically resent the SIGCHLD

         # handler to SIG_DFL.  Reset it just in case.

         self.set_sigchld_handler()

     def check_timeout(self):

         """Kills timed-out processes and returns the lowest time left."""

         if self.timeout <= 0:

             return None

         min_timeleft = None

         for task in self.running:

             timeleft = self.timeout - task.elapsed()

             if timeleft <= 0:

                 task.timedout()

                 continue

             if min_timeleft is None or timeleft < min_timeleft:

                 min_timeleft = timeleft

         if min_timeleft is None:

             return 0

         else:

             return max(0, min_timeleft)

def read_host_files(paths, default_user=None, default_port=None):

    """Reads the given host files.

    Returns a list of (host, port, user) triples.

    """

    hosts = []

    if paths:

        for path in paths:

            hosts.extend(read_host_file(path, default_user=default_user))

    return hosts

def read_host_file(path, default_user=None, default_port=None):

    """Reads the given host file.

    Lines are of the form: host[:port] [login].

    Returns a list of (host, port, user) triples.

    """

    lines = []

    f = open(path)

    for line in f:

        lines.append(line.strip())

    f.close()

    hosts = []

    for line in lines:

        # Skip blank lines or lines starting with #

        line = line.strip()

        if not line or line.startswith('#'):

            continue

        host, port, user = parse_host_entry(line, default_user, default_port)

        if host:

            hosts.append((host, port, user))

    return hosts

     def start(self, nodenum, iomap, writer, askpass_socket=None):

         """Starts the process and registers files with the IOMap."""

         self.writer = writer

         if writer:

             self.outfile, self.errfile = writer.open_files(self.pretty_host)

         # Set up the environment.

         environ = dict(os.environ)

         environ['PSSH_NODENUM'] = str(nodenum)

         environ['PSSH_HOST'] = self.host

         # Disable the GNOME pop-up password dialog and allow ssh to use

         # askpass.py to get a provided password.  If the module file is

         # askpass.pyc, we replace the extension.

         environ['SSH_ASKPASS'] = askpass_client.executable_path()

         if askpass_socket:

             environ['PSSH_ASKPASS_SOCKET'] = askpass_socket

         if self.verbose:

             environ['PSSH_ASKPASS_VERBOSE'] = '1'

         # Work around a mis-feature in ssh where it won't call SSH_ASKPASS

         # if DISPLAY is unset.

         if 'DISPLAY' not in environ:

             environ['DISPLAY'] = 'pssh-gibberish'

         # Create the subprocess.  Since we carefully call set_cloexec() on

         # all open files, we specify close_fds=False.

         self.proc = Popen(self.cmd, stdin=PIPE, stdout=PIPE, stderr=PIPE,

                 close_fds=False, preexec_fn=os.setsid, env=environ)

         self.timestamp = time.time()

         if self.inputbuffer:

             self.stdin = self.proc.stdin

             iomap.register_write(self.stdin.fileno(), self.handle_stdin)

         else:

             self.proc.stdin.close()

         self.stdout = self.proc.stdout

         iomap.register_read(self.stdout.fileno(), self.handle_stdout)

         self.stderr = self.proc.stderr

         iomap.register_read(self.stderr.fileno(), self.handle_stderr)