r|w d dl Z d dlZd dlmZ ddlmZ ddlmZmZm Z m
Z
m Z m Z m
Z
ddlmZmZmZmZ edz Zdd d
d Zd d
dZd d
dZddZd ZddZd ZdS ) N) mod_makedirs )lve_stats2_lib)boolean_to_yes_nois_positive_intmin_num_notify_converter repack_dictstr_to_booleantime_convertor_to_dicttime_unit_to_letter)LveStats2ExceptionStatsNotifierConfigStatsNotifierDir faults_dictz
/resellers.d/notifyResellernotifyResellerOnCustomersnotifyCustomers) NOTIFY_RESELLER_ON_TOTAL_FAULTS#NOTIFY_RESELLER_ON_CUSTOMERS_FAULTSNOTIFY_CUSTOMERS_ON_FAULTSresellercustomer)NOTIFY_MIN_FAULTS_RESELLERNOTIFY_MIN_FAULTS_CUSTOMER)NOTIFY_INTERVAL_RESELLERNOTIFY_INTERVAL_CUSTOMERrc & t | |d S )Nutf-8)modeencoding)open) file_namer s &py/clconfig/lve_stats2_reseller_lib.py_openr% / s w 7 7 77 c ~ t j d fddD } dd d d d d dd d d d
d d d d d d d
d d d d d| d
diS )z;
Creates default StatsNotifier config for reseller
faultsNotificationc . i | ]}|d | S )faultsToInclude ).0key admin_configs r$
z3_create_default_reseller_config..8 s2 #C &78= r& )memiopsionprocconcurrentConnectionscpunotifyResellers minimumNumberOfFaultsToNotifyadminuser)r r notify
unitOfTimeperiod)r; r< notifyResellerCustomers)r r7 r r: r* r )r get_notificationget) admin_faultsr. s @r$ _create_default_reseller_configrA 3 s "244889MNNL J L
!*67H*I )*I J7 S )*I J6 R/T /T ,,= >3?3I'3RS_3`/;H/Eg/Nx/X%Z %Z3?3I&3QR^3_/;H/Ef/Mh/W%Y %Y
!- ,-F G
r& Fc | t d t j t | d }t j | s|rt
ni 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+ |
|t0 }||d < ||d
< ||d< d|iS )ak
Retrieves lve-stats2 notifications parameters for resellers
:param bool defaults: True if we want get defaults when config is not set, else False
: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
}
}
Nreseller can`t be None_StatsNotifier.cfg %(lvestats_cfg)s read error: lvestats_cfgmessagecontext# =r )defaultr* r7 r: r( )
ValueErrorospathjoinResellerStatsNotifierDirexistsrA r% readlinescloseIOErrorOSErrorr
str
startswithstripsplitreseller_notify_dictr reseller_number_notify_dictreseller_notify_time_dictr r
r r )r defaults config_pathfconfige config_dictliner- valuenotify_dfaults_dnumber_notify_d
notify_time_dfaults_notification_dictfaults_include_dictmin_num_notify
period_notifys r$ r> r> K s ( 1222',, 7H9X9X9XYYK
7>>+ & & E4<D.000"DT + W T T T -LsSTvv-U.# t, t6 f$ r*}t% d/t' | z d
|id |d}~ww xY w| D ] \ }}
|
| d.|
t; |dd12 5 }| d3 |
ddd n # 1 swxY w Y n># t t" f$ r*}t% d4t' | z d
|id |d}~ww xY wt? j d5d6d7d89 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 NrC rD )r i wc 6 g | ]}| S r+ rZ r, re s r$
z$set_notification.. s ???
???r& rE rF rG c t | S Nr xs r$ z"set_notification.. s 2CA2F2F r& zfaultsToInclude/cpuc t | S rv rw rx s r$ rz z"set_notification.. s 4Ea4H4H r& zfaultsToInclude/nprocc t | S rv rw rx s r$ rz z"set_notification.. 1B11E1E r& zfaultsToInclude/ioc t | S rv rw rx s r$ rz z"set_notification.. s 5Fq5I5I r& zfaultsToInclude/memc t | S rv rw rx s r$ rz z"set_notification.. r} r& z%faultsToInclude/concurrentConnectionsc t | S rv rw rx s r$ rz z"set_notification.. s 3DQ3G3G r& zfaultsToInclude/iops)
NOTIFY_CPU NOTIFY_NPROC NOTIFY_IO
NOTIFY_MEMORY NOTIFY_EP NOTIFY_IOPSc B t | t | S rv r r ry ys r$ rz z"set_notification.. # _Q5G5G2aI\]^I_I_2a2a r& znotify/reseller/periodznotify/reseller/unitOfTimec B t | t | S rv r r s r$ rz z"set_notification.. r r& znotify/customer/periodznotify/customer/unitOfTimec t | S rv rw rx s r$ rz z"set_notification.. s 6G6J6J r& r c t | S rv rw rx s r$ rz z"set_notification.. s :KA:N:N r& r c t | S rv rw rx s r$ rz z"set_notification.. r} r& r z&minimumNumberOfFaultsToNotify/resellerz&minimumNumberOfFaultsToNotify/customer)r r r r r r r c | d } }|D ]
}|| } n%# t $ r d }|D ]
}|| } Y nw xY w|S )N/r( )r[ 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 rv r+ )r, ry r s r$ z#set_notification.. s- *O*O!??1+=+=*O*O*O*O*O*Or& r c 6 g | ]}| S r+ rr rs s r$ rt z$set_notification.. s ===tzz||===r& rJ rK rL z %(lvestats_cfg)s format error: z: r )r!
z %(lvestats_cfg)s write error: z+/sbin/service lvestats reload &>/dev/null &Tz /bin/bashF)shell
executablecheck)!rO rP rS r lenrN rQ rR updaterA r> dirnamer r% rU rT rV rW r
rX items
isinstancer enumeraterY rZ r[
IndexErrorappendr"
writelines
subprocessrun)r r r` ra config_linesrc faults_config_map
new_configr- valconfig_to_writeidxre rf r r s ` @@r$ set_notificationr sa & 7>>- . . #o2F2F!2K2KO1222',, 7H9X9X9XYYK
7>>+ & & D > @ @AAAA / B B BCCC 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 %a%a%=%A%C &b%a%=%A%C -K,JL\+]0N0NPk/l'E'EGX&Y&N&N P P Q Q Q J
&++-- S #s##
Q"1/#"6"6
3"(#a&*O*O*O*Os122w*O*O*O"P
3 H >= ===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.>
K
K AN L76N 7
M& M!!M&&N N=%N88N=5Q )P<0 Q <Q Q Q Q R%Q>>R)r )F)rO r clcommon.utilsr rK r clconfig_utilsr r r r r
r r r
r r r rR r\ r] r^ r% rA r> r r+ r& r$ r si
' ' ' ' ' ' c b b b b b b b b b b b+o= (8+F"3 #-", !+ * 8 8 8 8 07< 7< 7< 7