3
2a @ s d dl Z d dlZd dlZd dlZd dlZd dlZd dlZd dlmZm Z m
Z
d dl Z y d dl Z W n e
k
rx dZ Y nX dZdZdZdZdZdZd'ZG d
d d e jZG d d
d
eZG dd deZG dd de jZG dd de jZG dd deZ G dd de jZ G dd de jZ G dd de jZ G d d d e jZ G d d d e jZ!G d d! d!e!Z"G d"d# d#e jZ#e rG d$d% d%e$Z%dS )( N)ST_DEVST_INOST_MTIMEi<# i=# i># i?# i < c @ s. e Zd Zd ddZdd Zdd Zd d
ZdS ) BaseRotatingHandlerNFc C s0 t jj| |||| || _|| _d | _d | _d S )N)logging FileHandler__init__modeencodingnamerrotator)selffilenamer r delay r -/opt/alt/python36/lib64/python3.6/handlers.pyr
5 s
z BaseRotatingHandler.__init__c C sH y$| j |r| j tjj| | W n tk
rB | j| Y nX d S )N)shouldRollover
doRolloverr r emit Exception handleError)r recordr r r r ? s
zBaseRotatingHandler.emitc C s t | js|}n
| j|}|S )N)callabler
)r Z default_nameresultr r r rotation_filenameM s
z%BaseRotatingHandler.rotation_filenamec C s4 t | js$tjj|r0tj|| n | j|| d S )N)r r ospathexistsrename)r sourcedestr r r rotate` s
zBaseRotatingHandler.rotate)NF)__name__
__module__ __qualname__r
r r r# r r r r r / s
r c @ s& e Zd Zd ddZdd Zd d
ZdS ) RotatingFileHandlerar NFc C s. |dkr d}t j| |||| || _|| _d S )Nr r( )r r
maxBytes backupCount)r r r r) r* r r r r r r
z s
z RotatingFileHandler.__init__c C s | j r| j j d | _ | jdkrxtt| jd ddD ]^}| jd| j|f }| jd| j|d f }tjj|r4tjj|rtj | tj
|| q4W | j| jd }tjj|rtj | | j | j| | j s| j
| _ d S )Nr z%s.%dz.1)streamcloser* ranger baseFilenamer r r remover r# r _open)r iZsfndfnr r r r s$
z RotatingFileHandler.doRolloverc C sZ | j d kr| j | _ | jdkrVd| j| }| j jdd | j j t| | jkrVdS dS )Nr z%s
r+ )r- r2 r) formatseektelllen)r r msgr r r r s
z"RotatingFileHandler.shouldRollover)r( r r NF)r$ r% r& r
r r r r r r r' u s
r' c @ s6 e Zd ZdddZdd Zd
d Zd d
Zdd ZdS )TimedRotatingFileHandlerhr+ r NFc
C s t j| |d|| |j | _|| _|| _|| _| jdkrNd| _d| _d| _ n| jdkrld| _d| _d | _ n| jd
krd| _d | _d | _ n| jd
ks| jdkrd | _d| _d| _ n| jj
dr.d | _t | jdkrt d| j | jd dk s| jd dkrt d| j t
| jd | _d| _d| _ nt d| j tj| j tj| _ | j| | _| j}tjj|r~tj|t } n t
tj } | j| | _d S ) Nr( Sr+ z%Y-%m-%d_%H-%M-%Sz-^\d{4}-\d{2}-\d{2}_\d{2}-\d{2}-\d{2}(\.\w+)?$Mr z%Y-%m-%d_%H-%Mz'^\d{4}-\d{2}-\d{2}_\d{2}-\d{2}(\.\w+)?$Hz %Y-%m-%d_%Hz!^\d{4}-\d{2}-\d{2}_\d{2}(\.\w+)?$DMIDNIGHTr z%Y-%m-%dz^\d{4}-\d{2}-\d{2}(\.\w+)?$W r5 zHYou must specify a day for weekly rollover from 0 to 6 (0 is Monday): %s06z-Invalid day specified for weekly rollover: %sz'Invalid rollover interval specified: %si i iQ i iQ i: )r r
upperwhenr* utcatTimeintervalsuffixextMatch
startswithr9
ValueErrorint dayOfWeekrecompileASCIIr0 r r r statr timecomputeRollover
rolloverAt)
r r rG rJ r* r r rH rI tr r r r
sL
z!TimedRotatingFileHandler.__init__c C sd || j }| jdks"| jjdr`| jr4tj|}n
tj|}|d }|d }|d }|d }| jd krnt}n | jj d | jj
d | jj }||d | d | } | dk r| t7 } |d d
}|| }| jjdr`|}
|
| j kr`|
| j k r| j |
} nd|
| j d } || d } | js\|d }
tj| d }|
|kr\|
sPd}nd }| |7 } | }|S )NrA rB r r r+ rC r i i iQ r, r, i)
rJ rG rM rH rU gmtime localtimerI _MIDNIGHTZhourZminutesecondrP )r currentTimer rX Z currentHourZ
currentMinuteZ
currentSecondZ
currentDayZ rotate_tsrZdayZ
daysToWait
newRolloverAtdstNow
dstAtRolloveraddendr r r rV sH
z(TimedRotatingFileHandler.computeRolloverc C s t tj }|| jkrdS dS )Nr+ r )rO rU rW )r r rX r r r r K s
z'TimedRotatingFileHandler.shouldRolloverc C s t jj| j\}}t j|}g }|d }t|}xH|D ]@}|d | |kr6||d }| jj|r6|jt jj || q6W t|| j
k rg }n |j |d t|| j
}|S )N.) r r splitr0 listdirr9 rL matchappendjoinr* sort) r ZdirNameZbaseNameZ fileNamesr prefixZplenZfileNamerK r r r getFilesToDeleteW s
z)TimedRotatingFileHandler.getFilesToDeletec C s | j r| j j d | _ ttj }tj|d }| j| j }| jrNtj|}n6tj|}|d }||kr|rrd}nd }tj|| }| j | j
d tj | j | }t
jj|rt
j| | j| j
| | jdkrx| j D ]}t
j| qW | j s| j | _ | j|} x| |kr"| | j } q
W | jdks>| jjdrx| j rxtj| d
}
||
krx|sld }nd}| |7 } | | _d S ) Nr+ i rg r rA rB r, r, ir, i)r- r. rO rU r^ rW rJ rH r] r r0 ZstrftimerK r r r r1 r# r* ro r r2 rV rG rM ) r ra rd rX Z timeTupleZdstThenrf r4 src re r r r r n sH
$
z#TimedRotatingFileHandler.doRollover)r< r+ r NFFN)r$ r% r& r
rV r ro r r r r r r; s
9I r; c @ s. e Zd Zd ddZdd Zdd Zd
d ZdS )
WatchedFileHandlerr( NFc C s, t jj| |||| d\| _| _| j d S )Nr+ r, r, )r, r, )r r r
devino _statstream)r r r r r r r r r
s zWatchedFileHandler.__init__c C s0 | j r,tj| j j }|t |t | _| _d S )N)r- r fstatfilenor r rr rs )r sresr r r rt s z WatchedFileHandler._statstreamc C s yt j| j}W n tk
r( d }Y nX | sL|t | jksL|t | jkr| jd k r| jj | jj
d | _| j | _| j d S )N)
r rT r0 FileNotFoundErrorr rr r rs r- flushr. r2 rt )r rw r r r reopenIfNeeded s
"
z!WatchedFileHandler.reopenIfNeededc C s | j tjj| | d S )N)rz r r r )r r r r r r s zWatchedFileHandler.emit)r( NF)r$ r% r& r
rt rz r r r r r rq s
rq c @ sN e Zd Zdd ZdddZdd Zdd Zd
d Zd d
Zdd Z dd Z
dS )
SocketHandlerc C sZ t jj| || _|| _|d kr(|| _n
||f| _d | _d| _d | _d| _ d| _
d| _ d S )NFg ?g >@g @) r Handlerr
hostportaddresssock closeOnError retryTime
retryStartretryMax retryFactor)r r} r~ r r r r
s
zSocketHandler.__init__r+ c C sj | j d k r tj| j|d}nJtjtjtj}|j| y|j| j W n tk
rd |j Y nX |S )N)timeout)
r~ socketZcreate_connectionr AF_UNIX SOCK_STREAMZ
settimeoutconnectOSErrorr. )r r r r r r
makeSocket s
zSocketHandler.makeSocketc C s t j }| jd krd}n
|| jk}|ry| j | _d | _W nV tk
r | jd kr^| j| _n"| j| j | _| j| jkr| j| _|| j | _Y nX d S )NT) rU r r r r r Z retryPeriodr r )r ZnowZattemptr r r createSocket s
zSocketHandler.createSocketc C sR | j d kr| j | j rNy| j j| W n$ tk
rL | j j d | _ Y nX d S )N)r r sendallr r. )r rp r r r send8 s
zSocketHandler.sendc C sj |j }|r| j|}t|j}|j |d< d |d< d |d< |jdd tj|d}tj dt
|}|| S )Nr: argsexc_infomessager+ z>L) r r6 dict__dict__Z
getMessagepoppickledumpsstructpackr9 )r r ZeiZdummydrp Zslenr r r
makePickleK s
zSocketHandler.makePicklec C s0 | j r | jr | jj d | _ntjj| | d S )N)r r r. r r| r )r r r r r r a s
zSocketHandler.handleErrorc C s< y| j |}| j| W n tk
r6 | j| Y nX d S )N)r r r r )r r rp r r r r o s
zSocketHandler.emitc
C s@ | j z(| j}|r"d | _|j tjj| W d | j X d S )N)acquirer r. r r| release)r r r r r r. ~ s zSocketHandler.closeN)r+ ) r$ r% r& r
r r r r r r r. r r r r r{ s
r{ c @ s$ e Zd Zdd Zdd Zdd ZdS )DatagramHandlerc C s t j| || d| _d S )NF)r{ r
r )r r} r~ r r r r
s zDatagramHandler.__init__c C s* | j d krtj}ntj}tj|tj}|S )N)r~ r r ZAF_INET
SOCK_DGRAM)r Zfamilyrp r r r r s
zDatagramHandler.makeSocketc C s& | j d kr| j | j j|| j d S )N)r r sendtor )r rp r r r r s
zDatagramHandler.sendN)r$ r% r& r
r r r r r r r s r c @ s e Zd ZdZdZdZdZdZdZdZ dZ
dZ dZ dZ
dZdZdZdZdZd Zd
Zd Zd Zd
ZdZdZdZdZdZ dZ dZ eeee
eeee eeeed Z eeeeee ee
eeee eeeeeee e e dZ dddddd Z!d e"fe d fd d Z#d!d" Z$d#d$ Z%d%d& Z&d'd( Z'd)Z(d*Z)d+d, Z*d S )-
SysLogHandlerr r+ r5 rY rZ r[ r\ rC
) ZalertZcritcriticaldebugZemergerrerrorinfoZnoticeZpanicwarnwarning)ZauthZauthprivZcrondaemonZftpZkernZlprZmailZnewsZsecurityZsysloguserZuucpZlocal0Zlocal1Zlocal2Zlocal3Zlocal4Zlocal5Zlocal6Zlocal7r r r r r )DEBUGINFOWARNINGERRORCRITICALZ localhostNc C s0 t jj| || _|| _|| _t|trTd| _y| j | W n t
k
rP Y nX nd| _|d krht j }|\}}t j
||d|}|st
dx|D ]|}|\}}} }
} d } }
y(t j ||| }
|t jkr|
j| P W q t
k
r } z|} |
d k r|
j W Y d d }~X qX qW | d k r | |
| _ || _d S )NTFr z!getaddrinfo returns an empty list)r r| r
r facilitysocktype
isinstancestr
unixsocket_connect_unixsocketr r r Z getaddrinfor r r. )r r r r r} r~ Zressresafproto_Zsar r excr r r r
sB
zSysLogHandler.__init__c C s | j }|d krtj}tjtj|| _y| jj| || _ W nx tk
r | jj | j d k r` tj}tjtj|| _y| jj| || _ W n tk
r | jj Y nX Y nX d S )N)r r r r r r r. r )r r Z use_socktyper r r r S s&
z!SysLogHandler._connect_unixsocketc C s4 t |tr| j| }t |tr(| j| }|d> |B S )NrY )r r facility_namespriority_names)r r priorityr r r encodePriorityk s
z SysLogHandler.encodePriorityc
C s2 | j z| jj tjj| W d | j X d S )N)r r r. r r| r )r r r r r. x s
zSysLogHandler.closec C s | j j|dS )Nr ) priority_mapget)r Z levelNamer r r mapPriority s zSysLogHandler.mapPriority Tc C s y| j |}| jr | j| }| jr*|d7 }d| j| j| j|j }|jd}|jd}|| }| jry| j j
| W q t k
r | j j | j
| j | j j
| Y qX n*| jt jkr| j j|| j n | j j| W n tk
r | j| Y nX d S )N z<%d>zutf-8)r6 ident
append_nulr r r Z levelnameencoder r r r r. r r r r r r r r )r r r: Zprior r r r s.
zSysLogHandler.emit)+r$ r% r& Z LOG_EMERGZ LOG_ALERTZLOG_CRITZLOG_ERRZ LOG_WARNINGZ
LOG_NOTICEZLOG_INFOZ LOG_DEBUGZLOG_KERNZLOG_USERZLOG_MAILZ
LOG_DAEMONZLOG_AUTHZ
LOG_SYSLOGZLOG_LPRZLOG_NEWSZLOG_UUCPZLOG_CRONZ LOG_AUTHPRIVZLOG_FTPZ
LOG_LOCAL0Z
LOG_LOCAL1Z
LOG_LOCAL2Z
LOG_LOCAL3Z
LOG_LOCAL4Z
LOG_LOCAL5Z
LOG_LOCAL6Z
LOG_LOCAL7r r r SYSLOG_UDP_PORTr
r r r. r r r r r r r r r s 5
r c @ s& e Zd Zd ddZdd Zdd ZdS )
SMTPHandlerN @c C s t jj| t|ttfr(|\| _| _n|d | _| _t|ttfrR|\| _| _ nd | _|| _
t|t rn|g}|| _ || _
|| _|| _d S )N)r r| r
r listtuplemailhostmailportusernamepasswordfromaddrr toaddrssubjectsecurer )r r r r r credentialsr r r r r r
s
zSMTPHandler.__init__c C s | j S )N)r )r r r r r
getSubject s zSMTPHandler.getSubjectc C s ydd l }ddlm} dd l}| j}|s.|j}|j| j|| jd}| }| j |d< dj
| j |d< | j ||d< |j
j |d< |j| j| | jr| jd k r|j |j| j |j |j| j| j |j| |j W n tk
r | j| Y nX d S ) Nr ) EmailMessage)r ZFrom,ZToZSubjectZDate)smtplibZ
email.messager Z email.utilsr Z SMTP_PORTZSMTPr r r rl r r Zutilsr^ Z set_contentr6 r r ZehloZstarttlsZloginr Z send_messagequitr r )r r r r Zemailr~ Zsmtpr: r r r r s0
zSMTPHandler.emit)NNr )r$ r% r& r
r r r r r r r s
" r c @ s> e Zd ZdddZdd Zdd Zd d
Zd d Zd
d ZdS )NTEventLogHandlerN Applicationc C s t jj| ydd l}dd l}|| _|| _|s`tjj | jj
}tjj |d }tjj |d d}|| _ || _
| jj||| |j| _t j|jt j|jt j|jt j|jt j|ji| _W n" tk
r td d | _Y nX d S )Nr zwin32service.pydzWThe Python Win32 extensions for NT (service, event logging) appear not to be available.)r r| r
win32evtlogutil win32evtlogappname_welur r rh __file__rl dllnamelogtypeZAddSourceToRegistryZEVENTLOG_ERROR_TYPEdeftyper ZEVENTLOG_INFORMATION_TYPEr r ZEVENTLOG_WARNING_TYPEr r typemap ImportErrorprint)r r r r r r r r r r
s* zNTEventLogHandler.__init__c C s dS )Nr+ r )r r r r r getMessageID( s z NTEventLogHandler.getMessageIDc C s dS )Nr r )r r r r r getEventCategory2 s z"NTEventLogHandler.getEventCategoryc C s | j j|j| jS )N)r r levelnor )r r r r r getEventType; s z NTEventLogHandler.getEventTypec C sn | j rjyD| j|}| j|}| j|}| j|}| j j| j||||g W n tk
rh | j| Y nX d S )N) r r r r r6 Z ReportEventr r r )r r idcattyper: r r r r H s
zNTEventLogHandler.emitc C s t jj| d S )N)r r| r. )r r r r r. Y s zNTEventLogHandler.close)Nr ) r$ r% r& r
r r r r r. r r r r r s
r c @ s& e Zd Zd
ddZdd Zdd ZdS ) HTTPHandlerGETFNc C sb t jj| |j }|dkr$td| r:|d k r:td|| _|| _|| _|| _|| _ || _
d S )Nr POSTzmethod must be GET or POSTz3context parameter only makes sense with secure=True)r r ) r r| r
rF rN r} urlmethodr r context)r r} r r r r r r r r r
k s zHTTPHandler.__init__c C s |j S )N)r )r r r r r mapLogRecord s zHTTPHandler.mapLogRecordc C sx yPdd l }dd l}| j}| jr4|jj|| jd}n |jj|}| j}|j j
| j |}| j dkr|j
ddkrvd}nd}|d||f }|j| j | |j
d} | dkr|d | }| j dkr|jd d
|jd tt| | jr$dd l}
d | j jd
} d|
j| j jd } |jd| |j | j dkrH|j|jd
|j W n tk
rr | j | Y nX d S )Nr )r r ?&z%c%s:r z Content-typez!application/x-www-form-urlencodedzContent-lengthz%s:%szutf-8zBasic asciiZ
Authorization) Z http.clientZ urllib.parser} r ZclientZHTTPSConnectionr ZHTTPConnectionr parseZ urlencoder r findZ
putrequestZ putheaderr r9 r base64r Z b64encodestripdecodeZ
endheadersr Z getresponser r ) r r ZhttpZurllibr} r< r datasepr3 r rp r r r r s@
zHTTPHandler.emit)r FNN)r$ r% r& r
r r r r r r r f s
r c @ s4 e Zd Zdd Zdd Zdd Zdd Zd d
Zd S ) BufferingHandlerc C s t jj| || _g | _d S )N)r r| r
capacitybuffer)r r
r r r r
s zBufferingHandler.__init__c C s t | j| jkS )N)r9 r r
)r r r r r shouldFlush s z BufferingHandler.shouldFlushc C s" | j j| | j|r | j d S )N)r rk r ry )r r r r r r s
zBufferingHandler.emitc
C s" | j z
g | _W d | j X d S )N)r r r )r r r r ry s
zBufferingHandler.flushc C s z | j W d tjj| X d S )N)ry r r| r. )r r r r r. s zBufferingHandler.closeN)r$ r% r& r
r r ry r. r r r r r s
r c @ s> e Zd ZejddfddZdd Zdd Zd d
Zd d Z dS )
MemoryHandlerNTc C s" t j| | || _|| _|| _d S )N)r r
flushLeveltarget flushOnClose)r r
r r r r r r r
s zMemoryHandler.__init__c C s t | j| jkp|j| jkS )N)r9 r r
r r )r r r r r r s zMemoryHandler.shouldFlushc C s
|| _ d S )N)r )r r r r r setTarget s zMemoryHandler.setTargetc
C sD | j z,| jr2x| jD ]}| jj| qW g | _W d | j X d S )N)r r r handler )r r r r r ry s
zMemoryHandler.flushc C sB z| j r| j W d | j zd | _tj| W d | j X X d S )N)r ry r r r r. r )r r r r r. & s zMemoryHandler.close)
r$ r% r& r r r
r r ry r. r r r r r s r c @ s, e Zd Zdd Zdd Zdd Zdd Zd S )
QueueHandlerc C s t jj| || _d S )N)r r| r
queue)r r r r r r
B s zQueueHandler.__init__c C s | j j| d S )N)r
put_nowait)r r r r r enqueueI s zQueueHandler.enqueuec C s" | j | |j|_d |_d |_|S )N)r6 r r: r r )r r r r r prepareS s
zQueueHandler.preparec C s8 y| j | j| W n tk
r2 | j| Y nX d S )N)r r r r )r r r r r r l s zQueueHandler.emitN)r$ r% r& r
r r r r r r r r 7 s
r c @ sV e Zd ZdZddddZdd Zdd Zd
d Zd d
Zdd Z dd Z
dd Z dS )
QueueListenerNF)respect_handler_levelc G s || _ || _d | _|| _d S )N)r handlers_threadr )r r r r r r r r
s zQueueListener.__init__c C s | j j|S )N)r r )r blockr r r dequeue s zQueueListener.dequeuec C s& t j| jd | _}d|_|j d S )N)r T) threadingZThread_monitorr r start)r rX r r r r# s zQueueListener.startc C s |S )Nr )r r r r r r s zQueueListener.preparec C sD | j |}x4| jD ]*}| js"d}n |j|jk}|r|j| qW d S )NT)r r r r levelr )r r ZhandlerZprocessr r r r s
zQueueListener.handlec C sd | j }t|d}xNy0| jd}|| jkr*P | j| |r@|j W q t jk
rZ P Y qX qW d S )N task_doneT)r hasattrr _sentinelr r% ZEmpty)r qZ
has_task_doner r r r r" s
zQueueListener._monitorc C s | j j| j d S )N)r r r' )r r r r enqueue_sentinel s z QueueListener.enqueue_sentinelc C s | j | jj d | _d S )N)r) r rl )r r r r stop s
zQueueListener.stop) r$ r% r& r' r
r r# r r r" r) r* r r r r r x s
r i iQ )&r r r r r rU rQ rT r r r r r! r ZDEFAULT_TCP_LOGGING_PORTZDEFAULT_UDP_LOGGING_PORTZDEFAULT_HTTP_LOGGING_PORTZDEFAULT_SOAP_LOGGING_PORTr ZSYSLOG_TCP_PORTr_ r r r' r; rq r| r{ r r r r r r r r objectr r r r r s@ 8
FL `E (* PbO9I@