📁 File Manager Pro
v10.0.3 | PHP: 8.2.31
Server: LiteSpeed
2026-06-28 07:34:14
📂
/ (Root)
/
opt
/
hc_python
/
lib
/
python3.12
/
site-packages
/
sentry_sdk
/
integrations
/
redis
/
__pycache__
📍 /opt/hc_python/lib/python3.12/site-packages/sentry_sdk/integrations/redis/__pycache__
🔄 Refresh
✏️
Editing: redis_cluster.cpython-312.pyc
Read Only
� |�*jx � �� � d Z ddlmZ ddlmZmZ ddlmZ ddlm Z ddl m Z er&ddlm Z m Z ddlmZ dd lmZ ddlmZ dd lmZ dd lmZ dd �Z dd�Z dd�Zdd�Zy )z� Instrumentation for RedisCluster This is part of the main redis-py client. https://github.com/redis/redis-py/blob/master/redis/cluster.py � )� TYPE_CHECKING)�patch_redis_client�patch_redis_pipeline)�_set_db_data_on_span)�_parse_rediscluster_command)�capture_internal_exceptions)�Any�Union)� RedisCluster)�ClusterPipeline)� StreamedSpan)�SpanNc �p � |j � }|�$|j �t | |j � y y y )N)�get_default_node�connection_kwargsr )�span� async_redis_cluster_instance� default_nodes �Z/opt/hc_python/lib/python3.12/site-packages/sentry_sdk/integrations/redis/redis_cluster.py�_set_async_cluster_db_datar ! s< � � 0�@�@�B�L�� �L�$B�$B�$N� �T�<�#A�#A�B� %O� � c � � t � 5 t |dd � }|� |j }t | |� d d d � y # 1 sw Y y xY w)N�cluster_client)r �getattr�_clientr )r �%async_redis_cluster_pipeline_instance�clients r �#_set_async_cluster_pipeline_db_datar * sL � � %� &��>�@P�RV�W�� �>� 6�=�=� � #� � � � '� &� &�s �(<�Ac �t � |j � }|�&|j |j d�}t | |� y y )N)�host�port)r r r! r )r �redis_cluster_instancer �connection_paramss r �_set_cluster_db_datar$ ? sD � � *�:�:�<�L�� � �%�%� �%�%� �� �T�#4�5� r c �D � ddl m} m} t | dt �� t |j dt t �� ddl m} ddl m }m } ||j dt �� ||j dt t �� y# t $ r Y �Rw xY w# t $ r Y yw xY w) zLPatches the cluster module on redis SDK (as opposed to rediscluster library)r )r �clusterT)� is_cluster�set_db_data_fn)r' �get_command_args_fnr( )r& )�patch_redis_async_client�patch_redis_async_pipelineN)�redisr r& r r$ r r r � ImportError� redis.asyncio�+sentry_sdk.integrations.redis._async_commonr* r+ r r )r r& � async_clusterr* r+ s r �_patch_redis_clusterr1 L s� � � �/� � ��/� � � � #� #�� ;�/� � �:� � !� � &� &��5� � #� � )� )�� ;�>� ��= � � � ��" � � � �s" �B �B � B�B� B � B )r �Union[Span, StreamedSpan]r zAsyncRedisCluster[Any]�returnN)r r2 r zAsyncClusterPipeline[Any]r3 N)r r2 r" zRedisCluster[Any]r3 N)r3 N) �__doc__�typingr �*sentry_sdk.integrations.redis._sync_commonr r �-sentry_sdk.integrations.redis.modules.queriesr �#sentry_sdk.integrations.redis.utilsr �sentry_sdk.utilsr r r r, r �redis.asyncio.clusterr �AsyncClusterPipeline�AsyncRedisCluster�sentry_sdk.tracesr �sentry_sdk.tracingr r r r$ r1 � r r �<module>r@ s� ��� !�� O� K� 8��!�"��� /�'�C� %�C�":�C� �C� � %� �+F� � � �* 6� %� 6�?R� 6� � 6�' r
💾 Save Changes
❌ Cancel