File manager - Edit - /opt/saltstack/salt/lib/python3.10/site-packages/salt/states/__pycache__/elasticsearch.cpython-310.pyc
Back
o ;j�P � @ sx d Z ddlZddlZe�e�Zdd� Zddd�Zdd� Z dd d �Z d d � Z ddd�Z dd� Z dd� Zdd� Zdd� ZdS )zC State module to manage Elasticsearch. .. versionadded:: 2017.7.0 � Nc C � | i ddd�}z]t d | d�}|rZ| |v rZtd r0d| � d�|d < || |d d < d |d < W |S t d | d�|d < |d rOd| � �|d < || |d d < W |S d| � d�|d < W |S d| � d�|d < W |S ty� } zd|d < t|�|d < W Y d }~|S d }~ww )z^ Ensure that the named index is absent. name Name of the index to remove T� ��name�changes�result�comment�elasticsearch.index_get��index�test�Index � will be removedr r �oldNr zelasticsearch.index_deletezSuccessfully removed index zFailed to remove index � for unknown reasons� is already absentF��__salt__�__opts__� Exception�str)r �retr �err� r �M/opt/saltstack/salt/lib/python3.10/site-packages/salt/states/elasticsearch.py� index_absent �2 � �� ����r c C s | i ddd�}z^t d | d�}|s[td r)d�| �|d< d |i|d < d |d < W |S t d | |d�}|rJd| � �|d< d t d | d�| i|d < W |S d|d < d| � d|� �|d< W |S d| � d�|d< W |S ty� } zd|d < t|�|d< W Y d }~|S d }~ww )aJ Ensure that the named index is present. name Name of the index to add definition Optional dict for creation parameters as per https://www.elastic.co/guide/en/elasticsearch/reference/current/indices-create-index.html **Example:** .. code-block:: yaml # Default settings mytestindex: elasticsearch_index.present # Extra settings mytestindex2: elasticsearch_index.present: - definition: settings: index: number_of_shards: 10 Tr r zelasticsearch.index_existsr r z+Index {} does not exist and will be createdr �newr Nr zelasticsearch.index_create)r �bodyzSuccessfully created index r FzCannot create index z, r � is already present�r r �formatr r )r � definitionr Z index_exists�outputr r r r � index_present1 s< � �� � �����r$ c C sN | i ddd�}z�t d | |d�}|r|�|i ��di ��| d�durtd rGd �| |�|d < |�|i ��di ��| i �|d d < d|d < W |S t d | |d�|d < |d rtd| � d|� �|d < |�|i ��di ��| i �|d d < W |S d�| |�|d < W |S d�| |�|d < W |S ty� } zd|d < t|�|d < W Y d}~|S d}~ww )z� Ensure that the index alias is absent. name Name of the index alias to remove index Name of the index for the alias Tr r �elasticsearch.alias_get��aliases�indicesr' Nr z%Alias {} for index {} will be removedr r r r zelasticsearch.alias_deletezSuccessfully removed alias z for index z:Failed to remove alias {} for index {} for unknown reasonsz'Alias {} for index {} is already absentF)r �getr r! r r )r r r �aliasr r r r � alias_absentk sL � � � � �� ���� � ����r+ c C s\ | i ddd�}z�t d | |d�}i }|r"|�|i ��di ��| i �}|s&i }td ||�|d< |d s5|s�td rS|sDd �| |�|d < nd �| |�|d < d |d< W |S t d | ||d�}|rv|skd�| |�|d < W |S d�| |�|d < W |S d|d< d�| ||�|d < W |S d�| |�|d < W |S ty� } zd|d< t|�|d < W Y d }~|S d }~ww )a� Ensure that the named index alias is present. name Name of the alias index Name of the index definition Optional dict for filters as per https://www.elastic.co/guide/en/elasticsearch/reference/current/indices-aliases.html **Example:** .. code-block:: yaml mytestalias: elasticsearch.alias_present: - index: testindex - definition: filter: term: user: kimchy Tr r r% r& r' �dictdiffer.deep_diffr r z8Alias {} for index {} does not exist and will be createdr zLAlias {} for index {} exists with wrong configuration and will be overriddenNr zelasticsearch.alias_create)r* r( r z*Successfully created alias {} for index {}z+Successfully replaced alias {} for index {}Fz'Cannot create alias {} for index {}, {}z(Alias {} for index {} is already present)r r) � __utils__r r! r r )r r r" r r* r r# r r r r � alias_present� sf ��� �������� � � ����r. c C s | i ddd�}z\t d | d�}|rY| |v rYtd r0d| � d�|d < || |d d < d |d < W |S t d | d�|d < |d rOd�| �|d < || |d d < W |S d�| �|d < W |S d| � d�|d < W |S ty� } zd|d < t|�|d < W Y d }~|S d }~ww )zg Ensure that the named index template is absent. name Name of the index to remove Tr r � elasticsearch.index_template_get�r r �Index template r r r r Nr z#elasticsearch.index_template_deletez&Successfully removed index template {}z6Failed to remove index template {} for unknown reasonsr Fr )r r Zindex_templater r r r �index_template_absent� s> � �� ��� ����r2 Fc C s | i ddd�}z�t d | d�}|sZtd r*d| � d�|d < d |i|d < d |d < W |S t d | |d�}|rKd�| �|d < d t d | d�| i|d < W |S d|d < d�| |�|d < W |S |r�t|t�ritjj�|�}n|}t d | d�| }dD ]}|| i kr�||vr�||= qvt d ||�} t | �dkr�td r�d�| �|d < | |d < d |d < W |S t d | |d�}|r�d| � �|d < | |d < W |S d|d < d�| |�|d < W |S d�| �|d < W |S d| � d�|d < W |S t �y } zd|d < t| �|d < W Y d } ~ |S d } ~ ww ) aq Ensure that the named index template is present. name Name of the index to add definition Required dict for creation parameters as per https://www.elastic.co/guide/en/elasticsearch/reference/current/indices-templates.html check_definition If the template already exists and the definition is up to date **Example:** .. code-block:: yaml mytestindex2_template: elasticsearch.index_template_present: - definition: template: logstash-* order: 1 settings: number_of_shards: 1 Tr r z#elasticsearch.index_template_existsr0 r r1 �# does not exist and will be createdr r r Nr z#elasticsearch.index_template_create)r r z&Successfully created index template {}r/ Fz#Cannot create index template {}, {})Zmappingsr' Zsettingsr, r z.Index template {} exist but need to be updatedz$Successfully updated index template z#Cannot update index template {}, {}z3Index template {} is already present and up to dater ) r r r! � isinstancer �salt�utils�json�loadsr- �lenr ) r r" Zcheck_definitionr Zindex_template_existsr# Zdefinition_parsedZcurrent_template�key�diffr r r r �index_template_present s� � � H���� �?� �8� ���� �� ��� ������ ����r< c C r )zc Ensure that the named pipeline is absent name Name of the pipeline to remove Tr r �elasticsearch.pipeline_get��idr � Pipeline r r r r Nr z elasticsearch.pipeline_deletez Successfully removed pipeline zFailed to remove pipeline r r Fr )r r �pipeliner r r r �pipeline_absent� r rB c C s< | i ddd�}zyt d | d�}i }|r| |v r|| }td ||�|d< |d s*|svtd rG|s9d | � d �|d < nd �| �|d < d |d< W |S t d | |d�}|rg|s]d| � �|d < W |S d�| �|d < W |S d|d< d�| |�|d < W |S d | � d�|d < W |S ty� } zd|d< t|�|d < W Y d }~|S d }~ww )aX Ensure that the named pipeline is present. name Name of the index to add definition Required dict for creation parameters as per https://www.elastic.co/guide/en/elasticsearch/reference/master/pipeline.html **Example:** .. code-block:: yaml test_pipeline: elasticsearch.pipeline_present: - definition: description: example pipeline processors: - set: field: collector_timestamp_millis value: '{{ '{{' }}_ingest.timestamp{{ '}}' }}' Tr r r= r> r, r r r@ r3 r zBPipeline {} exists with wrong configuration and will be overriddenNr z elasticsearch.pipeline_create�r? r z Successfully created pipeline z!Successfully replaced pipeline {}Fz Cannot create pipeline {}, {}r )r r- r r! r r )r r" r rA r r# r r r r �pipeline_present� sR �� ��� �� � ����rD c C s | i ddd�}zbt d | d�}|r_td r1d| � d�|d < tjj�|d �|d d < d |d< W |S t d | d�|d< |d rUd�| �|d < tjj�|d �|d d < W |S d�| �|d < W |S d| � d�|d < W |S ty� } zd|d< t|�|d < W Y d }~|S d }~ww )zk Ensure that the search template is absent name Name of the search template to remove Tr r �!elasticsearch.search_template_getr> r �Search template r r �templater r Nr z$elasticsearch.search_template_deletez'Successfully removed search template {}z7Failed to remove search template {} for unknown reasonsr F) r r r5 r6 r7 r8 r! r r )r r rG r r r r �search_template_absent� s> � �� ��� ����rH c C s< | i ddd�}zyt d | d�}i }|r tjj�|d �}td ||�|d< |d s+|svtd rG|s9d �| �|d < nd �| �|d < d |d< W |S t d | |d�}|rg|s]d| � �|d < W |S d| � �|d < W |S d|d< d�| |�|d < W |S d| � d�|d < W |S ty� } zd|d< t |�|d < W Y d }~|S d }~ww )a� Ensure that the named search template is present. name Name of the search template to add definition Required dict for creation parameters as per http://www.elastic.co/guide/en/elasticsearch/reference/current/search-template.html **Example:** .. code-block:: yaml test_pipeline: elasticsearch.search_template_present: - definition: inline: size: 10 Tr r rE r> rG r, r r z5Search template {} does not exist and will be createdr zISearch template {} exists with wrong configuration and will be overriddenNr z$elasticsearch.search_template_createrC z%Successfully created search template z&Successfully replaced search template Fz$Cannot create search template {}, {}rF r ) r r5 r6 r7 r8 r- r r! r r )r r" r rG r r# r r r r �search_template_present sR ��� ��� � � ����rI )N)F)�__doc__�loggingZsalt.utils.jsonr5 � getLogger�__name__�logr r$ r+ r. r2 r< rB rD rH rI r r r r �<module> s #: 6T )o#F )
| ver. 1.4 |
Github
|
.
| PHP 8.2.30 | Generation time: 0 |
proxy
|
phpinfo
|
Settings