📁 File Manager Pro
v10.0.3 | PHP: 8.2.31
Server: LiteSpeed
2026-06-28 03:35:19
📂
/ (Root)
/
opt
/
hc_python
/
lib
/
python3.12
/
site-packages
/
sentry_sdk
/
integrations
/
__pycache__
📍 /opt/hc_python/lib/python3.12/site-packages/sentry_sdk/integrations/__pycache__
🔄 Refresh
✏️
Editing: clickhouse_driver.cpython-312.pyc
Read Only
� |�*jb � �b � d dl mZmZ d dlZd dlmZmZ d dlmZm Z m Z d dl m Z d dl mZ d dlmZmZ erd dlmZ d d l mZmZmZ n G d � d � Z G d � d � Z e� Z d dlmZ d dlmZ d dl m Z G d� de � Z ed� Z ed� Z!dd�Z"dd�Z#dd�Z$d d�Z%y# e $ r ed� �w xY w) � )� TYPE_CHECKING�TypeVarN)�OP�SPANDATA)� DidNotEnable� Integration�_check_minimum_version)�should_send_default_pii)�Span)�capture_internal_exceptions�ensure_integration_enabled)�Iterator)�Any�Callable� ParamSpecc � � e Zd Zd� Zy)r c � � d | _ d | _ y �N)�args�kwargs��self�_s �X/opt/hc_python/lib/python3.12/site-packages/sentry_sdk/integrations/clickhouse_driver.py�__init__zParamSpec.__init__ s � � �D�I� �D�K� N)�__name__� __module__� __qualname__r � r r r r s � � r r c � � e Zd Zd� Zy)� _Callablec � � y r r r s r � __getitem__z_Callable.__getitem__ s � �r N)r r r r$ r r r r" r" s � � r r" )�VERSION)�Client)� Connectionz clickhouse-driver not installed.c �, � e Zd ZdZde� �Zedd�� Zy)�ClickhouseDriverIntegration�clickhouse_driverzauto.db.Nc �p � t t t � t t j � t _ t � t t j � t _ t t d� r"t t j � t _ t t j � t _ y )N�receive_end_of_insert_query) r r) r% � _wrap_startr' � send_query�_wrap_send_data� _wrap_endr& �receive_end_of_query�hasattrr, �receive_resultr r r � setup_oncez&ClickhouseDriverIntegration.setup_once/ su � � � :�G�D� !,�J�,A�,A� B� � � �� '0��0K�0K�&L��#� �6�8� 9�1:��2�2�2�F� .� !*�&�*?�*?� @�� r ��returnN)r r r � identifier�origin� staticmethodr4 r r r r) r) + s' � �$�J�� �|� $�F��A� �Ar r) �P�Tc �: � � t t � � d� fd� � }|S )Nc �� �� | d }| d }t | � dkD r| d n|j d� }t | � dkD r| d n|j d� }t j t j |t j �� }||_ t ||� |j d|� |r|j d |� |r t � r|j d |� �| i |��}|S ) Nr � � �query_id� �params)�op�namer8 �queryz db.query_id� db.params) �len�get� sentry_sdk� start_spanr �DBr) r8 � _sentry_span� _set_db_data�set_datar ) r r � connectionrE r@ rB �span�ret�fs �r �_innerz_wrap_start.<locals>._innerI s� �� ��!�W� ��Q��� !�$�i�!�m�4��7����J�1G�� ��I��M��a��v�z�z�(�/C���$�$��u�u��.�5�5� �� #'� � ��T�:�&� � � �g�u�%� � �M�M�-�� 2� �-�/� �M�M�+�v� .� �� �� ��� r �r zP.argsr zP.kwargsr6 r; )r r) )rR rS s ` r r- r- H s% �� � � ;�Q�?�� @��: �Mr c � � � d� fd� }|S )Nc �p �� �| i |��}| d }t |j dd � }|��|� t � r|j d|� t � 5 |j j |j j d� d|j �� d d d � |j � |S # 1 sw Y �xY w)Nr rL z db.resultrE )�message�category�data) �getattrrO r rN r �scope�add_breadcrumb�_data�pop�finish)r r �res�instancerP rR s �r � _inner_endz _wrap_end.<locals>._inner_endk s� �� ��� �� ����7���x�*�*�N�D�A�� � ���#:�#<�� � �k�3�/�,�.�� � �)�)� �J�J�N�N�7� 3�g�D�J�J� *� � /� �K�K�M�� � /�.�s �AB,�,B5rT r )rR rb s ` r r0 r0 j s �� ��$ �r c �J �� t j � d�fd� } | t _ y )Nc �f �� � � t | j dd � }|��t || j � t � rf|j j dg � � t |t t f� r� j |� n|� d� � fd� } |� }|j d� � � | ||||g|��i |��S )NrL rF c 3 �F �K � �D ] } �j | � | �� � y �wr )�append)�item� db_params� orig_datas ��r �wrapped_generatorzD_wrap_send_data.<locals>._inner_send_data.<locals>.wrapped_generator� s$ �� �� �$-�D� %� ,� ,�T� 2�"&�J� %.�s � !)r6 z Iterator[Any]) rZ rO rM r r] rH � isinstance�list�tuple�extendrN ) r � sample_blockrY � types_check�columnarr r rP rj rh ri �original_send_datas @@�r �_inner_send_dataz)_wrap_send_data.<locals>._inner_send_data� s� �� � �t�����=�� � � ��t��� /�&�(� �J�J�N�N�;�� ;� � �d�T�5�M�2� �$�$�T�*� !%�I� '� -�.�D�� � �k�9�5�!� �,��k�8� �>B� �FL� � r )FF)r& � send_data)rs rr s @r r/ r/ � s% �� � �)�)�� ?D� �D (�F�r c �� � | j t j d� | j t j d� | j t j |j � | j t j |j � | j t j |j � | j t j |j � y )N� clickhousezclickhouse-driver) rN r � DB_SYSTEM�DB_DRIVER_NAME�SERVER_ADDRESS�host� SERVER_PORT�port�DB_NAME�database�DB_USER�user)rP rO s r rM rM � s� � ��M�M�(�$�$�l�3��M�M�(�)�)�+>�?��M�M�(�)�)�:�?�?�;��M�M�(�&�&� ���8��M�M�(�"�"�J�$7�$7�8��M�M�(�"�"�J�O�O�4r )rR �Callable[P, T]r6 r� r5 )rP r rO r' r6 N)&�typingr r rI �sentry_sdk.constsr r �sentry_sdk.integrationsr r r �sentry_sdk.scoper �sentry_sdk.tracingr �sentry_sdk.utilsr r �collections.abcr r r r r" r* r% �clickhouse_driver.clientr& � clickhouse_driver.connectionr' � ImportErrorr) r: r; r- r0 r/ rM r r r �<module>r� s� �� )� � *� U� U� 4� #� T� �(�/�/� � � � � �{�H�;�)�/��A�+� A�2 �c�N�� �C�L�� �D�,%(�P5��C � ;� �9� :�:�;�s �"B � B.
💾 Save Changes
❌ Cancel