OwlCyberSecurity - MANAGER
Edit File: boto3.cpython-312.pyc
� G��g; � �2 � d dl mZ d dlZd dlmZmZ d dlmZmZm Z d dl m Z d dl m Z mZmZmZ d dlmZ erd dlmZ d d lmZ d d lmZ d d lmZ d d lmZ d d lmZ d dl m Z d dl m Z G d� de� Z! ee!� d� � Z"d� Z#d� Z$y# e $ r e d� �w xY w)� )�partialN)�OP�SPANDATA)�_check_minimum_version� Integration� DidNotEnable)�Span)�capture_internal_exceptions�ensure_integration_enabled� parse_url� parse_version)� TYPE_CHECKING)�Any)�Dict)�Optional)�Type)� __version__)� BaseClient)� StreamingBody)� AWSRequestzbotocore is not installedc �* � e Zd ZdZde� �Zed� � Zy)�Boto3Integration�boto3z auto.http.c � �� t t � } t t | d� t j ��fd�}|t _ y )N�botocorec �T �� �| g|��i |�� | j }|j j j � }|j j dt t |�� � |j j dt � |j j dt � y )Nzrequest-created)� service_idz after-callzafter-call-error) �meta� service_modelr � hyphenize�events�registerr �_sentry_request_created�_sentry_after_call�_sentry_after_call_error)�self�args�kwargsr r � orig_inits ��L/opt/hc_python/lib/python3.12/site-packages/sentry_sdk/integrations/boto3.py�sentry_patched_initz8Boto3Integration.setup_once.<locals>.sentry_patched_init+ s� �� � �d� ,�T� ,�V� ,��9�9�D� �+�+�6�6�@�@�B�J� �K�K� � �!��/�J�G� � �K�K� � � �/A� B� �K�K� � �!3�5M� N� )r �BOTOCORE_VERSIONr r r �__init__)�versionr+ r) s @r* � setup_oncezBoto3Integration.setup_once# s8 �� � � 0�1�� � /��*�E� �'�'� � O� 2� �r, N)�__name__� __module__� __qualname__� identifier�origin� staticmethodr0 � r, r* r r s% � ��J��*� � &�F��2� �2r, r c � � d| �d|��}t j t j |t j �� }t � 5 t |j d�� }|j d|j � |j t j |j � |j t j |j � d d d � |j d| � |j d|� |j t j |j" � |j% � ||j& d < y # 1 sw Y �wxY w) Nzaws.�.��op�namer5 F)�sanitizezaws.request.urlzaws.service_idzaws.operation_name�_sentrysdk_span)� sentry_sdk� start_spanr � HTTP_CLIENTr r5 r r �url�set_datar � HTTP_QUERY�query� HTTP_FRAGMENT�fragment�set_tag� HTTP_METHOD�method� __enter__�context)r �request�operation_namer( � description�span� parsed_urls r* r# r# : s� � � ",�^�<�K� � � � �>�>� � �&�&� �D� %� &� �w�{�{�U�;� � � � �'�� � �8� � � �h�)�)�:�+;�+;�<� � � �h�,�,�j�.A�.A�B� '� �L�L�!�:�.��L�L�%�~�6��M�M�(�&�&����7� �N�N�� *.�G�O�O�%�&�! '� &�s �BE�Ec �v ��� � | j dd � }|�y |j d d d � |j d� }t |t � sy |j t j |j t j �� � |j �|j ��� fd�}||_ �� fd�}||_ y )Nr> �Bodyr: c �z �� �| i |��}|s�j � |S # t $ r �j � � w xY w�N)�finish� Exception)r' r( �ret� orig_read�streaming_spans ��r* �sentry_streaming_body_readz6_sentry_after_call.<locals>.sentry_streaming_body_readm sI �� � ��T�,�V�,�C�� �%�%�'��J��� � � !� !� #� � �s � �:c �6 �� �j � �| i |�� y rU )rV )r' r( � orig_closerZ s ��r* �sentry_streaming_body_closez7_sentry_after_call.<locals>.sentry_streaming_body_closez s �� �� � � ��D�#�F�#r, ) �pop�__exit__�get� isinstancer � start_childr �HTTP_CLIENT_STREAMrO r r5 �read�close) rL �parsedr( rP �bodyr[ r^ r] rY rZ s @@@r* r$ r$ W s� �� � �;�;�(�$� /�D� �|���M�M�$��d�#� �:�:�f� �D� �d�M� *���%�%� � � � � � � �&�&� &� �N� � � �I����J� � +�D�I�$� -�D�Jr, c �f � | j dd � }|�y |j t |� |d � y )Nr> )r_ r` �type)rL � exceptionr( rP s r* r% r% � s1 � � �;�;�(�$� /�D� �|���M�M�$�y�/�9�d�3r, )%� functoolsr r? �sentry_sdk.constsr r �sentry_sdk.integrationsr r r �sentry_sdk.tracingr �sentry_sdk.utilsr r r r �typingr r r r r r r r- �botocore.clientr �botocore.responser �botocore.awsrequestr � ImportErrorr r# r$ r% r7 r, r* �<module>rv s� �� � � *� U� U� #�� � !���� ��4�8�*�/�.� 2�{� 2�6 � ,�-�.� .�.�8(-�V4��O � 4� �2� 3�3�4�s �B �B