@j4 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 Zd 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 d|v rHt j | t j t j z t j z t j z d }n,t j | t j t j z }t j ||d S )Nw zutf-8)modeencoding)osopenO_WRONLYO_CREATO_TRUNC
O_NOFOLLOWO_RDONLYfdopen) file_namer! fds &py/clconfig/lve_stats2_reseller_lib.py_openr. / si
d{{
WY bj 82: E
UW\
]
]
WY bm ;
<
<
9RdW 5 5 55 c | t d d| v s+d| v s'd| v s#d| v s t j | rt dd| id t j t | d
}t j t }t j | |t j z st d ||d d |S )
an
Validate ``reseller`` as a bare system username and build its
StatsNotifier config path under ResellerStatsNotifierDir.
A real reseller username can never contain a path separator, a NUL byte
or '..', nor be an absolute path; rejecting those stops os.path.join from
silently discarding the base dir (absolute name) or traversing out of it.
Nzreseller can`t be None/\ z..z#invalid reseller name: %(reseller)sr messagecontextz_StatsNotifier.cfgz-reseller config path %(path)s escapes %(dir)s)pathdir)
ValueErrorr# r7 isabsr
joinResellerStatsNotifierDirrealpath
startswithsep)r config_pathreal_dirs r- _reseller_config_pathrB 8 s 1222 x48++tx/?/?x 27==#:#: -R.8(-C"E "E F F F',, 7H9X9X9XYYKw 899H
7 K ( ( 3 3Hrv4E F F V -\6A(-S-S"U "U V V V r/ 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..U s2 #C &78= r/ )memiopsionprocconcurrentConnectionscpunotifyResellers minimumNumberOfFaultsToNotifyadminuser)r r notify
unitOfTimeperiod)rW rX notifyResellerCustomers)r rS r rV rF r )r get_notificationget) admin_faultsrJ s @r- _create_default_reseller_configr] P 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 J t | }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' |
|t, }||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
}
}
%(lvestats_cfg)s read error: lvestats_cfgr4 N# =r )defaultrF rS rV rD )rB r# r7 existsr] r. readlinescloseIOErrorOSErrorr
strr> stripsplitreseller_notify_dictr reseller_number_notify_dictreseller_notify_time_dictr r
r r )r defaultsr@ fconfige config_dictlinerI valuenotify_dfaults_dnumber_notify_d
notify_time_dfaults_notification_dictfaults_include_dictmin_num_notify
period_notifys r- rZ rZ h s ( (11K
7>>+ & & E4<D.000"DT + W T T T -LsSTvv-U. $ r%}t- d1|
d(z d2| z d|id |d}~ww xY w| |v r| d0|| | |
< || = n># t4 t@ f$ r*}t- d1t/ | z d|id |d}~ww xY w| D ] \ } } | ! | d0| t% |d3 5 }|" d*# | ddd n # 1 swxY w Y n># t( t* f$ r*}t- d4t/ | z d|id |d}~ww xY wtI 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 N)r i r c 6 g | ]}| S rG rk rH ru s r-
z$set_notification.. s ???
???r/ r_ r` r4 c t | S Nr xs r- z"set_notification.. s 2CA2F2F r/ zfaultsToInclude/cpuc t | S r r r s r- r z"set_notification.. s 4Ea4H4H r/ zfaultsToInclude/nprocc t | S r r r s r- r z"set_notification.. 1B11E1E r/ zfaultsToInclude/ioc t | S r r r s r- r z"set_notification.. s 5Fq5I5I r/ zfaultsToInclude/memc t | S r r r s r- r z"set_notification.. r r/ z%faultsToInclude/concurrentConnectionsc t | S r r r s r- r z"set_notification.. s 3DQ3G3G r/ zfaultsToInclude/iops)
NOTIFY_CPU NOTIFY_NPROC NOTIFY_IO
NOTIFY_MEMORY NOTIFY_EP NOTIFY_IOPSc B t | t | S r r r r ys r- r z"set_notification.. # _Q5G5G2aI\]^I_I_2a2a r/ znotify/reseller/periodznotify/reseller/unitOfTimec B t | t | S r r r s r- r z"set_notification.. r r/ znotify/customer/periodznotify/customer/unitOfTimec t | S r r r s r- r z"set_notification.. s 6G6J6J r/ r c t | S r r r s r- r z"set_notification.. s :KA:N:N r/ r c t | S r r r s r- r 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 )Nr1 rD )rl KeyError)r7
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 r rG )rH r r s r- z#set_notification.. s- *O*O!??1+=+=*O*O*O*O*O*Or/ r
z illegal newline in %(key)s valuerI c 6 g | ]}| S rG r r s r- r z$set_notification.. s ===tzz||===r/ ra rb rc z %(lvestats_cfg)s format error: z: r z %(lvestats_cfg)s write error: z+/sbin/service lvestats reload &>/dev/null &Tz /bin/bashF)shell
executablecheck)&r# r7 re r lenrB updater] rZ dirnamer r$ r% r& O_EXCLr( rg FileExistsErrorr. rf rh ri r
rj items
isinstancer enumerater> rk rl r9
IndexErrorappend
writelinesr;
subprocessrun)r r r@ r, rq config_linesrs faults_config_map
new_configrI valrv config_to_writeidxru r r s ` @@r- set_notificationr s & 7>>- . . #o2F2F!2K2KO'11K
7>>+ & & D > @ @AAAA / B B BCCC 7>>"'//+66 7 7 :RW__[115999
7>>+ & & bkBJ&>&JR]&Z\abbB HRLLLL
D
\ + ?? ??? 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 !&&(( @ @
U 3u:: U!3!3$1S27 &? &? @ @
@ "4
>= ===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.r sx
' ' ' ' ' ' c b b b b b b b b b b b+o= (8+F"3 #-", !+ * 6 6 6 6 0 05< 5< 5< 5