Index: third_party/gsutil/boto/bin/instance_events |
diff --git a/third_party/gsutil/boto/bin/instance_events b/third_party/gsutil/boto/bin/instance_events |
new file mode 100755 |
index 0000000000000000000000000000000000000000..b36a4809766e2443dc7517cc06925fb7daddc5e7 |
--- /dev/null |
+++ b/third_party/gsutil/boto/bin/instance_events |
@@ -0,0 +1,145 @@ |
+#!/usr/bin/env python |
+# Copyright (c) 2011 Jim Browne http://www.42lines.net |
+# Borrows heavily from boto/bin/list_instances which has no attribution |
+# |
+# Permission is hereby granted, free of charge, to any person obtaining a |
+# copy of this software and associated documentation files (the |
+# "Software"), to deal in the Software without restriction, including |
+# without limitation the rights to use, copy, modify, merge, publish, dis- |
+# tribute, sublicense, and/or sell copies of the Software, and to permit |
+# persons to whom the Software is furnished to do so, subject to the fol- |
+# lowing conditions: |
+# |
+# The above copyright notice and this permission notice shall be included |
+# in all copies or substantial portions of the Software. |
+# |
+# THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS |
+# OR IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABIL- |
+# ITY, FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT |
+# SHALL THE AUTHOR BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER LIABILITY, |
+# WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, |
+# OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS |
+ |
+VERSION="0.1" |
+usage = """%prog [options] |
+Options: |
+ -h, --help show help message (including options list) and exit |
+""" |
+ |
+from operator import itemgetter |
+ |
+HEADERS = { |
+ 'ID': {'get': itemgetter('id'), 'length':14}, |
+ 'Zone': {'get': itemgetter('zone'), 'length':14}, |
+ 'Hostname': {'get': itemgetter('dns'), 'length':20}, |
+ 'Code': {'get': itemgetter('code'), 'length':18}, |
+ 'Description': {'get': itemgetter('description'), 'length':30}, |
+ 'NotBefore': {'get': itemgetter('not_before'), 'length':25}, |
+ 'NotAfter': {'get': itemgetter('not_after'), 'length':25}, |
+ 'T:': {'length': 30}, |
+} |
+ |
+def get_column(name, event=None): |
+ if name.startswith('T:'): |
+ return event[name] |
+ return HEADERS[name]['get'](event) |
+ |
+def list(region, headers, order, completed): |
+ """List status events for all instances in a given region""" |
+ |
+ import re |
+ |
+ ec2 = boto.connect_ec2(region=region) |
+ |
+ reservations = ec2.get_all_instances() |
+ |
+ instanceinfo = {} |
+ events = {} |
+ |
+ displaytags = [ x for x in headers if x.startswith('T:') ] |
+ |
+ # Collect the tag for every possible instance |
+ for res in reservations: |
+ for instance in res.instances: |
+ iid = instance.id |
+ instanceinfo[iid] = {} |
+ for tagname in displaytags: |
+ _, tag = tagname.split(':', 1) |
+ instanceinfo[iid][tagname] = instance.tags.get(tag,'') |
+ instanceinfo[iid]['dns'] = instance.public_dns_name |
+ |
+ stats = ec2.get_all_instance_status() |
+ |
+ for stat in stats: |
+ if stat.events: |
+ for event in stat.events: |
+ events[stat.id] = {} |
+ events[stat.id]['id'] = stat.id |
+ events[stat.id]['dns'] = instanceinfo[stat.id]['dns'] |
+ events[stat.id]['zone'] = stat.zone |
+ for tag in displaytags: |
+ events[stat.id][tag] = instanceinfo[stat.id][tag] |
+ events[stat.id]['code'] = event.code |
+ events[stat.id]['description'] = event.description |
+ events[stat.id]['not_before'] = event.not_before |
+ events[stat.id]['not_after'] = event.not_after |
+ if completed and re.match('^\[Completed\]',event.description): |
+ events[stat.id]['not_before'] = 'Completed' |
+ events[stat.id]['not_after'] = 'Completed' |
+ |
+ # Create format string |
+ format_string = "" |
+ for h in headers: |
+ if h.startswith('T:'): |
+ format_string += "%%-%ds" % HEADERS['T:']['length'] |
+ else: |
+ format_string += "%%-%ds" % HEADERS[h]['length'] |
+ |
+ |
+ print format_string % headers |
+ print "-" * len(format_string % headers) |
+ |
+ for instance in sorted(events, |
+ key=lambda ev: get_column(order, events[ev])): |
+ e = events[instance] |
+ print format_string % tuple(get_column(h, e) for h in headers) |
+ |
+if __name__ == "__main__": |
+ import boto |
+ from optparse import OptionParser |
+ from boto.ec2 import regions |
+ |
+ parser = OptionParser(version=VERSION, usage=usage) |
+ parser.add_option("-a", "--all", help="check all regions", dest="all", default=False,action="store_true") |
+ parser.add_option("-r", "--region", help="region to check (default us-east-1)", dest="region", default="us-east-1") |
+ parser.add_option("-H", "--headers", help="Set headers (use 'T:tagname' for including tags)", default=None, action="store", dest="headers", metavar="ID,Zone,Hostname,Code,Description,NotBefore,NotAfter,T:Name") |
+ parser.add_option("-S", "--sort", help="Header for sort order", default=None, action="store", dest="order",metavar="HeaderName") |
+ parser.add_option("-c", "--completed", help="List time fields as \"Completed\" for completed events (Default: false)", default=False, action="store_true", dest="completed") |
+ |
+ (options, args) = parser.parse_args() |
+ |
+ if options.headers: |
+ headers = tuple(options.headers.split(',')) |
+ else: |
+ headers = ('ID', 'Zone', 'Hostname', 'Code', 'NotBefore', 'NotAfter') |
+ |
+ if options.order: |
+ order = options.order |
+ else: |
+ order = 'ID' |
+ |
+ if options.all: |
+ for r in regions(): |
+ print "Region %s" % r.name |
+ list(r, headers, order, options.completed) |
+ else: |
+ # Connect the region |
+ for r in regions(): |
+ if r.name == options.region: |
+ region = r |
+ break |
+ else: |
+ print "Region %s not found." % options.region |
+ sys.exit(1) |
+ |
+ list(r, headers, order, options.completed) |