Ñò ýɪWc @s¿ddkZddkZddkZddkZddkZddkZddklZdeifd„ƒYZdd d„ƒYZdefd„ƒYZ d „Z e d jo e ƒndS( iÿÿÿÿN(t SSHCommandertAlertPolicyForCMS3XcBsPeZd„Zd„Zd„Zd„Zd„Zd„Zd„Zd„Z RS(cCstii|ƒdS(N(t BaseClasst__init__(tself((s`/home/jenkins/workspace/prepack-aio-release-4.2/prepack-aio/src/main/resources/scripts/Alerts.pyR scCsA|d}|iid|ƒt|iiƒƒotStSdS(Nis3SELECT IDENTIFIER FROM ALERTS WHERE IDENTIFIER='%s'(tcursortexecutetlentfetchalltTruetFalse(RtdatatalertIdentifier((s`/home/jenkins/workspace/prepack-aio-release-4.2/prepack-aio/src/main/resources/scripts/Alerts.pytcheckExistences  cCsdS(Ni((R((s`/home/jenkins/workspace/prepack-aio-release-4.2/prepack-aio/src/main/resources/scripts/Alerts.pyt getNextIdscCsyéd|i|dd!ƒ}|GH|ii|ƒtiƒ}y:|ddj o%|id|dd|dfƒnWntj onXy:|ddj o%|id|dd|dfƒnWntj onX|iƒSWn!tj o}|GH|i ƒSXdS(NsnINSERT INTO ALERTS (IDENTIFIER, ALERT_NAME , THRESH_COUNT, THRESH_SECS, FREQ_COUNT, FREQ_SECS, TYPE) VALUES %siiii( t tupleToStrRRt AlertActionstNonetinserttKeyErrortcommitt Exceptiontrollback(Rtid_R t statementtaaste((s`/home/jenkins/workspace/prepack-aio-release-4.2/prepack-aio/src/main/resources/scripts/Alerts.pyRs( ))cCs,yd|d|d|d|d|d|d|df}|GH|ii|ƒtiƒ}y7|d dj o"|i|dd|d fƒnWntj onXy7|d dj o"|i|dd|d fƒnWntj onX|iƒSWn!tj o}|GH|iƒSXdS( NsˆUPDATE ALERTS SET ALERT_NAME='%s', THRESH_COUNT='%s', THRESH_SECS='%s', FREQ_COUNT='%s', FREQ_SECS='%s', TYPE='%s' WHERE IDENTIFIER='%s'iiiiiiiii( RRRRtupdateRRRR(RR RRR((s`/home/jenkins/workspace/prepack-aio-release-4.2/prepack-aio/src/main/resources/scripts/Alerts.pyR2s(8 &&cCs‹|d}|d}tiƒ}yC|i|gƒd||f}|GH|ii|ƒ|iƒSWn!tj o}|GH|iƒSXdS(s5 data[0]: alert identifier data[1]: alert name iis>DELETE FROM ALERTS WHERE IDENTIFIER = '%s' AND ALERT_NAME='%s'N(RtdeleteRRRRR(RR talertIdt alertNameRRR((s`/home/jenkins/workspace/prepack-aio-release-4.2/prepack-aio/src/main/resources/scripts/Alerts.pyRJs   c Csfd}d}dddddg}|djpt|ƒ odSg}|ii||d ƒ|iiƒ}xñ|D]é}h}xOtt|ƒƒD];} || djod ||| R?R@RA( RIRGRJRKRLtdumpROR RCRl(RRQRRthst((s`/home/jenkins/workspace/prepack-aio-release-4.2/prepack-aio/src/main/resources/scripts/Alerts.pyt saveToFile8s ) cCs9|d}|d}|d}|d}d|||fS(Nii<s%02d:%02d:%02d((tsecsthrtmin((s`/home/jenkins/workspace/prepack-aio-release-4.2/prepack-aio/src/main/resources/scripts/Alerts.pyR|As     (R9R:RZRR<RHRlR RmRRRRƒt staticmethodR|(((s`/home/jenkins/workspace/prepack-aio-release-4.2/prepack-aio/src/main/resources/scripts/Alerts.pyR;ªs        tAlertPolicyForCMS5XcBs2eZdZd„Zd„Zd„Zd„ZRS(s-/opt/tandbergtv/cms/conf/logstash/alerts.yamlcCsti|dƒdS(N(R;RR(R((s`/home/jenkins/workspace/prepack-aio-release-4.2/prepack-aio/src/main/resources/scripts/Alerts.pyRKscCs—dttiƒƒ|_|iddddƒt|idƒiiƒ}z%|~}t i |i ƒƒ|_ WdQX|i djo g|_ ndS(Ns/tmp/alerts.%s.yamlRB( RDRERFRGRHRRIRJRKRLRMRNRO(RR=RQRR((s`/home/jenkins/workspace/prepack-aio-release-4.2/prepack-aio/src/main/resources/scripts/Alerts.pyR<Ns )cCs/dti|ifGHtiti|iƒdS(Ns/Start to copy alert configuration file %s to %s(RˆRZRGR`Ra(RRcRdR@Re((s`/home/jenkins/workspace/prepack-aio-release-4.2/prepack-aio/src/main/resources/scripts/Alerts.pyRHYsc Csnt|idƒiiƒ}z&|~}ti|i|dtƒWdQXti |it i ƒdt i GHdS(NRR€s#Saved alerts to configuration file ( RIRGRJRKRLRROR R`RaRˆRZ(RRQRR((s`/home/jenkins/workspace/prepack-aio-release-4.2/prepack-aio/src/main/resources/scripts/Alerts.pyRƒ]s)(R9R:RZRR<RHRƒ(((s`/home/jenkins/workspace/prepack-aio-release-4.2/prepack-aio/src/main/resources/scripts/Alerts.pyRˆIs   cCsÉthdd6dd6dd6dd6gƒ}|ihdd 6d d 6d d 6dd6dd6d d6dd6ƒ|ihdd 6d d 6d d 6dd6dd6d d6dd6ƒ|ihdd 6ƒ|iƒdS(Ns 127.0.0.1R>trootR?troot1234R@RAsIngest Validation WarningRs".*validationMessages.*= Warning:.*RviR i<R!idR"R#icR&sEPGManager Translation Alerts EPGManager Validation Rule Abort(R;RRRRƒ(RT((s`/home/jenkins/workspace/prepack-aio-release-4.2/prepack-aio/src/main/resources/scripts/Alerts.pytmainds+''t__main__(( RERRR`RLRWRRR;RˆR‹R9(((s`/home/jenkins/workspace/prepack-aio-release-4.2/prepack-aio/src/main/resources/scripts/Alerts.pyts       Ÿ