/usr/lib/python2.6/site-packages/boto/services
Edit: /usr/lib/python2.6/site-packages/boto/services/bs.pyc (7667B)
Ñò
Å-õSc @ s² d d k l Z d d k l Z d d k l Z d d k l Z d d k Z d d k Z d d k
Z
d d k l Z d e
f d „ ƒ YZ e d j o e ƒ Z e i ƒ n d S(
iÿÿÿÿ( t OptionParser( t
ServiceDef( t Submitter( t ResultProcessorN( t StringIOt BSc B s e Z d Z h d d 6d d 6d d 6d d 6d d
6d d 6Z d
„ Z d „ Z d „ Z d „ Z d „ Z d „ Z d „ Z
d „ Z d „ Z RS( s* usage: %prog [options] config_file commands# Clear input queue and output buckett resets! Submit local files to the servicet submits Start the servicet starts6 Report on the status of the service buckets and queuest statuss$ Retrieve output generated by a batcht retrieves0 List all batches stored in current output_domaint batchesc C s° d | _ t d | i ƒ | _ | i i d d d d d d d ƒ| i i d d
d d d d
d d ƒ| i i d d d d d d
d d ƒ| i i d d d d d d
d d d d ƒ| i i d d d d d d
d d d d ƒ| i i d d d d d d d d ƒ| i i d t ƒ | i i d d d d d d
d d d d! ƒ| i i d d" ƒ | i i d# d$ d d% d d
d d& d d' ƒ| i i d( d) d d d d
d d* d d+ ƒd S(, Nt usages --help-commandst actiont
store_truet destt
help_commandst helps' provides help on the available commandss -as --access-keyt storet typet strings your AWS Access Keys -ss --secret-keys your AWS Secret Access Keys -ps --patht paths3 the path to local directory for submit and retrieves -ks --keypairt keypairs. the SSH keypair used with launched instance(s)s -ls --leavet leaves> leave the files (don't retrieve) files during retrieve commands -ns --num-instancest
num_instancess" the number of launched instance(s)i s -is
--ignore-dirst appendt ignores4 directories that should be ignored by submit commands -bs
--batch-idt batchs1 batch identifier required by the retrieve command( t Nonet service_nameR t Usaget parsert
add_optiont set_defaultst False( t self( ( s4 /usr/lib/python2.6/site-packages/boto/services/bs.pyt __init__) s, $$ $$$c C s9 d GHx- | i i ƒ D] } d | | i | f GHq Wd S( Ns
Commands:s %s %s( t Commandst keys( R# t key( ( s4 /usr/lib/python2.6/site-packages/boto/services/bs.pyt print_command_helpA s c C sú | i i d ƒ } | oV d GHd } | i ƒ } x/ | o' | d 7} | i | ƒ | i ƒ } q3 Wd | GHn | i i d ƒ } | i i d ƒ } | o\ | o | i | i j o d Sd GHd } x" | D] } | d 7} | i ƒ qË Wd | GHn d S(
Nt input_queues clearing out input queuei i s deleted %d messagest
output_buckett input_buckets' delete generated files in output buckets deleted %d keys( t sdt get_objt readt delete_messaget namet delete( R# t iqt it mt obt ibt k( ( s4 /usr/lib/python2.6/site-packages/boto/services/bs.pyt do_resetF s.
c C s¸ | i i p | i i d ƒ n t i i | i i ƒ p | i i d | i i ƒ n t | i ƒ } | i | i i d | i i
d d t | i i ƒ } d | d GHd | d GHd S( Ns No path provideds Invalid path (%s)s" A total of %d files were submittedi s Batch Identifier: %si ( t optionsR R t errort ost existsR R, t submit_pathR R t True( R# t st t( ( s4 /usr/lib/python2.6/site-packages/boto/services/bs.pyt do_submit] s
c
C si | i i d ƒ } | i i d d ƒ } | i i d d ƒ } | p | i i d ƒ n t i ƒ } | i i d ƒ pF | i i d ƒ | i i d d | i ƒ | i i d d | i
ƒ n t ƒ } | i i | ƒ | i
| g ƒ } | d
} | i d | i ƒ d | i i d
| i i d | d | g ƒ } d | GHd | i GHx | i D] } d | i GHqOWd S( Nt ami_idt
instance_types m1.smallt security_groupt defaults3 ami_id option is required when starting the servicet Credentialst aws_access_key_idt aws_secret_access_keyi t user_datat key_namet max_countt security_groupss Starting AMI: %ss0 Reservation %s contains the following instances:s %s( R, t getR R: t botot connect_ec2t has_sectiont add_sectiont setRG RH R t writet get_all_imagest runt getvalueR9 R R t idt instances(
R# RB RC RD t ec2R? t rst imgt rR3 ( ( s4 /usr/lib/python2.6/site-packages/boto/services/bs.pyt do_starth s.
!
c C sº | i i d ƒ } | o d | i | i ƒ f GHn | i i d ƒ } | i i d ƒ } | oV | o | i | i j o d Sd } x | D] } | d 7} qŒ Wd | i | f GHn d S( NR) s7 The input_queue (%s) contains approximately %s messagesR* R+ i i s' The output_bucket (%s) contains %d keys( R, R- RW t countR0 ( R# R2 R5 R6 t totalR7 ( ( s4 /usr/lib/python2.6/site-packages/boto/services/bs.pyt do_status€ s c C sµ | i i p | i i d ƒ n t i i | i i ƒ p | i i d | i i ƒ n | i i p | i i d ƒ n t | i i | i ƒ } | i | i i d | i i
ƒd S( Ns No path provideds Invalid path (%s)s1 batch identifier is required for retrieve commandt get_file( R9 R R R: R; R< R R R, t get_resultsR ( R# R? ( ( s4 /usr/lib/python2.6/site-packages/boto/services/bs.pyt do_retrieveŽ s
c C sb | i i d ƒ } | o5 d GH| i d ƒ } x. | D] } d | i GHq4 Wn | i i d ƒ d S( Nt
output_domains Available Batches:s ['type'='Batch']s %ss& No output_domain specified for service( R, R- t queryR0 R R: ( R# t dRZ t item( ( s4 /usr/lib/python2.6/site-packages/boto/services/bs.pyt
do_batches˜ s c C sò | i i ƒ \ | _ | _ | i i o | i ƒ t i d ƒ n t | i ƒ d j o | i i d ƒ n | i d | _
t | i
ƒ | _ | i d | _
t | d | i
ƒ o! t | d | i
ƒ } | ƒ n | i i d | i
ƒ d S( Ni i s$ config_file and command are requiredi s do_%ss command (%s) not recognized( R t
parse_argsR9 t argsR R( t syst exitt lenR: t config_fileR R, t commandt hasattrt getattr( R# t method( ( s4 /usr/lib/python2.6/site-packages/boto/services/bs.pyt main¢ s
(
t __name__t
__module__R R% R$ R( R8 RA R] R` Rc Rh Rs ( ( ( s4 /usr/lib/python2.6/site-packages/boto/services/bs.pyR s
t __main__( t optparseR t boto.services.servicedefR t boto.services.submitR t boto.services.resultR RN Rk R; t boto.compatR t objectR Rt t bsRs ( ( ( s4 /usr/lib/python2.6/site-packages/boto/services/bs.pyt
s ”