0x1998 - MANAGER
Düzenlenen Dosya: redis_lib.cpython-311.pyc
� �h{ � � � d dl mZ d dlZd dlmZmZmZ d dlmZ d dl m Z m Z d dl mZ G d� de� � Z G d � d e� � Z G d � d e� � ZdS ) � )�absolute_importN)�Optional�Tuple�Dict)�gettext)�ExternalProgramFailed� run_command)� WposErrorc �" � � e Zd ZdZ� fd�Z� xZS )�DeadRedisPurgeAttemptzW Happens when somebody tries to purge redis instance which is not runnning c �f �� t � � � t d� � �� � d S )Nz�Unable to purge cache because cache database is not running. Enable at least one optimization feature to start cache database instance.)�message��super�__init__�_)�self� __class__s ��L/opt/cloudlinux/venv/lib64/python3.11/site-packages/clwpos/user/redis_lib.pyr z DeadRedisPurgeAttempt.__init__ sE �� � ������ Y�"Z� "Z�� [� [� [� [� [� )�__name__� __module__� __qualname__�__doc__r � __classcell__�r s @r r r sK �� � � � � �� � [� [� [� [� [� [� [� [� [r r c �, � � e Zd ZdZdedef� fd� Z� xZS )�PurgeFailedErrorzN Happens when redis is not able to purge cached data for some reason. �std_out�std_errc �z �� t � � � t d� � dd|pd|pdd��� � d S )Nz�Unable to purge cache. Database backend returned error of command "%(command)s" execution. Try again a bit later or contact your system administrator for help.z6stdout: <i>%(stdout)s</i> stderr: <i>%(stderr)s</i> �purge�empty)�command�stdout�stderr)r �details�contextr )r r r r s �r r zPurgeFailedError.__init__# sg �� � ������ ]� ^� ^�4� #�!�,�W�!�,�W�� � � � � � � r )r r r r �strr r r s @r r r sU �� � � � � �� � �� �c� � � � � � � � � � r r c � � e Zd Z ddededdfd�Zd� Zdedeeeef fd �Zde fd �Z de fd �Z de fd �Z dee fd �ZdS )� RedisLibUser� /opt/alt/redis/bin/redis-cli� socket_path�redis_cli_path�returnNc �" � || _ || _ d S )N)r- r. )r r- r. s r r zRedisLibUser.__init__4 s � �&��� ,����r c �L � | j d| j g|� d� � z S )Nz-s� )r. r- �split)r � redis_commands r �get_redis_shell_commandz$RedisLibUser.get_redis_shell_command9 s3 � � � � � � � � � � �� $� $� %� %r r$ c �" � | � |� � } t |d�� � \ }}}n_# t j t f$ rF}t t d� � d� |� � t |� � d��� � �d }~ww xY w|||fS )NT)�return_full_outputz6Error during %(command)s command execution: %(error)sr2 )r$ �error)r r( ) r5 r � subprocess�CalledProcessErrorr r r �joinr) )r r$ r4 � returncoder r r8 s r �run_redis_commandz RedisLibUser.run_redis_command@ s� � � �4�4�W�=�=� � �+6� �$�,� ,� ,� (�J����� �-�/D�E� � � ���S�T�T�$'�H�H�]�$;�$;�c�%�j�j�Q�Q�� � � ����� ���� �7�G�+�+s �- �B �AB�B c � � | � � � st � � �d}| � |� � \ }}}|dk sd|� � � vrt ||� � �d| � � � iS )z4 Clean entire redis cache for user. zflushall asyncr �ok� used_memory)�is_redis_aliver r= �lowerr �get_redis_used_memory)r � purge_commandr< r r s r � purge_rediszRedisLibUser.purge_redisM s� � � �"�"�$�$� *�'�)�)� )�(� �'+�'=�'=�m�'L�'L�$� �G�W� ��?�?�d�'�-�-�/�/� 9� 9�"�7�G�4�4� 4� �4�5�5�7�7� � r c �l � | � d� � \ }}}|dk od|� � � v S )z1 Check if user's redis is alive. �pingr �pong)r= rB �r r< r r s r rA zRedisLibUser.is_redis_alive^ s: � � "&�!7�!7��!?�!?� � �G�Q��Q��<�6�W�]�]�_�_�#<�<r c � � | � d� � \ }}}|dk o7t |� � � � d� � � � dk S )z� Check if user's redis is empty. Example (redis is empty): # Keyspace Example (redis is NOT empty): # Keyspace db0:keys=2,expires=0,avg_ttl=0 z info keyspacer � � )r= �len�stripr3 rI s r �is_redis_emptyzRedisLibUser.is_redis_emptye sP � � "&�!7�!7��!H�!H� � �G�Q��Q��H�3�w�}�}���'<�'<�T�'B�'B�#C�#C�q�#H�Hr c �� � | � d� � \ }}}|� d� � D ];}|� d� � s�|� d� � \ }}|dk r|ndc S dS )aL Return amount of memmory used by user's redis instance in human readable format (kb or mb). If redis status is offline, 'used_memory_value' value is null. 'info memory' command output: # Memory used_memory:369616 used_memory_human:360.95K ... z info memoryrK �used_memory_human�:�nullN)r= r3 � startswith)r r r �line�used_memory_values r rC z"RedisLibUser.get_redis_used_memoryq s� � � �.�.�}�=�=� ��7�A��M�M�$�'�'� N� N�D��?�?�#6�7�7� ��#'�:�:�c�?�?� �A� �(9�V�(C�(C�$�$�� M� M� M� N� Nr )r, )r r r r) r r5 r �intr= r rE �boolrA rO r rC � r r r+ r+ 2 s � � � � � � (F�-� -�C� -�!$�-�JN�-� -� -� -� %� %� %� ,�� ,��s�C��}�1E� ,� ,� ,� ,� �T� � � � �"=�� =� =� =� =� I�� I� I� I� I�N�x��}� N� N� N� N� N� Nr r+ )� __future__r r9 �typingr r r �clwposr r �clcommon.utilsr r �clwpos.cl_wpos_exceptionsr r r �objectr+ rY r r �<module>r` s# �� '� &� &� &� &� &� � � � � (� (� (� (� (� (� (� (� (� (� � � � � � � =� =� =� =� =� =� =� =� /� /� /� /� /� /� [� [� [� [� [�I� [� [� [�� � � � �y� � � �(ON� ON� ON� ON� ON�6� ON� ON� ON� ON� ONr
geri dön