"\W d dl Z d dlZd dlZd dlZd dlZd dlZd dlmZmZ d dl m
Z
d dl m Z m
Z
mZ d dlmZ dZ G d de
Z G d d
e
Z G d d e
ZdS )
N)ExternalProgramFailed run_command)LveStatsPlugin)atomic_write_csvatomic_write_strdeserialize_lve_id)mempages_to_bytesiseletskc 8 e Zd ZddZd Zed Zd ZdS ) FileSaver
/var/lve/infoc F || _ t j d | _ dS )z:type fname: strzplugin.file_saverNfnamelogging getLoggerlogselfr s /builddir/build/BUILDROOT/lve-stats-4.3.2-1.el9.x86_64/opt/cloudlinux/venv/lib/python3.11/site-packages/lvestats/plugins/generic/persistors.py__init__zFileSaver.__init__ s
$%899 c t | j | dS # t $ r,}| j d| j | Y d}~dS d}~ww xY w)z9
:type output: list
:rtype: None
%Error during saving the "%s" file: %sN)r r OSErrorr error)r outputes r writezFileSaver.write sq
S TZ 0 0 0 0 0 S S S HNNBDJPQ R R R R R R R R R Ss
A!A
Ac | j |j k pR| j |j k pB| j |j k p2| j |j k p"| j |j k p| j dz |j k }|dk r| j |j k }nd}|p|S )z
:type lve_usage: lvestats.plugins.generic.aggregators.AggregatedLveUsage
:type lve_stat: lvestat.LVEStat
:type lve_version: int
F)lepcpulcpulmemlmemphylnprocioliops)lve_stat lve_usage lve_versionres1res2s r compare_limitszFileSaver.compare_limits' s
LIM )
2|y~-
2} .
2 9#44
2 )"22
2
{T!Y\1
??>Y_4DDD|tr c ` |d }| di }|d }g }| D ]"\ }}g }| |t |j t |j t |j t |j t |j t |j t |j
t |j t |j t |j
t |j t |j t |j t |j dt |j dz t |j dz g |dk r;| t |j t |j g | dgdt- | z
z | |j | |j | |j | | $| D ]\ }} t7 | \ }}
|
r|r||vrd|vr| j d B| | |d |
rAg }| |dt | j dt | j dt | j ddt | j ddt | j ddddt | j g |dk r)| t | j dg | dgdt- | z
z | d | d | d | | | | d S ) z:type lve_data: dict LVE_VERSION lve_usage_5sstatsr r! z/No defaults collected to compare with, skipping)r+ r, r- N)!getitemsextendintmepr# cpu_usager% mem_usager& mem_fault mep_faultr' memphy memphy_faultr( nproc nproc_faultio_usager) r* iopslenappend cpu_fault
iops_faultio_faultr r warningr0 r$ r ) r lve_datar- usagesnew output_rowslve_idvdata new_lvestat is_resellers r executezFileSaver.execute= s }- nb11w ' % ' %IFAD KKJJJJ $$KK $$KK $$ $$ NNMM''MMLL
&&
OOt+II%%
, a AG AF
KKSYY/ 0 0 0
KK $ $ $ KK % % % KK
# # # t $ $ $ $#&99;; 5 - 5 - FK"4V"<"< FK
/
-&..F??H$$%VWWW && vay^i&jj '- DKK " 0 0 0 0 0 1 1 3 4 4 2 3 3 / /% , #a'' #K$5 6 6 ! KKSYY 7888KKNNNKKNNNKKNNN &&t,,,
; r N)r
)__name__
__module__ __qualname__r r staticmethodr0 rV r r r r si : : : :
S S S \ *e e e e e r r c l e Zd ZdZddZd Zd Zed Zd Z d Z
d Z d
Z d Z
d Zd
Zd ZdS )MySQLTopFileSaverz/usr/sbin/dbtop /var/lve/cloudlinux_dbtop.jsonc || _ d| _ t j d | _ | | _ | j r| d S d S )Nz/var/lve/governor.tsz"plugin.cloudlinux_dbtop_file_saver)r touch_fnamer r r _check_dbtop_exist _dbtop_exist_create_touch_filer s r r zMySQLTopFileSaver.__init__ se
1$%IJJ 3 3 5 5 & # # % % % % % & &r c n | | j | | j dS )z*
Try delete created files
N)_try_unlink_filer` r r s r __del__zMySQLTopFileSaver.__del__ s7
d ./// dj)))))r c N | j d| t j | dS # t $ r8}|j dk r"| j d|| Y d}~dS Y d}~dS d}~wt $ r'}| j d|| Y d}~dS d}~ww xY w)zb
Try delete file; push warning to log if wrong
:param fname: path to file
zDelete %s file zCan't delete %s file; %sN)r debugosunlinkr errnorL SystemError)r r r s r re z"MySQLTopFileSaver._try_unlink_file s
'/// D Ie H H Hw!|| !>>
HT%sC 0 0 0 HT%u - - - - -! Q Q Q HNN5t7GQ P P P P P P P P P Qs^ C& A C& #A<9C& ;A<<C& B$ C& $B((C& +B(,8C& &D07.D++D0c d}d}|dv r||fS d|v rd}nd|v rd}n d|v rd}nd} t | d d }n2# t t f$ r | j d
| Y nw xY w||fS ) z=
:rtype: (str, int)
:type value: str
-r )r r6 r$ readr unknown/rp z could not parse cause string: %s)r; splitr r} r r )r r~ cause_of_restricttime_of_restricts r _parse_dbtop_causez$MySQLTopFileSaver._parse_dbtop_cause s
I $&66 6 E>> %
u__ &
' ) F "5;;s#3#3B#7 8 8 *% F F F HNN=u E E E E E F "222s (A ,A=<A=c | j d| j t j | j S )zO
Check if dbtop util exist
:return bool: True if exist
zCheck exist %s file)r rj dbtoprk pathexistsrf s r ra z$MySQLTopFileSaver._check_dbtop_exist s3
,dj999w~~dj)))r c | }nR# t $ rE}dt | vr(| j dt | i cY d}~S d}~ww xY wi }|dd D ]} | \ }}}}} nM# t $ r@}| j dt | t | Y d}~dd}~ww xY w| | \ }
} t | d d | | d d | | d d z |
| d||< |S ) zT
Try obtain and parse data from dtop -c output
:rtype: dict
zCan't connect to socketz dbtop execution is failed: %sN zCan't unpack output: %s
%sr r )r$ r) r r )
_get_dbtop_outputr r r r r r} r r; r ) r dbtop_outputr resultr userr$ r r causer r s r get_dbtop_infoz MySQLTopFileSaver.get_dbtop_info s
1133LL$ (A66 >AGGGIIIIII "122& F
06 -c4
>!,--,,TZZ__Q-?@@4CYCYZ_ZeZefiZjZjklZmCnCnn%6$4 F4LL
s2
A&:A!A&!A&9B
C 6CC c | j dg}| j dd | t | }| d S )zJ
Run dbtop -c and split output
:return list[str]:
z-czRun "%s" command
)r r rj joinr stripr )r cmdr s r r z#MySQLTopFileSaver._get_dbtop_output& s^
z4 )388C==999"3'' !!##))$///r c | j d| j t j | } t | j | dS # t t f$ r,}| j d| j | Y d}~dS d}~ww xY w)za
Dump datat to file as json string
:param result dict: data to need dump
zDump data to %s filer N) r rj r jsondumpsr r r r r r json_resultr s r _outputzMySQLTopFileSaver._output0 s
-tz:::j(( S TZ 5 5 5 5 5! S S S HNNBDJPQ R R R R R R R R R Ss A
B
!BB
c t j | j o5t j t j | j j z
dk S )z
Check needed dump data to file. If touch file exist and was touched
last 60 seconds we need dump data
:return bool:
< )rk r r r` timestatst_mtimerf s r
_need_dumpz MySQLTopFileSaver._need_dump< sA w~~d .//jDIKK"'$JZB[B[Bd4dhj4jjr c | j r?| r-| d| i d S d S d S )N
dbgov_data)rb r r r )r rM s r rV zMySQLTopFileSaver.executeD sa @ !2!2 @ LL,(;(;(=(=> ? ? ? ? ? @ @ @ @r N)r^ )rW rX rY r r rg re rZ r rc r ra r r r r rV r[ r r r] r] s E& & & &* * * D D D
<
< \
< Q Q Q.3 3 3.* * * 60 0 0
S
S
Sk k k@ @ @ @ @r r] c " e Zd ZddZd Zd ZdS )CloudLinuxTopFileSaver /var/lve/cloudlinux_top.jsonc F || _ t j d | _ d S )Nz plugin.cloudlinux_top_file_saverr r s r r z CloudLinuxTopFileSaver.__init__J s
$%GHHr c t j | } t | j | d S # t t
f$ r,}| j d| j | Y d }~d S d }~ww xY w)Nr )r r r r r r r r r s r r z CloudLinuxTopFileSaver._outputN s j(( S TZ 5 5 5 5 5! S S S HNNBDJPQ R R R R R R R R R Ss - A*!A%%A*c v |d }| di }g g }}t | D ]\ }}t | \ }} |dk r||j d|j dz id|j it |j |j d|j
d|j dz id|j it |j
|j dd}
|dk r |j |
d d
< |j |
d d
< | r| |
| |
| ||d d S )
Nr2 r3 r allg Y@)epr$ r) mempno)idusagelimitr5 r rF r )users resellers)r8 listr9 r r< r= rE r rA rC r# r% r) r' r( rF r* rH r ) r rM r- rN r r r r rQ rU r s r rV z CloudLinuxTopFileSaver.executeU sj }- nb11 ry v||~~.. ' 'JC"4S"9"9 FKzz #i %u'> ? $en 5 0 > > ${
$i %uzE'9 : $eh / 0 ? ? $|
& !##,1JDM&),1KDM&) ' $$T****LL&&& u9==>>>>>r N)r )rW rX rY r r rV r[ r r r r I sM I I I IS S S"? "? "? "? "?r r )r r r rk r r clcommon.utilsr r lvestats.core.pluginr lvestats.lib.commons.funcr r r lvestats.lib.commons.sizeutilr
__author__r r] r r[ r r r s>
= = = = = = = = / / / / / / \ \ \ \ \ \ \ \ \ \ ; ; ; ; ; ;
K K K K K K K K \a@ a@ a@ a@ a@ a@ a@ a@H.? .? .? .? .?^ .? .? .? .? .?r