HEX
Server: Apache
System: Linux pdx1-shared-a1-38 6.6.104-grsec-jammy+ #3 SMP Tue Sep 16 00:28:11 UTC 2025 x86_64
User: mmickelson (3396398)
PHP: 8.1.31
Disabled: NONE
$ pwd: /lib/python3/dist-packages/awscli/customizations/s3/__pycache__/
Upload Files
File: //lib/python3/dist-packages/awscli/customizations/s3/__pycache__/utils.cpython-310.pyc
o

.&�aJr�	@s�ddlZddlZddlmZddlZddlZddlZddlZddlZddlm	Z	m
Z
ddlmZddl
mZmZddlmZddlmZddlmZe�e�Zd	Zed
dde�d�Zd
Zddddddddd�Ze�d�Ze�d�Ze�d�Ze�d�Z dd�Z!dd�Z"Gdd�dej#�Z$Gdd�de%�Z&Gdd �d ej'�Z(d!d"�Z)d#d$�Z*d%d&�Z+d'd(�Z,dYd)d*�Z-dZd,d-�Z.Gd.d/�d/e/�Z0d0d1�Z1ej2j3fd2d3�Z4d4d5�Z5Gd6d7�d7e%�Z6d8d9�Z7Gd:d;�d;e/�Z8Gd<d=�d=e	d=gd>���Z9e9Z:Gd?d@�d@e/�Z;GdAdB�dBe�Z<GdCdD�dDe�Z=GdEdF�dFe=�Z>GdGdH�dHe>�Z?GdIdJ�dJe?�Z@GdKdL�dLe>�ZAGdMdN�dNe�ZBGdOdP�dPeB�ZCGdQdR�dReB�ZDGdSdT�dTe=�ZEGdUdV�dVe�ZFGdWdX�dXe/�ZGdS)[�N)�datetime)�
namedtuple�deque)�parse)�tzlocal�tzutc)�BaseSubscriber)�bytes_print)�queue)�KiB�MiB�GiB�TiB�PiB�EiBi��)�tzinfol�ii@l)�kb�mb�gb�tb�kib�mib�gib�tibzT^(?P<bucket>arn:(aws).*:s3:[a-z\-0-9]*:[0-9]{12}:accesspoint[:/][^/]+)/?(?P<key>.*)$z�^(?P<bucket>arn:(aws).*:s3-outposts:[a-z\-0-9]+:[0-9]{12}:outpost[/:][a-zA-Z0-9\-]{1,63}[/:]accesspoint[/:][a-zA-Z0-9\-]{1,63})[/:]?(?P<key>.*)$z�^(?P<bucket>arn:(aws).*:s3-outposts:[a-z\-0-9]+:[0-9]{12}:outpost[/:][a-zA-Z0-9\-]{1,63}[/:]bucket[/:][a-zA-Z0-9\-]{1,63})[/:]?(?P<key>.*)$zs^(?P<bucket>arn:(aws).*:s3-object-lambda:[a-z\-0-9]+:[0-9]{12}:accesspoint[/:][a-zA-Z0-9\-]{1,63})[/:]?(?P<key>.*)$cCsvd}t|�}|dkrdS||krd|Stt�D] \}}||d}t|||�|kr8d||||fSqdS)a�Convert a size in bytes into a human readable format.

    For example::

        >>> human_readable_size(1)
        '1 Byte'
        >>> human_readable_size(10)
        '10 Bytes'
        >>> human_readable_size(1024)
        '1.0 KiB'
        >>> human_readable_size(1024 * 1024)
        '1.0 MiB'

    :param value: The size in bytes.
    :return: The size in a human readable format based on base-2 units.

    rrz1 Bytez%d Bytes�z%.1f %sN)�float�	enumerate�HUMANIZE_SUFFIXES�round)�value�base�	bytes_int�i�suffix�unit�r'�@/usr/lib/python3/dist-packages/awscli/customizations/s3/utils.py�human_readable_sizeCs��r)cCs�|��}|dd�dkr|dd���}n|dd���}t|�dko&|tv}|s<zt|�WSty;td|��wt|}t|dt|���|S)aConverts a human readable size to bytes.

    :param value: A string such as "10MB".  If a suffix is not included,
        then the value is assumed to be an integer representing the size
        in bytes.
    :returns: The converted value in bytes as an integer

    ���N�ib���rzInvalid size value: %s)�lower�len�SIZE_SUFFIX�int�
