
    \j                     p    d dl mZ d dlmZ d dlmZ d dlmZmZ erd dl m	Z	 d dl
mZ  G d ded	         Zy
)    )TYPE_CHECKING)Batcher)serialize_attribute)Item
PayloadRef)Any)Logc                   :    e Zd ZdZdZdZdZdZed	d       Z	d
dZ
y)
LogBatcherd   i  g      @logz%application/vnd.sentry.items.log+jsonc                 T   d| d   vr| d   | d   d<   d| d   vr| d   | d   d<   t        | d         dz  | j                  dd	      | j                  d
      t        | d         t        | d         | d   j                         D ci c]  \  }}|t	        |       c}}d}|S c c}}w )Nzsentry.severity_number
attributesseverity_numberzsentry.severity_textseverity_texttime_unix_nanog    eAtrace_idz$00000000-0000-0000-0000-000000000000span_idbody)	timestampr   r   levelr   r   )intgetstritemsr   )itemkvress       A/root/env/lib/python3.12/site-packages/sentry_sdk/_log_batcher.py_to_transport_formatzLogBatcher._to_transport_format   s    #4+==;?@Q;RD78!l);;9=o9ND56 T"234u<-STxx	*o./V%8<\8J8P8P8R.4q!&q))	
 
s   B$Nc                     t        | j                  | j                  ddit        d| j	                  |      gi            }| j                  dd|d       y )	N
item_count   r   )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_lostzLogBatcher._record_lost(   sd    **a Wt/H/H/N.O$PQ
 	#$	 	 	
    )r   r	   returnr   )r   r	   r5   N)__name__
__module____qualname__MAX_BEFORE_FLUSHMAX_BEFORE_DROPFLUSH_WAIT_TIMEr/   r0   staticmethodr!   r3    r4   r    r   r      s3    OOD:L &
r4   r   r	   N)typingr   sentry_sdk._batcherr   sentry_sdk.utilsr   sentry_sdk.enveloper   r   r   sentry_sdk._typesr	   r   r=   r4   r    <module>rC      s*      ' 0 0%,
 ,
r4   