← Back
Editing: cc_rsyslog.cpython-38.pyc
U Ӈg/. � @ s� U d Z ddlZddlZddlZddlZddlZddlmZmZm Z ddl m Z ddl m Z ddlmZ ddlmZmZ ddlmZ dd lmZ d eged gd �Zeed < dddi i dd gdd�Zdd gd�ddgd�ddgd�d�Ze�e �Z e� d�Z e� d�Z ed�d d �Z!d3d d �Z"d4d d!�Z#e$ee$d"�d#d$�Z%d%d&� Z&d5d'd(�Z'G d)d*� d*�Z(d6d+d,�Z)e dd-�d.d/�Z*e+e e e,dd0�d1d2�Z-dS )7z-Rsyslog: Configure system logging via rsyslog� N)� lifecycle�subp�util)�Cloud)�Config)� MetaSchema)� ALL_DISTROS�Distro)�loggers)� PER_INSTANCEZ cc_rsyslog�rsyslog)�idZdistrosZ frequencyZactivate_by_schema_keys�metaz/etc/rsyslog.dz20-cloud-config.conf�autoZrsyslogdF)� config_dir�config_filename�service_reload_command�remotes�configs� check_exe�packages�install_rsyslogz/usr/local/etc/rsyslog.d)r r zsysutils/rsyslogz/usr/pkg/etc/rsyslog.d)ZfreebsdZopenbsdZnetbsdz [ ]*[#]+[ ]*z_^(?P<proto>[@]{0,2})(([\[](?P<bracket_addr>[^\]]*)[\]])|(?P<addr>[^:]*))([:](?P<port>[0-9]+))?$)�distroc C s4 t }t�t�}| j|kr0tj||| j gdd�}|S )z�Construct a distro-specific rsyslog config dictionary by merging distro specific changes into base config. @param distro: String providing the distro class name. @returns: Dict of distro configurations for ntp clients. T)�reverse)�DISTRO_OVERRIDES�copy�RSYSLOG_CONFIGZosfamilyr Z mergemanydict�name)r Zdcfg�cfg� r �=/usr/lib/python3/dist-packages/cloudinit/config/cc_rsyslog.py� distro_default_rsyslog_configF s r! c C s( t �|�rdS |dkr dg}| |� dS )ai Install rsyslog package if not already installed. @param install_func: function. This parameter is invoked with the contents of the packages parameter. @param packages: list. This parameter defaults to ['rsyslog']. @param check_exe: string. The name of a binary that indicates the package the specified package is already installed. Nr )r Zwhich)Z install_funcr r r r r r T s r c C s. |dkr | � dd�}| �d|�S tj|dd�S )Nr �rsyslog_svcnamer z try-reloadT)Zcapture)� get_option�manage_servicer )r �command�servicer r r � reload_sysloge s r' )r r �returnc C s" | � di �}t|�}t| � d�t�rhtjddd� d| � d�i}d| krT| d |d< d| krh| d |d < dg tfd |d tfd|d tfd |d tfd |d ttffd |d tfd |d tfd|d tff}|D ]L\}}}||kr�|||< q�t|| |�s�t d|� d|� dt || �� ���q�|S )z�Return an updated config. Support converting the old top level format into new format. Raise a `ValueError` if some top level entry has an incorrect type. r z)The rsyslog key with value of type 'list'z22.2)Z deprecatedZdeprecated_versionr Zrsyslog_filenamer Z rsyslog_dirr r r r r r zInvalid type for key `z`. Expected type(s): z. Current type: ) �getr! � isinstance�listr Z deprecate�str�dict�bool� ValueError�type)r r �mycfgZ distro_configZfillup�key�defaultZvtypesr r r � load_configl s@ � � � �r4 c C s� g }t | �D ]�\}}t|t�rNd|kr8t�d|d � q |d }|�d|�}n|}|}|�� }|stt�d|d � q tj� ||�}d}||kr�d}|� |� z*d} |� d �s�d } t j ||| |d � W q tk r� t �td |� Y q X q |S ) N�contentz%No 'content' entry in config entry %s� �filenamez Entry %s has an empty filenameZab�wb� � )�omodezFailed to write to %s)� enumerater* r- �LOG�warningr) �strip�os�path�join�append�endswithr Z write_file� ExceptionZlogexc) r � def_fname�cfg_dir�filesZcur_posZentr5 r7 r; Zendlr r r �apply_rsyslog_changes� s< � rI c C s zt �| �\}}|�� }W n tk r8 | d }}Y nX |�� �� }d }t|�dkr\|}n"t|�dkrr|\}}n td| ��t�|�}|s�td| ��|�d�}|�d�p�|�d�}|�d�} |�d �r�|� d �s�td | ��|r�|s�|}t ||||| d �} | � � | S ) Nr6 � z line had multiple spaces: %sz Invalid host specification '%s'�proto�addrZ bracket_addr�port�[�]z"host spec had invalid brackets: %s�r �matchrK rL rM ) � COMMENT_RE�splitr? r/ �len� HOST_PORT_RErQ �group� startswithrD �SyslogRemotesLine�validate) �liner �dataZcommentZtoksrQ Z host_portrK rL rM �tr r r �parse_remotes_line� s> �r] c @ s. e Zd Zd dd�Zdd� Zdd� Zdd � ZdS ) rX Nc C s\ |sd}|| _ || _|s d}|dkr*d}n |dkr6d}|| _|| _|rRt|�| _nd | _d S )Nz*.*�udp�@�@@�tcp)r rQ rK rL �intrM )�selfr rQ rK rL rM r r r �__init__� s zSyslogRemotesLine.__init__c C sZ | j rHzt| j � W n2 tk rF } ztd| j �|�W 5 d }~X Y nX | jsVtd��d S )Nzport '%s' is not an integerzaddress is required)rM rb r/ rL )rc �er r r rY s ��zSyslogRemotesLine.validatec C s d| j | j| j| j| jf S )Nz.[name=%s match=%s proto=%s address=%s port=%s]rP )rc r r r �__repr__ s �zSyslogRemotesLine.__repr__c C s� | j d }| jdkr |d7 }n| jdkr0|d7 }d| jkrN|d| j d 7 }n || j7 }| jrl|d | j 7 }| jr�|d | j 7 }|S ) N� r^ r_ ra r` �:rN rO z:%sz # %s)rQ rK rL rM r )rc Zbufr r r �__str__ s zSyslogRemotesLine.__str__)NNNNN)�__name__� __module__� __qualname__rd rY rf ri r r r r rX � s � rX c C s� | sd S g }|d k r |� |� | �� D ]\\}}|s4q&z|� tt||d��� W q& tk r� } zt�d|||� W 5 d }~X Y q&X q&|d k r�|� |� d�|�d S )N)r z!failed loading remote %s: %s [%s]r: )rC �itemsr, r] r/ r= r> rB )r �header�footer�linesr rZ re r r r �remotes_to_rsyslog_cfg) s $ rq )�cloudr( c C sx z| j �dd� W n tjk r* Y dS X | j �dd� | j �� t�tj�� | j �dd� t�d� W 5 Q R X dS )z� This helper function bundles the necessary steps to disable BSD base syslog ``rc(8)`` reads its configuration on start, so after disabling syslogd, we need to tell rc to reload its config �enabledZsyslogdN�disableZonestopzOsyslogd is running before cloud-init! Please report this as bug to the porters!) r r$ r �ProcessExecutionErrorZ reload_init� contextlib�suppressr= �error)rr r r r � disable_and_stop_bsd_base_syslog; s �ry )r r rr �argsr( c C s^ d|krt �d| � d S t||j�}|d }|d rL|�t|d ddd�� |j�dd�}|d d kr�t|jj|d |d d � t � � r�|j� d|� t |� |d s�t �d� d S t |d |d |d d�}|s�t �d� d S zt|j|d d�}W n: tjk �r0 } zd}t �dt| �� W 5 d } ~ X Y nX |�rZt�� t�|j� t �d| |� d S )Nr z;Skipping module named %s, no 'rsyslog' key in configurationr r z# begin remotesz # end remotes)rn ro r" r Tr r )r r �enablez.Empty config rsyslog['configs'], nothing to dor r )r rF rG z0restart of syslog not necessary, no changes mader )r% FzFailed to reload syslog %sz%s configured %s files)r= �debugr4 r rC rq r# r Zinstall_packagesr Zis_BSDr$ ry rI r' r ru r> r, r Z reset_loggingZ setup_loggingr ) r r rr rz r1 r r& ZchangesZ restartedre r r r �handleS sb � �� � � � " r} )Nr )r )N)NN).�__doc__rv r Zloggingr@ �reZ cloudinitr r r Zcloudinit.cloudr Zcloudinit.configr Zcloudinit.config.schemar Zcloudinit.distrosr r Z cloudinit.logr Zcloudinit.settingsr r �__annotations__r r Z getLoggerrj r= �compilerR rU r! r r' r- r4 rI r] rX rq ry r, r+ r} r r r r �<module> sf �� ���� � /) &?
Save File
Cancel