o
ckF[f @ s` d dl mZ d dlmZ d dlmZ d dlmZ d dlmZ G dd deZ G dd d eZ
d
S ) )Bucket) S3Connection)SubdomainCallingFormat)check_lowercase_bucketname)get_utf8_valuec @ s e Zd ZdZdZdS )LocationUSEUN)__name__
__module__ __qualname__DEFAULTr r r 4/usr/lib/python3/dist-packages/boto/gs/connection.pyr s r c sb e Zd ZdZdZddddddddedde ddf fdd Zdejdd fd
d Z dd d
Z
Z S ) GSConnectionzstorage.googleapis.comz)Signature=%s&Expires=%d&GoogleAccessId=%sNTr /c s4 t t| j||||||||| |
| | |
dt|d d S )Ngoogle)suppress_consec_slashes)superr __init__r )selfgs_access_key_idgs_secret_access_key is_secureportproxy
proxy_port
proxy_user
proxy_passhostdebughttps_connection_factorycalling_formatpathr __class__r r r % s
zGSConnection.__init__STANDARDc C s t | |r|r||| jj< n| jj|i}|stj}d| }|r%d| }nd}d||f }| jdt||t|d} | }
| jdkrM| j | j| j
|
| jdkrX| | |S | j | j| j
|
) a
Creates a new bucket. By default it's located in the USA. You can
pass Location.EU to create bucket in the EU. You can also pass
a LocationConstraint for where the bucket should be located, and
a StorageClass describing how the data should be stored.
:type bucket_name: string
:param bucket_name: The name of the new bucket.
:type headers: dict
:param headers: Additional headers to pass along with the request to GCS.
:type location: :class:`boto.gs.connection.Location`
:param location: The location of the new bucket.
:type policy: :class:`boto.gs.acl.CannedACLStrings`
:param policy: A canned ACL policy that will be applied to the new key
in GCS.
:type storage_class: string
:param storage_class: Either 'STANDARD' or 'DURABLE_REDUCED_AVAILABILITY'.
z+%sz %s z;%s%sPUT)headersdatai )
r provider
acl_headerr r
make_requestr readstatusstorage_create_errorreason bucket_classstorage_response_error) r bucket_namer) locationpolicy
storage_class
location_elemstorage_class_elemr* responsebodyr r r
create_bucket1 s@
zGSConnection.create_bucketc C s" | | |}|r|j|dd |S )a
Retrieves a bucket by name.
If the bucket does not exist, an ``S3ResponseError`` will be raised. If
you are unsure if the bucket exists or not, you can use the
``S3Connection.lookup`` method, which will either return a valid bucket
or ``None``.
: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 )maxkeys)r3 get_all_keys)r r5 validater) bucketr r r
get_bucketj s zGSConnection.get_bucket)TN) r
r r DefaultHost QueryStringr r r r
r= rB
__classcell__r r r$ r r s
9r N) boto.gs.bucketr boto.s3.connectionr r r
boto.utilsr objectr r r r r r s