Dashboard
PHP:
8.2.30
OS:
Linux
User:
dh_nv8b2m
/
/
usr
/
lib
/
python3
/
dist-packages
/
awscli
/
customizations
/
s3
/
__pycache__
📤 Upload
📝 New File
📁 New Folder
Close
Editing: utils.cpython-310.pyc
o .&�aJr � @ s� d dl Z d dlZd dlmZ d dlZd dlZd dlZd dlZd dlZd dlm Z m Z d dl m Z d dl mZmZ d dlmZ d dlmZ d dlmZ e�e�Zd Zed d d e� d �Zd Zddddddddd�Ze� d�Z e� d�Z e� d�Z e� d�Z dd� Z!dd� Z"G dd � d e j#�Z$G d d � d e%�Z&G d d � d ej'�Z(d!d"� Z)d#d$� Z*d%d&� Z+d'd(� Z,dYd)d*�Z-dZd,d-�Z.G d.d/� d/e/�Z0d0d1� Z1ej2j3fd2d3�Z4d4d5� Z5G d6d7� d7e%�Z6d8d9� Z7G d:d;� d;e/�Z8G d<d=� d=e d=g d>���Z9e9Z:G d?d@� d@e/�Z;G dAdB� dBe�Z<G dCdD� dDe�Z=G dEdF� dFe=�Z>G dGdH� dHe>�Z?G dIdJ� dJe?�Z@G dKdL� dLe>�ZAG dMdN� dNe�ZBG dOdP� dPeB�ZCG dQdR� dReB�ZDG dSdT� dTe=�ZEG dUdV� dVe�ZFG dWdX� dXe/�ZGdS )[� N)�datetime)� namedtuple�deque)�parse)�tzlocal�tzutc)�BaseSubscriber)� bytes_print)�queue)�KiB�MiB�GiB�TiB�PiB�EiBi� � )�tzinfol � i i @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>.*)$c C sv d}t | �}|dkr dS ||k rd| S tt�D ] \}}||d }t|| | �|k r8d|| | |f S qdS )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. r r z1 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_sizeC s ��r) c C s� | � � } | dd� dkr| dd� � � }n| dd� � � }t| �dko&|tv }|s<zt| �W S ty; td| ��w t| }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���r zInvalid size value: %s)�lower�len� SIZE_SUFFIX�int� ValueError)r! r% �has_size_identifier� multiplierr' r' r( �human_readable_to_bytesc s � �r4 c @ s e Zd ZdZddd�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. Nc C sD t || j�}|r|�||d g� n||d gg}t|| j|� d S �Nr )�getattr�dest�append�setattr)�self�parser� namespace�values� option_string� filter_listr' r' r( �__call__� s zAppendFilter.__call__�N)�__name__� __module__� __qualname__�__doc__rA r' r' r' r( r5 ~ s r5 c @ � e Zd ZdS )�CreateDirectoryErrorN�rC rD rE r' r' r' r( rH � � rH c @ s2 e Zd ZdZd 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 � c C s2 t jj| |d� dd� t|d �D �| _|| _d S )N)�maxsizec S s g | ]}t g ��qS r' )r )�.0r$ r' r' r( � <listcomp>� s z0StablePriorityQueue.__init__.<locals>.<listcomp>r )r �Queue�__init__�range� priorities�default_priority)r; rM � max_priorityr' r' r( rQ � s z StablePriorityQueue.__init__c C s d}| j D ]}|t|�7 }q|S r6 )rS r. )r; �size�bucketr' r' r( �_qsize� s zStablePriorityQueue._qsizec C s* t t|d| j�| j�}| j| �|� d S )N�PRIORITY)�minr7 rT rS r9 )r; �item�priorityr' r' r( �_put� s �zStablePriorityQueue._putc C s | j D ] }|sq|�� S d S rB )rS �popleft)r; rW r' r' r( �_get� s �zStablePriorityQueue._getN)r rL )rC rD rE rF rQ rX r] r_ r' r' r' r( rK � s rK c C s( t �| �r td��t�| �rtd��d S )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 � ��re c C s� t | � t�| �}|r|�d�|�d�fS t�| �}|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�/r r � )re �#_S3_ACCESSPOINT_TO_BUCKET_KEY_REGEXra �group� _S3_OUTPOST_TO_BUCKET_KEY_REGEX�splitr. )rd ra � s3_componentsrW �s3_keyr' r' r( �find_bucket_key� s ro c C s | � 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)� startswithro rc r' r' r( �split_s3_bucket_key� s rr c C st zt �| �}W n ty } ztd| |f ��d}~ww z t�|jt� �}W n ttt fy4 d}Y nw |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�IOErrorr1 r � fromtimestamp�st_mtimer �OSError� OverflowError�st_size)�path�stats�e� update_timer' r' r( � get_file_stat� s ���� r c C s� | d }| d }|d }|d }|du r|d }dt jd�}| d r-|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_key s& ��r� Tc C s2 d}|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_warning0 s �r� c @ s" e Zd ZdZddd�Zdd� ZdS )�StdoutBytesWriterzd This class acts as a file-like object that performs the bytes_print function on write. Nc C � || _ d S rB )�_stdout)r; �stdoutr' r' r( rQ B � zStdoutBytesWriter.__init__c C s t || j� dS )zR Writes data to stdout as bytes. :param b: data to write N)r r� )r; �br' r' r( �writeE s zStdoutBytesWriter.writerB )rC rD rE rF rQ r� r' r' r' r( r� = s r� c C s6 zt �| �d W S ty tjd| dd� Y dS w )zpGiven a filename, guess it's content type. If the type cannot be guessed, a value of None is returned. r z?Unable to guess content type for %s due to UnicodeDecodeError: T)�exc_infoN)� mimetypes� guess_type�UnicodeDecodeError�LOGGER�debug)�filenamer' r' r( �guess_content_typeN s ��r� c C sN zt j�| �\}}t j�||�}t j�||�W S ty& t j�| � Y S w )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. )rs r{ rl �relpath�joinr1 �abspath)r� �start�dirname�basename� relative_dirr' r' r( � relative_pathd s �r� c C sH z t �| ||f� W dS ty# } 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_utimet s ���r� c @ rG )r� NrI r' r' r' r( r� � rJ r� c C s t | ��t� �S rB )r � astimezoner )� date_stringr' r' r( � _date_parser� s r� c @ s* e Zd ZdZefdd�Z ddd�ZdS )� BucketListerzList keys in a bucket.c C � || _ || _d S rB )�_clientr� )r; �client� date_parserr' r' r( rQ � � zBucketLister.__init__Nc c s� � |d|id�}|d ur||d< |d ur|� |� | j�d�}|jd i |��}|D ]#}|�dg �} | D ]} |d | d } | �| d �| d< | | fV q3q)d S ) 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)rC rD rE rF r� rQ r� r' r' r' r( r� � s �r� c s e Zd Zd� fdd� Z� ZS )� PrintTaskFNc s t t| ��| ||||�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)rC rD rE r� � __classcell__r' r' r� r( r� � s r� )r� r� r� r� c @ s e Zd ZdZedd� �Zedd� �Zedd� �Zedd � �Zed d � �Z ed d � �Z edd� �Z edd� �Z edd� �Z edd� �Zedd� �Zedd� �Zedd� �Zed d � �Zed d � �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. c C �@ | � ||� | �||� | �||� | �||� | �||� 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_paramsc C � | � ||� | �||� dS )z*Map CLI params to GetObject request paramsN�r� r� r� r' r' r( �map_get_object_params� � z)RequestParamsMapper.map_get_object_paramsc C sV | � ||� | �||� | �||� | �|� | �||� | �||� | �||� 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_paramsc C r� )z+Map CLI params to HeadObject request paramsNr� r� r' r' r( �map_head_object_params� r� z*RequestParamsMapper.map_head_object_paramsc C r� )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_paramsc C r� )z+Map CLI params to UploadPart request paramsNr� r� r' r' r( �map_upload_part_params� r� z*RequestParamsMapper.map_upload_part_paramsc C r� )z/Map CLI params to UploadPartCopy request paramsN)r� r� r� r' r' r( �map_upload_part_copy_params s �z/RequestParamsMapper.map_upload_part_copy_paramsc C � | � ||� d S rB �r� r� r' r' r( �map_delete_object_params � z,RequestParamsMapper.map_delete_object_paramsc C r� rB r� r� r' r' r( �map_list_objects_v2_params r� z.RequestParamsMapper.map_list_objects_v2_paramsc C � |� d�r |d |d< d S d S )N� request_payer� RequestPayer�r� r� r' r' r( r� � �z,RequestParamsMapper._set_request_payer_paramc C sP ddddddddd d � }|D ]}|� |�r || }|| ||< q| �||� d S ) 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 C sZ |� d�r)|d D ]!}z |�dd�\}}W n ty td��w ||| �|�< q d S d S )N�grants�=r z1grants should be of the form permission=principal)r� rl r1 �_permission_to_param)r� r� r� �grant� permission�granteer' r' r( r / s ��z%RequestParamsMapper._set_grant_paramsc C s8 |dkrdS |dkr dS |dkrdS |dkrdS t d ��) N�read� GrantRead�full�GrantFullControl�readacl� GrantReadACP�writeacl� GrantWriteACPz5permission must be one of: read|readacl|writeacl|full)r1 )r� r r' r' r( r : s z(RequestParamsMapper._permission_to_paramc C r� )N�metadata�Metadatar r� r' r' r( r� G r z(RequestParamsMapper._set_metadata_paramsc C s( |� d�r|� d�sd|d< d S d S d S )Nr' �MetadataDirective�REPLACEr )r� r� r' r' r( r� L s � �z5RequestParamsMapper._auto_populate_metadata_directivec C r� )N�metadata_directiver( r r� r' r' r( r� R s ��z1RequestParamsMapper._set_metadata_directive_paramc C s4 |� d�r |d |d< |� d�r|d |d< d S d S )N�sse�ServerSideEncryption�sse_kms_key_id� SSEKMSKeyIdr r� r' r' r( r� X s �z+RequestParamsMapper._set_sse_request_paramsc C �* |� d�r|d |d< |d |d< d S d S )N�sse_c�SSECustomerAlgorithm� sse_c_key�SSECustomerKeyr r� r' r' r( r� _ s �z-RequestParamsMapper._set_sse_c_request_paramsc C r/ )N�sse_c_copy_source� CopySourceSSECustomerAlgorithm�sse_c_copy_source_key�CopySourceSSECustomerKeyr r� r' r' r( �%_set_sse_c_copy_source_request_paramse s � ��z9RequestParamsMapper._set_sse_c_copy_source_request_paramsc C s | � ||� | �||� d S rB )r� r8 r� r' r' r( r� m r� z=RequestParamsMapper._set_sse_c_and_copy_source_request_paramsN)rC rD rE rF � classmethodr� r� r� r� r� r� r� r� r� r� r� r r r� r� r� r� r� r8 r� r' r' r' r( r� � sT r� c @ � e Zd ZdZdd� Zdd� ZdS )�ProvideSizeSubscriberzK A subscriber which provides the transfer size before it's queued. c C r� rB )rV )r; rV r' r' r( rQ x r� z ProvideSizeSubscriber.__init__c K s |j �| j� d S rB )�meta�provide_transfer_sizerV )r; �futurer� r' r' r( � on_queued{ s z ProvideSizeSubscriber.on_queuedN)rC rD rE rF rQ r? r' r' r' r( r; t s r; c @ s( e Zd ZdZdd� 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 K s\ d }z|� � W n ty } z|}W Y d }~nd }~ww |r'| �||� d S | �|� d S rB )�result� Exception� _on_failure� _on_success)r; r> r� �future_exceptionr} r' r' r( �on_done� s ��z OnDoneFilteredSubscriber.on_donec C � d S rB r' �r; r> r' r' r( rD � � z$OnDoneFilteredSubscriber._on_successc C rG rB r' �r; r> r} r' r' r( rC � rI z$OnDoneFilteredSubscriber._on_failureN)rC rD rE rF rF rD rC r' r' r' r( r@ � s r@ c @ r: )�DeleteSourceSubscriberz6A subscriber which deletes the source of the transfer.c C sB z| � |� W d S ty } z |�|� W Y d }~d S d }~ww rB )�_delete_sourcerB � set_exceptionrJ r' r' r( rD � s ��z"DeleteSourceSubscriber._on_successc C � t d��)Nz_delete_source()��NotImplementedErrorrH r' r' r( rL � � z%DeleteSourceSubscriber._delete_sourceN)rC rD rE rF rD rL r' r' r' r( rK � s rK c @ s0 e Zd ZdZdd� Zdd� Zdd� Zdd � Zd S ) � DeleteSourceObjectSubscriberz%A subscriber which deletes an object.c C r� rB )r� )r; r� r' r' r( rQ � r� z%DeleteSourceObjectSubscriber.__init__c C � |j S rB )rW �r; � call_argsr' r' r( � _get_bucket� � z(DeleteSourceObjectSubscriber._get_bucketc C rS rB )rf rT r' r' r( �_get_key� rW z%DeleteSourceObjectSubscriber._get_keyc C sN |j j}| �|�| �|�d�}|j�d�r |jd |d< | jjdi |�� d S )N)r� r� r� r' )r< rU rV rX r� r� r� � delete_object)r; r> rU �delete_object_kwargsr' r' r( rL � s � �z+DeleteSourceObjectSubscriber._delete_sourceN)rC rD rE rF rQ rV rX rL r' r' r' r( rR � s rR c @ r: )� DeleteCopySourceObjectSubscriberz+A subscriber which deletes the copy source.c C � |j d S )Nr� �� copy_sourcerT r' r' r( rV � r� z,DeleteCopySourceObjectSubscriber._get_bucketc C r\ �Nr� r] rT r' r' r( rX � r� z)DeleteCopySourceObjectSubscriber._get_keyN)rC rD rE rF rV rX r' r' r' r( r[ � s r[ c @ � e Zd ZdZdd� ZdS )�DeleteSourceFileSubscriberz"A subscriber which deletes a file.c C s t �|jjj� d S rB )rs �remover< rU �fileobjrH r' r' r( rL � s z)DeleteSourceFileSubscriber._delete_sourceN)rC rD rE rF rL r' r' r' r( ra � � ra c @ r: )� BaseProvideContentTypeSubscriberz@A subscriber that provides content type when creating s3 objectsc K s, t | �|��}|d ur||jjjd< d S d S )Nr )r� � _get_filenamer< rU r� )r; r> r� � guessed_typer' r' r( r? � s �z*BaseProvideContentTypeSubscriber.on_queuedc C rN )Nz_get_filename()rO rH r' r' r( rf � rQ z.BaseProvideContentTypeSubscriber._get_filenameN)rC rD rE rF r? rf r' r' r' r( re � s re c @ � e Zd Zdd� ZdS )�"ProvideUploadContentTypeSubscriberc C s |j jjS rB )r< rU rc rH r' r' r( rf � r� z0ProvideUploadContentTypeSubscriber._get_filenameN�rC rD rE rf r' r' r' r( ri � � ri c @ rh )� ProvideCopyContentTypeSubscriberc C s |j jjd S r_ )r< rU r^ rH r' r' r( rf � s z.ProvideCopyContentTypeSubscriber._get_filenameNrj r' r' r' r( rl � rk rl c @ r: )�!ProvideLastModifiedTimeSubscriberz Sets utime for a downloaded filec C r� rB )�_last_modified_time� _result_queue)r; �last_modified_time� result_queuer' r' r( rQ � r� z*ProvideLastModifiedTimeSubscriber.__init__c K sx |j jj}z| j�� }t�|�}t|t|�� W d S t y; } zd||f }| j � t ||�� W Y d }~d S d }~ww )NzNSuccessfully Downloaded %s but was unable to update the last modified time. %s) r< rU rc rn � timetuple�time�mktimer� r0 rB ro �putr� )r; r> r� r� �last_update_tuple� mod_timestampr} r� r' r' r( rD � s �� ��z-ProvideLastModifiedTimeSubscriber._on_successN)rC rD rE rF rQ rD r' r' r' r( rm � s rm c @ r` )�DirectoryCreatorSubscriberz4Creates a directory to download if it does not existc K sx t j�|jjj�}zt j�|�st �|� W d S W d S ty; } z|j t j ks0t d||f ��W Y d }~d S d }~ww )Nz!Could not create directory %s: %s) rs r{ r� r< rU rc �exists�makedirsrx r� �EEXISTrH )r; r> r� �dr} r' r' r( r? � s � ����z$DirectoryCreatorSubscriber.on_queuedN)rC rD rE rF r? r' r' r' r( rx � rd rx c @ s" e Zd ZdZdd� 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. c C r� rB )�_fileobj)r; rc r' r' r( rQ r� zNonSeekableStream.__init__Nc C s |d u r | j �� S | j �|�S rB )r~ r )r; �amtr' r' r( r s zNonSeekableStream.readrB )rC rD rE rF rQ r r' r' r' r( r} s r} rB )T)H�argparse�loggingr r� r� rs �rers � collectionsr r �dateutil.parserr � dateutil.tzr r �s3transfer.subscribersr � awscli.compatr r � getLoggerrC r� r � EPOCH_TIME�MAX_UPLOAD_SIZEr/ �compileri rk rb r` r) r4 �Actionr5 rB rH rP rK re ro rr r r� r� �objectr� r� r{ �curdirr� r� r� r� r� r� r� r� r; r@ rK rR r[ ra re ri rl rm rx r} r' r' r' r( �<module> s� � ���� , � <
Save
Cancel