�
_�*j� � �p � d dl mZ d dlmZ d dlmZmZ d dlmZ er d dl m Z d dl
m Z G d� ded � Z y
) � )�
TYPE_CHECKING)�Batcher)�Item�
PayloadRef)�serialize_attribute)�Any)�Logc �: � e Zd ZdZdZdZdZdZed d�� Z d
d�Z
y) �
LogBatcher�d i� g @�logz%application/vnd.sentry.items.log+jsonc
�T � d| d vr | d | d d< d| d vr | d | d d< t | d � dz | j dd � | j d
� t | d � t | d � | d j � D ��ci c] \ }}|t |� �� c}}d �}|S c c}}w )
Nzsentry.severity_number�
attributes�severity_numberzsentry.severity_text�
severity_text�time_unix_nanog e��A�trace_idz$00000000-0000-0000-0000-000000000000�span_id�body)� timestampr r �levelr r )�int�get�str�itemsr )�item�k�v�ress �F/opt/hc_python/lib/python3.12/site-packages/sentry_sdk/_log_batcher.py�_to_transport_formatz LogBatcher._to_transport_format s� � � #�4� �+=� =�;?�@Q�;R�D� � � 7� 8� !��l�);� ;�9=�o�9N�D� � � 5� 6� �T�"2� 3�4�u�<� ����-S�T��x�x� �*���o�.�/���V� �%�8<�\�8J�8P�8P�8R��8R�f�q�!��&�q�)�)�8R��
�� �
�� s �B$Nc � � t | j | j ddit d| j |� gd��� �� }| j dd|d� � y )
N�
item_count� � )�versionr )�json)�type� content_type�headers�payload�queue_overflow�log_item)�reason�
data_categoryr �quantity)r �TYPE� CONTENT_TYPEr r! �_record_lost_func)�selfr r- s r � _record_lostzLogBatcher._record_lost) sj � ����� �*�*� �a�� � � "� 7� 7�� =� >���
��
� � �#�$��� �
� )r r �returnr )r r r7 N) �__name__�
__module__� __qualname__�MAX_BEFORE_FLUSH�MAX_BEFORE_DROP�FLUSH_WAIT_TIMEr1 r2 � staticmethodr! r5 � r6 r r r
s3 � ����O��O� �D�:�L��� ��&
r6 r r N)
�typingr �sentry_sdk._batcherr �sentry_sdk.enveloper r �sentry_sdk.utilsr r �sentry_sdk._typesr r r? r6 r �<module>rE s* �� � '� 0� 0���%�1
��� � 1
r6