관리-도구
편집 파일: handlers.cpython-37.opt-2.pyc
B YI~d � � @ sv d dl Z d dlZd dlZd dlZd dlZd dlZd dlZd dlmZm Z m Z d dl Z d dl Z d dl Z dZdZdZdZdZdZdZG d d � d e j�ZG d d � d e�ZG d d� de�ZG dd� de j�ZG dd� de j�ZG dd� de�Z G dd� de j�Z G dd� de j�Z G dd� de j�Z G dd � d e j�Z G d d � d e j�Z!G d d � d e!�Z"G d!d"� d"e j�Z#G d#d$� d$e$�Z%dS )%� N)�ST_DEV�ST_INO�ST_MTIMEi<# i=# i># i?# i i�Q c @ s. e Zd Zd dd�Zdd� Zdd� Zd d � ZdS ) �BaseRotatingHandlerNFc C s0 t j�| ||||� || _|| _d | _d | _d S )N)�logging� FileHandler�__init__�mode�encoding�namer�rotator)�self�filenamer r �delay� r �5/opt/alt/python37/lib64/python3.7/logging/handlers.pyr 3 s z BaseRotatingHandler.__init__c C sH y$| � |�r| �� tj�| |� W n tk rB | �|� Y nX d S )N)�shouldRollover� doRolloverr r �emit� Exception� handleError)r �recordr r r r = s zBaseRotatingHandler.emitc C s t | j�s|}n | �|�}|S )N)�callabler )r Z default_name�resultr r r �rotation_filenameK s z%BaseRotatingHandler.rotation_filenamec C s4 t | j�s$tj�|�r0t�||� n | �||� d S )N)r r �os�path�exists�rename)r �source�destr 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 dd�Zdd� Zd d � ZdS ) �RotatingFileHandler�ar NFc C s. |dkr d}t �| ||||� || _|| _d S )Nr r& )r r �maxBytes� backupCount)r r r r' r( r r r r r r x s z RotatingFileHandler.__init__c C s� | j r| j �� d | _ | jdkr�xtt| jd dd�D ]^}| �d| j|f �}| �d| j|d f �}tj�|�r4tj�|�r�t� |� t� ||� q4W | �| jd �}tj�|�r�t� |� | � | j|� | j s�| � � | _ d S )Nr � ���z%s.%dz.1)�stream�closer( �ranger � baseFilenamer r r �remover r! r �_open)r �iZsfn�dfnr r r r � s$ z RotatingFileHandler.doRolloverc C sZ | j d kr| �� | _ | jdkrVd| �|� }| j �dd� | j �� t|� | jkrVdS dS )Nr z%s � r) )r+ r0 r' �format�seek�tell�len)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% s s r% c @ s6 e Zd Zddd�Zdd � Zd d � Zd d � Zdd� ZdS )�TimedRotatingFileHandler�hr) r NFc C s� t �| |d||� |�� | _|| _|| _|| _| jdkrLd| _d| _d| _ n�| jdkrjd| _d| _d | _ n�| jd kr�d | _d | _d | _ n�| jdks�| jdkr�d| _d| _d| _ n�| j� d��r*d| _t | j�dkr�t d| j ��| jd dk s�| jd dk�r t d| j ��t | jd �| _d| _d| _ nt d| j ��t�| j tj�| _ | j| | _| j}tj�|��rzt�|�t } n t t�� �} | �| �| _d S )Nr& �Sr) z%Y-%m-%d_%H-%M-%Sz-^\d{4}-\d{2}-\d{2}_\d{2}-\d{2}-\d{2}(\.\w+)?$�M�< z%Y-%m-%d_%H-%Mz'^\d{4}-\d{2}-\d{2}_\d{2}-\d{2}(\.\w+)?$�Hi z %Y-%m-%d_%Hz!^\d{4}-\d{2}-\d{2}_\d{2}(\.\w+)?$�D�MIDNIGHTi�Q z%Y-%m-%dz^\d{4}-\d{2}-\d{2}(\.\w+)?$�Wi�: r3 zHYou must specify a day for weekly rollover from 0 to 6 (0 is Monday): %s�0�6z-Invalid day specified for weekly rollover: %sz'Invalid rollover interval specified: %s)r r �upper�whenr( �utc�atTime�interval�suffix�extMatch� startswithr7 � ValueError�int� dayOfWeek�re�compile�ASCIIr. r r r �statr �time�computeRollover� rolloverAt) r r rE rH r( r r rF rG �tr r r r � sL z!TimedRotatingFileHandler.__init__c C sd || j }| jdks"| j�d��r`| jr4t�|�}n t�|�}|d }|d }|d }|d }| jd krnt}n | jj d | jj d | jj }||d | d | } | dk r�| t7 } |d d }|| }| j�d��r`|} | | j k�r`| | j k r�| j | } nd| | j d } || d } | j�s\|d } t�| �d }| |k�r\| �sPd }nd}| |7 } | }|S )Nr@ rA � � � � r= r r) � i�Q r* i��i ) rH rE rK rF rS �gmtime� localtimerG � _MIDNIGHTZhourZminute�secondrN )r � currentTimer rV Z currentHourZ currentMinuteZ currentSecondZ currentDayZ rotate_ts�rZdayZ daysToWait� newRolloverAt�dstNow� dstAtRollover�addendr r r rT sH z(TimedRotatingFileHandler.computeRolloverc C s t t�� �}|| jkrdS dS )Nr) r )rM rS rU )r r rV r r r r I s z'TimedRotatingFileHandler.shouldRolloverc C s� t j�| j�\}}t �|�}g }|d }t|�}xH|D ]@}|d |� |kr6||d � }| j�|�r6|�t j� ||�� q6W t|�| j k r�g }n |� � |d t|�| j � }|S )N�.) r r �splitr. �listdirr7 rJ �match�append�joinr( �sort) r ZdirNameZbaseNameZ fileNamesr �prefixZplenZfileNamerI r r r �getFilesToDeleteU s z)TimedRotatingFileHandler.getFilesToDeletec C s~ | j r| j �� d | _ tt�� �}t�|�d }| j| j }| jrNt�|�}n6t�|�}|d }||kr�|rrd}nd}t�|| �}| � | j d t� | j |� �}t j�|�r�t �|� | �| j |� | jdkr�x| �� D ]}t �|� q�W | js�| �� | _ | �|�} x| |k�r | | j } �qW | jdk�s<| j�d��rt| j�stt�| �d } || k�rt|�shd}nd}| |7 } | | _d S )Nr* i i��rf r r@ rA )r+ r, rM rS r] rU rH rF r\ r r. ZstrftimerI r r r r/ r! r( rn r r0 rT rE rK ) r r` rc rV Z timeTupleZdstThenre r2 �srb rd r r r r l sH " z#TimedRotatingFileHandler.doRollover)r: r) r NFFN)r" r# r$ r rT r rn r r r r r r9 � s 9I r9 c @ s. e Zd Zd dd�Zdd� Zdd � Zd d � ZdS ) �WatchedFileHandlerr& NFc C s, t j�| ||||� d\| _| _| �� d S )N)r* r* )r r r �dev�ino� _statstream)r r r r r r r r r � s zWatchedFileHandler.__init__c C s0 | j r,t�| j �� �}|t |t | _| _d S )N)r+ r �fstat�filenor r rq rr )r �sresr r r rs � s z WatchedFileHandler._statstreamc C s� yt �| j�}W n tk r( d }Y nX |rJ|t | jksJ|t | jkr�| jd k r�| j� � | j� � d | _| � � | _| � � d S )N) r rR r. �FileNotFoundErrorr rq r rr r+ �flushr, r0 rs )r rv r r r �reopenIfNeeded� s z!WatchedFileHandler.reopenIfNeededc C s | � � tj�| |� d S )N)ry r r r )r r r r r r � s zWatchedFileHandler.emit)r& NF)r" r# r$ r rs ry r r r r r rp � s rp c @ sN e Zd Zdd� Zddd�Zdd� Zdd � Zd d � Zd d � Zdd� Z dd� Z dS )� SocketHandlerc C sZ t j�| � || _|| _|d kr(|| _n ||f| _d | _d| _d | _d| _ d| _ d| _ d S )NFg �?g >@g @) r �Handlerr �host�port�address�sock� closeOnError� retryTime� retryStart�retryMax� retryFactor)r r| r} r r r r � s zSocketHandler.__init__r) c C sj | j d k r tj| j|d�}nJt�tjtj�}|�|� y|�| j� W n tk rd |� � � Y nX |S )N)�timeout) r} �socketZcreate_connectionr~ �AF_UNIX� SOCK_STREAMZ settimeout�connect�OSErrorr, )r r� r r r r � makeSocket s zSocketHandler.makeSocketc C s� t � � }| jd krd}n || jk}|r�y| �� | _d | _W nV tk r� | jd kr^| j| _n"| j| j | _| j| jkr�| j| _|| j | _Y nX d S )NT) rS r� r� r r� r� Z retryPeriodr� r� )r ZnowZattemptr r r � createSocket s zSocketHandler.createSocketc C sR | j d kr| �� | j rNy| j �|� W n$ tk rL | j �� d | _ Y nX d S )N)r r� �sendallr� r, )r ro r r r �send6 s zSocketHandler.sendc C sj |j }|r| �|�}t|j�}|�� |d< d |d< d |d< |�dd � t�|d�}t� dt |��}|| S )Nr8 �args�exc_info�messager) z>L) r� r4 �dict�__dict__Z getMessage�pop�pickle�dumps�struct�packr7 )r r ZeiZdummy�dro Zslenr r r � makePickleI s zSocketHandler.makePicklec C s0 | j r | jr | j�� d | _ntj�| |� d S )N)r� r r, r r{ r )r r r r r r _ s zSocketHandler.handleErrorc C s< y| � |�}| �|� W n tk r6 | �|� Y nX d S )N)r� r� r r )r r ro r r r r m s zSocketHandler.emitc C s@ | � � z(| j}|r"d | _|�� tj�| � W d | �� 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 rz � s rz c @ s$ e Zd Zdd� Zdd� Zdd� ZdS )�DatagramHandlerc C s t �| ||� d| _d S )NF)rz r r� )r r| r} r r r r � s zDatagramHandler.__init__c C s* | j d krtj}ntj}t�|tj�}|S )N)r} r� r� ZAF_INET� SOCK_DGRAM)r Zfamilyro r r r r� � s zDatagramHandler.makeSocketc C s& | j d kr| �� | j �|| j� d S )N)r r� �sendtor~ )r ro 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 d�Z 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) r3 rW rX rY rZ r[ � � � � � � � � � � � � ) ZalertZcrit�critical�debugZemerg�err�error�infoZnoticeZpanic�warn�warning)ZauthZauthprivZcron�daemonZftpZkernZlprZmailZnewsZsecurityZsyslog�userZuucpZlocal0Zlocal1Zlocal2Zlocal3Zlocal4Zlocal5Zlocal6Zlocal7r� r� r� r� r� )�DEBUG�INFO�WARNING�ERROR�CRITICALZ localhostNc C s0 t j�| � || _|| _|| _t|t�rTd| _y| � |� W n t k rP Y nX n�d| _|d krht j }|\}}t � ||d|�}|s�t d��x�|D ]|}|\}}} } } d } } y(t � ||| �} |t jkr�| �| � P W q� t k �r } z|} | d k r�| �� W d d }~X Y q�X q�W | d k �r | �| | _ || _d S )NTFr z!getaddrinfo returns an empty list)r r{ r r~ �facility�socktype� isinstance�str� unixsocket�_connect_unixsocketr� r� r� Z getaddrinfor� r� r, )r r~ r� r� r| r} ZressZres�af�proto�_Zsar� r �excr r r r sB zSysLogHandler.__init__c C s� | j }|d krtj}t�tj|�| _y| j�|� || _ W nx tk r� | j�� | j d k r`� tj}t�tj|�| _y| j�|� || _ W n tk r� | j�� � Y nX Y nX d S )N)r� r� r� r� r� r� r, r� )r r~ Z use_socktyper r r r� Q s& z!SysLogHandler._connect_unixsocketc C s4 t |t�r| j| }t |t�r(| j| }|d> |B S )NrW )r� r� �facility_names�priority_names)r r� �priorityr r r �encodePriorityi s z SysLogHandler.encodePriorityc C s2 | � � z| j�� tj�| � W d | �� X d S )N)r� r� r, r r{ r� )r r r r r, v s zSysLogHandler.closec C s | j �|d�S )Nr� )� priority_map�get)r Z levelNamer r r � mapPriority� s zSysLogHandler.mapPriority� Tc C s y�| � |�}| jr | j| }| jr*|d7 }d| �| j| �|j�� }|�d�}|�d�}|| }| jr�y| j � |� W q� t k r� | j � � | � | j� | j � |� Y q�X n*| jt jkr�| j �|| j� n | j �|� W n tk r� | �|� Y nX d S )N� z<%d>zutf-8)r4 �ident� append_nulr� r� r� Z levelname�encoder� r� r� r� r, r� r~ r� r� r� r� r r )r r r8 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 dd�Zdd� Zdd� ZdS ) � SMTPHandlerN� @c C s� t j�| � t|ttf�r(|\| _| _n|d | _| _t|ttf�rR|\| _| _ nd | _|| _ t|t �rn|g}|| _ || _ || _|| _d S )N)r r{ r r� �list�tuple�mailhost�mailport�username�password�fromaddrr� �toaddrs�subject�securer� )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 y�dd l }ddlm} dd l}| j}|s.|j}|j| j|| jd�}|� }| j |d< d� | j �|d< | � |�|d< |j �� |d< |�| �|�� | jr�| jd k r�|�� |j| j� |�� |�| j| j� |�|� |�� W n tk r� | �|� Y nX d S ) Nr )� EmailMessage)r� ZFrom�,ZToZSubjectZDate)�smtplibZ email.messager� Z email.utilsr� Z SMTP_PORTZSMTPr� r� r� rk r� r� Zutilsr] Z set_contentr4 r� r� ZehloZstarttlsZloginr� Z send_message�quitr r )r r r� r� Zemailr} Zsmtpr8 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 Zddd�Zdd� Zdd� Zd d � Zd d � Zd d� ZdS )�NTEventLogHandlerN� Applicationc C s� t j�| � y�dd l}dd l}|| _|| _|s`tj� | jj �}tj� |d �}tj� |d d�}|| _ || _ | j�|||� |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� win32evtlog�appname�_welur r rg �__file__rk �dllname�logtypeZAddSourceToRegistryZEVENTLOG_ERROR_TYPE�deftyper� ZEVENTLOG_INFORMATION_TYPEr� r� ZEVENTLOG_WARNING_TYPEr� r� �typemap� ImportError�print)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 �getEventCategory0 s z"NTEventLogHandler.getEventCategoryc C s | j �|j| j�S )N)r� r� �levelnor� )r r r r r � getEventType9 s z NTEventLogHandler.getEventTypec C sn | j rjyD| �|�}| �|�}| �|�}| �|�}| j �| j||||g� W n tk rh | �|� Y nX d S )N) r� r� r� r� r4 Z ReportEventr� r r )r r �id�cat�typer8 r r r r F s zNTEventLogHandler.emitc C s t j�| � d S )N)r r{ r, )r r r r r, W 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 dd�Zdd� Zdd � ZdS ) � HTTPHandler�GETFNc C s` t j�| � |�� }|dkr$td��|s8|d k r8td��|| _|| _|| _|| _|| _ || _ d S )N)r� �POSTzmethod must be GET or POSTz3context parameter only makes sense with secure=True) r r{ r rD rL r| �url�methodr� r� �context)r r| r� r� r� r� r� r r r r i 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 |j�|�}| j}|j � | � |��}| j dkr�|� d�dkrvd}nd}|d||f }|�| j |� |� d�} | dkr�|d | � }| j dkr�|�d d � |�d tt|��� | j�r$dd l} d | j �d �} d| �| ��� �d� } |�d| � |�� | j dk�rH|�|�d �� |�� W n tk �rr | � |� 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� r7 r� �base64r� Z b64encode�strip�decodeZ endheadersr� Z getresponser r ) r r ZhttpZurllibr| r: r� �data�sepr1 r ro r r r r � s@ zHTTPHandler.emit)r� FNN)r" r# r$ r r� r r r r r r� d s r� c @ s4 e Zd Zdd� Zdd� Zdd� Zdd� Zd d � Zd S ) �BufferingHandlerc C s t j�| � || _g | _d S )N)r r{ r �capacity�buffer)r r r r r r � s zBufferingHandler.__init__c C s t | j�| jkS )N)r7 r r )r r r r r � shouldFlush� s z BufferingHandler.shouldFlushc C s" | j �|� | �|�r | �� d S )N)r rj r rx )r r r r r r � s zBufferingHandler.emitc C s" | � � z g | _W d | �� X d S )N)r� r r� )r r r r rx � s zBufferingHandler.flushc C s z | � � W d tj�| � X d S )N)rx r r{ r, )r r r r r, � s zBufferingHandler.closeN)r" r# r$ r r r rx r, r r r r r � s r c @ s> e Zd Zejddfdd�Zdd� Zdd� Zd d � Zd d � Z dS ) � MemoryHandlerNTc C s" t �| |� || _|| _|| _d S )N)r r � flushLevel�target� flushOnClose)r r r r r r r r r � s zMemoryHandler.__init__c C s t | j�| jkp|j| jkS )N)r7 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 | � � z,| jr2x| jD ]}| j�|� qW g | _W d | �� X d S )N)r� r r �handler� )r r r r r rx s zMemoryHandler.flushc C sB z| j r| �� W d | �� zd | _t�| � W d | �� X X d S )N)r rx r� r r r, r� )r r r r r, $ s zMemoryHandler.close) r" r# r$ r r� r r r rx r, r r r r r � s r c @ s, e Zd Zdd� Zdd� Zdd� Zdd� Zd S ) � QueueHandlerc C s t j�| � || _d S )N)r r{ r �queue)r r r r r r @ s zQueueHandler.__init__c C s | j �|� d S )N)r � put_nowait)r r r r r �enqueueG s zQueueHandler.enqueuec C s6 | � |�}t�|�}||_||_d |_d |_d |_|S )N)r4 �copyr� r8 r� r� Zexc_text)r r r8 r r r �prepareQ s zQueueHandler.preparec C s8 y| � | �|�� W n tk r2 | �|� Y nX d S )N)r r r r )r r r r r r n s zQueueHandler.emitN)r" r# r$ r r r r r r r r r 5 s r c @ sV e Zd ZdZdd�dd�Zdd� 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 �|�S )N)r r� )r �blockr r r �dequeue� s zQueueListener.dequeuec C s& t j| jd� | _}d|_|�� d S )N)r T)� threadingZThread�_monitorr r� �start)r rV r r r r" � s zQueueListener.startc C s |S )Nr )r r r r r r � s zQueueListener.preparec C sD | � |�}x4| jD ]*}| js"d}n |j|jk}|r|�|� qW d S )NT)r r r r� �levelr )r r ZhandlerZprocessr r r r � s zQueueListener.handlec C sp | j }t|d�}xZy<| �d�}|| jkr6|r4|�� P | �|� |rL|�� W q t jk rf 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� d S )N)r r r& )r r r r �enqueue_sentinel� s z QueueListener.enqueue_sentinelc C s | � � | j�� d | _d S )N)r( r rk )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 z s r )&r r� r r� r� rS rO rR 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% r9 rp r{ rz r� r� r� r� r� r r r �objectr r r r r �<module> s: 8FL `E (* PbO9IE