/usr/lib/python2.6/site-packages/boto/s3
Edit: /usr/lib/python2.6/site-packages/boto/s3/connection.pyo (23607B)
-Sc @ s d d k Z d d k Z d d k l Z l Z d d k Z d d k l Z d d k 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 l Z d
Z d Z d e f d
YZ d e f d YZ d e f d YZ d e f d YZ d e f d YZ d e f d YZ d e f d YZ d e f d YZ! d e f d YZ" d S( iN( t sixt urllib( t detect_potential_s3sigv4( t AWSAuthConnection( t handler( t Bucket( t Key( t ResultSet( t BotoClientErrort S3ResponseErrorc C s% | d i p t d n t S( sJ
Bucket names must not contain uppercase characters. We check for
this by appending a lowercase character and testing with islower().
Note this also covers cases like numeric bucket names with dashes.
>>> check_lowercase_bucketname("Aaaa")
Traceback (most recent call last):
...
BotoClientError: S3Error: Bucket names cannot contain upper-case
characters when using either the sub-domain or virtual hosting calling
format.
>>> check_lowercase_bucketname("1234-5678-9123")
True
>>> check_lowercase_bucketname("abcdefg1234")
True
t asu Bucket names cannot contain upper-case characters when using either the sub-domain or virtual hosting calling format.( t islowerR t True( t n( ( s6 /usr/lib/python2.6/site-packages/boto/s3/connection.pyt check_lowercase_bucketname( s c s f d } | S( Nc s5 t | d j o t | d o n | | S( Ni i ( t lenR ( t argst kwargs( t f( s6 /usr/lib/python2.6/site-packages/boto/s3/connection.pyt wrapperB s $( ( R R ( ( R s6 /usr/lib/python2.6/site-packages/boto/s3/connection.pyt assert_case_insensitiveA s t _CallingFormatc B s> e Z d Z d d Z d Z d d Z d d Z RS( c C s d S( Nt ( ( t selft servert bucket( ( s6 /usr/lib/python2.6/site-packages/boto/s3/connection.pyt get_bucket_serverK s R c C sC d | } | | i | | 7} | | i | i | | 7} | S( Ns %s://( t
build_hostt get_patht build_path_base( R t
connectiont protocolR R t keyt url_base( ( s6 /usr/lib/python2.6/site-packages/boto/s3/connection.pyt build_url_baseN s
c C s& | d j o | S| i | | Sd S( NR ( R ( R R R ( ( s6 /usr/lib/python2.6/site-packages/boto/s3/connection.pyR T s
c C sK t i i | } d } | d j o d | } n | d t i i | S( NR t /s /%s( t botot utilst get_utf8_valueR t parset quote( R R R t path( ( s6 /usr/lib/python2.6/site-packages/boto/s3/connection.pyt build_auth_pathZ s
c C s& t i i | } d t i i | S( Ns /%s( R$ R% R& R R' R( ( R R R ( ( s6 /usr/lib/python2.6/site-packages/boto/s3/connection.pyR a s ( t __name__t
__module__R R" R R* R ( ( ( s6 /usr/lib/python2.6/site-packages/boto/s3/connection.pyR I s
t SubdomainCallingFormatc B s e Z e d Z RS( c C s d | | f S( Ns %s.%s( ( R R R ( ( s6 /usr/lib/python2.6/site-packages/boto/s3/connection.pyR h s ( R+ R, R R ( ( ( s6 /usr/lib/python2.6/site-packages/boto/s3/connection.pyR- f s t VHostCallingFormatc B s e Z e d Z RS( c C s | S( N( ( R R R ( ( s6 /usr/lib/python2.6/site-packages/boto/s3/connection.pyR o s ( R+ R, R R ( ( ( s6 /usr/lib/python2.6/site-packages/boto/s3/connection.pyR. m s t OrdinaryCallingFormatc B s e Z d Z d d Z RS( c C s | S( N( ( R R R ( ( s6 /usr/lib/python2.6/site-packages/boto/s3/connection.pyR v s R c C sE t i i | } d } | o | d | 7} n | t i i | S( NR# s %s/( R$ R% R& R R' R( ( R R R t path_base( ( s6 /usr/lib/python2.6/site-packages/boto/s3/connection.pyR y s
( R+ R, R R ( ( ( s6 /usr/lib/python2.6/site-packages/boto/s3/connection.pyR/ t s t( ProtocolIndependentOrdinaryCallingFormatc B s e Z d d Z RS( R c C s? d } | | i | | 7} | | i | i | | 7} | S( Ns //( R R R ( R R R R R R R! ( ( s6 /usr/lib/python2.6/site-packages/boto/s3/connection.pyR" s ( R+ R, R" ( ( ( s6 /usr/lib/python2.6/site-packages/boto/s3/connection.pyR1 s t Locationc B s> e Z d Z d Z d Z d Z d Z d Z d Z d Z d Z
RS( R t EUs us-west-1s us-west-2s sa-east-1s ap-northeast-1s ap-southeast-1s ap-southeast-2s
cn-north-1( R+ R, t DEFAULTR3 t USWestt USWest2t SAEastt APNortheastt APSoutheastt APSoutheast2t CNNorth1( ( ( s6 /usr/lib/python2.6/site-packages/boto/s3/connection.pyR2 s t NoHostProvidedc B s e Z RS( ( R+ R, ( ( ( s6 /usr/lib/python2.6/site-packages/boto/s3/connection.pyR< s t HostRequiredErrorc B s e Z RS( ( R+ R, ( ( ( s6 /usr/lib/python2.6/site-packages/boto/s3/connection.pyR= s t S3Connectionc B s e Z e i i d d d Z e i i d d d Z d Z d d e d d d d d e
d d e d d e d e e d d d Z
e d
Z d Z d Z d
Z d Z d d d d d d d d d d Z d d d e d d d d Z d d d e e d e d d Z d d Z d d Z e d d Z d d Z e d d Z d e i d d Z d d Z d d d d d d d d d Z RS( t s3t hosts s3.amazonaws.comt calling_formats) boto.s3.connection.SubdomainCallingFormats) Signature=%s&Expires=%d&AWSAccessKeyId=%si R# t awsc C s t } | t j o t } | i } n t | t i o t i i | } n | | _
| | _ | | _ t
t | i | | | | | | | | | d |
d | d |
d | d | d | d | d | | o' d | i j o t d
q n d S( Nt debugt https_connection_factoryR) t providert security_tokent suppress_consec_slashest validate_certst profile_names
hmac-v4-s3s6 When using SigV4, you must specify a 'host' parameter.( t FalseR< R t DefaultHostt
isinstanceR t string_typesR$ R% t
find_classRA t bucket_classt anont superR> t __init__t _required_auth_capabilityR= ( R t aws_access_key_idt aws_secret_access_keyt is_securet portt proxyt
proxy_portt
proxy_usert
proxy_passR@ RC RD RA R) RE RO RF RG RP RH RI t no_host_provided( ( s6 /usr/lib/python2.6/site-packages/boto/s3/connection.pyRR s(
c C s | i o d g Sd g Sd S( NRP R? ( RP ( R ( ( s6 /usr/lib/python2.6/site-packages/boto/s3/connection.pyRS s
c c s x | i D] } | Vq
Wd S( N( t get_all_buckets( R R ( ( s6 /usr/lib/python2.6/site-packages/boto/s3/connection.pyt __iter__ s
c C s | i | d j S( N( t lookupt None( R t bucket_name( ( s6 /usr/lib/python2.6/site-packages/boto/s3/connection.pyt __contains__ s c C s
| | _ d S( sX
Set the Bucket class associated with this bucket. By default, this
would be the boto.s3.key.Bucket class but if you want to subclass that
for some reason this allows you to associate your new class.
:type bucket_class: class
:param bucket_class: A subclass of Bucket that can be more specific
N( RO ( R RO ( ( s6 /usr/lib/python2.6/site-packages/boto/s3/connection.pyt set_bucket_class s c C s) d t i t i i | d i | f S( sX
Taken from the AWS book Python examples and modified for use with boto
s( {"expiration": "%s",
"conditions": [%s]}t ,( t timet strftimeR$ R% t ISO8601t join( R t expiration_timet
conditions( ( s6 /usr/lib/python2.6/site-packages/boto/s3/connection.pyt build_post_policy s ip t httpt STANDARDc C s | d j o
g } n | d j o
g } n t i t t i | } | i d | | i d o | i d | t d n | i d | | o0 | i d | | i h d d 6| d 6 n | o0 | i d | | i h d
d 6| d 6 n | o | i d | n | i i o< | i h d d 6| i i d 6 | i d
| i i n |
o0 | i h d d 6|
d 6 | i d |
n | o0 | i h d d 6| d 6 | i d | n | i | | }
t
i |
} | i h d d 6| d 6 | i h d d 6| i d 6 | i
i | } | i h d d 6| d 6 | i h d d 6| d 6 d | | i i | i | f } h | d 6| d 6S( s
Taken from the AWS book Python examples and modified for use with boto
This only returns the arguments required for the post form, not the
actual form. This does not return the file input field which also
needs to be added
:type bucket_name: string
:param bucket_name: Bucket to submit to
:type key: string
:param key: Key name, optionally add ${filename} to the end to
attach the submitted filename
:type expires_in: integer
:param expires_in: Time (in seconds) before this expires, defaults
to 6000
:type acl: string
:param acl: A canned ACL. One of:
* private
* public-read
* public-read-write
* authenticated-read
* bucket-owner-read
* bucket-owner-full-control
:type success_action_redirect: string
:param success_action_redirect: URL to redirect to on success
:type max_content_length: integer
:param max_content_length: Maximum size for this file
:type http_method: string
:param http_method: HTTP Method to use, "http" or "https"
:type storage_class: string
:param storage_class: Storage class to use for storing the object.
Valid values: STANDARD | REDUCED_REDUNDANCY
:type server_side_encryption: string
:param server_side_encryption: Specifies server-side encryption
algorithm to use when Amazon S3 creates an object.
Valid values: None | AES256
:rtype: dict
:return: A dictionary containing field names/values as well as
a url to POST to
.. code-block:: python
s {"bucket": "%s"}s ${filename}s ["starts-with", "$key", "%s"]s
{"key": "%s"}s
{"acl": "%s"}t aclt namet values! {"success_action_redirect": "%s"}t success_action_redirects ["content-length-range", 0, %i]s x-amz-security-tokens {"x-amz-security-token": "%s"}s x-amz-storage-classs {"x-amz-storage-class": "%s"}s x-amz-server-side-encryptions& {"x-amz-server-side-encryption": "%s"}t policyt AWSAccessKeyIdt signatureR s %s://%s/t actiont fieldsN( R` Re t gmtimet intt appendt endswithR RE RF Rk t base64t b64encodeRT t
_auth_handlert sign_stringRA R t server_name( R Ra R t
expires_inRn Rq t max_content_lengtht http_methodRv Rj t
storage_classt server_side_encryptiont
expirationRr t
policy_b64Rt t url( ( s6 /usr/lib/python2.6/site-packages/boto/s3/connection.pyt build_post_form_args sR :
R c
C s | i i | | }
| i i | | } | i i | i | } | i d o | d } n h }
| d j o | |
d
', validate=False)
bucket.get_all_keys(maxkeys=0)
:type bucket_name: string
:param bucket_name: The name of the bucket
:type headers: dict
:param headers: Additional headers to pass along with the request to
AWS.
:type validate: boolean
:param validate: If ``True``, it will try to verify the bucket exists
on the service-side. (Default: ``True``)
R N( t head_bucketRO ( R Ra t validateR ( ( s6 /usr/lib/python2.6/site-packages/boto/s3/connection.pyt
get_bucket s %c C s | i d | d | } | i } | i d j o | i | | S| i d j o: | i i | i | i | } d | _ d | _ | ni | i d j o: | i i | i | i | } d | _ d | _ | n | i i | i | i | d
S( s|
Determines if a bucket exists by name.
If the bucket does not exist, an ``S3ResponseError`` will be raised.
:type bucket_name: string
:param bucket_name: The name of the bucket
:type headers: dict
:param headers: Additional headers to pass along with the request to
AWS.
:returns: A object
t HEADR i i t AccessDenieds
Access Deniedi t NoSuchBuckets# The specified bucket does not existN( R R R RO RE R R t
error_codet
error_message( R Ra R R R t err( ( s6 /usr/lib/python2.6/site-packages/boto/s3/connection.pyR s,
c C s0 y | i | | d | } Wn
d } n X| S( sR
Attempts to get a bucket from S3.
Works identically to ``S3Connection.get_bucket``, save for that it
will return ``None`` if the bucket does not exist instead of throwing
an exception.
:type bucket_name: string
:param bucket_name: The name of the bucket
:type headers: dict
:param headers: Additional headers to pass along with the request to
AWS.
:type validate: boolean
:param validate: If ``True``, it will try to fetch all keys within the
given bucket. (Default: ``True``)
R N( R R` ( R Ra R R R ( ( s6 /usr/lib/python2.6/site-packages/boto/s3/connection.pyR_ ' s
c C s
t | | o2 | o | | | i i s1 t PUTR t datai i N( R RE t
acl_headerR2 R4 R R R t storage_create_errorR RO R ( R Ra R t locationRr R R R ( ( s6 /usr/lib/python2.6/site-packages/boto/s3/connection.pyt
create_bucket@ s$
c C sZ | i d | d | } | i } | i d j o" | i i | i | i | n d S( s
Removes an S3 bucket.
In order to remove the bucket, it must first be empty. If the bucket is
not empty, an ``S3ResponseError`` will be raised.
:type bucket_name: string
:param bucket_name: The name of the bucket
:type headers: dict
:param headers: Additional headers to pass along with the request to
AWS.
t DELETER i N( R R R RE R R ( R R R R R ( ( s6 /usr/lib/python2.6/site-packages/boto/s3/connection.pyt
delete_bucketo s
c
C s- t | | i o
| i } n t | t o
| i } n | i i | | }
t i i d |
| i i | | } t i i d | | i i
| i | } | oH |
d | 7}
t i i d |
| d | 7} t i i d | n t t
| i | |
| | | | | d | d | S( Ns path=%ss auth_path=%sR t override_num_retriest
retry_handler( RL RO Ro R RA R R$ t logRC R* R R RQ R> R (
R R R R R R t
query_argst senderR R R) R R@ ( ( s6 /usr/lib/python2.6/site-packages/boto/s3/connection.pyR s&
N(! R+ R, R$ t configt getRK t DefaultCallingFormatR R` R R< R RJ RR R RS R^ Rb Rc Rk R R R R] R R R R_ R2 R4 R R R ( ( ( s6 /usr/lib/python2.6/site-packages/boto/s3/connection.pyR> sP p 9
* -. (# t xml.saxR R{ t boto.compatR R Re t boto.authR t
boto.utilsR$ t boto.connectionR R t boto.s3.bucketR t boto.s3.keyR t boto.resultsetR t boto.exceptionR R R R t objectR R- R. R/ R1 R2 R< R= R> ( ( ( s6 /usr/lib/python2.6/site-packages/boto/s3/connection.pyt s,