0e f d dl Z d dlZd dlZd dlZd dlZd dlmZ d dlmZ d dl m
Z
m Z d dl m
Z
d dlmZ d dlZd dlZd dlmZ d dlmZ d d lmZmZmZmZ d d
lm Z d d l m Z d d l m Z d d
l!m"Z"m#Z# d dl$m%Z% d dl&m'Z' d dl(m)Z) dZ*dZ+da, G d de- Z. G d de/ Z0 G d de- Z1dS ) N bisect_left) defaultdict)IterableList)etree)SQLAlchemyError)getuser)_get_uid_for_select)configdbengine
lveinfolib uidconverter)SvgChart) ramerdouglas)dateutil) period_type2
ParseDatetime)
setup_logging) VWSimplifier)
svg_to_pngshaman localhost c & e Zd ZdZd dedefdZed Zed Z d Z
d d Z d
e e e
deee
fdZde e e
deee
fdZd Zdddddd dddf dZd Zd Zd Zd Zd dZd ZdS ) Rendererz
Renders data to file
aquamarinemax_points_on_graph fault_colorc z t j d | _ t | _ || _ || _ d S )NzChart Renderer)logging getLoggerlogr svg_chart_max_points_on_graph _fault_color)selfr r s /builddir/build/BUILDROOT/lve-stats-4.3.2-1.el9.x86_64/opt/cloudlinux/venv/lib/python3.11/site-packages/lvestats/lib/chart/__init__.py__init__zRenderer.__init__- s6 $%566!$7! ' c | S N )args r) _nopz
Renderer._nop3 s
r+ c ddg}t j | }t j | }| |t S )Nz%b-%dz
%b-%d %I:%M%p)r unixtimestamp_to_gm_datetime gm_to_localstrftime format_index)tsformatsgmlos r)
_ts_to_strzRenderer._ts_to_str7 sE O,
22
6
6
!"
%
%{{7<0111r+ c |dk rda d S d S )Ni
r )r5 )r(
period_secs r) set_period_seczRenderer.set_period_sec? s LLL r+ @r c |}|}d}t d D ]Q}t || }|} t | }|| k r|c S || j k r
|dk r|c S |}n|}|}||z dz }R|S )Nr
r> )ranger lenr& )
r( points epsilon_max epsilon_minepsilon_default
points_output
points_lenipoints_optimisedpoints_len_previouss
r) _optimisation_ramerdouglasz#Renderer._optimisation_ramerdouglasE s %
r ? ?A +FO D D ", -..J 000$$$$T 66666++++ - 0
- *[ 8B >OO r+ rC returnc X t | }| | j }|S r- )r from_numberr& )r( rC
simplifierresults r) _optimisation_polysimplifyz#Renderer._optimisation_polysimplify\ s* !&))
''(ABB
r+ linec t | | j k r,| |d }| | }|S )Ngffffff?)rD )rB r& rL rR )r( rS s r) optimise_pointszRenderer.optimise_pointsa sF t99t0 0 0224S2IID22488D r+ c Z t || }||dz
}|| }|dz
|||fS )z?
:type x_value: float
:type line: list
r r )r( rS x_valueposbeforeafters r) get_two_closestzRenderer.get_two_closestg s<
$((cAg S QwU**r+ Nc | S r- r. )vs r) zRenderer.| s r+ c | ||
|| \ }}}}| j |||||||| |
| j || | || j dS )aP
:type message: None|str
:type unit: None|str
:type y_legend_converter: (float) -> float
:type max_y: None|float
:type min_y: None|float
:type title: str
:type legend: dict
:type x_values: list
:type faults: (str, str, str)
:type data: defaultdict
)
title minimum_y maximum_yx_legendx_legend_generatey_legendy_legend_converterx_legend_converternamesunitmessage fault_linesr N)
_add_graphr% add_graphr: r' )r( datar` legendx_valuesmin_ymax_yx_labelsgenerate_n_xlabelsy_labelsrf ri rj faultscolorsdatasetsrk rh s r) rm zRenderer.add_graphq s 6 04tVVU]/^/^,+u 0 1 ## ) ! + + + + +r+ c g }g }g }i }| D ]\ } }
|
\ } } n # t $ r |
\ } } | j Y nw xY wfd|| D }
t t ||
}| | }| | ||| < | | | | | |||| }|r/| d | | j ~||||fS )z
:type legend: dict
:type x_values: list
:type faults: (str, str, str)
:type data: defaultdict
:rtype (list, list, list, list)
c & g | ]
} | S r. r. ).0ymodifiers r)
z'Renderer._add_graph.. s! ??? ???r+ rv )
items
ValueErrorr0 lowerlistziprU appendget_faults_linesr' )r( rn rv ro rp rx rh rw datasets_dictionarykeymetainfo legend_titlecolory_valuesrS line_optimisedrk r} s @r) rl zRenderer._add_graph st %||~~
!
!OS(
%08- eXX
%
%
%&.# e 9
% @???T#))++->???HHh//00D ! 1 1$ 7 7N OON + + +/= , LL & & & MM% ++D2EvxXX - LL " " " MM$+ , , , xe33s +AAc 2 g }|d |D \ }}}||v r||v rd t ||| D } t t || \ }
} t t || \ } }
| D ]} | || |
}| ||
| }|d |d k r ||f|vr| ||f a# t $ r+ | j dt | Y w xY w|S )z
:type x_values: list
:type faults: (str, str, str)
:type datasets_dictionary: dict
:type data: defaultdict
:rtype list
Nc 6 g | ]}| S r. )r )r{ xs r) r~ z-Renderer.get_faults_lines.. s 0K0K0Kq0K0K0Kr+ c $ g | ]
\ }}|d k |S r r. )r{ r r| s r) r~ z-Renderer.get_faults_lines.. s" SSS$!QQQRUUAUUUr+ r zCan't get fault line: %s)r r get_dotr
IndexErrorr$ errorstr)r( rn r rv rp rk
fault_name data_name
limit_namefaults_x
average_timesaverage limit_timeslimitfault average_dot limit_dots r) r zRenderer.get_faults_lines sb 0K0KF0K0K0K -J : 000YBU5U5USS#hZ8H*I*ISSS)-c3Fy3Q.R)S)S&
w%)#/B:/N*O%P%P" U % O OEO&*ll5'=&Q&Q $(LL{$K$K &q>IaL88k9=U]h=h=h ' . . Y/G H H H% O O O 'A3u::NNNNNOs A C 2DDc F ||d k r
||d fS ||d k r
||d fS ||| | f}nU# t $ rH | || \ }}}}||z
||z
z || || z
z || z } || f}Y nw xY w|S )z
:type line_times: list
:type line: list
:type fault_time: float
:rtype (float, float)
r )indexr r[ )
r(
fault_timerS
line_timesdot before_indexrY after_indexrZ dot_ys
r) r zRenderer.get_dot s B ' ' tBx' ' A & & tAw& &
& tJ$4$4Z$@$@ ABCC & & &7;7K7KJXb7c7c 4L&+uf$6># $tL'99; |$%
u%CCC &
s A AB B c J | j ||| j d S )N)rp numberrg )r%
_add_x_legendr: )r( rp ns r) add_common_x_legendz Renderer.add_common_x_legend s6 $$ # %
r+ c < | j || dS )z/
add empty rectangle with text
N)r% add_text_box)r( text font_sizes r) r zRenderer.add_text_box s"
##D)44444r+ c 4 | j S r- )r% dump)r( s r) renderzRenderer.render s ~""$$$r+ )r r )r> r r- )__name__
__module__ __qualname____doc__intr r* staticmethodr0 r: r= rL r floatr rR rU r[ rm rl r r r r r r. r+ r) r r ( s ( (C (C ( ( ( ( \ 2 2 \2 .(5/1J tTXY^T_O`
HXe_$= $tE{BS + + + # *{ ,+ ,+ ,+ ,+\!4 !4 !4F 2 0
5 5 5 5 % % % % %r+ r c e Zd Z fdZ xZS ) UserNotFoundc J t j d| dg|R i | d S )NzUser z
not found)superr* )r( user_nameargskwargs __class__s r) r* zUserNotFound.__init__ s< 6666HHHHHHHHHr+ )r r r r*
__classcell__)r s @r) r r sA I I I I I I I I Ir+ r c e Zd Zd Zed Zed Zd Zd Z ddZ ddZ
e j j
j j dd
Zd Zd Zd
Zd Zd S ) ChartMainc || _ || _ t ||t j | _ || _ t j | _ d S )N)
console_level) prog_name prog_descr r" ERRORr$ cfgr is_normalized_user_cpu)r( r r cnfs r) r* zChartMain.__init__
sF "" iw}MMM&,&C&E&E###r+ c t t }| D ]c}t t || }| D ]/\ }}|| t
|pd 0d|S )Nr )r r dictr r r r )rn show_columnsdata_collectedrowrow_dictkr] s r) convert_dbdata_to_dictz ChartMain.convert_dbdata_to_dict s $T** 8 8CC c 2 233H"..**
8
8A q!((qvA 7777
8 r+ c t t }| D ]\ }}d |D ||< |S )Nc 0 g | ]}t |pd S r )r )r{ r] s r) r~ z5ChartMain.convert_lvedata_to_dict.. s" 7771qvA 777r+ )r r r )rn by_keyr valuess r) convert_lvedata_to_dictz!ChartMain.convert_lvedata_to_dict sJ T"" ::<< 8 8KQ77777F1II
r+ c | j dt }t j t j | j d| j }| dt j ddd | dd fd
d | d d
t dd | ddt dd | ddd| | dddd | d d d d d!" | d#d$d%d&gd'd ( | d)d*d+d,gd-d,( | d.d/t d0d 1 | d2t
j 3 | d4t
j 3 | d5t
j 3 |S )6N server_idT)progadd_help descriptionz --versionzVersion numberversion)r helpdestactionz--periodzTime period
specify minutes with m, h - hours, days with d, and values: today, yesterday
5m - last 5 minutes, 4h - last four hours, 2d - last 2 days, as well as todayc $ t | S r- )r )value datetime_nows r) r^ z'ChartMain.make_parser..2 s |E>>JX->???
r+ c t )z`
:type parser: argparse.ArgumentParser
:rtype : argparse.ArgumentParser
NotImplementedError)r( r s r) customize_parserzChartMain.customize_parserf s
"###r+ Fc t )a:
Extracts data from database , in form of a tuple:
(dict, list)
where dict is
{
'cpu': [0, 5, 10 , 95.2, ...] -- values
'io': [0, 5, 10 , 95.2, ...] -- values
'foo': ,
}
and a list of timestamps for all that collected values:
2) [1, 2 ,3 ...]
:param show_all:
:rtype : tuple
:type engine: sqlalchemy.engine
:type from_ts: datetime.datetime
:type to_ts: datetime.datetime
:type server: str
:type user_id: int
r
)r( enginefrom_tsto_tsr user_idr s r) get_chart_datazChartMain.get_chart_datam s @ "###r+ c t )z
:rtype : None
:type renderer: Renderer
:type data_collected: dict
:type times: list
:type lve_version: str
:type show_all: bool
:type is_user: bool. True for user, False - admin
r
)r( rendererr times lve_versionr is_users r)
add_graphszChartMain.add_graphs s "###r+ Nc | }| | }||}ng t j | j }nL# t j $ r:}t j t | dz Y d }~dS d }~ww xY w|
t | }|j r,t |j |j f rt! d dS |j r |j \ }}nFt" j } |j p| t# j d z
}|j p| }| | r| || nt- j }
t1 dk r:|
r8|
t- j k r!t j d dS |j r[|j } t5 | |
} t7 | t8 rn.|
| vr*d |
d
| d }
t j |
dS | ||||j |
\ }}}nN# t> t@ f$ r:}t j t | dz Y d }~dS d }~ww xY w| ! ||||| }| " || dS )
N
r z2--period and [--from, --to] are mutually exclusiver r@ )minutesrootzPermission denied
z Permission denied. User with id z does not belong reseller `z`
)r )#r r r
make_db_enginer MakeDbExceptionsysstderrwriter
parse_argsr periodanyr r printr r timedelta_has_user_arguments_obtain_user_idosgetuidr
r r
isinstancer r r r r _render_output)r( r debug_enginer r eoptsftr r
reseller_namereseller_users error_msgr r r< exrendered_graphs r) mainzChartMain.main s !!##&&v.. #!FF
!0::+
Q$ ///qqqqq
d,, ; 3
DG 455 F G G G1 ; (;DAqq#,0022L
KlX-?-K-K-K KA'***qs/ A
B/BB0#I J %/JJ c 2 |j } |j }n# t $ r d }Y nw xY w|d}t }| | t j ||j } | |||| ||dk | }
|
S )Nr r )r )
r r AttributeErrorr r= r get_lve_versionr r r ) r( r r r0 r< r r r r r r7 s r) r, zChartMain._render s = JEE EEE =E::
+++ 0EE .%h % 1 1 1! ** s c |j dk r|j dk r t j | d }t j |d }nL# t t t f$ r2}| j
dt | Y d }~nd }~ww xY w|j dk rt | }|j dk rt |t rIt j j t j j | d S t j | d S t |t rd}nd }t) |j | 5 }| | d d d d S # 1 swxY w Y d S # t* $ r$ | j d
|j Y d S w xY w) Nr r utf8T) pretty_printz3Can not use pretty print for svg xml formatting; %sr wbwzUnable to create file: %s)r r r
fromstringencodetostring ImportErrorr UnicodeEncodeErrorr$ debugr r r+ bytesr stdoutbufferflushr! openIOErrorr )r( r0 r7 root_noder/
write_moder s r) r- zChartMain._output s% ;% DK3$6$6
^ ! ,^-B-B6-J-J K K !& !M!M!M -?@
^
^
^ TVYZ[V\V\]]]]]]]]
^ ;% ' 7 7N ;# .%00
1
!'')))
!''77777
00000
I ne44 %!%JJ!$J$+z22 1fLL 0001 1 1 1 1 1 1 1 1 1 1 1 1 1 1 1 1 1
I
I
I :DKHHHHHH
IsM =A B -(BB /F& 6F F& F F& F !F& &*GGc |j }n# t $ r d }Y nw xY w |j }n# t $ r d }Y nw xY w|*t j || j d |j | pd}|S )Nr )usernamelocal_server_idr db_enginer )r r: r r username_to_uidr r )r( r r0 r r s r) r( zChartMain._obtain_user_id s lGG GGG II III ?"2"DH[4I +9 9 9 ?<>
s
% 44c ^ t |d r|j pt |d o|j S )Nr r )hasattrr r )r( r0 s r) r' z ChartMain._has_user_arguments s1 i((9T\mwt[?Y?Y?l^b^lmr+ )Fr- )r r r r* r r r r r r r r libcommons
decorators
no_sigpiper8 r, r- r( r' r. r+ r) r r s F F F \ \A A AF$ $ $ !&
$ $ $ $D
$
$
$
$ \$/< < < 0/<| I I I8 n n n n nr+ r )2r r" r r r) bisectr collectionsr typingr r lxmlr sqlalchemy.excr r lvestats.lib.commons.decoratorsclcommon.cpapi.pluginlibr
"lvestats.lib.cloudlinux_statisticsr lvestats.libr r
r r lvestats.lib.chart.svggraphr lvestats.lib.chart.rdpr lvestats.lib.commonsr #lvestats.lib.commons.argparse_utilsr r lvestats.lib.commons.logsetupr lvestats.lib.chart.polysimplifyr lvestats.lib.chart.svg2pngr
__author__r r5 objectr Exceptionr r r. r+ r) rm s2
# # # # # # ! ! ! ! ! ! ! ! * * * * * * & & & & , , , , , , B B B B B B C C C C C C C C C C C C 0 0 0 0 0 0 / / / / / / ) ) ) ) ) ) K K K K K K K K 7 7 7 7 7 7 8 8 8 8 8 8 1 1 1 1 1 1
Y% Y% Y% Y% Y%v Y% Y% Y%xI I I I I9 I I I
Nn Nn Nn Nn Nn Nn Nn Nn Nn Nnr+