#NEWLINE# def process( self , event ) : #NEWLINE# #INDENT# bucket = event . format ( self . bucket ) #NEWLINE# path = event . format ( self . path ) #NEWLINE# filename = event [ 'filename' ] #NEWLINE# self . logger . info ( ( 'Uploading %s to s3://%s/%s' % ( filename , bucket , path ) ) ) #NEWLINE# s3 = boto . connect_s3 ( self . access_key , self . secret_key ) #NEWLINE# bucket = s3 . get_bucket ( bucket ) #NEWLINE# k = bucket . new_key ( path ) #NEWLINE# k . set_contents_from_filename ( filename )