P5Tc ! @ s d d k Z d d k l Z d d k l Z d d k l Z d d k l Z l Z l Z d d k
l Z d d k l
Z
d d k l Z d d k l Z d d
k l Z d d k l Z d d k l Z d d
k l Z d d k l Z d d k l Z d d k l Z 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( Z' d d k) Z) d d k* Z* d d k+ l, Z, d d k- l. Z. l/ Z/ l0 Z0 l1 Z1 d e2 f d YZ3 d d d d d g Z4 d e2 f d YZ5 d S( iN( t handler( t ResultSet( t BotoClientError( t Policyt CannedACLStringst Grant( t Key( t Prefix( t DeleteMarker( t MultiPartUpload( t CompleteMultiPartUpload( t MultiDeleteResult( t Error( t BucketListResultSet( t VersionedBucketListResultSet( t MultiPartUploadListResultSet( t Lifecycle( t Tags( t CORSConfiguration( t
BucketLogging( t website( t defaultdict( t BytesIOt sixt StringIOt urllibt S3WebsiteEndpointTranslatec B sv e Z e d Z d e d : s s s3-website-eu-west-1s eu-west-1s s3-website-us-west-1s us-west-1s s3-website-us-west-2s us-west-2s s3-website-sa-east-1s sa-east-1s s3-website-ap-northeast-1s ap-northeast-1s s3-website-ap-southeast-1s ap-southeast-1s s3-website-ap-southeast-2s ap-southeast-2s s3-website.cn-north-1s
cn-north-1c C s | i | S( N( t trans_region( t selft reg( ( s2 /usr/lib/python2.6/site-packages/boto/s3/bucket.pyt translate_regionD s ( t __name__t
__module__R R t classmethodR ( ( ( s2 /usr/lib/python2.6/site-packages/boto/s3/bucket.pyR 8 s
t READt WRITEt READ_ACPt WRITE_ACPt FULL_CONTROLt Bucketc B s[ e Z d Z d Z d Z d Z d Z dW dW e d Z d Z
d Z d Z d Z
d
Z d Z dW d Z dW dW dW e d
Z d Z d d d dW dW d Z d d d d dW dW d Z d d dW dW d Z d d Z d dW d Z d Z dW d Z dW d Z d Z dW d Z dW d Z d dW e dW e d Z e dW dW d Z! dW dW dW d Z" dW dW dW dW d Z# dW dW d e e dW dW d! Z$ d dW dW d" Z% d dW dW d# Z& d dW dW d$ d% Z' d dW dW d& Z( d dW dW d' Z) d dW dW d( Z* d dW dW d) Z+ e dW d* Z, e dW d+ Z- e dW dW d, Z. dW d- Z/ d. Z0 dW d/ Z1 d dW dW d0 Z2 dW d1 Z3 dW d2 Z4 dW d3 Z5 dW d4 Z6 d5 dW d6 Z7 e dW dW d7 Z8 dW d8 Z9 dW d9 Z: dW d: Z; dW d; Z< dW dW dW dW dW d< Z= dW d= Z> dW d> Z? dW d? Z@ dW d@ ZA dW dA ZB dW dB ZC dW dC ZD dD ZE dW dE ZF dW dF ZG dW dG ZH dW dH ZI dW dI ZJ dW dJ ZK dW dK ZL dW dL ZM dW e dW e dW dM ZN dW dN ZO dW dO ZP dW dP ZQ dQ ZR dR ZS dW dS dT ZT dW dU ZU dW dV ZV RS(X s. http://acs.amazonaws.com/groups/s3/LogDeliverys
%ss
%s%ss ([A-Za-z]+)s" ([A-Za-z]+)c C s | | _ | | _ | | _ d S( N( t namet
connectiont key_class( R R* R) R+ ( ( s2 /usr/lib/python2.6/site-packages/boto/s3/bucket.pyt __init__] s c C s d | i S( Ns ( R) ( R ( ( s2 /usr/lib/python2.6/site-packages/boto/s3/bucket.pyt __repr__b s c C s t t | S( N( t iterR
( R ( ( s2 /usr/lib/python2.6/site-packages/boto/s3/bucket.pyt __iter__e s c C s | i | d j S( N( t get_keyt None( R t key_name( ( s2 /usr/lib/python2.6/site-packages/boto/s3/bucket.pyt __contains__h s c C s d S( N( R1 ( R R) t attrsR* ( ( s2 /usr/lib/python2.6/site-packages/boto/s3/bucket.pyt startElementk s c C sH | d j o
| | _ n+ | d j o
| | _ n t | | | d S( Nt Namet CreationDate( R) t
creation_datet setattr( R R) t valueR* ( ( s2 /usr/lib/python2.6/site-packages/boto/s3/bucket.pyt
endElementn s
c C s
| | _ d S( s
Set the Key class associated with this bucket. By default, this
would be the boto.s3.key.Key class but if you want to subclass that
for some reason this allows you to associate your new class with a
bucket so that when you call bucket.new_key() or when you get a listing
of keys in the bucket you will get an instances of your key class
rather than the default.
:type key_class: class
:param key_class: A subclass of Key that can be more specific
N( R+ ( R R+ ( ( s2 /usr/lib/python2.6/site-packages/boto/s3/bucket.pyt
set_key_classv s c C s | i | d | S( s
Deprecated: Please use get_key method.
:type key_name: string
:param key_name: The name of the key to retrieve
:rtype: :class:`boto.s3.key.Key`
:returns: A Key object from this bucket.
t headers( R0 ( R R2 R= ( ( s2 /usr/lib/python2.6/site-packages/boto/s3/bucket.pyt lookup s
c C s | t j o7 | p | p | o t d d n | i | Sg } | o | i d | n | oG xD t i | D]/ \ } } | i d | t i i | f q} Wn | i | | | \ } }
| S( s
Check to see if a particular key exists within the bucket. This
method uses a HEAD request to check for the existence of the key.
Returns: An instance of a Key object or None
:param key_name: The name of the key to retrieve
:type key_name: string
:param headers: The headers to send when retrieving the key
:type headers: dict
:param version_id:
:type version_id: string
:param response_headers: A dictionary containing HTTP
headers/values that will override any headers associated
with the stored object in the response. See
http://goo.gl/EWOPb for details.
:type response_headers: dict
:param validate: Verifies whether the key exists. If ``False``, this
will not hit the service, constructing an in-memory object.
Default is ``True``.
:type validate: bool
:rtype: :class:`boto.s3.key.Key`
:returns: A Key object from this bucket.
s1 When providing 'validate=False', no other params s are allowed.s versionId=%ss %s=%s(
t FalseR t new_keyt appendR t iteritemsR t parset quotet _get_key_internal( R R2 R= t
version_idt response_headerst validatet query_args_lt rkt rvt keyt resp( ( s2 /usr/lib/python2.6/site-packages/boto/s3/bucket.pyR0 s
+c
C s d i | p d } | i i d | i | d | d | } | i | i d d j o | i | } | i i } t i
i | i | | _
x9 t i D]. } | i | | i | i i d d u u truei i i t
PrefixSkippedt InvalidArguments0 Invalid. No delete action taken for this object.t codet messagei u u s utf-8s Content-MD5s text/xmls Content-Typet t POSTR= RP t datai (' t nextt
StopIterationR~ R R R1 t tuplet lenR R R) RF R t reprR t errorsRA R R t saxutilst escapeR? R R RY RZ t compute_md5RT t
mfa_headerR* RU RV RW R R R R Rj Rk ( t hdrsR t countRL R2 RF R R t errort fpt md5Rl R R ( t resultt ikeysR RX t quiett mfa_tokenRP ( s2 /usr/lib/python2.6/site-packages/boto/s3/bucket.pyt delete_keys2 st
#*
( R. R R* RX ( R t keysR R R= R ( ( R R R R R RX RP s2 /usr/lib/python2.6/site-packages/boto/s3/bucket.pyt delete_keysz s !=
c
C s< | p t d n | i | d | d | d | d d S( s
Deletes a key from the bucket. If a version_id is provided,
only that version of the key will be deleted.
:type key_name: string
:param key_name: The key name to delete
:type version_id: string
:param version_id: The version ID (optional)
:type mfa_token: tuple or list of strings
:param mfa_token: A tuple or list consisting of the serial
number from the MFA device and the current value of the
six-digit token associated with the device. This value is
required anytime you are deleting versioned objects from a
bucket that has the MFADelete option on the bucket.
:rtype: :class:`boto.s3.key.Key` or subclass
:returns: A key object holding information on what was
deleted. The Caller can see if a delete_marker was
created or removed and what version_id the delete created
or removed.
s Empty key names are not allowedR= RF R RI N( R t _delete_key_internalR1 ( R R2 R= RF R ( ( s2 /usr/lib/python2.6/site-packages/boto/s3/bucket.pyt
delete_key s c C s | p g } | i i } | o | i d | n d i | p d } | o+ | p
h } n d i | | | i s c C s | i | d S( s
Returns the current status of website configuration on the bucket.
:rtype: dict
:returns: A dictionary containing a Python representation
of the XML response from S3. The overall structure is:
* WebsiteConfiguration
* IndexDocument
* Suffix : suffix that is appended to request that
is for a "directory" on the website endpoint
* ErrorDocument
* Key : name of object to serve when an error occurs
i ( t" get_website_configuration_with_xml( R R= ( ( s2 /usr/lib/python2.6/site-packages/boto/s3/bucket.pyt get_website_configuration s c C sG | i d | } t i } t i | | } t i i | | | S( si Get the website configuration as a
:class:`boto.s3.website.WebsiteConfiguration` object.
R= ( t get_website_configuration_xmlR R6 R R R R R ( R R= t
config_xmlR< R ( ( s2 /usr/lib/python2.6/site-packages/boto/s3/bucket.pyt get_website_configuration_obj s
c C sM | i d | } t i i } t i i | d } | i | | | f S( s
Returns the current status of website configuration on the bucket as
unparsed XML.
:rtype: 2-Tuple
:returns: 2-tuple containing:
1) A dictionary containing a Python representation of the XML response. The overall structure is:
* WebsiteConfiguration
* IndexDocument
* Suffix : suffix that is appended to request that is for a "directory" on the website endpoint
* ErrorDocument
* Key : name of object to serve when an error occurs
2) unparsed XML describing the bucket's website configuration
R= N( RA RY t jsonresponset ElementR R1 RC ( R R= R t eR ( ( s2 /usr/lib/python2.6/site-packages/boto/s3/bucket.pyR? s
c C s | i i d | i d d d | } | i i d } t i i | | i d j o% | i i i
| i | i | n | S( s! Get raw website configuration xmlR RP R R= s utf-8i ( R* RU R) RV R( RY R R RW RX Rj Rk ( R R= Rl R ( ( s2 /usr/lib/python2.6/site-packages/boto/s3/bucket.pyRA s c C sz | i i d | i d d d | } | i } t i i | | i d j o t S| i i i
| i | i | d S( sD
Removes all website configuration from the bucket.
R RP R R= i N( R* RU R) RV RY R R RW R RX Rj Rk ( R R= Rl R ( ( s2 /usr/lib/python2.6/site-packages/boto/s3/bucket.pyt delete_website_configuration s c C s^ | i g } | i t i | i | i d i | i i i d d d i | S( s
Returns the fully qualified hostname to use is you want to access this
bucket as a website. This doesn't validate whether the bucket has
been correctly configured as a website or not.
t .i( R) RA R R R RT R* t hostt split( R t l( ( s2 /usr/lib/python2.6/site-packages/boto/s3/bucket.pyt get_website_endpoint s )c C sj | i i d | i d d d | } | i } | i d j o | S| i i i | i | i | d S( s
Returns the JSON policy associated with the bucket. The policy
is returned as an uninterpreted JSON string.
R RP R R= i N( R* RU R) RV RW RX Rj Rk ( R R= Rl R ( ( s2 /usr/lib/python2.6/site-packages/boto/s3/bucket.pyt
get_policy s c C s | i i d | i d | d d d | } | i } | i d j o | i d j o t S| i i i | i | i | d S( s
Add or replace the JSON policy associated with the bucket.
:type policy: str
:param policy: The JSON policy as a string.
R R RP R R= i i N( R* RU R) RV RW R RX Rj Rk ( R R R= Rl R ( ( s2 /usr/lib/python2.6/site-packages/boto/s3/bucket.pyt
set_policy( s c C s | i i d | i d d d d d | } | i } | i d j o | i d j o t S| i i i | i | i | d S( NR R s /?policyRP R R= i i ( R* RU R) RV RW R RX Rj Rk ( R R= Rl R ( ( s2 /usr/lib/python2.6/site-packages/boto/s3/bucket.pyt
delete_policy: s c C s t | } t i i | } | d j o
h } n | d | d i i N( R1 R* RU R) R? RV R( t findR RY R R RW R
R R R~ R R R R R R+ Re Rf RF t encryptedRX Rj Rk ( R R2 t upload_idt xml_bodyR= RP Rl t contains_errorR RM R Rm ( ( s2 /usr/lib/python2.6/site-packages/boto/s3/bucket.pyt complete_multipart_upload s4
c C s d | } | i i d | i | d | d | } | i } t i i | | i d j o% | i i i | i | i
| n d S( s
To verify that all parts have been removed, so you don't get charged
for the part storage, you should call the List Parts operation and
ensure the parts list is empty.
s uploadId=%sR RP R= i N( R* RU R) RV RY R R RW RX Rj Rk ( R R2 R] R= RP Rl R ( ( s2 /usr/lib/python2.6/site-packages/boto/s3/bucket.pyt cancel_multipart_upload s
c C s | i i | i d | S( NR= ( R* t
delete_bucketR) ( R R= ( ( s2 /usr/lib/python2.6/site-packages/boto/s3/bucket.pyR s c C sa | i } t } t i | | } t | t p | i d } n t i i | | | S( Ns utf-8(
t get_xml_tagsR R R R~ R R R R R ( R Rl t tagsR ( ( s2 /usr/lib/python2.6/site-packages/boto/s3/bucket.pyt get_tags! s c C sj | i i d | i d d d d } | i } | i d j o | S| i i i | i | i | d S( NR RP t taggingR= i ( R* RU R) R1 RV RW RX Rj Rk ( R Rl R ( ( s2 /usr/lib/python2.6/site-packages/boto/s3/bucket.pyRc * s Rf c C s | d j o
h } n t i i t | } | d | d R R0 RE Rt Rw Ry R R R R R R R R@ R? R R R R R R R R R R R R R R R R R R R R
R R R R R% R/ R3 R4 R5 R= R7 R> R@ RC R? RA RG RL RM RN RO RR RT RU RV RW RZ R` Ra R Re Rc Rh Ri Rj ( ( ( s2 /usr/lib/python2.6/site-packages/boto/s3/bucket.pyR( K s 2 % 2 /! 0 3 J ` c
& $!'
/ !
! N & (6 RY R t boto.resultsetR t boto.exceptionR t boto.s3.aclR R R t boto.s3.keyR t boto.s3.prefixR t boto.s3.deletemarkerR t boto.s3.multipartR R
t boto.s3.multideleteR R t boto.s3.bucketlistresultsetR
R R t boto.s3.lifecycleR t boto.s3.taggingR t boto.s3.corsR t boto.s3.bucketloggingR t boto.s3R t boto.jsonresponset
boto.utilst xml.saxR t xml.sax.saxutilsR) t base64t collectionsR t boto.compatR R R R t objectR R R( ( ( ( s2 /usr/lib/python2.6/site-packages/boto/s3/bucket.pyt s< "