jFڣe d dl mZ d dlmZmZ d dlmZmZmZmZm Z d dlm
Z
d dl m Z d dl
mZmZmZmZmZ d dlmZ d dlmZmZmZ d d lmZ d d
lmZ d Zd Z G d
de Z dS ) )ceil)Integerdesc)and_selectfunccasecast)or_) uidconverter) gm_datetime_to_unixtimestamp gm_to_local unixtimestamp_to_gm_datetime local_to_gmround_1m)OutputFormatter)convert_to_listenumerate_duplicate_columnsadd_labes_to_column)dyn_time_unit_groups) history_govc & t j | d d t j | d d z t j | d d z S )z
:param sqlalchemy.orm.attributes.InstrumentedAttribute cause_of_restrict:
:return sqlalchemy.sql.elements.BinaryExpression:
& )r maxopcause_of_restricts /builddir/build/BUILDROOT/lve-stats-4.3.2-1.el9.x86_64/opt/cloudlinux/venv/lib/python3.11/site-packages/lvestats/lib/lveinfolib_gov.pyget_bitwise_restrictr" s
*"%%c**1--..
(,$'',,Q//
0
0 1
(,$'',,Q//
0
0 1 c
t | dk df| dk df| dk df| dk df| d k d
f| d k d f| d
k dfgd S )zv
:param sqlalchemy.sql.elements.BinaryExpression cause_of_restrict:
:return sqlalchemy.sql.elements.Case:
r Cr R CRr W CW RW CRW )else_)r r s r! get_cause_of_restrictr2 ( s
!
#S )
!
#S )
!
#T *
!
#S )
!
#T *
!
#T *
!
#U +
r# c h e Zd ZdZ ddZd Zd Zd Zd
Zd Z d Z
d
Z ddZ ddZ
dS )HistoryShowDBGovtsN localhostF?c |
| _ | | _ || _ || _ || _ || _ || _ || _ || _ || _ | pddi| _
|
dk rd| _ n|
| _ | | _ dS )a?
:param bool reverse:
:param sqlalchemy.engine.base.Engine dbengine:
:param datetime.datetime period_from:
:param datetime.datetime period_to:
:param int|None uid:
:param str server_id:
:param str|list|tuple|None show_columns:
:param str order_by:
:param int|None limit:
:param dict|None cfg:
:param int|None time_unit:
:param bool reverse:
:param list[str]|str|None by_usage:
:param float by_usage_percentage: value in range [0..1]
:return list:
server_idr6 N)
by_usage_percentageby_usagedbengine period_from period_touidr9 requested_columnsorder_bylimitcfg time_unitreverse)selfr= r> r? r@ r9 show_columnsrB rC rD rE rF r< r; s r! __init__zHistoryShowDBGov.__init__> s B $7
&""!-
4; 4 ?? !DNN &DN r# c V | j g S | | j \ }}t t t | t | j }t
t t | t | j }t | }t | }g }t t || D ]L\ }}}t | | _ t | | _ || _ ||
z
}M|S )zT
Show dbgov statistics with dynamic time-unit.
:rtype: list
)r@ _get_min_max_tsr r r r> minr? r reversedr r rE history_dbgov_show) rG max_tsmin_tsr> r? rowst_fromt_torE s r! history_dbgov_show_dynamicz+HistoryShowDBGov.history_dbgov_show_dynamicp s
8 I --dh77+&B6&J&JKK[Y]YiMjMjkk $@$H$HII;W[WeKfKfgg {++ Y'' '/0D[R[0\0\']'] . . #FD) *6 2 2D ( . .DN &DN D++-- -DD r# c V j t k s j g k rg S j .t j t t f s
j dk rg S t j }t j } j pd} || } | }
| }t t j
|| t j j k } | }t j t" rt% t' | t |t j j k | } j 5| |t j | } n#| |t j t j | } nt% t' | | | } t j t t f rD| t j t j } | t j t j | } j r(| | } j | }
t? j |
! dg fdfg dd fg dd fg } |
" | # S )
zM
Show statistics from history_gov table
:rtype: list
Nr USERc v t j t | j d j j S )Nr9 )r uid_to_usernameintrD r9 r= )uid_rG s r! z5HistoryShowDBGov.history_dbgov_show.. s. !=D 48K#8$.$-" " r# )CPUREADWRITEc D | | n t t | d S )Nr. )roundfloatxs r! r[ z5HistoryShowDBGov.history_dbgov_show.. s !)QQuUVxxYZI[I[ r# )TSFROMTOlCPUlREADlWRITECONc ( | | nt | S N)rY rb s r! r[ z5HistoryShowDBGov.history_dbgov_show.. s XYXaSTSTgjklgmgm r# )fieldsrQ orders)$r@ tuple
isinstancelistr
r> r? rC _get_table_aggregate_info_get_columns_for_select_get_order_by_queryr r r5 betweenr9
round_timerY r r whererB rE group_byr in_r< having_get_by_usage_queryr= executer rA fetchallcloseget_corrected_list) rG rR rS rC table_aggregate_infocolumns_to_selectorder_by_query where_querygroup_by_time_queryqueryrQ resultss ` r! rN z#HistoryShowDBGov.history_dbgov_show s; 8uww $(b..I 8
48dE](K(K PTPX\]P]P]I-d.>??+DN;;
"d $ = =fd K K ! 8 89M N N 112FGG;>11&$??AVZ^ZhAhii #oof 5 5 dh $ $ 23DEEFFtK DH)DEEFF.))
~) ':KOLLRRSXYY ':KO[Mjkkqqrwxx67HIIJJPPQ\]]ffguvvE$(T5M22
I KO$7$7TX$G$GHHNN% eEll
= QLL!9!9:N!O!OPPE}$$U++ ") H *))+[+[\GGGImImn
))+++r# c g }t | j D ]/}| || 0|S )z
Return list of columns that should be selected from table.
:param table_aggregate_info: dict from _get_table_aggregate_info
:return: query for each column
:rtype: list
)r rA appendlower)rG r r column_names r! rs z(HistoryShowDBGov._get_columns_for_select sU *4+ABB P PK $ $%9+:K:K:M:M%N O O O O r# c | j t | j t r| ||z
}n| }|S )z
Returns dictionary:
{
column_name: aggregate_query
}
Ignores t_from and t_to if self.uid is not None;
:type t_from: int
:type t_to: int
:rtype: dict
)r@ rp rq get_history_gov_all_users_func)rG rR rS columns_infos r! rr z*HistoryShowDBGov._get_table_aggregate_info sM 8 z$(D 9 9 >>tf}MMLL >>@@Lr# c H t t j t j t j t j g t j |k }| j |
d \ }}||fS )z^
Get min and max timestamp for given user id.
:rtype: tuple(int, int)
r ) r r rL r r5 r rw r@ r= r| r} )rG r@ r rP rO s r! rK z HistoryShowDBGov._get_min_max_ts sz
00$(;>2J2JKLLRRS^SbfiSijj ..u55>>@@Cv~ r# c | j | j dk r | j | _ | j dk r| j d| _ || j }| j dvr| j rt | }|S )zt
Create order_by query
:param history_gov_aggregate_func:
:return: sqlalchemy query
Nconr5 id)r r r5 )rB
DEFAULT_ORDERr@ r rF r )rG history_gov_aggregate_funcr s r! rt z$HistoryShowDBGov._get_order_by_query s} = DMU$:$: .DM =D TX%5 DM3DM4G4G4I4IJ = 3 3 3 3 !. 1 1N r# c x g }t | j D ]}| dk r.| |d |d z | j k H| dk r.| |d |d z | j k t t
| S )z
Get by_usage query.
:param table_aggregate_info: dict from _get_table_aggregate_info
:return:
cpulcpuiolio)r r< r r r; NotImplementedErrorr )rG r filter_list
by_usage_items r! r{ z$HistoryShowDBGov._get_by_usage_query s ,T] ; ;
,
,M ""$$--"")%03G3OOSWSkk $$&&$.."")$/2Fu2MMQUQii *+++K r# c t | j }| |dt j t
j }| |dt j t
j }|p| j }|Pt ||t
j t
j t
j t j
t
j t j t
j
t j t
j t j t
j t
j
z t j
t
j t
j z dt j
t
j t j
t
j t j
t
j t' t
j d }nt+ t- |dz }t ||t j
t
j t
j t
j t j t
j |z t j t
j
|z t j t
j |z dt j t
j t
j
z |z t j
t
j t
j z t j
t
j t j
t
j t j
t
j t' t/ t
j d }|S )z=
:type time_period: int
:rtype: dict
r )offsetts_queryr N)fromtor5 r userr readwriter r r r lreadlwriterestrictg N@)r r r5 r r r r r r r r r r r r )r
r> rv r rL r r5 rE r r@ r sum_cpusumsum_read sum_writeavglimit_write_on_period_endlimit_read_on_period_endlimit_cpu_on_period_endr2 r rY r r" )rG time_periodrR normalized_from
normalized_to
time_interval
column_labelsminutes_passeds r! r z/HistoryShowDBGov.get_history_gov_all_users_func sZ
.d.>?? //&TXknE]E]/^^ q48KNC[C[\\
#5t~
/ +'%.%/ 'O 8K$788 H[%9 : : !Xk&; < < (;#8;;O#OPP 8K$IKLp$pqq H[%H I I !Xk&J K K "h{'L M M 5k6S T T MM( !md&:!;!; < 22%/ 'O 8K$788>I H[%9 : :^ K !Xk&; < <~ M (;#8;;O#OPPSaa 8K$IKLp$pqq H[%H I I !Xk&J K K "h{'L M M 56J;Kh6i6i j j M& r# r c | t j }| j rp| j j j dk r.t
||z
| j z |z t | j z |z S t j ||z
| j z |z | j z |z S |S )a
Round time depending on time_unit.
Returns query, that returns nearest
(N * time_unit + time_from) for current ts.
:param ts_query: custom column
:type time_from: int
:type offset: int
:return:
Nsqlite)
r r5 rE r= url
drivernamer
r r floor)rG time_fromr r s r! rv zHistoryShowDBGov.round_timeW s "~H > } +x77h 2dn Dv MPWXX[_[iiluuuz8i#74>"IF"RSSVZVddgpppOr# )
Nr6 NNNNNFNr7 rl )r N)__name__
__module__ __qualname__r rI rT rN rs rr rK rt r{ r rv r# r! r4 r4 ; s M
0 0 0 0 d 2I, I, I,V
!
!
! $ "! ! !(5 5 5 5 n r# r4 N) mathr
sqlalchemyr r r r r r r
r lvestats.libr lvestats.lib.commons.dateutilr
r r r r lvestats.lib.lveinfolibr r r r r lvestats.ormr r" r2 objectr4 r r# r! r sw $ $ $ $ $ $ $ $ 5 5 5 5 5 5 5 5 5 5 5 5 5 5 % % % % % % 4 3 3 3 3 3 e e e e e e e e e e 8 8 8 8 8 8 $ $ $ $ $ $ &p p p p p v p p p p p r#