Viewing File: /usr/lib/python2.7/site-packages/euca2ools/commands/s3/putobject.pyo
ó
¡ôXc @ sà d d l Z d d l Z d d l Z d d l Z d d l Z d d l m Z d d l Z d d l m Z d d l
Z
d d l m Z d d l
Z d e e f d „ ƒ YZ d e f d „ ƒ YZ d S( iÿÿÿÿN( t Arg( t FileTransferProgressBarMixin( t S3Requestt PutObjectc B s e Z d Z e d d d d d( d d ƒe d d d d d( d d ƒe d
d e d d( d d ƒe d
d d( d d) ƒe d d d( d d ƒe d d d d d d d d d d d( d d ƒe d! d e j ƒg Z d" Z d# „ Z
d$ „ Z d% „ Z d& „ Z
d d' „ Z RS(* sÎ Upload an object to the server
Note that uploading a large file to a region other than the one the bucket is may result in "Broken pipe" errors or other connection problems that this program cannot detect.t sourcet metavart FILEt route_tot helps file to upload (required)t dests
BUCKET/KEYs6 bucket and key name to upload the object to (required)s --sizet typesP the number of
bytes to upload (required when reading from stdin)s --aclt choicest privates public-reads public-read-writes authenticated-reads bucket-owner-reads bucket-owner-full-controls
aws-exec-reads --mime-types% MIME type for the file being uploadeds --retryt retriest actiont store_constt consti t defaulti s' retry interrupted uploads up to 5 timess --progressbar-labelt PUTc K s, t j | | d | _ t j ƒ | _ d S( N( R t __init__t Nonet last_upload_errort threadingt Lockt _lock( t selft kwargs( ( sC /usr/lib/python2.7/site-packages/euca2ools/commands/s3/putobject.pyR @ s c C s] t j | ƒ | j d d k ri | j j d ƒ d k rM t j j d ƒ ‚ n t t j
| j d ƒ } nŽ t | j d t j
ƒ r t j | j d d | j j d ƒ ƒ} nJ | j j d ƒ d k rÚ t j j d ƒ ‚ n t | j d | j d ƒ } | | j d <| j d j d ƒ \ } } } | s>t j j d ƒ ‚ n | sYt j j d ƒ ‚ n d S(
NR t -t sizes0 argument --size is required when uploading stdins8 argument --size is required when uploading a file objectR t /s) destination bucket name must be non-emptys& destination key name must be non-empty( R t configuret argst getR t requestbuildert
exceptionst
ArgumentErrort _FileObjectExtentt syst stdint
isinstancet sixt string_typest
from_filenamet partition( R R t buckett _t key( ( sC /usr/lib/python2.7/site-packages/euca2ools/commands/s3/putobject.pyR F s*
%
c C sf | j d | _ | j j d ƒ r9 | j d | j d <n | j j d ƒ rb | j d | j d <n d S( NR t acls x-amz-aclt mime_types Content-Type( R t pathR t headers( R ( ( sC /usr/lib/python2.7/site-packages/euca2ools/commands/s3/putobject.pyt
preprocess^ s
c
C s= | j ƒ | j d } t | j ƒ | j d <t j d | j d | f d i | j j d ƒ p` d d 6ƒ } t | _
| j ƒ | j j d ƒ p• | j } | j
d
| d | j ƒ } | j ƒ x0 | j ƒ rï | j | j ƒ ƒ t j d ƒ qÀ W| j ƒ | j ƒ | j ƒ | j | j d k r3| j ‚ n Wd QXd S(
NR s Content-Lengtht targetR R R
i t retries_leftt progressbar_labelt labelt maxvalgš™™™™™©?( R3 R t bytesR R2 R t Threadt try_sendR t Truet daemont startt filenamet get_progressbart is_alivet updatet tellt timet sleept finisht joint closeR R R ( R R t
upload_threadt
pbar_labelt pbar( ( sC /usr/lib/python2.7/site-packages/euca2ools/commands/s3/putobject.pyt mainf s(
"
c C s‹ | | _ | d k r8 | j r8 | j j d ƒ d } n yl | j ƒ } | j } | j d j ƒ j d ƒ } | | k r£ | j j d | | ƒ t
j j d ƒ ‚ n Wnà t
j j k
rD} t
| t
j j ƒ r| d k r| j j d | ƒ | j ƒ | j | | d ƒ Sn | j $ | j j d d
t ƒ| | _ Wd QXd St k
r†} | j $ | j j d d
t ƒ| | _ Wd QXd SXd S( Ni s@ source cannot rewind, so requested retries will not be attemptedt ETagt "s* corrupt upload (our MD5: %s, their MD5: %ss# upload was corrupted during transits/ retrying upload (%i retry attempt(s) remaining)i s
upload failedt exc_info( t bodyt
can_rewindt logt noticet sendt read_hexdigestR2 t lowert stript errorR! R" t ClientErrorR' t TimeoutErrort infot rewindR; R R< R t Exception( R R R5 t responset our_md5t their_md5t err( ( sC /usr/lib/python2.7/site-packages/euca2ools/commands/s3/putobject.pyR; … s:
N( R s public-reads public-read-writes authenticated-reads bucket-owner-reads bucket-owner-full-controls
aws-exec-read( t __name__t
__module__t DESCRIPTIONR R t intt argparset SUPPRESSt ARGSt METHODR R R3 RL R; ( ( ( sC /usr/lib/python2.7/site-packages/euca2ools/commands/s3/putobject.pyR ) s. R$ c B s} e Z d d „ Z d „ Z e d d „ ƒ Z e d „ ƒ Z d „ Z d „ Z
d d „ Z e d „ ƒ Z d „ Z
d
„ Z RS( c C sp t | _ | | _ | | _ | | _ d | _ t j ƒ | _ t | j d ƒ rc | j j
ƒ | _ n d | _ d S( Ni RC (
t Falset closedR? t fileobjR t _FileObjectExtent__bytes_readt hashlibt md5t _FileObjectExtent__md5t hasattrRC t _FileObjectExtent__initial_posR ( R Rl R R? ( ( sC /usr/lib/python2.7/site-packages/euca2ools/commands/s3/putobject.pyR « s c C s | j S( N( R ( R ( ( sC /usr/lib/python2.7/site-packages/euca2ools/commands/s3/putobject.pyt __len__· s c C s: | d k r! t j j | ƒ } n | t | ƒ | d | ƒS( NR? ( R t euca2oolst utilt get_filesizet open( t clsR? R ( ( sC /usr/lib/python2.7/site-packages/euca2ools/commands/s3/putobject.pyR* º s c C s t | j d ƒ o | j d k S( Nt seek( Rq Rl Rr R ( R ( ( sC /usr/lib/python2.7/site-packages/euca2ools/commands/s3/putobject.pyRQ À s c C s | j j ƒ t | _ d S( N( Rl RH R< Rk ( R ( ( sC /usr/lib/python2.7/site-packages/euca2ools/commands/s3/putobject.pyRH Ä s
c C sj | j | j } | d k r( t ƒ ‚ n t | j ƒ } | | } | j t | ƒ 7_ | j j | ƒ | S( Ni ( R Rm t
StopIterationt nextRl t lenRp RB ( R t remainingt chunk( ( sC /usr/lib/python2.7/site-packages/euca2ools/commands/s3/putobject.pyR{ È s
iÿÿÿÿc C so | j | j } | d k r% | } n t | | ƒ } | j j | ƒ } | j t | ƒ 7_ | j j | ƒ | S( Ni ( R Rm t minRl t readR| Rp RB ( R R R} t chunk_lenR~ ( ( sC /usr/lib/python2.7/site-packages/euca2ools/commands/s3/putobject.pyR€ Ò s c C s
| j j ƒ S( N( Rp t hexdigest( R ( ( sC /usr/lib/python2.7/site-packages/euca2ools/commands/s3/putobject.pyRU Ý s c C sP t | j d ƒ s! t d ƒ ‚ n | j j | j ƒ d | _ t j ƒ | _ d S( NRy s file object is not seekablei ( Rq Rl t TypeErrorRy Rr Rm Rn Ro Rp ( R ( ( sC /usr/lib/python2.7/site-packages/euca2ools/commands/s3/putobject.pyR\ á s
c C s | j S( N( Rm ( R ( ( sC /usr/lib/python2.7/site-packages/euca2ools/commands/s3/putobject.pyRC é s N( Rb Rc R R Rs t classmethodR* t propertyRQ RH R{ R€ RU R\ RC ( ( ( sC /usr/lib/python2.7/site-packages/euca2ools/commands/s3/putobject.pyR$ ¦ s
( Rf Rn R% R RD R! R t requestbuilder.exceptionst requestbuilder.mixinsR R( t euca2ools.commands.s3R t euca2ools.utilRt R t objectR$ ( ( ( sC /usr/lib/python2.7/site-packages/euca2ools/commands/s3/putobject.pyt <module> s }
Back to Directory
File Manager