ValueError)r!r%�has_size_identifier�
multiplierr'r'r(�human_readable_to_bytescs	�
�r4c@seZdZdZddd�ZdS)�AppendFiltera�
    This class is used as an action when parsing the parameters.
    Specifically it is used for actions corresponding to exclude
    and include filters.  What it does is that it appends a list
    consisting of the name of the parameter and its value onto
    a list containing these [parameter, value] lists.  In this
    case, the name of the parameter will either be --include or
    --exclude and the value will be the rule to apply.  This will
    format all of the rules inputted into the command line
    in a way compatible with the Filter class.  Note that rules that
    appear later in the command line take preference over rulers that
    appear earlier.
    NcCsDt||j�}|r|�||dg�n||dgg}t||j|�dS�Nr)�getattr�dest�append�setattr)�self�parser�	namespace�values�
option_string�filter_listr'r'r(�__call__�s
zAppendFilter.__call__�N)�__name__�
__module__�__qualname__�__doc__rAr'r'r'r(r5~s
r5c@�eZdZdS)�CreateDirectoryErrorN�rCrDrEr'r'r'r(rH��rHc@s2eZdZdZd
dd�Zdd�Zdd	�Zd
d�ZdS)�StablePriorityQueuea�Priority queue that maintains FIFO order for same priority items.

    This class was written to handle the tasks created in
    awscli.customizations.s3.tasks, but it's possible to use this
    class outside of that context.  In order for this to be the case,
    the following conditions should be met:

        * Objects that are queued should have a PRIORITY attribute.
          This should be an integer value not to exceed the max_priority
          value passed into the ``__init__``.  Objects with lower
          priority numbers are retrieved before objects with higher
          priority numbers.
        * A relatively small max_priority should be chosen.  ``get()``
          calls are O(max_priority).

    Any object that does not have a ``PRIORITY`` attribute or whose
    priority exceeds ``max_priority`` will be queued at the highest
    (least important) priority available.

    r�cCs2tjj||d�dd�t|d�D�|_||_dS)N)�maxsizecSsg|]}tg��qSr')r)�.0r$r'r'r(�
<listcomp>�sz0StablePriorityQueue.__init__.<locals>.<listcomp>r)r
�Queue�__init__�range�
priorities�default_priority)r;rM�max_priorityr'r'r(rQ�s
zStablePriorityQueue.__init__cCs d}|jD]}|t|�7}q|Sr6)rSr.)r;�size�bucketr'r'r(�_qsize�s
zStablePriorityQueue._qsizecCs*tt|d|j�|j�}|j|�|�dS)N�PRIORITY)�minr7rTrSr9)r;�item�priorityr'r'r(�_put�s�zStablePriorityQueue._putcCs |jD]
}|sq|��SdSrB)rS�popleft)r;rWr'r'r(�_get�s

�zStablePriorityQueue._getN)rrL)rCrDrErFrQrXr]r_r'r'r'r(rK�s
rKcCs(t�|�r	td��t�|�rtd��dS)NzRs3 commands do not support S3 Object Lambda resources. Use s3api commands instead.zOs3 commands do not support Outpost Bucket ARNs. Use s3control commands instead.)�%_S3_OBJECT_LAMBDA_TO_BUCKET_KEY_REGEX�matchr1�*_S3_OUTPOST_BUCKET_ARN_TO_BUCKET_KEY_REGEX��s3_pathr'r'r(�block_unsupported_resources�s
�
��recCs�t|�t�|�}|r|�d�|�d�fSt�|�}|r&|�d�|�d�fS|�dd�}|d}d}t|�dkr<|d}||fS)z�
    This is a helper function that given an s3 path such that the path is of
    the form: bucket/key
    It will return the bucket and the key represented by the s3 path
    rW�key�/rr�)re�#_S3_ACCESSPOINT_TO_BUCKET_KEY_REGEXra�group�_S3_OUTPOST_TO_BUCKET_KEY_REGEX�splitr.)rdra�
