Rlj< d dl Z d dlZd dlmZ d dlmZ d dlmZ d dlm Z ddl
m Z m Z m
Z
mZ G d d e Zd
d d
d
d d
dddd
d d
dd ddd ddd
ZdZd Zd"dZd Zd Zd Zd Zd Zd"d Zd Zd Zd! Z dS )# N)Optional)etree)FormattedException)
MySQLGovernor )boolean_to_on_offstr_to_booleantime_convertor_to_dicttime_unit_to_letterc e Zd ZdS )DBGovernorExceptionN)__name__
__module__ __qualname__ O/opt/cloudlinux/venv/lib64/python3.11/site-packages/clconfig/db_governor_lib.pyr
r
s Dr r
offon limit60smodeunlimitkilllogPathtimeoutLONGr formatERROR)
modeOfOperationgatherDataForDetailedStatssave_uidlogRestrictedUsersQueries
scriptPathuserMaxConnections restrictType slowQueries restrictLogerrorLogz!/etc/container/mysql-governor.xmlc $ t | d S )Nzutf-8)encoding)open) file_names r _openr3 > s G , , ,,r c dt | z dz t | z }| | d }n# t t f$ r |cY S w xY w|S )a
Gets data from specified node and attribute
:param x: Parent node object
:param node: Node name to extract data
:param attrib: Attribute name to extract data
:param default: Default value to return if specified node/attribute not found
:return: Value
///@r )strxpathAttributeError
IndexError)xnodeattribdefaultpathdatas r get_data_from_xmlrA B sk c$ii $&V4wwt}}Q J ' Ks A A AAc t | } | d rt | dd dz }n| d r t | dd dz dz }nr| d r!t | dd dz dz dz }n<| d rt | dd }nt | }|S ) z~
Convert value in minutes, hours, days to seconds
:param value: value of slow limit
:return: value in seconds
mN< hd s)r7 lowerendswithint)valueresults r convert_time_value_to_secondsrO S s
JJ E ~~c U3B3Z 2% U3B3Z 2%* U3B3Z 2%*R/ U3B3Z U Mr c | d d }t | }t | S # t t t
f$ r |cY S w xY w)z
Gets slow queries timeout
:param x: Root node
:param default: Default value to return if timeout not found
:return: Timeout
z$default/limit[@name='slow']/@currentr )r8 rO rL r9 r:
ValueError)r; r> r@ s r get_slow_queries_timeoutrR h sb ww=>>qA,T224yy J
3 s 8; AAc d}| | }t | dk r| d }t | dk r)t j d }| | | d d }t j d }| | | dd n|d }| dt
| dS ) z{
Sets slow queries timeout
:param node: Root node
:param slow_timeout: new timeout value
:return: None
zdefault/limit[@name='slow']r r> r nameslowcurrentN)r8 lenr Elementappendsetr7 )r< slow_timeoutr? tag_list node_listnew_node default_node
tag_to_sets r set_slow_queries_timeoutra w s )Dzz$ H
8}}JJy)) y>>Q }Y//H KK ! ! !zz),,Q/ ]7++
J'''vv&&&& a[
NN9c, / /00000r c 2 dt | z }| | }t | dk r>t j | }| | | | }|d }| || dS )z
Sets value to specified node/attribute
:param x: Parent node
:param node_name: Node name
:param attribute_name: Attribute name
:param value: Value to set
:return: None
r5 r N)r7 r8 rW r rX rY rZ )r; node_nameattribute_namerM r? r\ r^ tags r set_data_to_xmlrf s #i.. Dwwt}}H
8}}=++ 774==
1+CGGNE"""""r c t | || } t | S # t $ r"}t t d| d| |d}~ww xY w)z
Get time from specified tag/attribute as seconds
:param x: XML object
:param tag_name: XML tag name
:param attr_name: XML object name
:return: Number of seconds. Throws DBGovernorException if any error
z has invalid value in governer/r6 N)rA r
Exceptionr
DbGovConfig)r; tag_name attr_namerM es r _get_timedict_from_xmlrm su
a9 5 5E%e,,, ! R R8 R Ry R R
s "
A A Ac t j t sdS | ;t t }t j | }n| }t |ddt d S )z
Get MySQL Governor mode. We return None if governor config isn't exists
All exceptions will be catched in top level functions
:param parsed_xml_tree: parsed governor config
Nlveuser% )
osr? existsri r3 r parsegetrootrA
DEFAULTS_DICT)parsed_xml_treefr; s r get_gov_mode_operationrx sl 7>>+ & & t + KNN " " $ $ Qumu >u /v /v1B1nV[CPQ^C_`iCj2l 2l1I!][hMijsMt1u1u &( &( M" )J}]?[\e?fgg':x }A]^fAghh&
&
M" /@5&R_`jRkluRv.w.w,=aP]^hPijrPs,t,t#% #% J /11222"K00 We 2E4M "5 7 Q Q Q!["H"HQ"H"HIIqPQs %K; KK; ;8M3M
Mc T t j t sdS t t }t j | }| dddt fdddt fdd d
t fd dd t fd
ddt fdddt fdddt fdddt fddd
t fdddt fdddt fdddt fg }|D ]G} |\ }}}}t d | } t ||| || 8# t $ r Y Dw xY wg d }
|
D ]a}|\ } } }} t d | }
t t d | }t ||||
| R# t $ r Y ^w xY w | d d }t || n# t $ r Y nw xY wt j | }t# t d 5 }| d!|z ddd n # 1 swxY w Y nd# t& t( t
j t
j t
j f$ r/}t1 d"t | z d#t id$ |d}~ww xY wt3 j d%d&d'd() dS )*a%
Set MySQL governer config
:param parameters_dict: Parameters to set dictionary. For example:
{
u'modeOfOperation': u'abusers',
u'scriptPath': u'',
u'gatherDataForDetailedStats': True,
u'userMaxConnections': 30,
u'logRestrictedUsersQueries': False,
u'restrictLog': {u'logPath': u'/var/log/dbgovernor-restrict.log', u'format': u'LONG'},
u'restrictedTimePeriods': {u'level1': {u'unitOfTime': u'seconds', u'period': 60},
u'level2': {u'unitOfTime': u'minutes', u'period': 15},
u'level3': {u'unitOfTime': u'hours', u'period': 1},
u'level4': {u'unitOfTime': u'days', u'period': 1},
u'timeout': {u'unitOfTime': u'hours', u'period': 1}},
u'errorLog': {u'logPath': u'/var/log/dbgovernor-error-my.log', u'level': u'DEBUG'},
u'slowQueries': {u'logPath': u'/var/log/dbgovernor-kill.log', u'kill': True, u'timeout': 30},
u'restrictType': {u'mode': u'limit', u'unlimit': {u'unitOfTime': u'seconds', u'period': 60}}
}
Any key in dictionary can absent, appropriate MySQL Governor parameter will not changed
:return: None. Throws DBGovernorException if error
Nz['modeOfOperation']ro rp z['scriptPath']r| r} z ['gatherDataForDetailedStats']rz r z['userMaxConnections']r~ z ['logRestrictedUsersQueries']r{ z['restrictLog']['logPath']r z['restrictLog']['format']r# z['errorLog']['logPath']r z['errorLog']['level']z['slowQueries']['logPath']r z['slowQueries']['kill']r z['restrictType']['mode']r parameters_dict))z%['restrictType']['unlimit']['period']z)['restrictType']['unlimit']['unitOfTime']r r )z-['restrictedTimePeriods']['level1']['period']z1['restrictedTimePeriods']['level1']['unitOfTime']r| r )z-['restrictedTimePeriods']['level2']['period']z1['restrictedTimePeriods']['level2']['unitOfTime']r| r )z-['restrictedTimePeriods']['level3']['period']z1['restrictedTimePeriods']['level3']['unitOfTime']r| r )z-['restrictedTimePeriods']['level4']['period']z1['restrictedTimePeriods']['level4']['unitOfTime']r| r )z.['restrictedTimePeriods']['timeout']['period']z2['restrictedTimePeriods']['timeout']['unitOfTime']r| r r, r wbs
%s
z%(dbgov_cfg)s error: dbgov_cfg)messagecontextz//sbin/service db_governor restart &>/dev/null &Tz /bin/bashF)shell
executablecheck)rq r? rr ri r3 r rs rt closer7 r evalrf KeyErrorr ra tostringr1 writer r r r r r
subprocessr )r rw r; control_data_listcontrol_data_iteminput_dict_keys xml_tag_namexml_attribute_namefunc_convertervalcontrol_data_pairs_listperiod_indexesperiod_unit_of_time_indexes
period_valperiod_unit_of_timeslow_queries_timeouts_xmlrl s r set_db_gov_configr s .LRw~~k** F + KNN " " $ $ #E5# 6
z8S 9
-{FDU V
%z3I3 O
,lECT U
):uc B
(*h D
&vs ;
$eVS 9
)>5# F
&?P Q
' % E
"3
TeQ /A>>_>>?? <1C^^TWEXEXYYYY
#
#
#
"9 \m YN 7 GY
""DN"D"D E E
&9$?nQl?n?n:o:o&p&p# <1C
EiTgEiEijjjj
#2=#A)#L $Q(< = = = = D q!!
+t
$
$ =
GG3e; < < < = = = = = = = = = = = = = = = We 2E4MuOc d R R R!.EA.N/:K.H#J #J K KPQ RR ND +UD D D D D Ds $H, C H, 54D*)H, *
D74H, 6D77H,
AFH,
F H, F H, # G H,
G H, G,H, ;H H, H$$H, 'H$(H, ,2J
*JJ
c t } | \ }}| |t | dS )z
Get db_governor status and version info
:return: dict(
'dbGovVersion': ,
'dbGovStatus': enabled|error|disabled,
'dbGovError': error details
)
) dbGovVersion dbGovStatus
dbGovError)r get_governor_statusget_governor_versionr7 )db_govstatuserrors r r r l sL __F..00MFE 3355 %jj r )N) rq r typingr lxmlr clcommon.clexceptionr clcommon.lib.mysql_governor_libr clconfig_utilsr r r
r r
ru ri r3 rA rO rR ra rf rm rx r r r r r r r s
3 3 3 3 3 3 9 9 9 9 9 9 ,
"&!&
)
4 2 - - - " * 1 1 18# # #* "P P P P"3Q 3Q 3QliD iD iDX r