] d dl Z d dlZd dlZd dlmZ d dlmZ d dlmZ d dl m
Z
d dl m Z d dl
mZ dZ G d d
e ZdS ) N)SQLAlchemyError)ClPwd)LveStatsPlugin) reboot_lock)dbgov_io_bytes_value) history_govi c e Zd ZdZ ej dej Z ee j
j Z
d Zd Zd Zd Zd Zd Zd S )
DBGovSaverz/var/lve/dbgovernor/zgovernor\.[0-9]+$c t j t | _ d| _ d | _ dt fd dt fdt fdt fd d d dt fdt fdt fd t fd
t fd t ff| _ t | j | _ t | _
| j
d | _ d S )
N localhostusernamesum_cpu sum_writesum_readnumber_of_restrictslimit_cpu_on_period_endlimit_read_on_period_endlimit_write_on_period_endcause_of_restrictuidi )logging getLogger__name__logger server_idenginestrfloatintheaderslen _headers_lenr cl_pwdget_sys_min_uidmin_uid)selfs /builddir/build/BUILDROOT/lve-stats-4.3.2-1.el9.x86_64/opt/cloudlinux/venv/lib/python3.11/site-packages/lvestats/plugins/generic/dbgov_saver.py__init__zDBGovSaver.__init__ s '11 $
%
"C (
& ,
' -
(# .
# &
CL
- -gg {22377 c F | d| j | _ d S )Nr )getr )r& configs r'
set_configzDBGovSaver.set_config4 s K @@r) c | j | S # | j j $ r'}| j d|| Y d }~dS d }~ww xY w)Nz#Can not obtain user id for "%s"; %s)r# get_uidNoSuchUserExceptionr debug)r& r
es r' get_user_idzDBGovSaver.get_user_id7 si ;&&x00 0{. K CXq Q Q Q22222 s A A
Ac
# K t j | j r s
7>>$/ * * ,4,3RZ5P5PQQE
,
,, " T_a @ @I iw??? <7(/(9(9(;(;
< < < < < < < < < < < < < < <#]22222 = = =K''(;<<<<<) , , , i5FQXYYY ,]a#'99;; )) > %)#$h- * (m+++, , , , , , , , , , , , , , , , , ,
,
,s` 7C B7+ C 7B; ;C >B; ? C $E!/ E! ;E E!E E!E E! E!c g }g }t | D ]\ }\ }}t |k r nw|D ]\} j d| | d } t
| d d }
j |
d} | t d t j | D | d r| d dk r
| d | d< | d j k r| | +# t t" f$ r j d
| Y Zw xY w| | i } t' 5 |r fd |D }
|
D ]b}|d }|d t) |d
|d t+ |d d t) |d |d d| |< c| t. j |
nE# t4 t6 f$ r1} j t9 | Y d}~nd}~ww xY w t; t= t> j | n# tB $ r Y nw xY wddd n # 1 swxY w Y | S )z
:type scanned: generator
:type conn: sqlalchemy.engine.base.Connection
:rtype: list(dict(str, int|str))
z write: %s;.r/ )r tsc J g | ] \ }}||d |d | f!S )r ).0h_v_s r'
z*DBGovSaver.write_to_db..i s7 'o'o'ovr2ln'oA1b (:'o'o'or) r r r
z?Can not parse file %s; data from file not be writen to databasec j g | ]/}fd t | D 0S )c . i | ]\ }}|j v ||S rZ )_history_gov_col)r[ kvr& s r'
z5DBGovSaver.write_to_db... s, XXX$!QQ$BW=W=WA=W=W=Wr) )listitems)r[ dr& s r' r^ z*DBGovSaver.write_to_db.. sI , , ,]^XXXX$qwwyy//XXX, , ,r) r r r r rY r r ) cpu_limitio_limit cpu_usageio_usageN)" enumerateMAX_FILES_PER_TRANSACTIONr r2 stripsplitr r updatedictzipr r+ r4 r% append
IndexError
ValueErrorrH r r roundexecuter __table__insertr KeyErrorr re mapr< unlinkOSError)r& connscanned values_list unlink_listn_rN linesline line_splitedfile_timestampvalues data_for_cmvalues_list_filtered
dbgov_datar r3 s ` r' write_to_dbzDBGovSaver.write_to_dbX s &/&8&8 * * "B"E(2--
v
vvK%%k4888#'::<<#5#5c#:#:L%( )=)=b)A%B%BN+/> P PFMM$'o'oT\[gIhIh'o'o'o"p"pqqq #JJu - - M "::e,,q00(,(8(8
9K(L(Lu
e} 44#**6222"J/ v v vK''(iktuuuuuv y ) ) ) ) ]]
00, , , ,bm, , ,( ';
( /)34M)N(< *+E F
SnHo) ) */z)/Da)H)H( > @ @AA8 8 80A A A , , ,4? ? ?B
r) r
)r r< r sqlalchemy.excr clcommon.clpwdr lvestats.core.pluginr lvestats.lib.commons.funcr lvestats.lib.commons.sizeutilr lvestats.orm.history_govr rm r
rZ r) r' r s * * * * * * / / / / / / 1 1 1 1 1 1 > > > > > > 0 0 0 0 0 0 O O O O O O O O O Or)