s3_componentsrW�s3_keyr'r'r(�find_bucket_key�s

rocCs|�d�r|dd�}t|�S)z�Split s3 path into bucket and key prefix.

    This will also handle the s3:// prefix.

    :return: Tuple of ('bucketname', 'keyname')

    zs3://�N)�
startswithrorcr'r'r(�split_s3_bucket_key�s
rrc
Cstzt�|�}Wnty}ztd||f��d}~wwz
t�|jt��}Wnttt	fy4d}Ynw|j
|fS)z�
    This is a helper function that given a local path return the size of
    the file in bytes and time of last modification.
    z(Could not retrieve file stat of "%s": %sN)�os�stat�IOErrorr1r�
fromtimestamp�st_mtimer�OSError�
OverflowError�st_size)�path�stats�e�update_timer'r'r(�
get_file_stat�s����
	rc
Cs�|d}|d}|d}|d}|dur|d}dtjd�}|dr-|t|d�d�}n	|�||�d	}|�||d�}|d
rV|d}	|	|�||||�7}	|	|fS|d}	|	|fS)z�
    This is a helper function that determines the destination path and compare
    key given parameters received from the ``FileFormat`` class.
    �srcr8�typeNr{rg)�s3�local�dir_op����use_src_name)rs�sepr.rl�replace)
�files�src_pathr�r8�src_type�	dest_type�	sep_table�rel_path�compare_key�	dest_pathr'r'r(�find_dest_path_comp_keys&��r�TcCs2d}|r|d|d}||}t|ddd�}|S)zN
    This creates a ``PrintTask`` for whenever a warning is to be thrown.
    z	warning: zSkipping file z. FT)�message�error�warning)�
WarningResult)r{�
error_message�	skip_file�print_string�warning_messager'r'r(�create_warning0s�r�c@s"eZdZdZddd�Zdd�ZdS)�StdoutBytesWriterzd
    This class acts as a file-like object that performs the bytes_print
    function on write.
    NcC�
||_dSrB)�_stdout)r;�stdoutr'r'r(rQB�
zStdoutBytesWriter.__init__cCst||j�dS)zR
        Writes data to stdout as bytes.

        :param b: data to write
        N)r	r�)r;�br'r'r(�writeEszStdoutBytesWriter.writerB)rCrDrErFrQr�r'r'r'r(r�=s
r�cCs6zt�|�dWStytjd|dd�YdSw)zpGiven a filename, guess it's content type.

    If the type cannot be guessed, a value of None is returned.
    rz?Unable to guess content type for %s due to UnicodeDecodeError: T)�exc_infoN)�	mimetypes�
guess_type�UnicodeDecodeError�LOGGER�debug)�filenamer'r'r(�guess_content_typeNs	��r�cCsNztj�|�\}}tj�||�}tj�||�WSty&tj�|�YSw)z�Cross platform relative path of a filename.

    If no relative path can be calculated (i.e different
    drives on Windows), then instead of raising a ValueError,
    the absolute path is returned.

    )rsr{rl�relpath�joinr1�abspath)r��start�dirname�basename�relative_dirr'r'r(�
relative_pathds�r�c
CsHzt�|||f�WdSty#}z|jtjkr|�td��d}~ww)aB
    Set the utime of a file, and if it fails, raise a more explicit error.

    :param filename: the file to modify
    :param desired_time: the epoch timestamp to set for atime and mtime.
    :raises: SetFileUtimeError: if you do not have permission (errno 1)
    :raises: OSError: for all errors other than errno 1
    zrThe file was downloaded, but attempting to modify the utime of the file failed. Is the file owned by another user?N)rs�utimerx�errno�EPERM�SetFileUtimeError)r��desired_timer}r'r'r(�set_file_utimets	���r�c@rG)r�NrIr'r'r'r(r��rJr�cCst|��t��SrB)r�
