DJ. X d dl Z d dlZd dlmZ G d de Z G d d ZdS ) N)bursting_events_tablec e Zd Z fdZ xZS )TableDoesNotExistErrorc j d| d| _ t | j d S )NzTable "z " does not exist in the database)messagesuper__init__)self
table_name __class__s /builddir/build/BUILDROOT/lve-stats-4.3.2-1.el9.x86_64/opt/cloudlinux/venv/lib/python3.11/site-packages/lvestats/lib/bursting/history.pyr z TableDoesNotExistError.__init__ s5 MMMM
&&&&& )__name__
__module__ __qualname__r
__classcell__)r s @r
r r s8 ' ' ' ' ' ' ' ' 'r r c
e Zd Z d dej j j dej dej dedz de ddf d Z
de ej j fd
Z
dS ) HistoryShowBurstingN localhostdbengine period_from period_touid server_idreturnc L || _ || _ || _ || _ || _ d S )N)r r r r r )r
r r r r r s r
r z HistoryShowBursting.__init__ s, !
&""r c
X t j | j }t j | vrt
t j | j }| j }t j
t j j t j j t j j
g t j t j j | j k t j j |k t j j |k | j t j j | j k nd }t j
t j j t j t j j d g t j t j j | j k t j j |k | j t j j | j k nd t j j d }t j
t j j t j j t j j
g t j |t j t j j |j j k t j j |j j k }t j || }| |j j |j j }| j 5 }| | } ddd n # 1 swxY w Y | S )z
Get history from the 'bursting_events' table.
Retrieving records within the required time frame,
along with one record preceding this time frame
to detect the bursting status at the start of the time frame.
NT
max_timestampsubquery) sainspectr r nameget_table_namesr r timestampr selectclve_id
event_typewhereand_r r funcmaxlabelgroup_byalias select_fromjoinr unionorder_byconnectexecutefetchall)
r
inspectorts_fromts_tostmt1r stmt2stmt
connectionresults
r
getzHistoryShowBursting.get$ s- Jt}-- %Y-F-F-H-H H H()>)CDD D",,..((** ! # * ! # - ! # .
5 G%'1T^C%'1W<%'1U:@D@T&(/48;;Z^
9 ! # * GKK-/9 : : @ @ Q Q
5 G%'1T^C%'1G;@D@T&(/48;;Z^
( ! # *
%
! # * ! # - ! # .
; ! &)+2hj6GG)+59QQ
x
}} FM F
]
"
"
$
$ 9
''--6688F 9 9 9 9 9 9 9 9 9 9 9 9 9 9 9
s +(N N#&N#)Nr )r r r r enginebaseEnginedatetimeintstrr listRowProxyr? r r
r r s $("-
#
# 9>0
# & /
# % -
# Dj
#
#
37
#
#
#
#JT"),- J J J J J Jr r )rC
sqlalchemyr lvestats.ormr Exceptionr r rH r r
rL s . . . . . .' ' ' ' 'Y ' ' 'X X X X X X X X X Xr