관리-도구
편집 파일: sessions.cpython-311.pyc
� �܋f � � � d dl Z d dlZd dlmZmZ d dlmZ d dlZd dlm Z d dl m Z d dl m Z d dlmZ e r*d dlmZ d d lmZ d d lmZ d d lmZ d d lmZ d d lmZ d dlmZ dd�Zedd�� � ZdZdZd� Z G d� de � � Z dS )� N)�Thread�Lock)�contextmanager)�Envelope)�Session)� TYPE_CHECKING)�format_timestamp)�Any)�Callable)�Dict)� Generator)�List)�Optional)�Unionc � � | �t j j } | j j }|�+| j r | j j ni }|� dd� � }|S )z<Utility function to find out if session tracking is enabled.N�auto_session_trackingF)� sentry_sdk�Hub�current�scope� _force_auto_session_tracking�client�options�get)�hub� should_track�client_optionss �J/opt/cloudlinux/venv/lib64/python3.11/site-packages/sentry_sdk/sessions.py� is_auto_session_tracking_enabledr sU � � �{��n�$���9�9�L���/2�z�A���+�+�r��%�)�)�*A�5�I�I� � �� � applicationc # �� K � | �t j j } t | � � }|r| � |�� � dV � |r| � � � dS dS # |r| � � � w w xY w)z8Starts and stops a session automatically around a block.N)� session_mode)r r r r � start_session� end_session)r r# r s r r r % s� � � � � �{��n�$��3�C�8�8�L�� 5� ���|��4�4�4� � ���� � � �O�O� � � � � � � ��<� � �O�O� � � � � ���s �A � A5)�exited�abnormal�crashed�d c �d � t |� � t | � � � � � d�S )N)�attrs� aggregates)�dict�list�values)�aggregate_statesr+ s r �make_aggregate_enveloper1 9 s+ � ��%�[�[��5E�5L�5L�5N�5N�0O�0O� P� P�Pr c �< � e Zd Z d d�Zd� Zd� Zd� Zd� Zd� Zd� Z d S ) �SessionFlusher�< c � � || _ || _ g | _ i | _ d | _ t � � | _ t � � | _ d | _ d| _ d S )NT) � capture_func�flush_interval�pending_sessions�pending_aggregates�_threadr � _thread_lock�_aggregate_lock�_thread_for_pid�_running)�selfr6 r7 s r �__init__zSessionFlusher.__init__? sV � � )��� ,��� "�� �"$�� ��� � �F�F��� #�v�v�� � #�� � �� � � r c � � | j }g | _ | j 5 | j }i | _ d d d � � n # 1 swxY w Y t � � }|D ]W}t |j � � t k r#| � |� � t � � }|� |� � �X|� � � D ]h\ }}t |j � � t k r#| � |� � t � � }|� t ||� � � � �it |j � � dk r| � |� � d S d S )Nr ) r8 r< r9 r �len�items�MAX_ENVELOPE_ITEMSr6 � add_session� add_sessionsr1 )r? r8 r9 �envelope�sessionr+ �statess r �flushzSessionFlusher.flushO s� � � �0�� "�� � � !� )� )�!%�!8� �&(�D� #� )� )� )� )� )� )� )� )� )� )� )���� )� )� )� )� �:�:��'� *� *�G��8�>�"�"�&8�8�8��!�!�(�+�+�+�#�:�:�� � � �� )� )� )� )� /� 5� 5� 7� 7� J� J�M�E�6��8�>�"�"�&8�8�8��!�!�(�+�+�+�#�:�:�� � !� !�"9�&�%�"H�"H� I� I� I� I� �x�~� � �� "� "� � � �h� '� '� '� '� '� #� "s �1�5�5c � � � � j t j � � k r � j �d S � j 5 � j t j � � k r� j � d d d � � d S � fd�}t |�� � }d|_ |� � � |� _ t j � � � _ d d d � � n # 1 swxY w Y d S )Nc � �� � j r=t j � j � � � j r� � � � � j �;d S d S �N)r> �time�sleepr7 rJ �r? s �r r: z/SessionFlusher._ensure_running.<locals>._threadr sW �� ��m� %��J�t� 2�3�3�3��}� %� � � � � � � �m� %� %� %� %� %r )�targetT)r= �os�getpidr: r; r �daemon�start)r? r: �threads ` r �_ensure_runningz SessionFlusher._ensure_runningj s" �� � � �2�9�;�;� .� .�4�<�3K��4� � � /� /��#�r�y�{�{�2�2�t�|�7O�� /� /� /� /� /� /� /� /� %� %� %� %� %� �7�+�+�+�F� �F�M� �L�L�N�N�N�!�D�L�#%�9�;�;�D� � /� /� /� /� /� /� /� /� /� /� /���� /� /� /� /� �ts �%B;� AB;�;B?�B?c � � | j 5 |� d�� � }t t |� � � � � � � }|j }| j � |i � � }|� |i � � }d|vrt |j � � |d< |j dk r |� dd� � dz |d< nl|j dk r |� dd� � dz |d< nD|j dk r |� dd� � dz |d< n |� d d� � dz |d < d d d � � d S # 1 swxY w Y d S ) NF)�with_user_info�startedr( r � r' �erroredr& ) r< �get_json_attrs�tuple�sortedrC �truncated_startedr9 � setdefaultr �statusr �errors)r? rH r+ � primary_key� secondary_keyrI �states r �add_aggregate_sessionz$SessionFlusher.add_aggregate_session� s� � � � !� =� =��*�*�%�*�@�@�E� ��u�{�{�}�}� 5� 5�6�6�K� #� 5�M��,�7�7� �R�H�H�F��%�%�m�R�8�8�E���%�%�#3�G�4M�#N�#N��i� � �~��*�*�#(�9�9�Y��#:�#:�Q�#>��i� � �� �:�-�-�$)�I�I�j�!�$<�$<�q�$@��j�!�!�� �!�#�#�#(�9�9�Y��#:�#:�Q�#>��i� � �"'�)�)�H�a�"8�"8�1�"<��h��% =� =� =� =� =� =� =� =� =� =� =� =���� =� =� =� =� =� =s �D,E�E�Ec �� � |j dk r| � |� � n,| j � |� � � � � | � � � d S )N�request)r# rg r8 �append�to_jsonrW )r? rH s r rE zSessionFlusher.add_session� sb � � � �9� ,� ,� � &� &�w� /� /� /� /� � !� (� (�� � �):�):� ;� ;� ;� � � � � � � � r c � � d| _ d S )NF)r> rP s r �killzSessionFlusher.kill� s � � �� � � r c �. � | � � � d S rM )rm rP s r �__del__zSessionFlusher.__del__� s � � � � � � � � � r N)r4 ) �__name__� __module__� __qualname__r@ rJ rW rg rE rm ro � r r r3 r3 > s� � � � � � � � � � � � (� (� (�6� � �, =� =� =�> � � � � � �� � � � r r3 rM )Nr! ) rR rN � threadingr r � contextlibr r �sentry_sdk.enveloper �sentry_sdk.sessionr �sentry_sdk._typesr �sentry_sdk.utilsr �typingr r r r r r r r r �TERMINAL_SESSION_STATESrD r1 �objectr3 rs r r �<module>r} s� �� � � � � � � � � "� "� "� "� "� "� "� "� %� %� %� %� %� %� � � � � (� (� (� (� (� (� &� &� &� &� &� &� +� +� +� +� +� +� -� -� -� -� -� -�� ������� � � � � � ������� � � � � � ������� � � � � � � � � � � � � � � � � � � � � � � � <� �� �Q� Q� Q� q� q� q� q� q�V� q� q� q� q� qr