File manager - Edit - /opt/saltstack/salt/lib/python3.10/site-packages/salt/netapi/rest_tornado/__pycache__/event_processor.cpython-310.pyc
Back
o ;j� � @ s< d dl Z d dlZd dlZd dlZe �e�ZG dd� d�ZdS )� Nc @ sX e Zd ZdZdd� Zdd� Zdd� Zdd � Zd d � Zd d � Z dd� Z dd� Z dd� Z dS )�SaltInfozP Class to handle processing and publishing of "real time" Salt upates. c C s || _ i | _i | _dS )zb handler is expected to be the server side end of a websocket connection. N)�handler�jobs�minions)�selfr � r �\/opt/saltstack/salt/lib/python3.10/site-packages/salt/netapi/rest_tornado/event_processor.py�__init__ s zSaltInfo.__init__c C s� t �d� i }t �d� | j�� D ]\}}t �|� i }|�|� |�d|i� |||< qt �d� d|i}| j�tjj � |�d � dS )z7 Publishes minions as a list of dicts. zin publish minionsz starting loop�idz ended loopr � N) �log�debugr �items�updater � write_message�salt�utils�json�dumps)r r �minionZ minion_infoZ curr_minion�retr r r �publish_minions s zSaltInfo.publish_minionsc C s* ||i}t jj�|�d }| j�|� dS )z9 Publishes the data to the event stream. r N)r r r r r r )r �key�dataZ publish_dataZpubr r r �publish0 s zSaltInfo.publishc C sl |d }|d }|� d�d }| j�|d�si | j|< | j| }|�d|d i� t�d| j� | �� dS ) zO Associate grains data with a minion and publish minion update �tagr �/���NZgrains�returnz/In process minion grains update with minions=%s)�splitr �getr r r r )r � event_datar � event_info�midr r r r �process_minion_update8 s z SaltInfo.process_minion_updatec C s� |d }|d }|� d�\}}}}}| j�|i �}|�di ��|i �}|�d|d i� |�d|d i� |�d|d i� tdd � |d �� D ��} | rQd |d < | �d | j� d S )z� Process a /ret event returned by Salt for a particular minion. These events contain the returned results from a particular execution. r r r r r �retcode�successc S s g | ]\}}|d �qS )r& r )�.0r# r r r r � <listcomp>[ s z2SaltInfo.process_ret_job_event.<locals>.<listcomp>Zcomplete�stater N)r r � setdefaultr �allr r ) r r! r r" �_�jidr# �jobr Z job_completer r r �process_ret_job_eventJ s �z SaltInfo.process_ret_job_eventc C sz d}|d }|d }i }|d D ]}ddi||< q|d |d ||d |d |d d d �}|| j |d < | �d| j � dS )z� Creates a new job with properties from the event data like jid, function, args, timestamp. Also sets the initial state to started. Minions that are participating in this job are also noted. Nr r r r& Fr- Z_stamp�fun�tgt�tgt_typeZrunning)r- Z start_timer r0 r1 r2 r) r )r r )r r! r. r r" r r# r r r �process_new_job_eventc s � z SaltInfo.process_new_job_eventc C sZ |d }|d }|d dkr| j �|d d� n|d dkr'| j �|d i � | �� dS )z� Tag: salt/key Data: {'_stamp': '2014-05-20T22:45:04.345583', 'act': 'delete', 'id': 'compute.home', 'result': True} r r Zact�deleter N�accept)r �popr* r )r r! r r" r r r �process_key_event� s zSaltInfo.process_key_eventc C sp t �d� d}t|d �dg ��r t|d �dg ��}nt| j�t|d �dg �� }|D ]}d}t �d|� | j�|d� q-t|d �d g ��r[t �d � t|d �d g ��}d}n(t|d �dg ��t| j� r�t �d � t|d �dg ��t| j� }d}ng }d �|�}|D ] } t �d � i | j| < q�|r�d}tj� |�} | � d|dddd|d�� |r�| � � dS dS )zt Check if any minions have connected or dropped. Send a message to the client if they have. z In presenceFr ZlostZpresentTz Popping %sN�newzgot new minionszdetected new minions�,z Adding minion� grains.items�list�client�localZ local_async)r0 r1 Z expr_type�moder< Z asynchronous�token) r r �setr r r6 �joinr ZnetapiZ NetapiClient�runr ) r � salt_datar? �opts�changedZdropped_minionsr Z new_minionsr1 r# r< r r r �process_presence_events� sP � �� �z SaltInfo.process_presence_eventsc C s t �dt�� � t �|d � t �|� |d �d�}t|�dk r#dS |d dkrct �d� |d d kr@t �d � | �|� dS |d d kr_t �d � | �|� |d d dkra| �|� dS dS dS |d dkrut �d� | � |� dS |d dkr�| � |||� dS dS )z1 Process events and publish data z In process %sr r � N� r. z In job part 1� r8 z In new jobr zIn retr r0 r: r zIn keyZpresence) r r � threading�current_threadr �lenr3 r/ r$ r7 rF )r rC r? rD �partsr r r �process� s0 � �zSaltInfo.processN) �__name__� __module__� __qualname__�__doc__r r r r$ r/ r3 r7 rF rN r r r r r s 8r ) �loggingrJ Z salt.netapir Zsalt.utils.json� getLoggerrO r r r r r r �<module> s
| ver. 1.4 |
Github
|
.
| PHP 8.2.30 | Generation time: 0 |
proxy
|
phpinfo
|
Settings