QwЕ d dl Z d dlZd dlZd dlmZ d dlZd dlmZm Z d dl
m Z d dl m
Z
d dlmZmZmZ d dlmZ d dlmZmZ d d lmZmZ d d
lmZ d d l m Z d d l m Z m Z d d
l!m"Z" d dl#m$Z$ dZ% G d de& Z'dS ) N)Callable)FormattedExceptioncpapi) NotSupported)getuser)GovernorStatus
MySQLGovernorMySQLGovException)dbengine)func
server_status)get_users_for_resellerskip_user_by_maxuid)
setup_logging)g_users_manager)HIDE_MAX_UID_LVE_PARAMETER str_to_bool)cloudlinux_top_parser)uid_to_usernamezN/Ac e Zd ZddZed Zd Zd ZddZd Z d Z
dd Z d Z ed
Z
ej j j j d ZdS )
CloudLinuxTopNc t |dt j t j | _ d| _ d| _ d| _ | dd | _ t | t d | _ d | _
||| _ n> t j | | _ n## t j $ r}|| _
Y d }~nd }~ww xY wt% | _ | j \ | _ | _ t/ j | j | _ t5 d k r| n
t9 | _ d S )
Nr )config caller_name
file_level
console_levelz /var/lve/cloudlinux_top.jsonz /var/lve/cloudlinux_dbtop.jsonz/var/lve/governor.ts server_id localhosttrueroot) r loggingWARNINGFATAL_logfnamefname_db touch_fnamegetr r r hide_maxuid_lve engine_errorenginer make_db_engineMakeDbExceptionr mysql_governorget_governor_statusgovernor_statusgovernor_errorr get_governor_mode
governor_moder _get_adminsset_admins)selfcnfr+ es /builddir/build/BUILDROOT/lve-stats-4.3.2-1.el9.x86_64/opt/cloudlinux/venv/lib/python3.11/site-packages/lvestats/lib/info/cloudlinux_top.py__init__zCloudLinuxTop.__init__ sL !O!-) ) ) 4
8
1 k:: *3773Mv+V+V W W DKK
& & 5c : : +
&
&
&$%!!!!!!
& +oo 3 3 5 5 2 d 1 ! 3D4G H H-4YY&-@-@t'')))cee s B6 6CCCc t t j S # t t f$ r t cY S w xY wN)r adminsr AttributeErrorr5 r: r4 zCloudLinuxTop._get_admins5 s@ <>> ! n- 55LLL s 77c F t || j | j | j S )N)uidlocal_server_idr db_engine)r r r+ )r7 rC s r: _get_username_by_idz!CloudLinuxTop._get_username_by_id< s+ Nnk
rA c h fd}d d |d |d d d d d d
}|| S ) z returns key function for sortedc fd}|S )Nc ~ | d }|d vrdS d | }| S )Nid
dbgov_datar )rF )kusername dbgov_statscl_datar7 values r: keyz.mysql_key..keyH sI 33AdG<<7<#888 1"),"7"AK&u--rA r@ )rP rQ rO r7 s ` r: mysql_keyz/CloudLinuxTop._get_order_key..mysql_keyG s.
.
.
.
.
.
.
. JrA c * | d d d S )Nusagecpuallr@ rL s r: z.CloudLinuxTop._get_order_key..R s QwZ .u 5 rA c * | d d d S )NrT iorV r@ rW s r: rX z.CloudLinuxTop._get_order_key..S s AgJt ,U 3 rA rU rZ c : | d dd S )NrT iopsr r( rW s r: rX z.CloudLinuxTop._get_order_key..V s ajnnVQ 7 7 rA c | d d S )NrT epr@ rW s r: rX z.CloudLinuxTop._get_order_key..W s AgJt , rA c : | d dd S )NrT pnor r] rW s r: rX z.CloudLinuxTop._get_order_key..X s qz~~eQ 7 7 rA c : | d dd S )NrT memr r] rW s r: rX z.CloudLinuxTop._get_order_key..Y s ajnnUA 6 6 rA )rU rZ mysql_cpumysql_ior\ r_ nprocpmemr@ )r7 orderrO rR
order_key_maps ` ` r: _get_order_keyz CloudLinuxTop._get_order_keyD sy 6533"5))! $77,,7766
U##rA c t |d 5 }t j | }ddd n # 1 swxY w Y n# t t f$ r |}Y nw xY w|S )a
Try load and parse json data from file; return if loading or
parsing wrong
:param fname: path to parsed file
:param None|dict default: default data if loaded file is wrong
:return None| dict: return loaded data
zutf-8)encodingN)openjsonloadIOErrorOSError)r7 r% default json_filerO s r: _load_from_json_filez"CloudLinuxTop._load_from_json_file] s eg...
/) )I..
/
/
/
/
/
/
/
/
/
/
/
/
/
/
/! GGG s, A 4 A 8A 8A AAc t j | j dS # t t f$ r$ | j d| j Y dS w xY w)z:
Trying touch the file to signal new data
zRAn error occurred while touching file %s. Database statistics may be not availableN)r touchr' rp rq r$ error)r7 s r: _touch_dbtopzCloudLinuxTop._touch_dbtopl s~ Z Jt' ( ( ( ( (! Z Z Z IOO GHLHX
Z
Z
Z
Z
Z
Z Zs 1AAc | | j g g d }| | | j di i |S )zZ
Load and join data from separate files
:return dict: loaded data
)users resellersrK )rt r% updater& )r7 rO s r:
_load_datazCloudLinuxTop._load_datav sR
++DJ"SU8V8VWWt00 r@RSSTTTrA TrU c N g }g }g } t }
|
dk } | s|rH| t j | |r t |p
t } n|
g} | } t
| d | || d }
|
D ]_}| j rt |d r |
|d pt }| p|du}|r|| vs || j v rY|t k rt |d< t |d< nMt j
|d
pt |d< t j |t |
pt |d< |r|d t k s||d vs|r|t k s||vr||d < |r,| j t" j k r| || | | | | d |cxk rt+ | k rn ] nat
| d
g | || d }| rZ|D ]W}|
|d }|r||p
t k r4|t }||d< | | X||fS )a
:type order: str
:type show_mysql: bool
:type limit: int|None
:type domain_filter: str|None
:type username_filter: str|None
:param None|str reseller: get information about given reseller
:rtype: tuple[list, list]
r rz T)rQ reverserJ NdomainresellerF) raise_excrM r r{ name)r rx r build_users_cacher r} sortedrj r) r rF
NOT_AVAILABLEr6 get_reseller
get_domainboolr0 r ENABLED_add_mysql_dataappendlenr( )r7 username_filter
domain_filterlimit
show_mysqlrh r users_resultresellers_result
users_listcurrent_user_namecurrent_user_is_adminrO cl_users_data_ordereduserrM should_skip_userscl_resellers_data_ordered
reseller_infos r: _get_datazCloudLinuxTop._get_data s<
#II 1V ; -H - -h 7 7 7
K 3H4I J J
+,J//## &ww'7T=P=PQVX_=`=`jn o o o ) D #
(;DJ(G(G
//T
;;L}H %: 9 QXT=Q
XZ%?%?8t|C[C[=((!.X#0Z #2#?TY#Z#Z#Z#k^kZ !0!;HPTUbPcPc!d!d!d!uhuX
4>]#B#Bm[_`h[iFiFi$ Gj*2m*C*C^fGfGf 'D
>d 2n6L L L$$T7H=== % % % Q%C%C%C%C#l2C2C%C%C%C%C%C
7;;{B//T5H5HPW5X5Xbf g g g " 7!:
7
7
33M$4GHH X-B C C # ,H(0
f% ''
6666 ---rA c 4 |d |ddddd }| j dk r | j | }|d |d d d< |d d
z |d d d< n/# t $ r"}t
j | _ || _ Y d }~nd }~ww xY w|d |d
d d< |d |d
d d< nd|d d d< d|d d d< t |d |d
d d |d
d d< t |d |d
d d |d
d d< |d dk r d|d< |d d|d dd|d< d S d|d< d S )z
add mysql statistics to the user dict
:type cl_data: dict
:type user: dict
:type username: str
rK r -)rU rZ cause_of_restricttime_of_restrictrV r rU mysql i rZ NrT r T
restrictedr z
Violated the z limit)timereason restrictionF)
r( r3 r. get_limits_by_userr
r ERRORr0 r1 min)r7 r rO rM rN mysql_limitsr9 s r: r z CloudLinuxTop._add_mysql_data s l+// QSa P P
& &
F # 2 E Eh O O
1=QW
e$W-/;A/EW
d#G,, %
(
(
('5';$&'######
( -8,>DM% )+6t+ $ r }|j |d< |j |d< Y d}~nd}~ww xY w| | dfS )z$
:rtype: (str, int)
timestamp)z4Use --json option, other modes currently unsupportedr r resultcontextNr z[Permission denied. Reseller can view information only about himself. Option --for-reseller=z is forbidden.r )r r r r rh r success)r rz r{ mySqlGov mySqlGovModewarning) r r
parse_argsrn
ValueErrorargsr r for_resellerr
check_server_statusRUNNINGstatus_descriptionr* messager r rM r max
hide_mysqlorder_byr| r0 r3 r r r1 r? rp strr )
r7 r parserr namespacer9 error_msglvestats_statusrz r{ s
r: mainzCloudLinuxTop.main s
'(( ty{{+ + ))$//I >
QPP
Q + + + vayF8 "F9 <<''* * * * * * * +
99 9#9#E)J`dkdmdmJmJmX1:1GX X XI )F8 "F9 <<''* *';== m 3 3 3 , ? PF8
* # 0 8F8 $ 1 9F9
/#'>>$-$6"+"2#-#,#7 7#, & 3
$2 $5 $5 y
' "!* $ 4$($6 8 8 9 9 9 '>+???(,(;(CF9%/,0,?,Gy))) / / /,.y)))/ @%
'
'
'#&q66x $&y!!!!!!%
.
.
.#$9x $%Iy!!!!!!
.* ||F##Q&&sS A
B+A?9B?B=G2 G G.-G.2
I<H
I%H>>Ir= )NNNTrU N)__name__
__module__ __qualname__r; staticmethodr4 rF rj rt rx r} r r r lvestatslibcommons
decorators
no_sigpiper r@ rA r: r r s L L L L. \
$ $ $2
Z Z Z #' $ !
L. L. L. L.\#' #' #'J ; ; \; \$/>' >' 0/>' >' >'rA r )(rn r! r typingr lvestats.lib.commons.decoratorsr clcommonr r clcommon.cpapir clcommon.cpapi.pluginlibr clcommon.libr r r
lvestats.libr lvestats.lib.commonsr r
lvestats.lib.commons.funcr r lvestats.lib.commons.logsetupr "lvestats.lib.commons.users_managerr lvestats.lib.configr r ,lvestats.lib.parsers.cloudlinux_top_argparser lvestats.lib.uidconverterr r objectr r@ rA r: r s & & & & . . . . . . . . ' ' ' ' ' ' , , , , , , I I I I I I I I I I ! ! ! ! ! ! 4 4 4 4 4 4 4 4 Q Q Q Q Q Q Q Q 7 7 7 7 7 7 > > > > > > G G G G G G G G N N N N N N 5 5 5 5 5 5
\' \' \' \' \'F \' \' \' \' \'rA