B
?F[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 )LocationZUSEUN)__name__
__module__ __qualname__DEFAULTr r
r
1lib/python3.7/site-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 )NZgoogle)suppress_consec_slashes)superr __init__r )selfZgs_access_key_idZgs_secret_access_keyZ is_secureZportproxyZ
proxy_portZ
proxy_userZ
proxy_passZhostdebugZhttps_connection_factoryZcalling_formatpathr ) __class__r
r r % s
zGSConnection.__init__ZSTANDARDc C s t | |r*|r ||| jj< n | jj|i}|s4tj}d| }|rJd| }nd}d||f }| jdt||t|d} | }
| jdkr| j | j| j
|
| jdkr| | |S | j | j| j
|
d S )
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%sZPUT)headersdatai N)
r ZproviderZ
acl_headerr r Z make_requestr readZstatusZstorage_create_errorreason bucket_classZstorage_response_error) r bucket_namer locationZpolicyZ
storage_classZ
location_elemZstorage_class_elemr ZresponseZbodyr
r
r
create_bucket1 s4
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 )Zmaxkeys)r Z get_all_keys)r r Zvalidater Zbucketr
r
r
get_bucketj s zGSConnection.get_bucket)TN) r r
r Z DefaultHostZ QueryStringr r r r r" r#
__classcell__r
r
)r r r s 7r N) Zboto.gs.bucketr Zboto.s3.connectionr r r Z
boto.utilsr objectr r r
r
r
r s