/usr/lib/python2.6/site-packages/boto/services
Edit: /usr/lib/python2.6/site-packages/boto/services/result.pyo (5034B)
Ñò
Å-õSc @ sX d d k Z d d k l Z l Z d d k l Z d d k Z d e f d „ ƒ YZ d S( iÿÿÿÿN( t datetimet timedelta( t parse_tst ResultProcessorc B sk e Z d Z d d „ Z d „ Z d „ Z e d „ Z e e d „ Z e d „ Z
d „ Z e e d „ Z RS(
s log.csvc C s‹ | | _ | | _ d | _ d | _ d | _ t i | _ t i | _
t i | _ t i | _
| i i d ƒ | _ | i i d ƒ | _ d S( Ni t output_queuet
output_domain( t sdt batcht Nonet log_fpt num_filest
total_timeR t maxt min_timet mint max_timeR t
earliest_timet latest_timet get_objt queuet domain( t selft
batch_nameR t mimetype_files( ( s8 /usr/lib/python2.6/site-packages/boto/services/result.pyt __init__ s c C s´ t | d ƒ } t | d ƒ } | | } | | i j o
| | _ n | | i j o
| | _ n | i | i 7_ | | i j o
| | _ n | | i j o
| | _ n d S( Ns Service-Reads
Service-Write( R R R
R t secondsR R ( R t msgt
start_timet end_timet elapsed_time( ( s8 /usr/lib/python2.6/site-packages/boto/services/result.pyt calculate_stats, s
c C sà t | i ƒ ƒ } | i pK t t i i | | i ƒ d ƒ | _ d i | ƒ } | i i | d ƒ n g } xI | D]A } | | } | i d ƒ d j o d | } n | i
| ƒ qt Wd i | ƒ } | i i | d ƒ d S( Nt at ,s
i s "%s"( t sortedt keysR t opent ost patht joint LogFileNamet writet findt append( R R R% R" t linet valuest keyt value( ( s8 /usr/lib/python2.6/site-packages/boto/services/result.pyt log_message: s
$
c
C sï | i | | ƒ | i | ƒ | d i d ƒ } d | j o t i d | d ƒ } n t i d | d ƒ } x{ | D]s } | oW | i d ƒ d } | i | ƒ } t i i | | ƒ } d | | f GH| i | ƒ n | i d 7_ qt Wd S(
Nt OutputKeyR t OutputBuckett s3t Buckett ;i s retrieving file: %s to %si (
R/ R t splitt botot lookupR$ R% R& t get_contents_to_filenameR
(
R t recordR% t get_filet outputst buckett outputt key_nameR- t file_name( ( s8 /usr/lib/python2.6/site-packages/boto/services/result.pyt process_recordI s
c C s„ | i i ƒ } xn | of d | j oF | d | i j o2 | i | | | ƒ | o | i i | ƒ ql n | i i ƒ } q Wd S( Nt Batch( R t readR R@ t delete_message( R R% R: t
delete_msgt m( ( s8 /usr/lib/python2.6/site-packages/boto/services/result.pyt get_results_from_queueZ s !c C sA | i i d | i ƒ } x! | D] } | i | | | ƒ q Wd S( Ns ['Batch'='%s']( R t queryR R@ ( R R% R: t rst item( ( s8 /usr/lib/python2.6/site-packages/boto/services/result.pyt get_results_from_domainc s c C ss | i i d ƒ } | oV d GHxN | D]B } t i i | | ƒ } d | | f GH| i | ƒ | i d q% Wn d S( Nt
output_bucketsC No output queue or domain, just retrieving files from output_buckets retrieving file: %s to %si ( R R R$ R% R& R8 R
( R R% R< R- R? ( ( s8 /usr/lib/python2.6/site-packages/boto/services/result.pyt get_results_from_bucketh s
c C s5 t i i | ƒ p t i | ƒ n | i o | i | | ƒ n, | i o | i | | ƒ n | i | ƒ | i o | i i
ƒ n d | i GH| i d j o t | i
ƒ | i | _ d | i i GHd | i i GHd | i GH| i | i | _ d | i i GHd | i i d | i } d | GHn d S(
Ns" %d results successfully retrieved.i s Minimum Processing Time: %ds Maximum Processing Time: %ds Average Processing Time: %fs Elapsed Time: %dg ð?g N@s$ Throughput: %f transactions / minute( R$ R% t isdirt mkdirR RF R RJ RL R t closeR
t floatR t avg_timeR
R R R R R ( R R% R: RD t tput( ( s8 /usr/lib/python2.6/site-packages/boto/services/result.pyt get_resultsr s&
N(
t __name__t
__module__R' R R R R/ t TrueR@ RF RJ RL RS ( ( ( s8 /usr/lib/python2.6/site-packages/boto/services/result.pyR s
( R$ R R t
boto.utilsR R6 t objectR ( ( ( s8 /usr/lib/python2.6/site-packages/boto/services/result.pyt
s