File manager - Edit - /opt/saltstack/salt/lib/python3.10/site-packages/salt/engines/__pycache__/logentries.cpython-310.pyc
Back
o ;jd � @ s d Z ddlZddlZddlZddlZddlZddlZddlZzddl Z dZ W n e y1 dZ Y nw zddl Z dZ W n e yE dZ Y nw e�e�Zdd� ZG dd� d�Zzddl Z dZ W n e yk eZdZ Y n w G d d � d e�ZeZd d � Z ddd�ZdS )av An engine that sends events to the Logentries logging service. :maintainer: Jimmy Tang (jimmy_tang@rapid7.com) :maturity: New :depends: ssl, certifi :platform: all .. versionadded:: 2016.3.0 To enable this engine the master and/or minion will need the following python libraries ssl certifi If you are running a new enough version of python then the ssl library will be present already. You will also need the following values configured in the minion or master config. :configuration: Example configuration .. code-block:: yaml engines: - logentries: endpoint: data.logentries.com port: 10000 token: 057af3e2-1c05-47c5-882a-5cd644655dbf The 'token' can be obtained from the Logentries service. To test this engine .. code-block:: bash salt '*' test.ping cmd.run uptime � NTFc C s t rtrdS dS )NTF)� HAS_CERTIFI�HAS_SSL� r r �K/opt/saltstack/salt/lib/python3.10/site-packages/salt/engines/logentries.py� __virtual__I s r c @ s8 e Zd Z ddd�Zdd� Zd d � Zd d � Zd d� ZdS )�PlainTextSocketAppenderT�data.logentries.com�P � c C sD || _ || _|| _d| _d| _d| _tjj� d�| _ || _ d | _ d S )Ng�������?� zG It appears the LOGENTRIES_TOKEN parameter you entered is incorrect! u ) �LE_API�LE_PORT� LE_TLS_PORT� MIN_DELAY� MAX_DELAYZ INVALID_TOKEN�salt�utils� stringutils�to_str�LINE_SEP�verbose�_conn)�selfr r r r r r r �__init__N s � z PlainTextSocketAppender.__init__c C s* t � t jt j�| _| j�| j| jf� d S �N)�socket�AF_INET� SOCK_STREAMr �connectr r �r r r r �open_connectionb s z'PlainTextSocketAppender.open_connectionc C s� | � � | j} z| �� W d S ty | jr t�d� Y nw |d9 }|| jkr-| j}|t� d|� }zt � |� W n t yD � w q)NTz Unable to connect to Logentries� r ) �close_connectionr r � Exceptionr �log�warningr �random�uniform�time�sleep�KeyboardInterrupt)r Z root_delay�wait_forr r r �reopen_connectionf s* �� ��z)PlainTextSocketAppender.reopen_connectionc C s | j d ur | j �� d S d S r )r �closer r r r r" } s �z(PlainTextSocketAppender.close_connectionc C sN |� d| j�d } z| j�|� W n ty | �� Y q w | �� d S )N� )�replacer r �send�OSErrorr, r" )r �dataZ multiliner r r �put� s � zPlainTextSocketAppender.putN)Tr r r )�__name__� __module__� __qualname__r r r, r" r3 r r r r r M s � r c @ s e Zd Zdd� ZdS )�TLSSocketAppenderc C sX t � t jt j�}tj|d d dtjttdtj�t� � ddd� }|� | j | j f� || _ d S )NF�PROTOCOL_TLSv1_2T) �sock�keyfile�certfile� server_side� cert_reqs� ssl_version�ca_certs�do_handshake_on_connect�suppress_ragged_eofs)r r r �ssl� wrap_socket� CERT_REQUIRED�getattr�PROTOCOL_TLSv1�certifi�wherer r r r )r r9 r r r r � s � z!TLSSocketAppender.open_connectionN)r4 r5 r6 r r r r r r7 � s r7 c C sJ | � d��d�rtjjj| | d dd�}|S tjjjd| | d dd�}|S )N�idZ_master�sock_dirT)�listenZminion)�optsrJ rK )�get�endswithr r �eventZget_master_event� get_event)rL � event_busr r r �event_bus_context� s � ��rR r �' �salt/engines/logentriesc C s� t t��K}t�d� zt�|�}W n ty t�d� Y nw td| |d�}|� � |� � }|rNd� t j j�|�t j j�|�t j j�|�f�}|�|� q,1 sRw Y dS )z> Listen to salt events and forward them to Logentries zLogentries engine startedz Not a valid logentries tokenF)r r r T� N)rR Z__opts__r$ �debug�uuidZUUID� ValueErrorr% �SocketAppenderr, rP �joinr r r r �json�dumpsr3 r" ) Zendpoint�port�token�tagrQ �valZappenderrO �msgr r r �start� s* � �� ��rb )r rS NrT )�__doc__�loggingr& r r( rW Zsalt.utils.eventr Zsalt.utils.jsonrG r � ImportErrorrB r � getLoggerr4 r$ r r rY r7 rR rb r r r r �<module> sL , � � C ��
| ver. 1.4 |
Github
|
.
| PHP 8.2.30 | Generation time: 0 |
proxy
|
phpinfo
|
Settings