婀A" 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)LveStatsPluginLveStatsPluginTerminated) reboot_lock)history history_gov history_x60incidentshamanc 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)
periodbatchexecute_timeoutkeep_history_days db_enginelogging getLoggerlogdb_type server_idselfs /builddir/build/BUILDROOT/lve-stats-4.3.2-1.el9.x86_64/opt/cloudlinux/venv/lib/python3.11/site-packages/lvestats/plugins/generic/cleaners.py__init__zHistoryCleaner.__init__ sL
! !# $%566 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)intgetr r r r )r configs r!
set_configzHistoryCleaner.set_config( sv !$VZZ0CTE[%\%\!]!] &**Xr2233b8 zz)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) 48d 4r 9B > CCDDDr# c t j t j j j D ]_}| st j j dt | i }| | `d S )Nuid)
oslistdirlvestatslibsnapshot
SNAPSHOT_PATHisdigitSnapshotr*
delete_old)ts_tor3 snaps r! clean_old_snapshotsz"HistoryCleaner.clean_old_snapshots1 sx :hl 3 ABB # #C;;==
<(115#c((2CDDD OOE " " " " # #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 pathexistsr6 r7 r8 r9 r? r r r timeit
default_timerdeleter createdr
tsr incident_end_timecommitqueryr minr filterr one enumerateranger* r r r rollbackwarningstrr close)
r lve_datat_minsession
start_time
first_created iteration timestampeelapseds
r! executezHistoryCleaner.execute9 s ##%% KUSSS
7>>(,/= > > , $ $U + + + ;<<<
]] # # 7l77799G -//J
G[+2EuMMM G[+.%HHH GXx/I5QQQ MM$(7?";";<<CCGDUY]YgDghhllnnopq -6eC
$F 3W===
"/11J>$F 3W===
G# # # # # # # # # # # # # # # # # # s^ 1P%G>KO
M>;LO
M>(AM99M>>O
A P%
A
PP%%P),P)c | | ||k |j | j k d d S )NF)synchronize_session)rL rN r rG )r rX table ts_columnlimits r! rG zHistoryCleaner.deletee sW
e ##I$5u$.7XYY`` % a
r# N) __name__
__module__ __qualname__r" r& r- r1 staticmethodr? r_ rG r# r! r r s > > > E E E # # \#* * * X
r# r )r r4 rE
sqlalchemyr sqlalchemy.excr sqlalchemy.ormr lvestats.lib.snapshotr6 lvestats.core.pluginr r lvestats.lib.commons.funcr lvestats.ormr r
r r
__author__r ri r# r! rr 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
P
P
P
P
P
^ P
P
P
P
P
r#