File manager - Edit - /opt/saltstack/salt/lib/python3.10/site-packages/salt/log_handlers/__pycache__/logstash_mod.cpython-310.pyc
Back
o ;jH7 � @ s� d Z ddlZddlZddlZddlZddlZddlZddlZddl m Z z ddl Z ddl Z W n e y7 Y nw e�e�ZdZdd� Zdd� ZG d d � d ej�ZG d d � d ejj�ZG d d� dej�ZdS )a� Logstash Logging Handler ======================== .. versionadded:: 0.17.0 This module provides some `Logstash`_ logging handlers. UDP Logging Handler ------------------- For versions of `Logstash`_ before 1.2.0: In the salt configuration file: .. code-block:: yaml logstash_udp_handler: host: 127.0.0.1 port: 9999 version: 0 msg_type: logstash In the `Logstash`_ configuration file: .. code-block:: text input { udp { type => "udp-type" format => "json_event" } } For version 1.2.0 of `Logstash`_ and newer: In the salt configuration file: .. code-block:: yaml logstash_udp_handler: host: 127.0.0.1 port: 9999 version: 1 msg_type: logstash In the `Logstash`_ configuration file: .. code-block:: text input { udp { port => 9999 codec => json } } Please read the `UDP input`_ configuration page for additional information. ZeroMQ Logging Handler ---------------------- For versions of `Logstash`_ before 1.2.0: In the salt configuration file: .. code-block:: yaml logstash_zmq_handler: address: tcp://127.0.0.1:2021 version: 0 In the `Logstash`_ configuration file: .. code-block:: text input { zeromq { type => "zeromq-type" mode => "server" topology => "pubsub" address => "tcp://0.0.0.0:2021" charset => "UTF-8" format => "json_event" } } For version 1.2.0 of `Logstash`_ and newer: In the salt configuration file: .. code-block:: yaml logstash_zmq_handler: address: tcp://127.0.0.1:2021 version: 1 In the `Logstash`_ configuration file: .. code-block:: text input { zeromq { topology => "pubsub" address => "tcp://0.0.0.0:2021" codec => json } } Please read the `ZeroMQ input`_ configuration page for additional information. .. admonition:: Important Logstash Setting One of the most important settings that you should not forget on your `Logstash`_ configuration file regarding these logging handlers is ``format``. Both the `UDP` and `ZeroMQ` inputs need to have ``format`` as ``json_event`` which is what we send over the wire. Log Level ......... Both the ``logstash_udp_handler`` and the ``logstash_zmq_handler`` configuration sections accept an additional setting ``log_level``. If not set, the logging level used will be the one defined for ``log_level`` in the global configuration file section. HWM ... The `high water mark`_ for the ZMQ socket setting. Only applicable for the ``logstash_zmq_handler``. .. admonition:: Inspiration This work was inspired in `pylogstash`_, `python-logstash`_, `canary`_ and the `PyZMQ logging handler`_. .. _`Logstash`: http://logstash.net .. _`canary`: https://github.com/ryanpetrello/canary .. _`pylogstash`: https://github.com/turtlebender/pylogstash .. _`python-logstash`: https://github.com/vklochan/python-logstash .. _`PyZMQ logging handler`: https://github.com/zeromq/pyzmq/blob/master/zmq/log/handlers.py .. _`UDP input`: http://logstash.net/docs/latest/inputs/udp .. _`ZeroMQ input`: http://logstash.net/docs/latest/inputs/zeromq .. _`high water mark`: http://api.zeromq.org/3-2:zmq-setsockopt � N)� LOG_LEVELS�logstashc C s& t dtv dtv g�st�d� dS tS )N�logstash_udp_handler�logstash_zmq_handlerz�None of the required configuration sections, 'logstash_udp_handler' and 'logstash_zmq_handler', were found in the configuration. Not loading the Logstash logging handlers module.F)�any�__opts__�logZtrace�__virtualname__� r r �R/opt/saltstack/salt/lib/python3.10/site-packages/salt/log_handlers/logstash_mod.py� __virtual__� s ��r c c s| � d } }}dt v r]t d �dd �} t d �dd �}t d �dd�}t d �dd�}| d u r9|d u r9t�d� n$t||d �}t| |�}|�|� |�tt d �d t �d d �� � |V d t v r�t d �d d �}t d �dd�}t d �dd�}|d u r�t�d� n$t|d�}t ||d�}|�|� |�tt d �d t �d d �� � |V | d u r�|d u r�|d u r�dV d S d S d S d S )Nr �host�port�versionr �msg_typer z�The required 'logstash_udp_handler' configuration keys, 'host' and/or 'port', are not properly configured. Not configuring the logstash UDP logging handler.)r r Z log_level�errorr �addressZhwm�� z�The required 'logstash_zmq_handler' configuration key, 'address', is not properly configured. Not configuring the logstash ZMQ logging handler.)r )�zmq_hwmF) r �getr �debug�LogstashFormatter�DatagramLogstashHandler� setFormatter�setLevelr �ZMQLogstashHander) r r r r r Zlogstash_formatterZ udp_handlerr Z zmq_handlerr r r �setup_handlers� sh � � ����� ���� �r c s8 e Zd Zd � fdd� Zd dd�Zdd � Zd d � Z� ZS )r r r c s8 || _ || _|| _t| d|� ��| _t� jd d d� d S )NZformat_v)�fmt�datefmt)�msg_pathr r �getattr�format�super�__init__)�selfr r r �� __class__r r r# s zLogstashFormatter.__init__Nc C s t j �|j��� d d� d S )N����Z)�datetime�utcfromtimestamp�created� isoformat)r$ �recordr r r r � formatTime s z LogstashFormatter.formatTimec C s� t jj�� }| �|�|j|j|j|j|j |j |j |j d�|� � | j� d|� d| j� �|| jdg| jd�}|jrA| �|j�|d d< |j�� D ].\}}|dv rOqF|d u rZ||d |< qFt|ttttttf�rl||d |< qFt|�|d |< qFt jj � |�S ) N)� levelname�logger�lineno�pathname�process� threadName�funcName� processNamez://�/�salt)� @timestamp�@fieldsz@messagez@sourcez @source_hostz @source_pathz@tagsz@typer: �exc_info��args�asctimer+ r; �exc_text�filenamer5 �idr/ �levelnor1 �module�msecsrD �message�msg�namer2 r3 r6 �relativeCreated�threadr4 ) r8 �utils�network�get_fqhostnamer. r/ rG r1 r2 r3 r4 r5 r6 � getMessager r r; �formatException�__dict__�items� isinstance�str�bool�dict�float�int�list�repr�json�dumps)r$ r- r � message_dict�key�valuer r r � format_v0 s> � � zLogstashFormatter.format_v0c C s� d| � |�tjj�� |j|j|j|j|j |j |j |j |� � dg| jd�}|jr/| �|j�|d< |j�� D ](\}}|dv r=q4|d u rF|||< q4t|ttttttf�rV|||< q4t|�||< q4tjj� |�S )N� r8 )z@versionr9 r r/ r0 r1 r2 r3 r4 r5 r6 rE �tags�typer; r< ) r. r8 rJ rK rL r/ rG r1 r2 r3 r4 r5 r6 rM r r; rN rO rP rQ rR rS rT rU rV rW rX rY rZ )r$ r- r[ r\ r] r r r � format_v1T s8 �zLogstashFormatter.format_v1)r r r �N)�__name__� __module__� __qualname__r# r. r^ rb � __classcell__r r r% r r s Br c @ s e Zd ZdZdd� ZdS )r z' Logstash UDP logging handler. c C s t jj�| �|��S rc )r8 rJ � stringutils�to_bytesr! )r$ r- r r r � makePickle� s z"DatagramLogstashHandler.makePickleN)rd re rf �__doc__rj r r r r r � s r c sD e Zd ZdZejdf� fdd� Zedd� �Zdd� Z d d � Z � Z S ) r z' Logstash ZMQ logging handler. r c s4 t � j|d� d | _| _|| _|| _t�� | _d S )N)�level) r" r# �_context� _publisher�_address�_zmq_hwm�os�getpid�_pid)r$ r rl r r% r r r# � s zZMQLogstashHander.__init__c C s� t �� }t| d�r| j|krP|| _t�� | _| j�tj�| _ z | j � tj | j � W n t tjjfyH | j � tj| j � | j � tj| j � Y nw | j �| j� | j S )Nrn )rq rr r rs �zmqZContextrm �socketZPUBrn � setsockoptZHWMrp �AttributeErrorr ZZMQErrorZSNDHWMZRCVHWM�connectro )r$ Z current_pidr r r � publisher� s �zZMQLogstashHander.publisherc C s$ t jj�| �|��}| j�|� d S rc )r8 rJ rh ri r! ry �send)r$ r- Zformatted_objectr r r �emit� s zZMQLogstashHander.emitc C sr | j d ur5t| j d�r| j �d� d S t| dd �d ur(| j�tjd� | j�� | j j du r7| j � � d S d S d S )N�destroyr rn F) rm �hasattrr| r rn rv rt ZLINGER�close�closedZterm)r$ r r r r~ � s � zZMQLogstashHander.close) rd re rf rk �logging�NOTSETr# �propertyry r{ r~ rg r r r% r r � s r )rk r) r� Zlogging.handlersrq Zsalt.utils.jsonr8 Zsalt.utils.networkZsalt.utils.stringutilsZ salt._loggingr rt Z zmq.error� ImportError� getLoggerrd r r r r � Formatterr �handlersZDatagramHandlerr �Handlerr r r r r �<module> s0 � F
| ver. 1.4 |
Github
|
.
| PHP 8.2.30 | Generation time: 0 |
proxy
|
phpinfo
|
Settings