Edit File: cleaners.cpython-311.pyc
� L( e� � �� � d dl mZ d dl mZ d dlmZ d dlZd dlZd dlZd dlm Z d dl m Z d dl m Z d dlmZ d d lmZmZ d d lmZmZmZmZ d dlZd Z G d � d e� � ZdS )� )�absolute_import)�division)�rangeN)� sessionmaker)�OperationalError)�func)� reboot_lock)�LveStatsPlugin�LveStatsPluginTerminated)�history� history_x60� history_gov�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.1-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* s� � �!$�V�Z�Z�0C�04�0F�&H� &H� "I� "I�� ��&�*�*�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_threshold1 s) � ��4�8�d� 4�R� 7�� :�2� =�=�>�>�>r& 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_tor6 �snaps r$ �clean_old_snapshotsz"HistoryCleaner.clean_old_snapshots4 s^ � ��:�h�l� 3� A�B�B� #� #�C��<�(�1�1�5�#�,�?�?�D� �O�O�E� "� "� "� "� #� #r& c �f � | � � � }| j � d|z � � 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 }~nad }~wtP $ rQ | j � d� � |�% � � |�) � � tQ � � �w xY wt j � � |z dz } | j � d | z � � |�) � � nO# t j � � |z dz } | j � d | z � � |�) � � 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)*r4 r �debugr7 �path�existsr9 r: r; r< rA r r r �timeit� default_timer�deleter �createdr �tsr �incident_end_time�commit�queryr �minr �filterr! �one� enumerater r- r r r �rollback�warning�strr �close) r# �lve_data�t_min�session� start_time� first_created� iteration� timestamp�e�elapseds r$ �executezHistoryCleaner.execute: s� � ��#�#�%�%�� ����K�e�S�T�T�T� �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���� � � � '� � �d�h�w��.G�.G� H� H� O� O�PW�Pa�ei�es�Ps� t� t� x� x� z� z�{|� }� !G� BG� �,5�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� ���� :� %� &� � 6�7� C�E� E� E� �� R� �K�K���'�/�5�I�I�I��N�N�$�$�$���#� )� )� )�� � �"�"�"��� � ��Q���(�(�(�(�(�(�(�(�����+� 1� 1� 1����� G�H�H�H�� � �"�"�"�� � ����.�0�0�0� 1���� "�/�1�1�J�>�$�F������ 3�g� =�>�>�>�� � ������ "�/�1�1�J�>�$�F������ 3�g� =�>�>�>�� � ���������C! � ! � ! � ! � ! � ! � ! � ! � ! � ! � ! � ! ���� ! � ! � ! � ! � ! � ! sR �"1P&�G>K�O � M;� ;L �O � A M;�;O �>A P&� A P�P&�&P*�-P*c � � |� |� � � ||k |j | j k � � � d�� � d S )NF)�synchronize_session)rN rP r! rI )r# rY �table� ts_column�limits r$ rI zHistoryCleaner.deleted sF � �� � �e� � � �V�I��%�u��$�.�'H� I� I� �V��V� .� .� .� .� .r& N) �__name__� __module__� __qualname__r% r) r0 r4 � staticmethodrA r` rI � r& r$ r r s� � � � � � � � � � � � �>� >� >�?� ?� ?� �#� #� �\�#� ( � ( � ( �T/� /� /� /� /r& r ) � __future__r r �builtinsr r7 r rG �sqlalchemy.ormr �sqlalchemy.excr � sqlalchemyr �lvestats.lib.commons.funcr �lvestats.core.pluginr r � lvestats.ormr r r r �lvestats.lib.snapshotr9 � __author__r rj r& r$ �<module>ru s+ �� '� &� &� &� &� &� � � � � � � � � � � � � � � � � ���� � � � � '� '� '� '� '� '� +� +� +� +� +� +� � � � � � � 1� 1� 1� 1� 1� 1� I� I� I� I� I� I� I� I� D� D� D� D� D� D� D� D� D� D� D� D� � � � � � �N/� N/� N/� N/� N/�^� N/� N/� N/� N/� N/r&