|
Server : nginx/1.24.0 System : Linux ip-172-31-33-48 6.14.0-1011-aws #11~24.04.1-Ubuntu SMP Fri Aug 1 02:07:25 UTC 2025 x86_64 User : www-data ( 33) PHP Version : 8.3.6 Disable Function : NONE Directory : /lib/python3/dist-packages/botocore/__pycache__/ |
Upload File : |
�
P��e; � � � d dl Z d dlmZ d dlmZ d dlmZ d dlm Z d dl
m Z d dl m
Z
mZmZ d dlmZ d d l
mZ d d
lmZ e j& e� Z G d � d e� Zd
� Zy)� N)�IOBase)�
ProtocolError)�ReadTimeoutError)�parsers)�set_socket_timeout)�IncompleteReadErrorr �ResponseStreamingError)� ScalarTypes)�
XMLParseError)�first_non_none_responsec �~ � e Zd ZdZdZd� Zd� Zd� Zd� Zdd�Z d � Z
d
� Z d � Z d � Z
d
� Ze Zedfd�Zefd�Zd� Zd� Zd� Zy)�
StreamingBodyae Wrapper class for an http response body.
This provides a few additional conveniences that do not exist
in the urllib3 model:
* Set the timeout on the socket (i.e read() timeouts)
* Auto validation of content length, if the amount of bytes
we read does not match the content length, an exception
is raised.
i c �. � || _ || _ d| _ y )Nr )� _raw_stream�_content_length� _amount_read)�self�
raw_stream�content_lengths �3/usr/lib/python3/dist-packages/botocore/response.py�__init__zStreamingBody.__init__5 s � �%��� -�� � ��� c � � y �N� �r s r �__del__zStreamingBody.__del__: s � �
r c �| � t | j |� y# t $ r t j dd�� � w xY w)z&Set the timeout seconds on the socket.zbCannot access the socket object of a streaming response. It's possible the interface has changed.T)�exc_infoN)r r �AttributeError�logger�error)r �timeouts r r z StreamingBody.set_socket_timeout@ sF � � � �t� /� /�� 9�� � � �L�L�-� �
�
�
� �s � �";c �V � | j j � S # t $ r Y yw xY w)NF)r �readabler r s r r% zStreamingBody.readableW s. � � ��#�#�,�,�.� .�� � �� �s � � (�(Nc �, � | j j |� }| xj t |� z
c_ |�|s|dkD r| j � |S # t $ r }t |j |�� �d}~wt
$ r}t
|�� �d}~ww xY w)zhRead at most amt bytes from the stream.
If the amt argument is omitted, read all data.
)� endpoint_urlr" N)r" r )
r �read�URLLib3ReadTimeoutErrorr �url�URLLib3ProtocolErrorr r �len�_verify_content_length)r �amt�chunk�es r r( zStreamingBody.read] s� � �
2��$�$�)�)�#�.�E�
���S��Z�'�� �;�u��q��
� '� '� )�� �� '� @�"����Q�?� ?��#� 2�(�q�1� 1�� 2�s# �A � B� A6�6 B� B�Bc �6 � | j j � S r )r � readlinesr s r r2 zStreamingBody.readlinesq s � �� � �)�)�+�+r c �8 � | j | j � S )z:Return an iterator to yield 1k chunks from the raw stream.)� iter_chunks�_DEFAULT_CHUNK_SIZEr s r �__iter__zStreamingBody.__iter__t s � �� � �� 8� 8�9�9r c �T � | j | j � }|r|S t � �)z-Return the next 1k chunk from the raw stream.)r( r5 �
StopIteration)r �
current_chunks r �__next__zStreamingBody.__next__x s' � � � � �$�":�":�;�
� � � ��o� r c � � | j S r )r r s r � __enter__zStreamingBody.__enter__ s � �� � � r c �8 � | j j � y r �r �close)r �type�value� tracebacks r �__exit__zStreamingBody.__exit__� s � � ��� � � r Fc # �� K � d}| j |� D ]; }||z j d� }|dd D ] }|j |� d �� � |d }�= |r|j |� d �� yy�w)z�Return an iterator to yield lines from the raw stream.
This is achieved by reading chunk of bytes (of size chunk_size) at a
time from the raw stream, and then yielding lines from there.
r TN���r )r4 �
splitlines)r �
chunk_size�keepends�pendingr/ �lines�lines r �
iter_lineszStreamingBody.iter_lines� s� � �� � ���%�%�j�1� �E� �u�_�0�0��6�E� �c�r�
�
3���o�o�h�/��2�2�
3��B�i�G� �
��$�$�X�.�q�1� 1� �s �A,A.c # �D K � | j |� }|dk( ry|�� � �w)z\Return an iterator to yield chunks of chunk_size bytes from the raw
stream.
r N)r( )r rG r9 s r r4 zStreamingBody.iter_chunks� s/ � �� � � �I�I�j� 1�M� ��#�� � � �s � c � � | j �M| j t | j � k7 r*t | j t | j � �� �y y )N)� actual_bytes�expected_bytes)r r �intr r s r r- z$StreamingBody._verify_content_length� s\ � � � � � +��0A�0A�S� � � �F
� 1
� &� !� .� .� "�4�#7�#7� 8��
�1
� +r c �6 � | j j � S r )r �tellr s r rS zStreamingBody.tell� s � �� � �$�$�&�&r c �8 � | j j � y)z*Close the underlying http response stream.Nr> r s r r? zStreamingBody.close� s � � ��� � � r r )�__name__�
__module__� __qualname__�__doc__r5 r r r r% r( r2 r6 r: r< rC �nextrL r4 r- rS r? r r r r r & sk � �
� �� �
� �.� �(,�:� � �!� �D�$7�%�
2� &9� �
�'�!r r c �v � | j d }|j |j d�}|d dk\ r|j |d< nG| j r,t |j |d j d� � |d< n|j |d< t j |� }||j || j � fS )N�protocol)�headers� status_coder] i, �bodyr\ zcontent-length) �metadatar\ r] �content�has_streaming_outputr �raw�getr �
create_parser�parse� output_shape)�operation_model�
http_responser[ �
response_dict�parsers r � get_responserk � s� � � �'�'�
�3�H� �(�(�$�0�0��M� �]�#�s�*� -� 5� 5�
�f� � � -� -� -� � � �}�Y� 7� ;� ;�<L� M�!
�
�f� � !.� 5� 5�
�f� �
�
"�
"�8�
,�F� �&�,�,���3�3�� � r )�logging�ior �urllib3.exceptionsr r+ r r) �botocorer �botocore.compatr �botocore.exceptionsr r r
r �botocore.hooksr � getLoggerrU r! r rk r r r �<module>rt sV �� � � D� J� � .�� � !� )� 2�
�� � �8� $��K!�F� K!�\r