|
Server : Apache System : Linux iad1-shared-b8-43 6.6.49-grsec-jammy+ #10 SMP Thu Sep 12 23:23:08 UTC 2024 x86_64 User : dh_edsupp ( 6597262) PHP Version : 8.2.26 Disable Function : NONE Directory : /lib/python3/dist-packages/boto/__pycache__/ |
Upload File : |
o
ckF[O� � @ sx d dl Z d dlZd dlZd dlZd dlmZ d dlmZ d dlmZ G dd� de �Z
G dd� de
�Z G d d
� d
e
�Z dS ) � N)� DeleteMarker��BotoClientError)�InvalidUriErrorc @ s� e Zd ZdZdZdZi Zdd� Zdd� Zdd� Z d d
� Z
d d � Z d
d� Z dd� Z
d.dd�Zdd� Z d/dd�Z d0dd�Zd1dd �Zd2d d �Zd1d d �Zd2d!d"�Zd.d#d$�Z % d3d&d'�Z d4d(d)�Zd*d+� Zd,d-� ZdS )5�
StorageUriz�
Base class for representing storage provider-independent bucket and
object name with a shorthand URI-like syntax.
This is an abstract class: the constructor cannot be called (throws an
exception if you try).
Nc C s t d��)zBUncallable constructor on abstract base StorageUri class.
z0Attempt to instantiate abstract StorageUri classr ��self� r �2/usr/lib/python3/dist-packages/boto/storage_uri.py�__init__6 s zStorageUri.__init__c C s | j S )z%Returns string representation of URI.��urir r r r
�__repr__< s zStorageUri.__repr__c C s | j |j kS )z#Returns true if two URIs are equal.r )r r
r r r
�equals@ � zStorageUri.equalsc C s* |d u rt d�t�d||f d����d S )N�
z�Attempt to get %s for "%s" failed. This can happen if the URI refers to a non-existent object or if you meant to operate on a directory (e.g., leaving off -R option on gsutil cp, mv, or ls of a bucket)�P )r �join�textwrap�wrap)r �resp�levelr
r r r
�check_responseD s
���zStorageUri.check_responsec C �. t t| �t�r| jstd|| jf ��d S d S )Nz%s on bucket-less URI (%s))�
issubclass�type�BucketStorageUri� bucket_namer r
�r �
function_namer r r
�_check_bucket_uriL s
��z StorageUri._check_bucket_uric C r )Nz%s on object-less URI (%s))r r r � object_namer r
r r r r
�_check_object_uriQ s
��z StorageUri._check_object_uric K s4 |D ]}|| rt j�d||t|| �f � qd S )Nz$Warning: %s ignores argument: %s=%s
)�sys�stderr�write�str)r r �args�argr r r
�_warn_about_argsV s ����zStorageUri._warn_about_argsc K s t | jpd�}t| d�rd|vr| j|d< |�|� | js�| j| jv r+| j| j | _n]| jdkrHddlm } |||fi |��| _| j| j| j< n@| jdkrpddl
m } ddlm } |� |d < |||fi |��| _| j| j| j< n| jd
kr�dd l
m} || �| _ntd | j ��| j| j_| jS )
a�
Opens a connection to appropriate provider, depending on provider
portion of URI. Requires Credentials defined in boto config file (see
boto/pyami/config.py).
@type storage_uri: StorageUri
@param storage_uri: StorageUri specifying a bucket or a bucket+object
@rtype: L{AWSAuthConnection<boto.gs.connection.AWSAuthConnection>}
@return: A connection to storage service provider of the given URI.
r �suppress_consec_slashes�s3r )� S3Connection�gs)� GSConnection)�OrdinaryCallingFormat�calling_format�file)�FileConnectionzUnrecognized scheme "%s")�dict�connection_args�hasattrr* �update�
connection�scheme�
provider_pool�boto.s3.connectionr, �boto.gs.connectionr. r/ �boto.file.connectionr2 r �debug) r �
access_key_id�secret_access_key�kwargsr4 r, r. r/ r2 r r r
�connect] sF
�
��
��
�
zStorageUri.connectc C s" t t| �t�o| jd up| jd uS �N)r r r �
version_id�
generationr r r r
� has_version� s
�zStorageUri.has_versionFc C s( | � d� | �||�}|�| j|||�S )N�
delete_key)r" �
get_bucketrF r! �r �validate�headersrC � mfa_token�bucketr r r
rF � �
�zStorageUri.delete_key� c C sD | � d� | j|d�}|rdd� |j|||d�D �S |j|||d�S )N� list_bucket�rJ c s s � | ]
}t |t�s|V qd S rB )�
isinstancer )�.0�vr r r
� <genexpr>� s � �z)StorageUri.list_bucket.<locals>.<genexpr>)�prefix� delimiterrJ )r rG �
list_versions�list)r rU rV rJ � all_versionsrL r r r
rO � s
��zStorageUri.list_bucketc C s | � ||�}|�|�S rB )rG � get_all_keys)r rI rJ rU rL r r r
rZ � s
zStorageUri.get_all_keysc C s6 | � d� | �� }|�| j||�}| �|d| j� |S )NrG rL )r rA rG r r r
)r rI rJ �connrL r r r
rG � s
zStorageUri.get_bucketc C s: | � d� | �||�}|�| j||�}| �|d| j� |S )N�get_key�key)r" rG r\ r! r r
�r rI rJ rC rL r] r r r
r\ � s
zStorageUri.get_keyc C s" | � d� | �||�}|�| j�S )N�new_key)r" rG r_ r! �r rI rJ rL r r r
r_ � �
zStorageUri.new_keyc C sD | � d� | jddd� | �d |�}| �|d| j� |j|||d�S )Nr\ F)rI r] �rC )r" r) r\ r r
�get_contents_to_file)r �fprJ rC r] r r r
�get_contents_to_stream� s
z!StorageUri.get_contents_to_stream�
c
C sf | � d� | �d |�}
| �|
d| j� | r%|
j||||||||| d� d S |
�||||||||� d S )Nrc r] )� hash_algs)r" r\ r r
rc ) r rd rJ �cb�num_cb�torrentrC �res_download_handler�response_headersrg r] r r r
rc � s
��z StorageUri.get_contents_to_filec C s8 | � d� | �||�}| �|d| j� |�|||||�S )N�get_contents_as_stringr] )r" r\ r r
rm )r rI rJ rh ri rj rC r] r r r
rm � s
�z!StorageUri.get_contents_as_stringc C �$ | � � }|jj}| �|d| j� |S )N� acl_class)rA �providerro r r
)r r[ ro r r r
ro � � zStorageUri.acl_classc C rn )N� canned_acls)rA rp rr r r
)r r[ rr r r r
rr � rq zStorageUri.canned_acls�NN�FNNN)rN rN NF�FNN�FN)NNrf FNNNN)FNNrf FN)�__name__�
__module__� __qualname__�__doc__r7 r4 r9 r r r r r r" r) rA rE rF rO rZ rG r\ r_ re rc rm ro rr r r r r
r sF
:
�
�
�
� r c @ s� e Zd ZdZdZeg �Z d�dd�Zd d
� Zd d � Z d
d� Z
d�dd�Z d�dd�Z dd� Z
dd� Zd�dd�Zd�dd�Zd�dd �Zd�d d �Zd�d d �Zd�d!d"�Zd�d#d$�Z d�d%d&�Z d�d'd(�Z d�d)d*�Z d�d+d,�Zd�d-d.�Zd/d0� Zd1d2� Z d3d4� Z d5d6� Z d7d8� Z d9d:� Z d;d<� Z!d=d>� Z"d?d@� Z#dAdB� Z$ d�dDdE�Z%d�dFdG�Z&d�dHdI�Z'dJdK� Z( d�dLdM�Z) d�dNdO�Z*d�dPdQ�Z+ d�dRdS�Z, d�dTdU�Z- d�dVdW�Z. d�dXdY�Z/ d�d[d\�Z0 d�d]d^�Z1 d�d_d`�Z2 a d�dbdc�Z3 d�ddde�Z4d�dfdg�Z5d�dhdi�Z6 d�djdk�Z7d�dldm�Z8d�dndo�Z9d�dpdq�Z: d�drds�Z;d�dtdu�Z<d�dvdw�Z= d�dxdy�Z>d�dzd{�Z? d�d|d}�Z@d�d~d�ZA d�d�d��ZBd�d�d��ZCdS )�r z�
StorageUri subclass that handles bucket storage providers.
Callers should instantiate this class by calling boto.storage_uri().
�/Nr TFc
C sb || _ || _|| _|| _|r|| _|| _|| _|o t|�| _| | _ t
| j�p)t
|�| _ | � � dS )a� Instantiate a BucketStorageUri from scheme,bucket,object tuple.
@type scheme: string
@param scheme: URI scheme naming the storage provider (gs, s3, etc.)
@type bucket_name: string
@param bucket_name: bucket name
@type object_name: string
@param object_name: object name, excluding generation/version.
@type debug: int
@param debug: debug level to pass in to connection (range 0..2)
@type connection_args: map
@param connection_args: optional map containing args to be
passed to {S3,GS}Connection constructor (e.g., to override
https_connection_factory).
@param suppress_consec_slashes: If provided, controls whether
consecutive slashes will be suppressed in key paths.
@param version_id: Object version id (S3-specific).
@param generation: Object generation number (GCS-specific).
@param is_latest: boolean indicating that a versioned object is the
current version
After instantiation the components are available in the following
fields: scheme, bucket_name, object_name, version_id, generation,
is_latest, versionless_uri, version_specific_uri, uri.
Note: If instantiated without version info, the string representation
for a URI stays versionless; similarly, if instantiated with version
info, the string representation for a URI stays version-specific. If you
call one of the uri.set_contents_from_xyz() methods, a specific object
version will be created, and its version-specific URI string can be
retrieved from version_specific_uri even if the URI was instantiated
without version info.
N)
r8 r r! r= r4 r* rC �intrD � is_latest�bool�is_version_specific�_build_uri_strings)
r r8 r r! r= r4 r* rC rD r} r r r
r � s $ zBucketStorageUri.__init__c C s� | j r9| jr9d| j| j | jf | _| jr d| j| jf | _n | jr*d| j| jf | _| jr3| j| _d S | j| _d S | j rGd| j| j f | _d S d| j | _d S )Nz
%s://%s/%sz%s#%sz%s://%s/z%s://) r r! r8 �versionless_urirD �version_specific_urirC r r
r r r r
r� - s$
�
�� z#BucketStorageUri._build_uri_stringsc C s4 | � t|dd �t|dd �t|dd �t|dd �� d S )NrC rD r} �md5)�_update_from_values�getattr)r r] r r r
�_update_from_key@ s
�z!BucketStorageUri._update_from_keyc C s$ || _ || _|| _| �� || _d S rB )rC rD r} r� r� )r rC rD r} r� r r r
r� G s
z$BucketStorageUri._update_from_valuesc C st | � d� | �||�}| �� jdkr |j| j||p| jd�}n| �� jdkr0|j| j|| jd�}| �|d| j � |S )Nr\ �awsrb �google�rD r] )
r" rG � get_provider�namer\ r! rC rD r r
r^ r r r
r\ N s
�
�zBucketStorageUri.get_keyc C sf | � d� | �||�}| �� jdkr |p| j}|�| j|||�S | �� jdkr1|j| j|| jd�S d S )NrF r� r� r� )r" rG r� r� rC rF r! rD rH r r r
rF Z s
�
��zBucketStorageUri.delete_keyc C s$ | � d� t| j| j|| j| jd�S )z�Instantiate a BucketStorageUri from the current BucketStorageUri,
but replacing the object_name.
@type new_name: string
@param new_name: new object name
�clone_replace_name)r r! r= r* )r r r8 r r= r* �r �new_namer r r
r� f s
�z#BucketStorageUri.clone_replace_namec
C sn | � d� d}d}d}t|d�r|j}t|d�r|j}t|d�r#|j}t|j�� |jj |j | j
| j |||d�S )a) Instantiate a BucketStorageUri from the current BucketStorageUri, by
replacing the object name with the object name and other metadata found
in the given Key object (including generation).
@type key: Key
@param key: key for the new StorageUri to represent
�clone_replace_keyNFrC rD r} )r r! r= r* rC rD r} ) r r5 rC rD r} r rp �get_provider_namerL r� r= r* )r r] rC rD r} r r r
r� s s(
�z"BucketStorageUri.clone_replace_keyc C sn | � d� | �||�}| jpd}| �� jdkr$|p| j}|�|||�}n |j||| jd�}| �|d| j � |S )zreturns a bucket's acl�get_aclrN r� r� �acl)
r rG r! r� r� rC r� rD r r
)r rI rJ rC rL �key_namer� r r r
r� � s
zBucketStorageUri.get_aclc C �4 | � d� | �||�}|�|�}| �|d| j� |S )z%returns a bucket's default object acl� get_def_aclr� )r rG r� r r
)r rI rJ rL r� r r r
r� � �
z BucketStorageUri.get_def_aclc C r� )zreturns a bucket's CORS XML�get_cors�cors)r rG r� r r
)r rI rJ rL r� r r r
r� � r� zBucketStorageUri.get_corsc C sD | � d� | �||�}| jdkr|�||� dS |�|�� |� dS )z#sets or updates a bucket's CORS XMLz set_cors r+ N)r rG r8 �set_cors�to_xml)r r� rI rJ rL r r r
r� � s
zBucketStorageUri.set_corsc C � | � d� | �||�}|�|�S )N� get_location)r rG r� r` r r r
r� � �
z BucketStorageUri.get_locationc C s8 | � d� | jdkrtd| j ��| �||�}|�|�S )N�get_storage_classr- z.get_storage_class() not supported for %s URIs.)r r8 �
ValueErrorrG r� r` r r r
r� � s
�
z"BucketStorageUri.get_storage_classc C s> | � d� | jdkrtd| j ��| �||�}|�||� dS )z!Updates a bucket's storage class.�set_storage_classr- z.set_storage_class() not supported for %s URIs.N)r r8 r� rG r� )r �
storage_classrI rJ rL r r r
r� � s
� z"BucketStorageUri.set_storage_classc C s( | � d� | �||�}|�|| j||�S )N�get_subresource)r rG r� r! )r � subresourcerI rJ rC rL r r r
r� � rM z BucketStorageUri.get_subresourcec C s� | � d� | jdkrtd| j ��| jr1|rtd��| �||�}| �|d| j� |�|||� d S | jrD| � ||�}|�||||� d S t
d| j ��)N�add_group_email_grantr- z2add_group_email_grant() not supported for %s URIs.zDadd_group_email_grant() on key-ful URI cannot specify recursive=Truer] z-add_group_email_grant() on bucket-less URI %s) r r8 r� r! r\ r r
r� r rG r )r �
permission�
email_address� recursiverI rJ r] rL r r r
r� � s&
�
��z&BucketStorageUri.add_group_email_grantc C �\ | � d� | js| �||�}|�||||� d S | �||�}| �|d| j� |�||� d S )N�add_email_grantr] )r r! rG r� r\ r r
)r r� r� r� rI rJ rL r] r r r
r� � s
� z BucketStorageUri.add_email_grantc C r� )N�add_user_grantr] )r r! rG r� r\ r r
)r r� �user_idr� rI rJ rL r] r r r
r� � s
z BucketStorageUri.add_user_grantc C s | � d� | �|�}|�|�S )Nz list_grants )r rG � list_grants�r rJ rL r r r
r� s
z BucketStorageUri.list_grantsc C � dS )�3Returns True if this URI names a file or directory.Fr r r r r
� is_file_uri
� z BucketStorageUri.is_file_uric C r� )�2Returns True if this URI names a bucket or object.Tr r r r r
� is_cloud_uri r� z BucketStorageUri.is_cloud_uric C � t | j �S )z�
Returns True if this URI names a directory or bucket. Will return
False for bucket subdirs; providing bucket subdir semantics needs to
be done by the caller (like gsutil does).
�r~ r! r r r r
�names_container s z BucketStorageUri.names_containerc C �
t | j�S )z0Returns True if this URI names a file or object.r� r r r r
�names_singleton �
z BucketStorageUri.names_singletonc C r� �z+Returns True if this URI names a directory.Fr r r r r
�names_directory r� z BucketStorageUri.names_directoryc C r� )�*Returns True if this URI names a provider.)r~ r r r r r
�names_provider" r z BucketStorageUri.names_providerc C s t | j�o
t | j �S )�(Returns True if this URI names a bucket.)r~ r r! r r r r
� names_bucket& s z BucketStorageUri.names_bucketc C r� )�&Returns True if this URI names a file.Fr r r r r
�
names_file* r� zBucketStorageUri.names_filec C � | � � S )�)Returns True if this URI names an object.�r� r r r r
� names_object. � z BucketStorageUri.names_objectc C r� )z8Returns True if this URI represents input/output stream.Fr r r r r
� is_stream2 r� zBucketStorageUri.is_streamrN c C sB | � d� | �� }| jdkr|�| j||||�S |�| j|||�S )Nzcreate_bucket r- )r rA r8 �
create_bucketr )r rJ �location�policyr� r[ r r r
r� 6 s
�z BucketStorageUri.create_bucketc C s | � d� | �� }|�| j|�S )N�
delete_bucket)r rA r� r �r rJ r[ r r r
r� B s
z BucketStorageUri.delete_bucketc C s | � � }|�|�S rB )rA �get_all_bucketsr� r r r
r� G s
z BucketStorageUri.get_all_bucketsc C s" | � � }|j}| �|d| j� |S )Nrp )rA rp r r
)r r[ rp r r r
r� K s z BucketStorageUri.get_providerc C sd | � d� |p | jp d}| �||�}| jr#|j|||| j||d� dS |p'| j}|�||||� dS )z Sets or updates a bucket's ACL.�set_aclrN �rD �
if_generation�if_metagenerationN)r r! rG rD r� rC ) r �
acl_or_strr� rI rJ rC r� r� rL r r r
r� Q s
�
zBucketStorageUri.set_aclc C sf | � d� |p | jp d}| �||�}| jr#|j|||| j||d� dS |p'| j}|j||||d� dS )z2Sets or updates a bucket's ACL with an XML string.� set_xml_aclrN r� rb N)r r! rG rD r� rC ) r � xmlstringr� rI rJ rC r� r� rL r r r
r� _ s
�
�z BucketStorageUri.set_xml_aclc C �" | � d� | �||��||� dS )zASets or updates a bucket's default object ACL with an XML string.�set_def_xml_aclN)r rG r� )r r� rI rJ r r r
r� n s
z BucketStorageUri.set_def_xml_aclc C r� )z.Sets or updates a bucket's default object ACL.� set_def_aclN)r rG r� )r r� rI rJ rC r r r
r� s s
z BucketStorageUri.set_def_aclc C sD | � d� | jd|d� | �||�}| �|d| j� |�||� dS )z>Sets or updates a bucket's acl to a predefined (canned) value.�set_canned_aclrb r] N)r" r) r\ r r
r� �r �acl_strrI rJ rC r] r r r
r� y s
z BucketStorageUri.set_canned_aclc C s8 | � d� | �||�}| �|d| j� |�|||� dS )zXSets or updates a bucket's default object acl to a predefined
(canned) value.zset_def_canned_acl r] N)r r\ r r
�set_def_canned_aclr� r r r
r� � s
z#BucketStorageUri.set_def_canned_aclc C s. | � d� | �||�}|�||| j||� d S )N�set_subresource)r rG r� r! )r r� �valuerI rJ rC rL r r r
r� � s
�z BucketStorageUri.set_subresourcerf c
C sn | � d� | j|d�} | jdkr$|rtj�d� | �|||||||�}
n | �||||||||�}
| �| � |
S )N�set_contents_from_stringrP r- z^Warning: GCS does not support reduced_redundancy; argument ignored by set_contents_from_string)r" r_ r8 r# r$ r% r� r� ) r �srJ �replacerh ri r� r� �reduced_redundancyr] �resultr r r
r� � s
��
z)BucketStorageUri.set_contents_from_stringc
C s� | � d� | j|d�} | jdkr+| j||||||||| |
d�
} |
r*| �d |
jd |� n| jd|
d� | j||||||||| d� } | �| � | S )N�set_contents_from_filerP r- )�size�rewind�res_upload_handler)r� )r� r� )r" r_ r8 r� r� rD r) r� )
r rd rJ r� rh ri r� r� r� r� r� r] r� r r r
r� � s*
�
����
z'BucketStorageUri.set_contents_from_filec C s: | � d� | �d|�}|j||||||d�}| �|� |S )N�set_contents_from_streamF)r� r� )r" r_ r� r� ) r rd rJ r� rh r� r� �dst_keyr� r r r
r� � s
�
z)BucketStorageUri.set_contents_from_stream�STANDARDc C s\ | � d� | jd|d�} |
r | j| j|||||||| |
d�
S | j| j||||||||| d�
S )zReturns newly created key.�copy_keyF)rI rJ )
� new_key_name�src_bucket_name� src_key_name�metadatar� � preserve_acl� encrypt_keyrJ �
query_args�src_generation)
r� r� r� r� �src_version_idr� r� r� rJ r� )r" rG r� r! ) r r� r� r� r� r� r� r� rJ r� r� �
dst_bucketr r r
r� � s$
��zBucketStorageUri.copy_keyc C s* | � d� | �||�}|j|||d� d S )N�enable_loggingrP )r rG r� )r �
target_bucket�
target_prefixrI rJ rC rL r r r
r� � s
z BucketStorageUri.enable_loggingc C s& | � d� | �||�}|j|d� d S )N�disable_loggingrP )r rG r� �r rI rJ rC rL r r r
r� � s
z BucketStorageUri.disable_loggingc C s" | � d� | �||�}|j|d�S )N�get_logging_configrP )r rG r� r� r r r
r� � ra z#BucketStorageUri.get_logging_configc C s> | � d� | �||�}|s|s|�|� d S |�|||� d S )N�set_website_config)r rG � delete_website_configuration�configure_website)r �main_page_suffix� error_keyrI rJ rL r r r
r� � s
z#BucketStorageUri.set_website_configc C r� )N�get_website_config)r rG �get_website_configurationr` r r r
r � r� z#BucketStorageUri.get_website_configc C s | � d� | �d|�}|�|�S )N�get_versioning_configF)r rG �get_versioning_statusr� r r r
r � r� z&BucketStorageUri.get_versioning_configc C s" | � d� | �d|�}|�||�S )N�configure_versioningF)r rG r )r �enabledrJ rL r r r
r � ra z%BucketStorageUri.configure_versioningc C s | � d�j||||d�S )NFrP )r\ �set_remote_metadata)r �
metadata_plus�metadata_minusr� rJ r r r
� set_metadata s
�z BucketStorageUri.set_metadatac C sT | � d� g }|D ]}|�|�� � |j|d _q | �� j|||d�| _| �� | S )N�compose���)� content_typerJ )r" �appendr_ rD r
r� )r �
componentsr rJ �component_keys�surir r r
r
s
�zBucketStorageUri.composec C r� )z+Returns a bucket's lifecycle configuration.�get_lifecycle_config� lifecycle)r rG r r r
)r rI rJ rL �lifecycle_configr r r
r r� z%BucketStorageUri.get_lifecycle_configc C s& | � d� | �||�}|�||� dS )z3Sets or updates a bucket's lifecycle configuration.�configure_lifecycleN)r rG r )r r rI rJ rL r r r
r s
z$BucketStorageUri.configure_lifecyclec C s8 | � d� | jdkrtd| j ��| �d|�}|�|�S )N�get_billing_configr- z/get_billing_config() not supported for %s URIs.F)r r8 r� rG r r� r r r
r $ s
�
z#BucketStorageUri.get_billing_configc C s@ | � d� | jdkrtd| j ��| �||�}|j||d� dS )z1Sets or updates a bucket's billing configuration.�configure_billingr- z.configure_billing() not supported for %s URIs.)�requester_paysrJ N)r r8 r� rG r )r r rI rJ rL r r r
r - s
� z"BucketStorageUri.configure_billingc C s: | � d� | jdkrtd| j ��| �||�}|j|d�S )z0Returns a GCS bucket's encryption configuration.�get_encryption_configr- z2get_encryption_config() not supported for %s URIs.rP )r r8 r� rG r r` r r r
r 8 s
� z&BucketStorageUri.get_encryption_configc C s( | � d� | �||�}|j||d� dS )z-Sets a GCS bucket's encryption configuration.�set_encryption_config)�default_kms_key_namerJ N)r rG r )r r rI rJ rL r r r
r C s
�z&BucketStorageUri.set_encryption_configc C s6 | j s
td| j ��| �|�}|j| j |d�}t|�S )z8Returns True if the object exists or False if it doesn'tz exists on object-less URI (%s)rP )r! r r
rG r\ r~ )r rJ rL r] r r r
�existsK s
zBucketStorageUri.exists)NNr NTNNFru rt rv )FFNrB )NrN NN)rN FNNNN)NTNrf NNF) NTNrf NNNFN)NTNNF)NNr� FFNNN)NFNN)NNFNrs )NFN)Drw rx ry rz �delim�set� capabilitiesr r� r� r� r\ rF 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� 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 � s�
�1
�
�
�
�
�
�
�
�
�
�
�
�
�
�
�
�
�
�
�
�
�
�r c @ s� e Zd ZdZejZd dd�Zdd� Zdd� Z d d
� Z
d d � Z d
d� Z dd� Z
dd� Zdd� Zdd� Zdd� Zdd� Zdd � Zd!d d �Zd S )"�FileStorageUriz�
StorageUri subclass that handles files in the local file system.
Callers should instantiate this class by calling boto.storage_uri().
See file/README about how we map StorageUri operations onto a file system.
Fc C s, d| _ d| _|| _d| | _|| _|| _dS )a� Instantiate a FileStorageUri from a path name.
@type object_name: string
@param object_name: object name
@type debug: boolean
@param debug: whether to enable debugging on this StorageUri
After instantiation the components are available in the following
fields: uri, scheme, bucket_name (always blank for this "anonymous"
bucket), object_name.
r1 rN zfile://N)r8 r r! r
r= �stream)r r! r= r� r r r
r ^ s
zFileStorageUri.__init__c C s t || j| j�S )z�Instantiate a FileStorageUri from the current FileStorageUri,
but replacing the object_name.
@type new_name: string
@param new_name: new object name
)r r= r r� r r r
r� r s z!FileStorageUri.clone_replace_namec C r� )r� Tr r r r r
r� { r� zFileStorageUri.is_file_uric C r� )r� Fr r r r r
r� r� zFileStorageUri.is_cloud_uric C r� )z5Returns True if this URI names a directory or bucket.)r� r r r r
r� � r� z FileStorageUri.names_containerc C s
| � � S )z<Returns True if this URI names a file (or stream) or object.)r� r r r r
r� � r� z FileStorageUri.names_singletonc C s | j rdS tj�| j�S r� )r �os�path�isdirr! r r r r
r� � s z FileStorageUri.names_directoryc C r� )r� Fr r r r r
r� � r� z FileStorageUri.names_providerc C r� )r� Fr r r r r
r� � r� zFileStorageUri.names_bucketc C r� )r� r� r r r r
r� � r� zFileStorageUri.names_filec C r� )r� Fr r r r r
r� � r� zFileStorageUri.names_objectc C r� )zAReturns True if this URI represents input/output stream.
)r~ r r r r r
r� � s
zFileStorageUri.is_streamc C s | � � �� dS )z$Closes the underlying file.
N)r\ �closer r r r
r$ � s zFileStorageUri.closeNc C s t j�| j�S )z6Returns True if the file exists or False if it doesn't)r! r" r r! )r �_headers_not_usedr r r
r � s zFileStorageUri.exists)FrB )rw rx ry rz r! �sepr r r� r� r� r� r� r� r� r� r� r� r� r$ r r r r r
r T s"
r )
�botor! r# r �boto.s3.deletemarkerr �boto.exceptionr r �objectr r r r r r r
�<module> s T e