astimezoner)�date_stringr'r'r(�_date_parser�sr�c@s*eZdZdZefdd�Z		ddd�ZdS)�BucketListerzList keys in a bucket.cC�||_||_dSrB)�_clientr�)r;�client�date_parserr'r'r(rQ��
zBucketLister.__init__Nccs��|d|id�}|dur||d<|dur|�|�|j�d�}|jd	i|��}|D]#}|�dg�}	|	D]}
|d|
d}|�|
d�|
d<||
fVq3q)dS)
N�PageSize)�Bucket�PaginationConfig�Prefix�list_objects_v2�Contentsrg�Key�LastModifiedr')�updater��
get_paginator�paginate�getr�)r;rW�prefix�	page_size�
extra_args�kwargs�	paginator�pages�page�contents�content�source_pathr'r'r(�list_objects�s$�
���zBucketLister.list_objects)NNN)rCrDrErFr�rQr�r'r'r'r(r��s�r�cseZdZd�fdd�	Z�ZS)�	PrintTaskFNcstt|��|||||�S)aN
        :param message: An arbitrary string associated with the entry.   This
            can be used to communicate the result of the task.
        :param error: Boolean indicating a failure.
        :param total_parts: The total number of parts for multipart transfers.
        :param warning: Boolean indicating a warning
        )�superr��__new__)�clsr�r��total_partsr���	__class__r'r(r��s�zPrintTask.__new__)FNN)rCrDrEr��
__classcell__r'r'r�r(r��sr�)r�r�r�r�c@seZdZdZedd��Zedd��Zedd��Zedd	��Zed
d��Z	edd
��Z
edd��Zedd��Zedd��Z
edd��Zedd��Zedd��Zedd��Zedd��Zedd��Zed d!��Zed"d#��Zed$d%��Zed&d'��Zed(d)��Zd*S)+�RequestParamsMappera�A utility class that maps CLI params to request params

    Each method in the class maps to a particular operation and will set
    the request parameters depending on the operation and CLI parameters
    provided. For each of the class's methods the parameters are as follows:

    :type request_params: dict
    :param request_params: A dictionary to be filled out with the appropriate
        parameters for the specified client operation using the current CLI
        parameters

    :type cli_params: dict
    :param cli_params: A dictionary of the current CLI params that will be
        used to generate the request parameters for the specified operation

    For example, take the mapping of request parameters for PutObject::

        >>> cli_request_params = {'sse': 'AES256', 'storage_class': 'GLACIER'}
        >>> request_params = {}
        >>> RequestParamsMapper.map_put_object_params(
                request_params, cli_request_params)
        >>> print(request_params)
        {'StorageClass': 'GLACIER', 'ServerSideEncryption': 'AES256'}

    Note that existing parameters in ``request_params`` will be overridden if
    a parameter in ``cli_params`` maps to the existing parameter.
    cC�@|�||�|�||�|�||�|�||�|�||�dS)z*Map CLI params to PutObject request paramsN)�_set_general_object_params�_set_metadata_params�_set_sse_request_params�_set_sse_c_request_params�_set_request_payer_param�r��request_params�
