Index: third_party/boto/boto/services/bs.py |
diff --git a/third_party/boto/boto/services/bs.py b/third_party/boto/boto/services/bs.py |
new file mode 100755 |
index 0000000000000000000000000000000000000000..3d700315db444f23370da01fa79e226e93b62da4 |
--- /dev/null |
+++ b/third_party/boto/boto/services/bs.py |
@@ -0,0 +1,179 @@ |
+#!/usr/bin/env python |
+# Copyright (c) 2006-2008 Mitch Garnaat http://garnaat.org/ |
+# |
+# 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 |
+# IN THE SOFTWARE. |
+from optparse import OptionParser |
+from boto.services.servicedef import ServiceDef |
+from boto.services.submit import Submitter |
+from boto.services.result import ResultProcessor |
+import boto |
+import sys, os, StringIO |
+ |
+class BS(object): |
+ |
+ Usage = "usage: %prog [options] config_file command" |
+ |
+ Commands = {'reset' : 'Clear input queue and output bucket', |
+ 'submit' : 'Submit local files to the service', |
+ 'start' : 'Start the service', |
+ 'status' : 'Report on the status of the service buckets and queues', |
+ 'retrieve' : 'Retrieve output generated by a batch', |
+ 'batches' : 'List all batches stored in current output_domain'} |
+ |
+ def __init__(self): |
+ self.service_name = None |
+ self.parser = OptionParser(usage=self.Usage) |
+ self.parser.add_option("--help-commands", action="store_true", dest="help_commands", |
+ help="provides help on the available commands") |
+ self.parser.add_option("-a", "--access-key", action="store", type="string", |
+ help="your AWS Access Key") |
+ self.parser.add_option("-s", "--secret-key", action="store", type="string", |
+ help="your AWS Secret Access Key") |
+ self.parser.add_option("-p", "--path", action="store", type="string", dest="path", |
+ help="the path to local directory for submit and retrieve") |
+ self.parser.add_option("-k", "--keypair", action="store", type="string", dest="keypair", |
+ help="the SSH keypair used with launched instance(s)") |
+ self.parser.add_option("-l", "--leave", action="store_true", dest="leave", |
+ help="leave the files (don't retrieve) files during retrieve command") |
+ self.parser.set_defaults(leave=False) |
+ self.parser.add_option("-n", "--num-instances", action="store", type="string", dest="num_instances", |
+ help="the number of launched instance(s)") |
+ self.parser.set_defaults(num_instances=1) |
+ self.parser.add_option("-i", "--ignore-dirs", action="append", type="string", dest="ignore", |
+ help="directories that should be ignored by submit command") |
+ self.parser.add_option("-b", "--batch-id", action="store", type="string", dest="batch", |
+ help="batch identifier required by the retrieve command") |
+ |
+ def print_command_help(self): |
+ print '\nCommands:' |
+ for key in self.Commands.keys(): |
+ print ' %s\t\t%s' % (key, self.Commands[key]) |
+ |
+ def do_reset(self): |
+ iq = self.sd.get_obj('input_queue') |
+ if iq: |
+ print 'clearing out input queue' |
+ i = 0 |
+ m = iq.read() |
+ while m: |
+ i += 1 |
+ iq.delete_message(m) |
+ m = iq.read() |
+ print 'deleted %d messages' % i |
+ ob = self.sd.get_obj('output_bucket') |
+ ib = self.sd.get_obj('input_bucket') |
+ if ob: |
+ if ib and ob.name == ib.name: |
+ return |
+ print 'delete generated files in output bucket' |
+ i = 0 |
+ for k in ob: |
+ i += 1 |
+ k.delete() |
+ print 'deleted %d keys' % i |
+ |
+ def do_submit(self): |
+ if not self.options.path: |
+ self.parser.error('No path provided') |
+ if not os.path.exists(self.options.path): |
+ self.parser.error('Invalid path (%s)' % self.options.path) |
+ s = Submitter(self.sd) |
+ t = s.submit_path(self.options.path, None, self.options.ignore, None, |
+ None, True, self.options.path) |
+ print 'A total of %d files were submitted' % t[1] |
+ print 'Batch Identifier: %s' % t[0] |
+ |
+ def do_start(self): |
+ ami_id = self.sd.get('ami_id') |
+ instance_type = self.sd.get('instance_type', 'm1.small') |
+ security_group = self.sd.get('security_group', 'default') |
+ if not ami_id: |
+ self.parser.error('ami_id option is required when starting the service') |
+ ec2 = boto.connect_ec2() |
+ if not self.sd.has_section('Credentials'): |
+ self.sd.add_section('Credentials') |
+ self.sd.set('Credentials', 'aws_access_key_id', ec2.aws_access_key_id) |
+ self.sd.set('Credentials', 'aws_secret_access_key', ec2.aws_secret_access_key) |
+ s = StringIO.StringIO() |
+ self.sd.write(s) |
+ rs = ec2.get_all_images([ami_id]) |
+ img = rs[0] |
+ r = img.run(user_data=s.getvalue(), key_name=self.options.keypair, |
+ max_count=self.options.num_instances, |
+ instance_type=instance_type, |
+ security_groups=[security_group]) |
+ print 'Starting AMI: %s' % ami_id |
+ print 'Reservation %s contains the following instances:' % r.id |
+ for i in r.instances: |
+ print '\t%s' % i.id |
+ |
+ def do_status(self): |
+ iq = self.sd.get_obj('input_queue') |
+ if iq: |
+ print 'The input_queue (%s) contains approximately %s messages' % (iq.id, iq.count()) |
+ ob = self.sd.get_obj('output_bucket') |
+ ib = self.sd.get_obj('input_bucket') |
+ if ob: |
+ if ib and ob.name == ib.name: |
+ return |
+ total = 0 |
+ for k in ob: |
+ total += 1 |
+ print 'The output_bucket (%s) contains %d keys' % (ob.name, total) |
+ |
+ def do_retrieve(self): |
+ if not self.options.path: |
+ self.parser.error('No path provided') |
+ if not os.path.exists(self.options.path): |
+ self.parser.error('Invalid path (%s)' % self.options.path) |
+ if not self.options.batch: |
+ self.parser.error('batch identifier is required for retrieve command') |
+ s = ResultProcessor(self.options.batch, self.sd) |
+ s.get_results(self.options.path, get_file=(not self.options.leave)) |
+ |
+ def do_batches(self): |
+ d = self.sd.get_obj('output_domain') |
+ if d: |
+ print 'Available Batches:' |
+ rs = d.query("['type'='Batch']") |
+ for item in rs: |
+ print ' %s' % item.name |
+ else: |
+ self.parser.error('No output_domain specified for service') |
+ |
+ def main(self): |
+ self.options, self.args = self.parser.parse_args() |
+ if self.options.help_commands: |
+ self.print_command_help() |
+ sys.exit(0) |
+ if len(self.args) != 2: |
+ self.parser.error("config_file and command are required") |
+ self.config_file = self.args[0] |
+ self.sd = ServiceDef(self.config_file) |
+ self.command = self.args[1] |
+ if hasattr(self, 'do_%s' % self.command): |
+ method = getattr(self, 'do_%s' % self.command) |
+ method() |
+ else: |
+ self.parser.error('command (%s) not recognized' % self.command) |
+ |
+if __name__ == "__main__": |
+ bs = BS() |
+ bs.main() |