관리-도구
편집 파일: cleaners.cpython-311.pyc
� �Cg] � � � d dl Z d dlZd dlZd dlmZ d dlmZ d dlmZ d dl Z d dl m Z m Z d dlmZ d dlmZmZmZmZ dZ G d � d e � � ZdS ) � N)�func)�OperationalError)� sessionmaker)�LveStatsPlugin�LveStatsPluginTerminated)� reboot_lock)�history� history_gov� history_x60�incident�shamanc �H � e Zd Zd� Zd� Zd� Zd� Zed� � � Zd� Z d� Z dS ) �HistoryCleanerc � � d| _ d| _ d| _ d| _ d | _ t j d� � | _ d| _ d | _ d S )N� i`T � � r �sqlite) �period�batch�execute_timeout�keep_history_days� db_engine�logging� getLogger�log�db_type� server_id��selfs ��/builddir/build/BUILDROOT/lve-stats-4.2.10-1.el8.x86_64/opt/cloudlinux/venv/lib/python3.11/site-packages/lvestats/plugins/generic/cleaners.py�__init__zHistoryCleaner.__init__ sL � � �� � �� � !�� �!#�� � ����$�%5�6�6��� �� � ����� c � � || _ d S )N)r )r �engines r! � set_db_enginez HistoryCleaner.set_db_engine% s � � ����r# c �, � t |� d| j � � � � | _ t |� dd� � � � dz | _ |� d| j � � | _ |� dd� � | _ d S )Nr r �< r r � localhost)�int�getr r r r )r �configs r! � set_configzHistoryCleaner.set_config( sv � �!$�V�Z�Z�0C�T�E[�%\�%\�!]�!]�� ��&�*�*�X�r�2�2�3�3�b�8�� � �z�z�)�T�\�:�:�� � ���K��=�=����r# c �L � t | j | j dz dz dz z � � S )N� r( )r* �nowr r s r! �time_thresholdz HistoryCleaner.time_threshold. s) � ��4�8�d� 4�r� 9�B� >�� C�C�D�D�Dr# c �� � t j t j j j � � D ]=}t j j � d|i� � }|� | � � �>d S )N�uid)�os�listdir�lvestats�lib�snapshot� SNAPSHOT_PATH�Snapshot� delete_old)�ts_tor3 �snaps r! �clean_old_snapshotsz"HistoryCleaner.clean_old_snapshots1 s^ � ��:�h�l� 3� A�B�B� #� #�C��<�(�1�1�5�#�,�?�?�D� �O�O�E� "� "� "� "� #� #r# c �d � | � � � }| j � d|� � t j � t j j j � � r| � |� � | j � d� � t � � 5 t | j �� � � � }t j � � } | � |t" t" j |� � | � |t& t& j |� � | � |t* t* j |� � |� � � |� t3 j t6 j � � � � � t6 j | j k � � � � � d p|}t? tA tC |� � | j" z tC |� � | j" � � � � D ]�\ }}| � |t6 t6 j |� � |� � � t j � � |z | j# k r$| j � d|||z dz � � n<��| � |t6 t6 j |� � |� � � n�# tH $ rE}|�% � � | j �& tO |� � � � Y d }~nfd }~wtP $ rV}| j � d� � |�% � � |�) � � tQ � � |�d }~ww xY wt j � � |z dz } | j � d | � � |�) � � nM# t j � � |z dz } | j � d | � � |�) � � w xY w d d d � � d S # 1 swxY w Y d S ) Nz2Records with timestamp less then %d will be erasedz"Deleting old records from database)�bindr z Iterations: %s. Deleted: %shr z&Cleaner terminated. Trying to rollbacki� zExecution time: %d)*r1 r �debugr4 �path�existsr6 r7 r8 r9 r> r r r �timeit� default_timer�deleter �createdr �tsr �incident_end_time�commit�queryr �minr �filterr �one� enumerate�ranger* r r r �rollback�warning�strr �close) r �lve_data�t_min�session� start_time� first_created� iteration� timestamp�e�elapseds r! �executezHistoryCleaner.execute7 s� � ��#�#�%�%�� ����K�U�S�S�S� �7�>�>�(�,�/�=� >� >� ,� � $� $�U� +� +� +� ����;�<�<�<� �]�]� # � # �7�l���7�7�7�9�9�G� �-�/�/�J� �� � �G�[�+�2E�u�M�M�M�� � �G�[�+�.�%�H�H�H�� � �G�X�x�/I�5�Q�Q�Q���� � � � �M�M�$�(�7�?�";�";�<�<�C�C�G�DU�Y]�Yg�Dg�h�h�l�l�n�n�op�q� � � � -6�e�C� �<N�<N�QU�Q[�<[�]`�af�]g�]g�im�is�6t�6t�,u�,u� %� %�(�I�y��K�K���'�/�9�M�M�M��N�N�$�$�$� �+�-�-� �:�T�=Q�Q�Q� ���� :�I� �Ta�Ha�fm�Gn�� � � �� R� �K�K���'�/�5�I�I�I��N�N�$�$�$���#� )� )� )�� � �"�"�"��� � ��Q���(�(�(�(�(�(�(�(�����+� 8� 8� 8����� G�H�H�H�� � �"�"�"�� � ����.�0�0�a�7����� 8���� "�/�1�1�J�>�$�F������ 3�W�=�=�=�� � ������ "�/�1�1�J�>�$�F������ 3�W�=�=�=�� � ���������G# � # � # � # � # � # � # � # � # � # � # � # ���� # � # � # � # � # � # s^ � 1P%�G>K�O � M>�;L�O � M>�(AM9�9M>�>O �A P%� A P�P%�%P)�,P)c � � |� |� � � ||k |j | j k � � � d�� � d S )NF)�synchronize_session)rK rM r rF )r rW �table� ts_column�limits r! rF zHistoryCleaner.deletec sW � �� � �e� � �#�#�I��$5�u��$�.�7X�Y�Y�`�`� %� a� � � � � r# N) �__name__� __module__� __qualname__r" r& r- r1 � staticmethodr> r^ rF � r# r! r r s� � � � � � � � � � � � �>� >� >� E� E� E� �#� #� �\�#� * � * � * �X � � � � r# r )r r4 rD � sqlalchemyr �sqlalchemy.excr �sqlalchemy.ormr �lvestats.lib.snapshotr6 �lvestats.core.pluginr r �lvestats.lib.commons.funcr � lvestats.ormr r r r � __author__r rh r# r! �<module>rq s� �� ���� � � � � � � � � � � � � � � +� +� +� +� +� +� '� '� '� '� '� '� � � � � I� I� I� I� I� I� I� I� 1� 1� 1� 1� 1� 1� D� D� D� D� D� D� D� D� D� D� D� D� � �N � N � N � N � N �^� N � N � N � N � N r#