cli_paramsr'r'r(�map_put_object_params��
z)RequestParamsMapper.map_put_object_paramscC�|�||�|�||�dS)z*Map CLI params to GetObject request paramsN�r�r�r�r'r'r(�map_get_object_params��z)RequestParamsMapper.map_get_object_paramscCsV|�||�|�||�|�||�|�|�|�||�|�||�|�||�dS)z+Map CLI params to CopyObject request paramsN)r��_set_metadata_directive_paramr��!_auto_populate_metadata_directiver��)_set_sse_c_and_copy_source_request_paramsr�r�r'r'r(�map_copy_object_params�s
�z*RequestParamsMapper.map_copy_object_paramscCr�)z+Map CLI params to HeadObject request paramsNr�r�r'r'r(�map_head_object_params�r�z*RequestParamsMapper.map_head_object_paramscCr�)z6Map CLI params to CreateMultipartUpload request paramsN)r�r�r�r�r�r�r'r'r(�"map_create_multipart_upload_params�r�z6RequestParamsMapper.map_create_multipart_upload_paramscCr�)z+Map CLI params to UploadPart request paramsNr�r�r'r'r(�map_upload_part_params�r�z*RequestParamsMapper.map_upload_part_paramscCr�)z/Map CLI params to UploadPartCopy request paramsN)r�r�r�r'r'r(�map_upload_part_copy_paramss�z/RequestParamsMapper.map_upload_part_copy_paramscC�|�||�dSrB�r�r�r'r'r(�map_delete_object_params�z,RequestParamsMapper.map_delete_object_paramscCr�rBr�r�r'r'r(�map_list_objects_v2_paramsr�z.RequestParamsMapper.map_list_objects_v2_paramscC�|�d�r
|d|d<dSdS)N�
request_payer�RequestPayer�r�r�r'r'r(r��
�z,RequestParamsMapper._set_request_payer_paramc
CsPddddddddd	d
�	}|D]}|�|�r||}||||<q|�||�dS)N�ACL�StorageClass�WebsiteRedirectLocation�ContentType�CacheControl�ContentDisposition�ContentEncoding�ContentLanguage�Expires)	�acl�
storage_class�website_redirect�content_type�
cache_control�content_disposition�content_encoding�content_language�expires)r��_set_grant_params)r�r�r��general_param_translation�cli_param_name�request_param_namer'r'r(r�s �
�z.RequestParamsMapper._set_general_object_paramsc	CsZ|�d�r)|dD]!}z
|�dd�\}}Wnty td��w|||�|�<q	dSdS)N�grants�=rz1grants should be of the form permission=principal)r�rlr1�_permission_to_param)r�r�r��grant�
permission�granteer'r'r(r/s
��z%RequestParamsMapper._set_grant_paramscCs8|dkrdS|dkrdS|dkrdS|dkrdStd	��)
N�read�	GrantRead�full�GrantFullControl�readacl�GrantReadACP�writeacl�
GrantWriteACPz5permission must be one of: read|readacl|writeacl|full)r1)r�rr'r'r(r:sz(RequestParamsMapper._permission_to_paramcCr�)N�metadata�Metadatarr�r'r'r(r�Grz(RequestParamsMapper._set_metadata_paramscCs(|�d�r|�d�sd|d<dSdSdS)Nr'�MetadataDirective�REPLACEr)r�r�r'r'r(r�Ls

��z5RequestParamsMapper._auto_populate_metadata_directivecCr�)N�metadata_directiver(rr�r'r'r(r�Rs

��z1RequestParamsMapper._set_metadata_directive_paramcCs4|�d�r|d|d<|�d�r|d|d<dSdS)N�sse�ServerSideEncryption�sse_kms_key_id�SSEKMSKeyIdrr�r'r'r(r�Xs


�z+RequestParamsMapper._set_sse_request_paramscC�*|�d�r|d|d<|d|d<dSdS)N�sse_c�SSECustomerAlgorithm�	sse_c_key�SSECustomerKeyrr�r'r'r(r�_s
�z-RequestParamsMapper._set_sse_c_request_paramscCr/)N�sse_c_copy_source�CopySourceSSECustomerAlgorithm�sse_c_copy_source_key�CopySourceSSECustomerKeyrr�r'r'r(�%_set_sse_c_copy_source_request_paramses
���z9RequestParamsMapper._set_sse_c_copy_source_request_paramscCs|�||�|�||�dSrB)r�r8r�r'r'r(r�mr�z=RequestParamsMapper._set_sse_c_and_copy_source_request_paramsN)rCrDrErF�classmethodr�r�r�r�r�r�r�r�r�r�r�rrr�r�r�r�r�r8r�r'r'r'r(r��sT



















r�c@� eZdZdZdd�Zdd�ZdS)�ProvideSizeSubscriberzK
    A subscriber which provides the transfer size before it's queued.
    cCr�rB)rV)r;rVr'r'r(rQxr�zProvideSizeSubscriber.__init__cKs|j�|j�dSrB)�meta�provide_transfer_sizerV)r;�futurer�r'r'r(�	on_queued{szProvideSizeSubscriber.on_queuedN)rCrDrErFrQr?r'r'r'r(r;tsr;c@s(eZdZdZdd�Zdd�Zdd�ZdS)	�OnDoneFilteredSubscriberz�Subscriber that differentiates between successes and failures

    It is really a convenience class so developers do not have to have
    to constantly remember to have a general try/except around future.result()
    c
Ks\d}z|��Wnty}z|}WYd}~nd}~ww|r'|�||�dS|�|�dSrB)�result�	Exception�_on_failure�_on_success)r;r>r��future_exceptionr}r'r'r(�on_done�s��z OnDoneFilteredSubscriber.on_donecC�dSrBr'�r;r>r'r'r(rD��z$OnDoneFilteredSubscriber._on_successcCrGrBr'�r;r>r}r'r'r(rC�rIz$OnDoneFilteredSubscriber._on_failureN)rCrDrErFrFrDrCr'r'r'r(r@�s
r@c@r:)�DeleteSourceSubscriberz6A subscriber which deletes the source of the transfer.c
CsBz|�|�WdSty }z|�|�WYd}~dSd}~wwrB)�_delete_sourcerB�
set_exceptionrJr'r'r(rD�s��z"DeleteSourceSubscriber._on_successcC�td��)Nz_delete_source()��NotImplementedErrorrHr'r'r(rL��z%DeleteSourceSubscriber._delete_sourceN)rCrDrErFrDrLr'r'r'r(rK�srKc@s0eZdZdZdd�Zdd�Zdd�Zdd	�Zd
S)�DeleteSourceObjectSubscriberz%A subscriber which deletes an object.cCr�rB)r�)r;r�r'r'r(rQ�r�z%DeleteSourceObjectSubscriber.__init__cC�|jSrB)rW�r;�	call_argsr'r'r(�_get_bucket��z(DeleteSourceObjectSubscriber._get_bucketcCrSrB)rfrTr'r'r(�_get_key�rWz%DeleteSourceObjectSubscriber._get_keycCsN|jj}|�|�|�|�d�}|j�d�r|jd|d<|jjdi|��dS)N)r�r�r�r')r<rUrVrXr�r�r��
delete_object)r;r>rU�delete_object_kwargsr'r'r(rL�s��z+DeleteSourceObjectSubscriber._delete_sourceN)rCrDrErFrQrVrXrLr'r'r'r(rR�srRc@r:)� DeleteCopySourceObjectSubscriberz+A subscriber which deletes the copy source.cC�
|jdS)Nr���copy_sourcerTr'r'r(rV�r�z,DeleteCopySourceObjectSubscriber._get_bucketcCr\�Nr�r]rTr'r'r(rX�r�z)DeleteCopySourceObjectSubscriber._get_keyN)rCrDrErFrVrXr'r'r'r(r[�sr[c@�eZdZdZdd�ZdS)�DeleteSourceFileSubscriberz"A subscriber which deletes a file.cCst�|jjj�dSrB)rs�remover<rU�fileobjrHr'r'r(rL�sz)DeleteSourceFileSubscriber._delete_sourceN)rCrDrErFrLr'r'r'r(ra��rac@r:)� BaseProvideContentTypeSubscriberz@A subscriber that provides content type when creating s3 objectscKs,t|�|��}|dur||jjjd<dSdS)Nr)r��
_get_filenamer<rUr�)r;r>r��guessed_typer'r'r(r?�s�z*BaseProvideContentTypeSubscriber.on_queuedcCrN)Nz_get_filename()rOrHr'r'r(rf�rQz.BaseProvideContentTypeSubscriber._get_filenameN)rCrDrErFr?rfr'r'r'r(re�srec@�eZdZdd�ZdS)�"ProvideUploadContentTypeSubscribercCs
|jjjSrB)r<rUrcrHr'r'r(rf�r�z0ProvideUploadContentTypeSubscriber._get_filenameN�rCrDrErfr'r'r'r(ri��ric@rh)� ProvideCopyContentTypeSubscribercCs|jjjdSr_)r<rUr^rHr'r'r(rf�sz.ProvideCopyContentTypeSubscriber._get_filenameNrjr'r'r'r(rl�rkrlc@r:)�!ProvideLastModifiedTimeSubscriberz Sets utime for a downloaded filecCr�rB)�_last_modified_time�
_result_queue)r;�last_modified_time�result_queuer'r'r(rQ�r�z*ProvideLastModifiedTimeSubscriber.__init__c
Ksx|jjj}z|j��}t�|�}t|t|��WdSt	y;}zd||f}|j
�t||��WYd}~dSd}~ww)NzNSuccessfully Downloaded %s but was unable to update the last modified time. %s)
r<rUrcrn�	timetuple�time�mktimer�r0rBro�putr�)r;r>r�r��last_update_tuple�
mod_timestampr}r�r'r'r(rD�s


�� ��z-ProvideLastModifiedTimeSubscriber._on_successN)rCrDrErFrQrDr'r'r'r(rm�srmc@r`)�DirectoryCreatorSubscriberz4Creates a directory to download if it does not existc
Ksxtj�|jjj�}ztj�|�st�|�WdSWdSty;}z|j	t	j
ks0td||f��WYd}~dSd}~ww)Nz!Could not create directory %s: %s)rsr{r�r<rUrc�exists�makedirsrxr��EEXISTrH)r;r>r��dr}r'r'r(r?�s�
����z$DirectoryCreatorSubscriber.on_queuedN)rCrDrErFr?r'r'r'r(rx�rdrxc@s"eZdZdZdd�Zddd�ZdS)�NonSeekableStreama�Wrap a file like object as a non seekable stream.

    This class is used to wrap an existing file like object
    such that it only has a ``.read()`` method.

    There are some file like objects that aren't truly seekable
    but appear to be.  For example, on windows, sys.stdin has
    a ``seek()`` method, and calling ``seek(0)`` even appears
    to work.  However, subsequent ``.read()`` calls will just
    return an empty string.

    Consumers of these file like object have no way of knowing
    if these files are truly seekable or not, so this class
    can be used to force non-seekable behavior when you know
    for certain that a fileobj is non seekable.

    cCr�rB)�_fileobj)r;rcr'r'r(rQr�zNonSeekableStream.__init__NcCs|dur	|j��S|j�|�SrB)r~r)r;�amtr'r'r(rs
zNonSeekableStream.readrB)rCrDrErFrQrr'r'r'r(r}sr}rB)T)H�argparse�loggingrr�r�rs�rers�collectionsrr�dateutil.parserr�dateutil.tzrr�s3transfer.subscribersr�
awscli.compatr	r
�	getLoggerrCr�r�
EPOCH_TIME�MAX_UPLOAD_SIZEr/�compilerirkrbr`r)r4�Actionr5rBrHrPrKrerorrrr�r��objectr�r�r{�curdirr�r�r�r�r�r�r�r�r;r@rKrRr[rarerirlrmrxr}r'r'r'r(�<module>s�
�
���� ,


�
<	
@ Telegram