📁 File Manager Pro
v10.0.2 | PHP: 8.1.34
Server: LiteSpeed
2026-06-27 15:20:00
📂
/
/
opt
/
hc_python
/
lib
/
python3.12
/
site-packages
/
sentry_sdk
/
integrations
/
redis
/
__pycache__
✏️
Editing: utils.cpython-312.pyc
� Yr*jj � � � d dl mZ d dlmZ d dlmZmZmZmZm Z d dl m Z d dl m Z d dlmZ d dlmZ er d dl mZmZmZmZ d ed d d efd �Zddd efd�Zddd efd�Zded dddd dfd�Zd"d�Zddde d dd e d d d d f d �Z ddde d ed dd d f d!�Z y )#� )� TYPE_CHECKING)�SPANDATA)�"_COMMANDS_INCLUDING_SENSITIVE_DATA� _MAX_NUM_ARGS�_MAX_NUM_COMMANDS�_MULTI_KEY_COMMANDS�_SINGLE_KEY_COMMANDS)�should_send_default_pii)� StreamedSpan)�Span)�SENSITIVE_DATA_SUBSTITUTE)�Any�Optional�Sequence�Union�name�args� Sequence[Any]�returnc � � | g}| j � }t � }t |� D ]� \ }}|t kD r nt|t v r|j t � �/|dk( }|r|j t |� � �Q|r|j t |� � �n|j t � �� dj |� }|S )Nr � ) �lowerr � enumerater r �appendr �repr�join) r r � command_parts�name_low�send_default_pii�i�arg�arg_is_the_key�commands �R/opt/hc_python/lib/python3.12/site-packages/sentry_sdk/integrations/redis/utils.py�_get_safe_commandr% s� � ��F�M��z�z�|�H�.�0���D�/���3� �}� � � �9� 9� � � �!:� ;� ��a��� � � � ��c�� +� � �$�$�T�#�Y�/� �$�$�%>�?� "�" �h�h�}�%�G� �N� �keyr c �x � t | t � r | j � S t | � S # t $ r Y yw xY w)N� )� isinstance�bytes�decode�UnicodeDecodeError�str�r' s r$ � _safe_decoder0 / s< � ��#�u� � ��:�:�<� � �s�8�O�� "� �� �s �- � 9�9c �� � t | t t t f� rdj d� | D � � } | S t | t � r t | � } | S | �d} | S t | � } | S )Nz, c 3 �2 K � | ] }t |� �� � y �w�N)r0 )�.0�xs r$ � <genexpr>z!_key_as_string.<locals>.<genexpr>; s � �� �5��A� �Q���s �r) )r* �dict�list�tupler r+ r0 r. r/ s r$ �_key_as_stringr: 9 sn � ��#��d�E�*�+��i�i�5��5�5�� �J� �C�� ��3� �� �J� ���� �J� �#�h�� �Jr& � method_namezOptional[tuple[Any, ...]]�kwargszOptional[dict[str, Any]]zOptional[tuple[str, ...]]c �v � d}|�#| j � t v r t |� }|S |�Dt |� dk\ r6t |d t t t f� rt |d � }|S |d f}|S |�Id|v rEt |d t t f� r!t |d � dkD rt |d � }|S |d �|d f}|S )z� Gets the key (or keys) from the given method_name. The method_name could be a redis command or a django caching command N� r r' )r r r9 �lenr* r7 r8 )r; r r< r' s r$ � _get_safe_keyr@ F s� � � �C� ��K� -� -� /�3F� F��D�k��$ �J�! � �c�$�i�1�n� �d�1�g��d�E� 2� 3���Q��.�C� �J� ��7�*�C� �J� � ���� �f�U�m�d�E�]� 3��6�%�=�!�A�%��F�5�M�*�� �J� �e�}�(� �e�}�&�� �Jr& c � � | j S r3 )r )r# s r$ �_parse_rediscluster_commandrB h s � � �<�<�r& �spanzUnion[Span, StreamedSpan]� is_cluster�get_command_args_fn�is_transaction� commands_seqNc �< � t | t � ry | j d|� | j d|� g }t |� D ]9 \ }}|t k\ r n+ ||� }|j t |d |dd � � �; | j dt |� |d�� y )N�redis.is_clusterzredis.transactionr r> zredis.commands)�count� first_ten) r* r �set_tagr r r r% �set_datar? ) rC rD rE rF rG �commandsr r! r# s r$ �_set_pipeline_datarO l s� � � �$� �%���L�L�#�Z�0��L�L�$�n�5��H��L�)���3� �!� !� �%�c�*�����)�'�!�*�g�a�b�k�B�C� *� �M�M��� �&�!� �r& c �� � t | t � r#|rg| j t j |� nF| j d|� |r2| j d|� | j t j |� |ro|rl|j � }|t v s|t v rKt |� dk( r<t | t � r| j d|d � y | j d|d � y y y y y )NrI z redis.commandr> z db.redis.keyr z redis.key) r* r � set_attributer �DB_OPERATION_NAMErL � DB_OPERATIONr r r r? )rC rD r r r s r$ �_set_client_datarT � s� � � �$� �%� � � � �x� 9� 9�4� @� � � �'��4� � �L�L� �$� /� �L�L��.�.�� 5� ���:�:�<�� �,� ,� �+� +��D� �Q���$� �-��"�"�>�4��7�;�� � �[�$�q�'�2� 1?� +� �tr& )r# r r r ) �typingr �sentry_sdk.constsr �$sentry_sdk.integrations.redis.constsr r r r r �sentry_sdk.scoper �sentry_sdk.tracesr �sentry_sdk.tracingr �sentry_sdk.utilsr r r r r r. r% r0 r: r@ rB �boolrO rT � r& r$ �<module>r^ s �� � &�� � 5� *� #� 6��5�5��C� �� �3� �6�e� �� � �� �#� � �� � %� � '� � !� �D� � %� �� � � � � � "� � � �>3� %�3�37�3�?B�3�KP�3� �3r&
💾 Save Changes
❌ Cancel