| Index: third_party/pexpect/examples/monitor.py
|
| diff --git a/third_party/pexpect/examples/monitor.py b/third_party/pexpect/examples/monitor.py
|
| new file mode 100644
|
| index 0000000000000000000000000000000000000000..9cb0eaf1db66d4e5a4a7f51e9c15f6ed2005d4b2
|
| --- /dev/null
|
| +++ b/third_party/pexpect/examples/monitor.py
|
| @@ -0,0 +1,229 @@
|
| +#!/usr/bin/env python
|
| +
|
| +''' This runs a sequence of commands on a remote host using SSH. It runs a
|
| +simple system checks such as uptime and free to monitor the state of the remote
|
| +host.
|
| +
|
| +./monitor.py [-s server_hostname] [-u username] [-p password]
|
| + -s : hostname of the remote server to login to.
|
| + -u : username to user for login.
|
| + -p : Password to user for login.
|
| +
|
| +Example:
|
| + This will print information about the given host:
|
| + ./monitor.py -s www.example.com -u mylogin -p mypassword
|
| +
|
| +It works like this:
|
| + Login via SSH (This is the hardest part).
|
| + Run and parse 'uptime'.
|
| + Run 'iostat'.
|
| + Run 'vmstat'.
|
| + Run 'netstat'
|
| + Run 'free'.
|
| + Exit the remote host.
|
| +
|
| +PEXPECT LICENSE
|
| +
|
| + This license is approved by the OSI and FSF as GPL-compatible.
|
| + http://opensource.org/licenses/isc-license.txt
|
| +
|
| + Copyright (c) 2012, Noah Spurrier <noah@noah.org>
|
| + PERMISSION TO USE, COPY, MODIFY, AND/OR DISTRIBUTE THIS SOFTWARE FOR ANY
|
| + PURPOSE WITH OR WITHOUT FEE IS HEREBY GRANTED, PROVIDED THAT THE ABOVE
|
| + COPYRIGHT NOTICE AND THIS PERMISSION NOTICE APPEAR IN ALL COPIES.
|
| + THE SOFTWARE IS PROVIDED "AS IS" AND THE AUTHOR DISCLAIMS ALL WARRANTIES
|
| + WITH REGARD TO THIS SOFTWARE INCLUDING ALL IMPLIED WARRANTIES OF
|
| + MERCHANTABILITY AND FITNESS. IN NO EVENT SHALL THE AUTHOR BE LIABLE FOR
|
| + ANY SPECIAL, DIRECT, INDIRECT, OR CONSEQUENTIAL DAMAGES OR ANY DAMAGES
|
| + WHATSOEVER RESULTING FROM LOSS OF USE, DATA OR PROFITS, WHETHER IN AN
|
| + ACTION OF CONTRACT, NEGLIGENCE OR OTHER TORTIOUS ACTION, ARISING OUT OF
|
| + OR IN CONNECTION WITH THE USE OR PERFORMANCE OF THIS SOFTWARE.
|
| +
|
| +'''
|
| +
|
| +from __future__ import print_function
|
| +
|
| +from __future__ import absolute_import
|
| +
|
| +import os, sys, re, getopt, getpass
|
| +import pexpect
|
| +
|
| +
|
| +try:
|
| + raw_input
|
| +except NameError:
|
| + raw_input = input
|
| +
|
| +
|
| +#
|
| +# Some constants.
|
| +#
|
| +COMMAND_PROMPT = '[#$] ' ### This is way too simple for industrial use -- we will change is ASAP.
|
| +TERMINAL_PROMPT = '(?i)terminal type\?'
|
| +TERMINAL_TYPE = 'vt100'
|
| +# This is the prompt we get if SSH does not have the remote host's public key stored in the cache.
|
| +SSH_NEWKEY = '(?i)are you sure you want to continue connecting'
|
| +
|
| +def exit_with_usage():
|
| +
|
| + print(globals()['__doc__'])
|
| + os._exit(1)
|
| +
|
| +def main():
|
| +
|
| + global COMMAND_PROMPT, TERMINAL_PROMPT, TERMINAL_TYPE, SSH_NEWKEY
|
| + ######################################################################
|
| + ## Parse the options, arguments, get ready, etc.
|
| + ######################################################################
|
| + try:
|
| + optlist, args = getopt.getopt(sys.argv[1:], 'h?s:u:p:', ['help','h','?'])
|
| + except Exception as e:
|
| + print(str(e))
|
| + exit_with_usage()
|
| + options = dict(optlist)
|
| + if len(args) > 1:
|
| + exit_with_usage()
|
| +
|
| + if [elem for elem in options if elem in ['-h','--h','-?','--?','--help']]:
|
| + print("Help:")
|
| + exit_with_usage()
|
| +
|
| + if '-s' in options:
|
| + host = options['-s']
|
| + else:
|
| + host = raw_input('hostname: ')
|
| + if '-u' in options:
|
| + user = options['-u']
|
| + else:
|
| + user = raw_input('username: ')
|
| + if '-p' in options:
|
| + password = options['-p']
|
| + else:
|
| + password = getpass.getpass('password: ')
|
| +
|
| + #
|
| + # Login via SSH
|
| + #
|
| + child = pexpect.spawn('ssh -l %s %s'%(user, host))
|
| + i = child.expect([pexpect.TIMEOUT, SSH_NEWKEY, COMMAND_PROMPT, '(?i)password'])
|
| + if i == 0: # Timeout
|
| + print('ERROR! could not login with SSH. Here is what SSH said:')
|
| + print(child.before, child.after)
|
| + print(str(child))
|
| + sys.exit (1)
|
| + if i == 1: # In this case SSH does not have the public key cached.
|
| + child.sendline ('yes')
|
| + child.expect ('(?i)password')
|
| + if i == 2:
|
| + # This may happen if a public key was setup to automatically login.
|
| + # But beware, the COMMAND_PROMPT at this point is very trivial and
|
| + # could be fooled by some output in the MOTD or login message.
|
| + pass
|
| + if i == 3:
|
| + child.sendline(password)
|
| + # Now we are either at the command prompt or
|
| + # the login process is asking for our terminal type.
|
| + i = child.expect ([COMMAND_PROMPT, TERMINAL_PROMPT])
|
| + if i == 1:
|
| + child.sendline (TERMINAL_TYPE)
|
| + child.expect (COMMAND_PROMPT)
|
| + #
|
| + # Set command prompt to something more unique.
|
| + #
|
| + COMMAND_PROMPT = "\[PEXPECT\]\$ "
|
| + child.sendline ("PS1='[PEXPECT]\$ '") # In case of sh-style
|
| + i = child.expect ([pexpect.TIMEOUT, COMMAND_PROMPT], timeout=10)
|
| + if i == 0:
|
| + print("# Couldn't set sh-style prompt -- trying csh-style.")
|
| + child.sendline ("set prompt='[PEXPECT]\$ '")
|
| + i = child.expect ([pexpect.TIMEOUT, COMMAND_PROMPT], timeout=10)
|
| + if i == 0:
|
| + print("Failed to set command prompt using sh or csh style.")
|
| + print("Response was:")
|
| + print(child.before)
|
| + sys.exit (1)
|
| +
|
| + # Now we should be at the command prompt and ready to run some commands.
|
| + print('---------------------------------------')
|
| + print('Report of commands run on remote host.')
|
| + print('---------------------------------------')
|
| +
|
| + # Run uname.
|
| + child.sendline ('uname -a')
|
| + child.expect (COMMAND_PROMPT)
|
| + print(child.before)
|
| + if 'linux' in child.before.lower():
|
| + LINUX_MODE = 1
|
| + else:
|
| + LINUX_MODE = 0
|
| +
|
| + # Run and parse 'uptime'.
|
| + child.sendline ('uptime')
|
| + child.expect('up\s+(.*?),\s+([0-9]+) users?,\s+load averages?: ([0-9]+\.[0-9][0-9]),?\s+([0-9]+\.[0-9][0-9]),?\s+([0-9]+\.[0-9][0-9])')
|
| + duration, users, av1, av5, av15 = child.match.groups()
|
| + days = '0'
|
| + hours = '0'
|
| + mins = '0'
|
| + if 'day' in duration:
|
| + child.match = re.search('([0-9]+)\s+day',duration)
|
| + days = str(int(child.match.group(1)))
|
| + if ':' in duration:
|
| + child.match = re.search('([0-9]+):([0-9]+)',duration)
|
| + hours = str(int(child.match.group(1)))
|
| + mins = str(int(child.match.group(2)))
|
| + if 'min' in duration:
|
| + child.match = re.search('([0-9]+)\s+min',duration)
|
| + mins = str(int(child.match.group(1)))
|
| + print()
|
| + print('Uptime: %s days, %s users, %s (1 min), %s (5 min), %s (15 min)' % (
|
| + duration, users, av1, av5, av15))
|
| + child.expect (COMMAND_PROMPT)
|
| +
|
| + # Run iostat.
|
| + child.sendline ('iostat')
|
| + child.expect (COMMAND_PROMPT)
|
| + print(child.before)
|
| +
|
| + # Run vmstat.
|
| + child.sendline ('vmstat')
|
| + child.expect (COMMAND_PROMPT)
|
| + print(child.before)
|
| +
|
| + # Run free.
|
| + if LINUX_MODE:
|
| + child.sendline ('free') # Linux systems only.
|
| + child.expect (COMMAND_PROMPT)
|
| + print(child.before)
|
| +
|
| + # Run df.
|
| + child.sendline ('df')
|
| + child.expect (COMMAND_PROMPT)
|
| + print(child.before)
|
| +
|
| + # Run lsof.
|
| + child.sendline ('lsof')
|
| + child.expect (COMMAND_PROMPT)
|
| + print(child.before)
|
| +
|
| +# # Run netstat
|
| +# child.sendline ('netstat')
|
| +# child.expect (COMMAND_PROMPT)
|
| +# print child.before
|
| +
|
| +# # Run MySQL show status.
|
| +# child.sendline ('mysql -p -e "SHOW STATUS;"')
|
| +# child.expect (PASSWORD_PROMPT_MYSQL)
|
| +# child.sendline (password_mysql)
|
| +# child.expect (COMMAND_PROMPT)
|
| +# print
|
| +# print child.before
|
| +
|
| + # Now exit the remote host.
|
| + child.sendline ('exit')
|
| + index = child.expect([pexpect.EOF, "(?i)there are stopped jobs"])
|
| + if index==1:
|
| + child.sendline("exit")
|
| + child.expect(EOF)
|
| +
|
| +if __name__ == "__main__":
|
| + main()
|
|
|