]A t d dl Z d dlZd dlZd dlZd dlmZmZmZ d dlZd dl m
Z
m Z d dl Z
d dlmZmZ d dlmZmZ d dlmZmZ d dlmZ d dlmZ d d lm Z m Z d d
l m Z m Z d d l!m"Z"m#Z# d d l$m%Z% ei d
ej& ej' Z(e
j) j* j+ j, d d Z-de.e/e/f dej0 j1 j2 de3e/ de/fdZ4de.e/e/f de3e/ de j5 fdZ6de3ej0 j7 dedede/fdZ8 G d de3 Z9de3ej0 j7 d e:d e:de3e9 fd Z;dS ) N)datetime timedeltatimezone)OperationalErrorProgrammingError)HistoryShowBurstingTableDoesNotExistError)
ParseDatetimecheck_non_negative_int) gm_to_local local_to_gm)get_ascii_table)
setup_logging) ConfigError read_config)make_db_engineMakeDbException)BurstingEventTypebursting_events_table)is_bursting_supportedzlve-bursting-info) caller_name
file_level
console_levelreturnc \ t s#t d t j d t } t | }t
| |t j dd }|rt | d S d S # t $ rB}t |j t d t j d Y d }~d S d }~wt t t t f$ r;}t d| t j d Y d }~d S d }~ww xY w)Nz?Bursting Limits feature is not supported in current environment )cfgz2Enable Bursting Limits feature to create the tablez>Error occurred while executing the "lve-bursting-info" utility)exc_info)r printsysexitr r _mainargvr messager r r r logerror)r dbengineoutputes /builddir/build/BUILDROOT/lve-stats-4.3.2-1.el9.x86_64/opt/cloudlinux/venv/lib/python3.11/site-packages/lvestats/lib/bursting/info.pymainr+ " s7 " "
OPPP
mm!c***sHchqrrl33 &MMMMM !
ai
BCCC . _ M R s$ AB
D+7C D+00D&&D+configr' r# c t | | }t t |d }t |j }t ||||j |j }| }t ||| }|S )Nfrom)r' period_from period_touid server_id) _parse_argsr
getattrtor idr2 get _build_table) r, r' r# namespaceperiod_from_utc
period_to_utc history_showrowstables r* r" r" 7 s FD))I "')V"<"<==O --M&# L% L D
> >E L c t j d }| dt d | dt | dd d
| }t j }t d }| d
dt ||z
ddd | ddt |ddd | | S )Nz1Utility for displaying bursting limits statistics) descriptionz--idz-display records only for the specified LVE id)typehelpz --server-idr2 localhostzFused with central database for multiple servers, default "%(default)s")rB defaultrC r )hoursz-fz--from+zidisplay records from the specified date and time; if not provided, will assume the last 1-hour time framezYYYY-MM-DD[ HH:MM])actionrE nargsrC metavarz-tz--tozodisplay records up to the specified date and time; if not provided, will include records up to the current time) argparseArgumentParser add_argumentr strr7 add_argument_groupr nowr r
parse_args)r, r# parser group_period datetime_nowdefault_timedeltas r* r3 r3 M s:
$GI I IF
#
< > > >
; 44
U W W W ,,..L<>>L "*** h 00G$ & & & f L$ & & & T " ""r? r= dt_fromdt_toc t | | | }t |g dd }|S )zt
Build string representation of a console-displayable table
using the rows retrieved from the DB table.
)IDFromTor )fields
padding_width)_build_table_rows timestampr )r= rV rW
table_rowsr> s r* r8 r8 v s\ #4#*#4#4#6#6#(??#4#46 6J
J#7#7#7*+
-
-
-E Lr? c 8 e Zd ZdZefdedededef fd
Z xZS )TableRowz%Y-%m-%d %H:%M:%S.%flve_idstartendformat_c L t t j |t j }t t j |t j }t || | | | g d S N)r r
fromtimestampr utcsuper__init__strftime)selfrc rd re rf dt_startdt_end __class__s r* rl zTableRow.__init__ s x 5eX\ J JKK X 3C F FGG
&"++G44 //'224 5 5 5 5 5r? ) __name__
__module__ __qualname__DEFAULT_FORMATintfloatrN rl
__classcell__)rq s @r* rb rb sp +N !/
5
5
5
5
5
5
5
5
5
5
5
5
5
5
5r? rb ts_fromts_toc g }t j | d }|D ]P\ }}t | }d}d\ }} |d t j j |k r4d}|d t j j t j j k r|}t |t | D ]}
||
t j j t j j k r | ||
t j j }R|U||
t j j } | t ||| d\ }} |$| t ||| R|S )zk
Build table rows representing time frame intervals
when bursting was enabled for each LVE id.
c 0 | t j j S rh )r crc )rows r* z#_build_table_rows.. s c"7"9"@ A r? )keyr )NNr ) itertoolsgroupbylistr r} r_
event_typer STARTEDvaluerangelenappendrb ) r= ry rz result grouped_datarc groupfirst_event_idxts_from_ts_to_is r* r^ r^ sy F $ AAC C CL & = =
U %&
8)+5 6 @ @ OQx-/:;?P?X?^^^" E
33 * *AQx-/:;?P?X?^^^# $Qx(=(?(I JH 1X 3 5 ?@F MM(68V<< = = = ) Hff MM(68U;; < < < Mr? )r N)r s
2 2 2 2 2 2 2 2 2 2 = = = = = = = = & & & & U U U U U U U U U U U U U U U U B B B B B B B B 5 5 5 5 5 5 7 7 7 7 7 7 8 8 8 8 8 8 8 8 A A A A A A A A A A A A A A A A I I I I I ImB 3 &")-1 1 1
+ ,+($sCx. IN)S ! ,&#S#X &#d3i &#H