관리-도구
편집 파일: handlers.cpython-39.opt-2.pyc
a R�f� � @ 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 �Q c @ s6 e Zd ZdZdZd dd�Zdd� Zdd� Zd d � ZdS ) �BaseRotatingHandlerNFc C s. t jj| |||||d� || _|| _|| _d S )N��mode�encoding�delay�errors)�logging� FileHandler�__init__r r r ��self�filenamer r r r � r �5/opt/alt/python39/lib64/python3.9/logging/handlers.pyr 6 s �z BaseRotatingHandler.__init__c C sF z$| � |�r| �� tj�| |� W n ty@ | �|� Y n0 d S �N)�shouldRollover� doRolloverr r �emit� Exception� handleError�r �recordr r r r A s zBaseRotatingHandler.emitc C s t | j�s|}n | �|�}|S r )�callable�namer)r Z default_name�resultr r r �rotation_filenameO s z%BaseRotatingHandler.rotation_filenamec C s4 t | j�s$tj�|�r0t�||� n | �||� d S r )r �rotator�os�path�exists�rename)r �source�destr r r �rotateb s zBaseRotatingHandler.rotate)NFN) �__name__� __module__� __qualname__r r 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 s2 |dkr d}t j| |||||d� || _|| _d S )Nr r, �r r r )r r �maxBytes� backupCount)r r r r. r/ r r r r r r r | s �z RotatingFileHandler.__init__c C s� | j r| j �� d | _ | jdkr�t| jd dd�D ]^}| �d| j|f �}| �d| j|d f �}tj�|�r2tj�|�r�t� |� t� ||� q2| �| 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 t j�| j�r t j�| j�s dS | jd u r4| �� | _| jdkrvd| �|� }| j� dd� | j� � t |� | jkrvdS dS )NFr z%s � T) r! r" r# r5 �isfiler2 r7 r. �format�seek�tell�len�r r �msgr r r r � s z"RotatingFileHandler.shouldRollover)r, r r NFN)r( r) r* r r r r r r r r+ w s � "r+ c @ s6 e Zd Zddd�Zdd � Zd d � Zd d � Zdd� ZdS )�TimedRotatingFileHandler�hr0 r NFc C s� t j| |d||| d� |�� | _|| _|| _|| _| jdkrPd| _d| _d| _ n�| jdkrnd| _d | _d | _ n�| jd kr�d | _d | _d| _ n�| jdks�| jdkr�d| _d| _d| _ n�| j� d��r0d| _t | j�dkr�t d| j ��| jd dk �s| jd dk�rt d| j ��t | jd �| _d| _d| _ nt d| j ��t�| j tj�| _ | j| | _| j}tj�|��r�t�|�t } n t t�� �} | �| �| _d S ) Nr, r- �Sr0 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+)?$�H� z %Y-%m-%d_%Hz!^\d{4}-\d{2}-\d{2}_\d{2}(\.\w+)?$�D�MIDNIGHTr z%Y-%m-%dz^\d{4}-\d{2}-\d{2}(\.\w+)?$�Wi�: r: 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� startswithr? � ValueError�int� dayOfWeek�re�compile�ASCIIr5 r! r" r# �statr �time�computeRollover� rolloverAt) r r rO rR r/ r r rP rQ r �tr r r r � sP � z!TimedRotatingFileHandler.__init__c C sd || j }| jdks"| j�d��r`| jr4t�|�}n t�|�}|d }|d }|d }|d }| jd u rnt}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 )NrJ rK � � � � rF r r0 � r r1 ���rH ) rR rO rU rP r] �gmtime� localtimerQ � _MIDNIGHTZhourZminute�secondrX )r � currentTimer r` Z currentHourZ currentMinuteZ currentSecondZ currentDayZ rotate_ts�rZdayZ daysToWait� newRolloverAt�dstNow� dstAtRollover�addendr r r r^ sL �� z(TimedRotatingFileHandler.computeRolloverc C s> t j�| j�r t j�| j�s dS tt�� �}|| jkr:dS dS )NFT)r! r" r# r5 r; rW r] r_ )r r r` r r r r U s z'TimedRotatingFileHandler.shouldRolloverc C s$ t j�| j�\}}t �|�}g }t j�|�\}}|d }t|�}|D ]�} | jd u r`| �|�s�qDn6| �|�s�| � |�r�t| �|d kr�| |d � � s�qD| d |� |krD| |d � } | �d�} | D ](} | j � | �r�|� t j�|| �� qDq�qDt|�| jk �rg }n |�� |d t|�| j � }|S )N�.r0 )r! r" �splitr5 �listdir�splitextr? r rU �endswith�isdigitrT �match�append�joinr/ �sort) r ZdirNameZbaseNameZ fileNamesr �n�e�prefixZplenZfileNamerS �parts�partr r r �getFilesToDeleted s8 �� z)TimedRotatingFileHandler.getFilesToDeletec C sv | 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�| �� D ]}t �|� q�| js�| �� | _ | �|�} | |k�r| | j } �q| jdk�s4| j�d��rl| j�slt�| �d } || k�rl|�s`d}nd}| |7 } | | _d S )Nr1 rH rf rq r rJ rK )r2 r3 rW r] rh r_ rR rP rg r r5 �strftimerS r! r" r# r6 r' r/ r� r r7 r^ rO rU ) r rk rn r` Z timeTupleZdstThenrp r9 �srm ro r r r r � sJ � " z#TimedRotatingFileHandler.doRollover)rC r0 r NFFNN)r( r) r* r r^ r r� r r r r r rB � s � <I*rB c @ s. e Zd Zd dd�Zdd� Zdd � Zd d � ZdS ) �WatchedFileHandlerr, NFc C s0 t jj| |||||d� d\| _| _| �� d S )Nr )r1 r1 )r r r �dev�ino� _statstreamr r r r r � s � zWatchedFileHandler.__init__c C s0 | j r,t�| j �� �}|t |t | _| _d S r )r2 r! �fstat�filenor r r� r� �r Zsresr r r r� � s z WatchedFileHandler._statstreamc C s� zt �| j�}W n ty& d }Y n0 |rH|t | jksH|t | jkr~| jd ur~| j� � | j� � d | _| � � | _| � � d S r ) r! r\ r5 �FileNotFoundErrorr r� r r� r2 �flushr3 r7 r� r� r r r �reopenIfNeeded� s z!WatchedFileHandler.reopenIfNeededc C s | � � tj�| |� d S r )r� r r r r r r r r � s zWatchedFileHandler.emit)r, NFN)r( r) r* r r� r� r r r r r r� � s � r� c @ sN e Zd Zdd� Zddd�Zdd� Zdd � Zd d � Zd d � Zdd� Z dd� Z dS )� SocketHandlerc C sZ t j�| � || _|| _|d u r(|| _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__r0 c C sh | j d ur tj| j|d�}nHt�tjtj�}|�|� z|�| j� W n tyb |� � � Y n0 |S )N��timeout) r� �socketZcreate_connectionr� �AF_UNIX� SOCK_STREAMZ settimeout�connect�OSErrorr3 )r r� r r r r � makeSocket. s zSocketHandler.makeSocketc C s� t � � }| jd u rd}n || jk}|r�z| �� | _d | _W nT ty� | jd u r\| j| _n"| j| j | _| j| jkr~| j| _|| j | _Y n0 d S �NT) r] r� r� r� r� r� Z retryPeriodr� r� )r ZnowZattemptr r r � createSocket? s zSocketHandler.createSocketc C sP | j d u r| �� | j rLz| j �|� W n" tyJ | j �� d | _ Y n0 d S r )r� r� �sendallr� r3 �r r� r r r �send[ s zSocketHandler.sendc C sj |j }|r| �|�}t|j�}|�� |d< d |d< d |d< |�dd � t�|d�}t� dt |��}|| S )NrA �args�exc_info�messager0 z>L) r� r< �dict�__dict__Z getMessage�pop�pickle�dumps�structZpackr? )r r ZeiZdummy�dr� Zslenr r r � makePicklen s zSocketHandler.makePicklec C s0 | j r | jr | j�� d | _ntj�| |� d S r )r� r� r3 r r� r r r r r r � s zSocketHandler.handleErrorc C s: z| � |�}| �|� W n ty4 | �|� Y n0 d S r )r� r� r r )r r r� r r r r � s zSocketHandler.emitc C sH | � � z0| j}|r"d | _|�� tj�| � W | �� n | �� 0 d S r )�acquirer� r3 r r� �release)r r� r r r r3 � s zSocketHandler.closeN)r0 ) r( r) r* r r� r� r� r� r r r3 r r r r r� s r� c @ s$ e Zd Zdd� Zdd� Zdd� ZdS )�DatagramHandlerc C s t �| ||� d| _d S )NF)r� r r� r� r r r r � s zDatagramHandler.__init__c C s* | j d u rtj}ntj}t�|tj�}|S r )r� r� r� ZAF_INET� SOCK_DGRAM)r Zfamilyr� r r r r� � s zDatagramHandler.makeSocketc C s& | j d u r| �� | j �|| j� d S r )r� r� �sendtor� r� r r r r� � s zDatagramHandler.sendN)r( r) r* r r� r� r r r r r� � s r� c @ s4 e Zd ZdZdZdZdZdZdZdZ dZ dZ dZ dZ dZdZdZdZdZd Zd Zd Zd Zd ZdZdZdZdZdZ dZ dZ dZ dZ dZ!dZ"eeee eeee eeeed� Z#eeeeeee ee eeeeee eee e e e e e!e"d�Z$dd d d d d �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/d0� Z.d"S )1� SysLogHandlerr r0 r: ra rb rc rd re � � � � � � � � � � � � � � � � ) ZalertZcrit�critical�debugZemerg�err�error�infoZnoticeZpanic�warn�warning)ZauthZauthprivZconsoleZcron�daemonZftpZkernZlprZmailZnewsZntpZsecurityz solaris-cronZsyslog�userZuucpZlocal0Zlocal1Zlocal2Zlocal3Zlocal4Zlocal5Zlocal6Zlocal7r� r� r� r� r� )�DEBUG�INFO�WARNING�ERROR�CRITICALZ localhostNc C s2 t j�| � || _|| _|| _t|t�rRd| _z| � |� W n t yN Y n0 n�d| _|d u rft j }|\}}t � ||d|�}|s�t d��|D ]�}|\}}} } } d } } z.t � ||| �} |t jkr�| �| � W �qW q� t �y } z |} | d ur�| �� W Y d }~q�d }~0 0 q�| d u�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� r3 )r r� r� r� r� r� Zress�resZaf�proto�_Zsar� r� �excr r r r G sB zSysLogHandler.__init__c C s� | j }|d u rtj}t�tj|�| _z| j�|� || _ W nt ty� | j�� | j d ur^� tj}t�tj|�| _z| j�|� || _ W n ty� | j�� � Y n0 Y n0 d S r )r� r� r� r� r� r� r3 r� )r r� Z use_socktyper r r r� } s& z!SysLogHandler._connect_unixsocketc C s4 t |t�r| j| }t |t�r(| j| }|d> |B S )Nra )r� r� �facility_names�priority_names)r r� Zpriorityr r r �encodePriority� s z SysLogHandler.encodePriorityc C s: | � � z"| j�� tj�| � W | �� n | �� 0 d S r )r� r� r3 r r� r� �r r r r r3 � s zSysLogHandler.closec C s | j �|d�S )Nr� )� priority_map�get)r Z levelNamer r r � mapPriority� s zSysLogHandler.mapPriority� Tc C s� z�| � |�}| jr | j| }| jr*|d7 }d| �| j| �|j�� }|�d�}|�d�}|| }| jr�z| j � |� W q� t y� | j � � | � | j� | j � |� Y q�0 n*| jt jkr�| j �|| j� n | j �|� W n ty� | �|� Y n0 d S )N� z<%d>�utf-8)r< �ident� append_nulr� r� r� Z levelname�encoder� r� r� r� r3 r� r� r� r� r� r� r r )r r rA Zprior r r r � s0 � 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_FTPZLOG_NTPZ LOG_SECURITYZ LOG_CONSOLEZ LOG_SOLCRONZ LOG_LOCAL0Z LOG_LOCAL1Z LOG_LOCAL2Z LOG_LOCAL3Z LOG_LOCAL4Z LOG_LOCAL5Z LOG_LOCAL6Z LOG_LOCAL7r� r� r� �SYSLOG_UDP_PORTr r� r� r3 r� r� r� r r r r r r� � s� �� �� 6 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 r )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 r )r� r r r r � getSubject s zSMTPHandler.getSubjectc C s z�dd l }ddlm} dd l}| j}|s.|j}|j| j|| jd�}|� }| j |d< d� | j �|d< | � |�|d< |j �� |d< |�| �|�� | jr�| jd ur�|�� |j| j� |�� |�| j| j� |�|� |�� W n ty� | �|� Y n0 d S ) Nr )� EmailMessager� ZFrom�,ZToZSubjectZDate)�smtplibZ email.messager� Z email.utilsr� Z SMTP_PORTZSMTPr� r� r� ry r� r� Zutilsrh Z set_contentr< r� r� ZehloZstarttlsZloginr� Z send_message�quitr r )r r r� r� Zemailr� ZsmtprA 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�| � z�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 ty� td� d | _Y n0 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" rr �__file__ry �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 8 s, � zNTEventLogHandler.__init__c C s dS )Nr0 r r r r r � getMessageIDR s z NTEventLogHandler.getMessageIDc C s dS )Nr r r r r r �getEventCategory\ s z"NTEventLogHandler.getEventCategoryc C s | j �|j| j�S r )r r� �levelnor r r r r � getEventTypee s z NTEventLogHandler.getEventTypec C sl | j rhzD| �|�}| �|�}| �|�}| �|�}| j �| j||||g� W n tyf | �|� Y n0 d S r ) r r r r r< Z ReportEventr r r )r r �id�cat�typerA r r r r r s zNTEventLogHandler.emitc C s t j�| � d S r )r r� r3 r� r r r r3 � s zNTEventLogHandler.close)Nr ) r( r) r* r r r r r r3 r r r r r� . s r� c @ s. e Zd Zd dd�Zdd� Zdd � Zd d � ZdS ) � HTTPHandler�GETFNc C s` t j�| � |�� }|dvr$td��|s8|d ur8td��|| _|| _|| _|| _|| _ || _ d S )N)r �POSTzmethod must be GET or POSTz3context parameter only makes sense with secure=True) r r� r rN rV r� �url�methodr� r� �context)r r� r r r� r� r r r r r � s zHTTPHandler.__init__c C s |j S r )r� r r r r � mapLogRecord� s zHTTPHandler.mapLogRecordc C s0 dd l }|r |jj|| jd�}n |j�|�}|S )Nr )r )Z http.clientZclientZHTTPSConnectionr ZHTTPConnection)r r� r� ZhttpZ connectionr r r � getConnection� s zHTTPHandler.getConnectionc C sV �z0dd l }| j}| �|| j�}| j}|j�| �|��}| jdkrj|� d�dkrVd}nd}|d||f }|� | j|� |� d�}|dkr�|d |� }| jdkr�|� dd � |� d t t |��� | j�rdd l} d | j �d �} d | �| ��� �d� } |� d| � |�� | jdk�r(|�|�d �� |�� W n t�yP | �|� Y n0 d S )Nr r �?�&z%c%s�:r z Content-typez!application/x-www-form-urlencodedzContent-lengthz%s:%sr� zBasic �asciiZ Authorization)Z urllib.parser� r r� r �parseZ urlencoder r �findZ putrequestZ putheaderr� r? r� �base64r� Z b64encode�strip�decodeZ endheadersr� Z getresponser r ) r r Zurllibr� rC r �data�sepr8 r! r� r r r r � s> � zHTTPHandler.emit)r FNN)r( r) r* r r r r r r r r r � s � r c @ s4 e Zd Zdd� Zdd� Zdd� Zdd� Zd d � Zd S ) �BufferingHandlerc C s t j�| � || _g | _d S r )r r� r �capacity�buffer)r r' r r r r � s zBufferingHandler.__init__c C s t | j�| jkS r )r? r( r' r r r r � shouldFlush� s z BufferingHandler.shouldFlushc C s" | j �|� | �|�r | �� d S r )r( rx r) r� r r r r r s zBufferingHandler.emitc C s. | � � z| j�� W | �� n | �� 0 d S r )r� r( �clearr� r� r r r r� s zBufferingHandler.flushc C s, z| � � W tj�| � ntj�| � 0 d S r )r� r r� r3 r� r r r r3 s zBufferingHandler.closeN)r( r) r* r r) r r� r3 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 r )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 r )r? r( r' r r, r r r r r) = s �zMemoryHandler.shouldFlushc C s* | � � z|| _W | �� n | �� 0 d S r )r� r- r� )r r- r r r � setTargetD s zMemoryHandler.setTargetc C sL | � � z4| jr2| jD ]}| j�|� q| j�� W | �� n | �� 0 d S r )r� r- r( �handler* r� r r r r r� N s zMemoryHandler.flushc C sz zB| j r| �� W | �� z d | _t�| � W | �� qv| �� 0 n2| �� z d | _t�| � W | �� n | �� 0 0 d S r )r. r� r� r- r& r3 r� r� r r r r3 _ s � zMemoryHandler.close) r( r) r* r r� r r) r/ r� r3 r r r r r+ # s � r+ c @ s, e Zd Zdd� Zdd� Zdd� Zdd� Zd S ) � QueueHandlerc C s t j�| � || _d S r )r r� r �queue)r r2 r r r r { s zQueueHandler.__init__c C s | j �|� d S r )r2 � put_nowaitr r r r �enqueue� s zQueueHandler.enqueuec C s6 | � |�}t�|�}||_||_d |_d |_d |_|S r )r< �copyr� rA r� r� Zexc_textr@ r r r �prepare� s zQueueHandler.preparec C s6 z| � | �|�� W n ty0 | �|� Y n0 d S r )r4 r6 r r r r r r r � s zQueueHandler.emitN)r( r) r* r r4 r6 r r r r r r1 p s r1 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 r )r2 �handlers�_threadr8 )r r2 r8 r9 r r r r � s zQueueListener.__init__c C s | j �|�S r )r2 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 r` r r r r? � s zQueueListener.startc C s |S r r r r r r r6 � s zQueueListener.preparec C s@ | � |�}| jD ]*}| js d}n |j|jk}|r|�|� qd S r� )r6 r9 r8 r �levelr0 )r r ZhandlerZprocessr r r r0 � s zQueueListener.handlec C sn | j }t|d�}z>| �d�}|| ju r6|r2|�� W qj| �|� |rL|�� W q t jyf Y qjY q0 qd S )N� task_doneT)r2 �hasattrr< � _sentinelrA r0 ZEmpty)r �qZ has_task_doner r r r r> � s zQueueListener._monitorc C s | j �| j� d S r )r2 r3 rC r� r r r �enqueue_sentinel s z QueueListener.enqueue_sentinelc C s | � � | j�� d | _d S r )rE r: ry r� r r r �stop s zQueueListener.stop) r( r) r* rC r r< r? r6 r0 r> rE rF r r r r r7 � s r7 )&r r� r! r� r� r] rY r\ r r r r2 r= r5 ZDEFAULT_TCP_LOGGING_PORTZDEFAULT_UDP_LOGGING_PORTZDEFAULT_HTTP_LOGGING_PORTZDEFAULT_SOAP_LOGGING_PORTr� ZSYSLOG_TCP_PORTri r r r+ rB r� r� r� r� r� r� r� r r& r+ r1 �objectr7 r r r r �<module> s: 8JQ yH (* PbZ9ME