Rlj* d dl Z d dlZd dlmZ d dlmZ ddlmZmZm Z m
Z
m Z m Z m
Z
G d de ZdZed z Zd
d d d
dZdddddddZdddddZdd d Zd dd Zd#d Zd$d!Zd$d"ZdS )% N)FormattedException) mod_makedirs )boolean_to_yes_nois_positive_intmin_num_notify_converter repack_dictstr_to_booleantime_convertor_to_dicttime_unit_to_letterc e Zd ZdS )LveStats2ExceptionN)__name__
__module__ __qualname__ N/opt/cloudlinux/venv/lib64/python3.11/site-packages/clconfig/lve_stats2_lib.pyr r s Dr r z /etc/sysconfig/lvestats.configz/StatsNotifier.cfg notifyAdminnotifyResellersnotifyCustomersnotifyResellerCustomers) NOTIFY_ADMINNOTIFY_RESELLERNOTIFY_CUSTOMER NOTIFY_INCLUDE_RESELLER_CUSTOMERmemiopsnprocioconcurrentConnectionscpu)
NOTIFY_MEMORY NOTIFY_IOPS NOTIFY_NPROC NOTIFY_IO NOTIFY_EP
NOTIFY_CPUnotifyFromEmailreportAdminMail
notifySubject
notifyCharset)NOTIFY_FROM_EMAILREPORT_ADMIN_EMAILNOTIFY_FROM_SUBJECTNOTIFY_CHARSET_EMAILuseradmin)NOTIFY_MIN_FAULTS_USERNOTIFY_MIN_FAULTS_ADMIN)NOTIFY_INTERVAL_ADMINNOTIFY_INTERVAL_USERrc & t | |d S )Nutf-8)modeencoding)open) file_namer: s r _openr> ; s w 7 7 77r c ^ t }t j | si S t | }| }| n># t t f$ r*}t dt | z d|id |d}~ww xY wi }|D ]_}| d s| dk r0|
d \ }}| ||< `t } t }
t } t" } t% | |t& }
t% |
|t& }t% | |t( d }t% | |t* }t% t, |t d }||
d
< ||
d < ||
d < ||
d
< d|
iS )a
Retrieves lve-stats2 notifications parameters
:param str reseller: reseller name, if we want notifications parameters for a reseller
:return: dict. For example:
{'faultsNotification': {'notifyResellerCustomers': True,
'notifyResellers': True,
'minimumNumberOfFaultsToNotify': {'admin': 0, 'user': 0},
'notifyAdmin': True,
'notify': {'admin': {'unitOfTime': 'hours', 'period': 12},
'user': {'unitOfTime': 'hours', 'period': 12}
},
'faultsToInclude': {'mem': True, 'iops': False, 'io': False,
'nproc': False, 'concurrentConnections': False,
'cpu': True},
'notifyCustomers': False
}
}
%(lvestats_cfg)s read error: lvestats_cfgmessagecontextN# =r )defaultfaultsToInclude minimumNumberOfFaultsToNotifynotifyemailfaultsNotification)StatsNotifierConfigospathexistsr> readlinescloseIOErrorOSErrorr str
startswithstripsplit notify_dict faults_dictnumber_notify_dictnotify_time_dictr r
r r email_notify_dict)reseller config_pathfconfige config_dictlinekeyvaluenotify_dfaults_dnumber_notify_d
notify_time_dfaults_notification_dictfaults_include_dictmin_num_notify
period_notifyemail_settingss r get_notificationrq ? s & &K
7>>+ & & T + W T T T -LsSTvv-U.# t$ t0 f$ r*}t d3t | z d|id |d}~ww xY w| D ] \ }}
|
| d2|
d5 }t5 t7 ||
}
t9 |dd67 5 }| d8 |
ddd n # 1 swxY w Y n># t t f$ r*}t d9t | z d|id |d}~ww xY wt? j d:d;d dS )?a
Sets lve-stats2 notifications parameters
:param parameters_dict: Parametres to set. For example:
{u'notifyResellers': True,
u'faultsToInclude': {u'mem': True, u'iops': False, u'io': False, u'nproc': False,
u'concurrentConnections': False, u'cpu': True},
u'minimumNumberOfFaultsToNotify': {u'admin': 0, u'user': 0},
u'notifyAdmin': True,
u'notify': {u'admin': {u'unitOfTime': u'hours', u'period': 12},
u'user': {u'unitOfTime': u'hours', u'period': 12}
},
u'notifyResellerCustomers': True,
u'notifyCustomers': False
}
:param str reseller: either reseller name or None
r Ni wc 6 g | ]}| S r rX .0re s r
z$set_notification.. s ???
???r r@ rA rB c t | S Nr xs r z"set_notification.. s 2CA2F2F r zfaultsToInclude/cpuc t | S rz r{ r| s r r~ z"set_notification.. s 4Ea4H4H r zfaultsToInclude/nprocc t | S rz r{ r| s r r~ z"set_notification.. 1B11E1E r zfaultsToInclude/ioc t | S rz r{ r| s r r~ z"set_notification.. s 5Fq5I5I r zfaultsToInclude/memc t | S rz r{ r| s r r~ z"set_notification.. r r z%faultsToInclude/concurrentConnectionsc t | S rz r{ r| s r r~ z"set_notification.. s 3DQ3G3G r zfaultsToInclude/iops)r( r% r& r# r' r$ c B t | t | S rz r r r} ys r r~ z"set_notification.. s# /!2D2D/^FYZ[F\F\/^/^ r znotify/admin/periodznotify/admin/unitOfTimec B t | t | S rz r r s r r~ z"set_notification.. s# 1C1C.]EXYZE[E[.].] r znotify/user/periodznotify/user/unitOfTimec t | S rz r{ r| s r r~ z"set_notification.. s #4Q#7#7 r r c t | S rz r{ r| s r r~ z"set_notification.. &7&:&: r r c t | S rz r{ r| s r r~ z"set_notification.. r r r c t | S rz r{ r| s r r~ z"set_notification.. s 7H7K7K r r z#minimumNumberOfFaultsToNotify/adminz"minimumNumberOfFaultsToNotify/user)r5 r6 r r r r r4 r3 zemail/notifyFromEmailzemail/notifySubjectzemail/reportAdminMailzemail/notifyCharset)r- r/ r. r0 c | d } }|D ]
}|| } n%# t $ r d }|D ]
}|| } Y nw xY w|S )N/rM )rY KeyError)rP
path_partspointpartnotifier_paramsparameters_dicts r get_val_by_pathz)set_notification..get_val_by_path s ZZ__
$#E"
$
$ d
$ $ $ $#$89E"
$
$ d
$
$ $ s ( A
A
c 3 . K | ]} | V d S rz r )rw r} r s r z#set_notification.. s- *O*O!??1+=+=*O*O*O*O*O*Or r c 6 g | ]}| S r ru rv s r rx z$set_notification.. s ===tzz||===r rE rF rG z %(lvestats_cfg)s format error: z: c | d s| dk rdS | d \ }}|dk S )NrE rF TrG None)rW rX rY )_line__values r filter_config_linesz-set_notification..filter_config_lines sO C EKKMMR$7$74KK$$ 6 r r9 )r;
z %(lvestats_cfg)s write error: z+/sbin/service lvestats reload &>/dev/null &Tz /bin/bashF)shell
executablecheck)!rO rP rQ rN lenrq dirnamer r> rS rR rT rU r rV updateitems
isinstancer enumeraterW rX rY
ValueError
IndexErrorappendlistfilterr<
writelinesjoin
subprocessrun)r r_ r` ra config_linesrc faults_config_map
new_configrf valconfig_to_writeidxre rg r r r s ` @@r set_notificationr x sI & 7>>- . . #o2F2F!2K2KO%K&((O 7>>"'//+66 7 7 :RW__[115999
7>>+ & & (
k3 %%'''\ + ?? ??? W \ \ \ -LsSTvv-U.<>Q-R"T "T U UZ[ \\ )G(FH]'^*H*HJa)b'E'EG[&\+I+IK`*a'E'EGn&o)G)GI_(` b b "^"^"7";"= "^!]"6":!< 87 G : := ===OT"<00 $ $ICs##
tzz||r'9'9
F !ZZ__
UU
F
F
F( @cAgCWCWQUCWCW W . <*> *> ? ?DEF
F j *-'A'A
3'A'A$ sO $
j ! T T T -NQTUVQWQW-W. =)O2& O> 2O66O> 9O6:O> >P9%P44P9)r7 rz )rO r clcommon.clexceptionr clcommon.utilsr clconfig_utilsr r r r r
r r r StatsNotifierDirrN rZ r[ r^ r\ r] r> rq r r r r r s
3 3 3 3 3 3 ' ' ' ' ' ' + 4 &)== ,"3"33LN N
!& $ & 3 " $ $ +<+<,;-<> >
1718: : .5,24 4
8 8 8 86< 6< 6< 6