V5* d dl Z d dlZd dlZd dlZd dlmZmZ d dlZd dlZd dl m
Z
d dl m Z d dl
mZ d dlmZ d dlmZ d dlmZmZ d d lmZmZ d d
lmZ d d lmZm Z m Z m Z d d l m Z d d
l!m"Z"m#Z#m$Z$ ei dej% ej% Z&dZ'd Z(d Z)d Z*d Z+ddZ,d Z-d Z.ej/ j0 j1 j2 d Z3e4dk r= e3 e dS # e$ r Z5e56 Y dZ5[5dS dZ5[5ww xY wdS ) N)OperationalErrorProgrammingError) uidconverter)dateutil)get_ascii_table)
setup_logging) ConfigError) read_configis_normalized_user_cpu)make_db_engineMakeDbException)prepare_data_json)OutputFormatterHistoryShowUnion servers_infoget_supported_columns)HistoryShowDBGov)lveinfo_parser dbgov_parserDEF_BLANK_VALUElveinfo) caller_name
file_level
console_levelc fd| D S )z
Convert rows and its headers name to list dictionaries
:param list|tuple|generator rows:
:param list|tuple fields:
:return list:
c J g | ] }t t | S )dictzip).0row_fieldss /builddir/build/BUILDROOT/lve-stats-4.3.2-1.el9.x86_64/opt/cloudlinux/venv/lib/python3.11/site-packages/lvestats/lib/info/lveinfomain.py
z$_convert_to_dict..* s+ 5 5 5DVT"" # # 5 5 5 r )rowsr" s `r# _convert_to_dictr' # s 6 5 5 5 5 5 55r% c t j | }| | | | dS )z
Save rows and its headers to stream
:param list|tuple|generator rows:
:param list|tuple fields: first csv file line
:param file stream: stream to write data
:return:
N)csvwriterwriterow writerows)r& r" stream
csv_writers r# save_csvr/ - sA F##J r% c B | j dk o| j s| j o| j S )z
Normalization is done only if namespace.style == 'user', user id is specified, and either
csv or json output selected
:param namespace: command line options/settings
:return: True if normalizagin of CPU should be done
user)styler) jsonid) namespaces r# is_cpu_output_normalizabler6 : s& ?f $ [)-*I9> [y|[r% c d|v r| d }n| S d|v r| d }nd}d|v r| d }nd}g }| D ]}t | }| | t || }d||< |dk r t || |z dz ||< |dk r t || |z dz ||< |S )z
Normalize CPU data, making limit always be 100%. This is used to show end user usage relative to their limits
:param list rows: rows with data
:param list|tuple fields: columns name
:return list: normalized rows
lCPUaCPUmCPU Y@d )indexlistappendfloat) r& r"
lcpu_index acpuindex mcpuindexnew_rows_prow_rowlcpus r#
normalize_cpurI E s \\&))
LL((
LL(( H B BE{{ T*%&& Z ?? #DO 4 4t ;c ADO ?? #DO 4 4t ;c ADO Or% c |Q t | }n?# t $ r2}t t | Y d }~d S d }~ww xY w|t
j dd }nt | }d|v rt | || \ }}}nqt t t j | | }|
| }|j r t d }t | }nt! ||| \ }}| | |j s|j r| g dd |j r+t+ || |j d S |j r"t/ t1 ||j S | g d
d | g d d
| g dd t5 ||j S )N)cfg --dbgov)nameverconfigdbengine)Serverz LVE version)aIOmIOlIOc ( t | dz d S )Ng @ )roundx_s r# zmain_.. s RWXZ]bXbdeRfRf r% r" order)r- ) aVMemmVMemlVMemaPMemmPMemlPMemrS rT rU bytes)aEPmEPlEPEPfVMemFCPUfaNprocmNproclNprocPMemFNprocFIOfaIOPSmIOPSlIOPSIOPSfpowers_of_1000)uCPUuEPuVMemuPMemuIOuNprocuIOPS
percentage)r" )r r
logerrorstrsysargvr?
dbgov_mainr NAMElvestats __version__
parse_argsr r
lvestats_mainset_rowsr) r3 add_orderr/
get_fieldsr r' r" r ) rP rQ argv_e_argsr5 output_formattedr& parsers r# main_r h s` %&111HH IIc!ff FFFFF
} U E,6vuh,O,O) #TT Tx/CF]efff%%e,, ! P ./H I I ))DD%28Y%O%O " d d### } h h""*?*?*?GfGf"ggg}
Q!#3#>#>#@#@ WWWWWW Q !12BDTD[!\!\]]] ""*u*u*u)0 # 2 2 2""R R RYi # k k k ""#^#^#^`lmmm /8H8OPPPPs
A'A Ac t j ddgdfddgdfg }| g dd t j t d }t j j }t j d
r t i d t j }nd }t ||j | j j j j j d
z j j j |pt0 }| j dk r| }n| }j sj r"j r| dgfd n#j r | dg fd t? j } t? }
tC |
" tC | } | r| | fd tG r$tI rtK ||j }||fS )NFromTodatetimestrftime)orders)r9 r; r8 rS rT rU c : t t | S N)intrX rY s r# r[ z lvestats_main.. s E"II r% r\ from LVEINFODEBUGr )r r r< )rQ period_from period_touid show_columns server_id time_unitlimitby_usageby_usage_percentageby_fault thresholdorder_byr~ r: IDc j pj S r )r1
reseller_name)xr5 s r# r[ z lvestats_main.. s in G 0G r% c f t j | d j p| S )Nr )r uid_to_username get_defaultr )r rQ r5 r s r# r[ z lvestats_main.. s: l :6%%k22#X / / 423 r% ) lve_versionc . j t nj S r ) blank_valuer )_r5 s r# r[ z lvestats_main.. s y/D/LOOR[Rg r% )&r r r r local_to_gmgetattrtoosenvirongetr loggingDEBUGr r4 r r r r r r} r r r r~ set_normalised_outputproceed_dyn_time_unitproceedr1 r display_usernamer r set
differencer r6 rI ) rQ r5 r r utc_fromutc_tolog_ history_showr& supported_columns_ all_columnsunsupported_columnss ``` r# r r s & $ ,~z.JKM M M &S&S&S%>%> @ @ @#GIv$>$>??H
!),
/
/F z~~n%% RYgmTTT# L%0022%%o# % 04 7#%# KC L &&(((b 1133##%% 592 5* 5""
FGGGG I I I I # 5""
F 4 4 4 4 4 4 5 5 5 /6;MNNN'))K k**55c:L6M6MNN i""&gggg # i i i >$>y$I$I > T<#<== T !!r% c p | d t | | }| | }t |j ddgdfddgd fdgdfdgd fd gd
fd d gd
fg }t j t |d }t j |j }t ||||j
| |j |j
|j | |j |j |j dz }|j dk r| } n| } ||| fS )NrM )rP rQ FROMTOr c , t j | d S )Nz %m-%d %H:%Mr r dts r# r[ z dbgov_main.. s (@M)# )# r% TSc , t j | d S )Nz%m-%d %H:%M:%Sr r s r# r[ z dbgov_main.. s 8$!& !& r% CPUc | dk rdn| S NgMbP?r r r s r# r[ z dbgov_main.. s QYYA r% READWRITEc | dk rdn| S r r r s r# r[ z dbgov_main.. s q5yy!!a r% )r" r r r< ) rQ r r r r r r r rK r r r r: )remover r r formatr r r r r r4 r r r r r r r} history_dbgov_show_dynamichistory_dbgov_show)
rP r rQ r r5 r r r r r& s
r# r r s LL
(
;
;
;F!!%((I& d^Z (d^ # #
$VZ V & &
'W55 6g
? ? @
#GIv$>$>??H
!),
/
/F#x6 L'7'B'B'D'D% 0Bo6Y5H#9MPT9T L b 6688..00 & ,,r% c t | g|R i |}|rt | d S d S # t t f$ r2}t t
| Y d }~d S d }~ww xY wr )r printr r r~ r r )rP argskwargsstr_exs r# mainr s V-d---f-- $KKKKK
. / #b''s ' A*'A%%A*__main__)NN)7r) r r r sqlalchemy.excr r r lvestats.lib.commons.decorators lvestats.libr lvestats.lib.commonsr lvestats.lib.commons.funcr lvestats.lib.commons.logsetupr lvestats.lib.configr r
r lvestats.lib.dbenginer r
lvestats.lib.jsonhandlerr lvestats.lib.lveinfolibr r r r lvestats.lib.lveinfolib_govr $lvestats.lib.parsers.lveinfoargparser r r ERRORr~ r r' r/ r6 rI r r r libcommons
decorators
no_sigpiper __name__ce log_and_exitr r% r# r s
= = = = = = = = & & & & % % % % % % ) ) ) ) ) ) 5 5 5 5 5 5 7 7 7 7 7 7 + + + + + + C C C C C C C C A A A A A A A A 6 6 6 6 6 6( ( ( ( ( ( ( ( ( ( ( ( 8 8 8 8 8 8 ^ ^ ^ ^ ^ ^ ^ ^ ^ ^mBI'-W^Wdeee6 6 6
\ \ \ F-Q -Q -Q -Q`7" 7" 7"t - - -D
+ ,+ z [[]]
s C D"C<<D