File manager - Edit - /opt/saltstack/salt/lib/python3.10/site-packages/salt/modules/__pycache__/elasticsearch.cpython-310.pyc
Back
o ;j�� � @ st d Z ddlZddlmZmZ e�e�ZzddlZddlm Z e�d�� ej � dZ W n e y5 dZ Y nw dd � Zdnd d �Zdod d �Zdndd�Zdpdd�Zdqdd�Zdrdd�Z dsdd�Zdpdd�Zdtdd �Zdtd d �Zdrd d �Zdtd!d"�Z dud#d$�Zdnd%d&�Z dvd(d)�Z dvd*d+�Z dtd,d-�Z dnd.d/�Z dnd0d1�Z!dnd2d3�Z" 4 dwd5d6�Z# 7 dxd8d9�Z$dnd:d;�Z%dtd<d=�Z&dtd>d?�Z'dnd@dA�Z(dndBdC�Z)dtdDdE�Z*dndFdG�Z+dndHdI�Z,dndJdK�Z-dndLdM�Z.dndNdO�Z/dndPdQ�Z0dodRdS�Z1dndTdU�Z2dndVdW�Z3dndXdY�Z4dodZd[�Z5dnd\d]�Z6dnd^d_�Z7dnd`da�Z8 dydbdc�Z9 doddde�Z:drdfdg�Z;drdhdi�Z<dndjdk�Z=dndldm�Z>dS )za� Elasticsearch - A distributed RESTful search and analytics server Module to provide Elasticsearch compatibility to Salt (compatible with Elasticsearch version 1.5.2+) .. versionadded:: 2015.8.0 :depends: `elasticsearch-py <http://elasticsearch-py.readthedocs.org/en/latest/>`_ :configuration: This module accepts connection configuration details either as parameters or as configuration settings in /etc/salt/minion on the relevant minions: .. code-block:: yaml elasticsearch: host: '10.10.10.100:9200' elasticsearch-cluster: hosts: - '10.10.10.100:9200' - '10.10.10.101:9200' - '10.10.10.102:9200' elasticsearch-extra: hosts: - '10.10.10.100:9200' use_ssl: True verify_certs: True ca_certs: /path/to/custom_ca_bundle.pem number_of_shards: 1 number_of_replicas: 0 functions_blacklist: - 'saltutil.find_job' - 'pillar.items' - 'grains.items' proxies: - http: http://proxy:3128 - https: http://proxy:1080 When specifying proxies the requests backend will be used and the 'proxies' data structure is passed as-is to that module. This data can also be passed into pillar. Options passed into opts will overwrite options passed into pillar. Some functionality might be limited by elasticsearch-py and Elasticsearch server versions. � N)�CommandExecutionError�SaltInvocationError)�RequestsHttpConnection� elasticsearchTFc C s t sdS dS )z5 Only load if elasticsearch libraries exist. )FzCCannot load module elasticsearch: elasticsearch libraries not foundT)�HAS_ELASTICSEARCH� r r �N/opt/saltstack/salt/lib/python3.10/site-packages/salt/modules/elasticsearch.py� __virtual__G s r c C sp d}d}d}d}d}d}d}|du rd}t |t�r!td |d�} nt |t�r(|} | rj| �d| �} | s8| �d| �} | �d d�}| �d d�}| �d d�}| �d d�}| �d d�} | �dd�} | �dd�}| rj| rj| | f}| sodg} t | t�rw| g} z*|r�G dd� dt�} tj| | ||||||d�}n tj| |||||d�}|�� W |S tj j y� } zt d� | | ���d} ~ ww )z+ Return the elasticsearch instance NFT� r z config.option�host�hosts�proxies�use_ssl�ca_certs� verify_certs�username�password�timeoutz127.0.0.1:9200c s e Zd Z� fdd�Z� ZS )z&_get_instance.<locals>.ProxyConnectionc s* |� di �}t� j|i |�� || j_d S )Nr )�pop�super�__init__�sessionr )�self�args�kwargsr �� __class__r r r } s z/_get_instance.<locals>.ProxyConnection.__init__)�__name__� __module__� __qualname__r � __classcell__r r r r �ProxyConnection| s r! )Zconnection_classr r r r � http_authr )r r r r" r z=Could not connect to Elasticsearch host/ cluster {} due to {}) � isinstance�str�__salt__�dict�getr r Z Elasticsearch�info� exceptions�TransportErrorr �format)r �profile�esr r r r r" r Z_profiler r r! �errr r r � _get_instanceS sz � � �����r/ c C s> zt ||� W dS ty } z | r� W Y d}~dS d}~ww )ar .. versionadded:: 2017.7.0 Test connection to Elasticsearch instance. This method does not fail if not explicitly specified. allow_failure Throw exception if ping fails CLI Example: .. code-block:: bash salt myminion elasticsearch.ping allow_failure=True salt myminion elasticsearch.ping profile=elasticsearch-extra NFT)r/ r )Z allow_failurer r, �er r r �ping� s ���r1 c C sD t | |�}z|�� W S tjy! } z td�|j|j���d}~ww )z� .. versionadded:: 2017.7.0 Return Elasticsearch information. CLI Example: .. code-block:: bash salt myminion elasticsearch.info salt myminion elasticsearch.info profile=elasticsearch-extra zKCannot retrieve server information, server returned code {} with message {}N)r/ r( r r* r r+ � status_code�error)r r, r- r0 r r r r( � s ���r( c C �L t ||�}z |jj| |d�W S tjy% } z td�|j|j���d}~ww )ag .. versionadded:: 2017.7.0 Return Elasticsearch node information. nodes List of cluster nodes (id or name) to display stats for. Use _local for connected node, empty for all flat_settings Flatten settings keys CLI Example: .. code-block:: bash salt myminion elasticsearch.node_info flat_settings=True )�node_id� flat_settingszICannot retrieve node information, server returned code {} with message {}N) r/ �nodesr( r r* r r+ r2 r3 )r7 r6 r r, r- r0 r r r � node_info� s ����r8 �clusterc C �N t ||�}z |jj| ||d�W S tjy& } z td�|j|j���d}~ww )a� .. versionadded:: 2017.7.0 Return Elasticsearch cluster health. index Limit the information returned to a specific index level Specify the level of detail for returned information, default 'cluster', valid choices are: 'cluster', 'indices', 'shards' local Return local information, do not retrieve the state from master node CLI Example: .. code-block:: bash salt myminion elasticsearch.cluster_health )�index�level�localzKCannot retrieve health information, server returned code {} with message {}N) r/ r9 Zhealthr r* r r+ r2 r3 )r; r< r= r r, r- r0 r r r �cluster_health� s ���r> c C sJ t ||�}z|jj| d�W S tjy$ } z td�|j|j���d}~ww )a% .. versionadded:: 2017.7.0 Return Elasticsearch cluster stats. nodes List of cluster nodes (id or name) to display stats for. Use _local for connected node, empty for all CLI Example: .. code-block:: bash salt myminion elasticsearch.cluster_stats )r5 zFCannot retrieve cluster stats, server returned code {} with message {}N) r/ r9 Zstatsr r* r r+ r2 r3 )r7 r r, r- r0 r r r � cluster_stats s ����r? c C r4 )a; .. versionadded:: 3000 Return Elasticsearch cluster settings. flat_settings Return settings in flat format. include_defaults Whether to return all default clusters setting. CLI Example: .. code-block:: bash salt myminion elasticsearch.cluster_get_settings )r6 �include_defaultszICannot retrieve cluster settings, server returned code {} with message {}N) r/ r9 � get_settingsr r* r r+ r2 r3 )r6 r@ r r, r- r0 r r r �cluster_get_settings( s �����rB c C s\ | sd}t |��t||�}z |jj| |d�W S tjy- } z td�|j|j ���d}~ww )a{ .. versionadded:: 3000 Set Elasticsearch cluster settings. body The settings to be updated. Can be either 'transient' or 'persistent' (survives cluster restart) http://www.elastic.co/guide/en/elasticsearch/reference/current/cluster-update-settings.html flat_settings Return settings in flat format. CLI Example: .. code-block:: bash salt myminion elasticsearch.cluster_put_settings '{"persistent": {"indices.recovery.max_bytes_per_sec": "50mb"}}' salt myminion elasticsearch.cluster_put_settings '{"transient": {"indices.recovery.max_bytes_per_sec": "50mb"}}' z%You must provide a body with settings)�bodyr6 zGCannot update cluster settings, server returned code {} with message {}N) r r/ r9 � put_settingsr r* r r+ r2 r3 )rC r6 r r, �messager- r0 r r r �cluster_put_settingsJ s ����rF c C s� t ||�}|r|rd}t|��|r td |t�dd�d�}z|jj| ||d�}|�dd�W S tjyF } z t d � || | j | j ���d } ~ ww ) af Create an alias for a specific index/indices indices Single or multiple indices separated by comma, use _all to perform the operation on all indices. alias Alias name body Optional definition such as routing or filter as defined in https://www.elastic.co/guide/en/elasticsearch/reference/current/indices-aliases.html source URL of file specifying optional definition such as routing or filter. Cannot be used in combination with ``body``. CLI Example: .. code-block:: bash salt myminion elasticsearch.alias_create testindex_v1 testindex �7Either body or source should be specified but not both.�cp.get_file_str�saltenv�base�rI )r; �namerC � acknowledgedFzKCannot create alias {} in index {}, server returned code {} with message {}N) r/ r r% �__opts__r' �indicesZ put_aliasr r* r r+ r2 r3 ) rO �aliasr rC r, �sourcer- rE �resultr0 r r r � alias_createm s$ ����rS c C s� t ||�}|r|rd}t|��|r td |t�dd�d�}z|jj| |d�}|�dd�W S tjj y8 Y d S tj yP } z t d � || | j | j���d } ~ ww ) aC Delete an alias of an index indices Single or multiple indices separated by comma, use _all to perform the operation on all indices. aliases Alias names separated by comma CLI Example: .. code-block:: bash salt myminion elasticsearch.alias_delete testindex_v1 testindex rG rH rI rJ rK �r; rL rM FTzKCannot delete alias {} in index {}, server returned code {} with message {}N)r/ r r% rN r' rO Z delete_aliasr r) � NotFoundErrorr* r r+ r2 r3 ) rO �aliasesr rC r, rQ r- rE rR r0 r r r � alias_delete� s( ����rW c C sf t ||�}z |jj| |d�W S tjjy Y dS tjy2 } z td�| ||j |j ���d}~ww )aV Return a boolean indicating whether given alias exists indices Single or multiple indices separated by comma, use _all to perform the operation on all indices. aliases Alias names separated by comma CLI Example: .. code-block:: bash salt myminion elasticsearch.alias_exists None testindex )rL r; F�HCannot get alias {} in index {}, server returned code {} with message {}N) r/ rO Z exists_aliasr r) rU r* r r+ r2 r3 )rV rO r r, r- r0 r r r � alias_exists� s ����rY c C sf t ||�}z |jj| |d�W S tjjy Y dS tjy2 } z td�|| |j |j ���d}~ww )aW Check for the existence of an alias and if it exists, return it indices Single or multiple indices separated by comma, use _all to perform the operation on all indices. aliases Alias names separated by comma CLI Example: .. code-block:: bash salt myminion elasticsearch.alias_get testindex rT NrX ) r/ rO Z get_aliasr r) rU r* r r+ r2 r3 )rO rV r r, r- r0 r r r � alias_get� s ����rZ c C s� t ||�}|r|rd}t|��|r td |t�dd�d�}z |j| |||d�W S tjy? } z td� | | j | j ���d} ~ ww ) a� Create a document in a specified index index Index name where the document should reside doc_type Type of the document body Document to store source URL of file specifying document to store. Cannot be used in combination with ``body``. id Optional unique document identifier for specified doc_type (empty for random) CLI Example: .. code-block:: bash salt myminion elasticsearch.document_create testindex doctype1 '{}' rG rH rI rJ rK )r; �doc_typerC �idzKCannot create document in index {}, server returned code {} with message {}N) r/ r r% rN r' r; r r* r r+ r2 r3 ) r; r[ rC r\ r r, rQ r- rE r0 r r r �document_create� s" ����r] c C sf t ||�}z |j| ||d�W S tjjy Y dS tjy2 } z td�|| |j|j ���d}~ww )a8 Delete a document from an index index Index name where the document resides doc_type Type of the document id Document identifier CLI Example: .. code-block:: bash salt myminion elasticsearch.document_delete testindex doctype1 AUx-384m0Bug_8U80wQZ )r; r[ r\ NzNCannot delete document {} in index {}, server returned code {} with message {}) r/ �deleter r) rU r* r r+ r2 r3 )r; r[ r\ r r, r- r0 r r r �document_delete � ���r_ �_allc C sf t ||�}z |j| ||d�W S tjjy Y dS tjy2 } z td�|| |j|j ���d}~ww )a� Return a boolean indicating whether given document exists index Index name where the document resides id Document identifier doc_type Type of the document, use _all to fetch the first document matching the ID across all types CLI Example: .. code-block:: bash salt myminion elasticsearch.document_exists testindex AUx-384m0Bug_8U80wQZ �r; r\ r[ F�RCannot retrieve document {} from index {}, server returned code {} with message {}N) r/ �existsr r) rU r* r r+ r2 r3 �r; r\ r[ r r, r- r0 r r r �document_exists5 r` rf c C sf t ||�}z |j| ||d�W S tjjy Y dS tjy2 } z td�|| |j|j ���d}~ww )a� Check for the existence of a document and if it exists, return it index Index name where the document resides id Document identifier doc_type Type of the document, use _all to fetch the first document matching the ID across all types CLI Example: .. code-block:: bash salt myminion elasticsearch.document_get testindex AUx-384m0Bug_8U80wQZ rb Nrc ) r/ r' r r) rU r* r r+ r2 r3 re r r r � document_getS r` rg c C s� t ||�}|r|rd}t|��|r td |t�dd�d�}z|jj| |d�}|�dd�o1|�d d �W S tjyV } zd |j krGW Y d }~d S t d � | |j |j ���d }~ww )a= Create an index index Index name body Index definition, such as settings and mappings as defined in https://www.elastic.co/guide/en/elasticsearch/reference/current/indices-create-index.html source URL to file specifying index definition. Cannot be used in combination with ``body``. CLI Example: .. code-block:: bash salt myminion elasticsearch.index_create testindex salt myminion elasticsearch.index_create testindex2 '{"settings" : {"index" : {"number_of_shards" : 3, "number_of_replicas" : 2}}}' rG rH rI rJ rK )r; rC rM FZshards_acknowledgedTZ index_already_exists_exceptionNz?Cannot create index {}, server returned code {} with message {}) r/ r r% rN r' rO �creater r* r3 r r+ r2 ) r; rC r r, rQ r- rE rR r0 r r r � index_createq s. �� ����ri c C �n t ||�}z|jj| d�}|�dd�W S tjjy Y dS tjy6 } z td� | |j |j ���d}~ww )z� Delete an index index Index name CLI Example: .. code-block:: bash salt myminion elasticsearch.index_delete testindex �r; rM FTz?Cannot delete index {}, server returned code {} with message {}N) r/ rO r^ r' r r) rU r* r r+ r2 r3 )r; r r, r- rR r0 r r r � index_delete� s ����rl c C sb t ||�}z|jj| d�W S tjjy Y dS tjy0 } z td�| |j |j ���d}~ww )z� Return a boolean indicating whether given index exists index Index name CLI Example: .. code-block:: bash salt myminion elasticsearch.index_exists testindex rk F�ACannot retrieve index {}, server returned code {} with message {}N) r/ rO rd r r) rU r* r r+ r2 r3 �r; r r, r- r0 r r r � index_exists� � ����ro c C �b t ||�}z|jj| d�W S tjjy Y dS tjy0 } z td�| |j |j ���d}~ww )z� Check for the existence of an index and if it exists, return it index Index name CLI Example: .. code-block:: bash salt myminion elasticsearch.index_get testindex rk Nrm ) r/ rO r' r r) rU r* r r+ r2 r3 rn r r r � index_get� rp rr �closedc C �^ t ||�}z|jj| |||d�}|�dd�W S tjy. } z td�| |j|j ���d}~ww )u� .. versionadded:: 2017.7.0 Open specified index. index Index to be opened allow_no_indices Whether to ignore if a wildcard indices expression resolves into no concrete indices. (This includes _all string or when no indices have been specified) expand_wildcards Whether to expand wildcard expression to concrete indices that are open, closed or both., default ‘closed’, valid choices are: ‘open’, ‘closed’, ‘none’, ‘all’ ignore_unavailable Whether specified concrete indices should be ignored when unavailable (missing or closed) CLI Example: .. code-block:: bash salt myminion elasticsearch.index_open testindex �r; �allow_no_indices�expand_wildcards�ignore_unavailablerM Fz=Cannot open index {}, server returned code {} with message {}N) r/ rO �openr' r r* r r+ r2 r3 � r; rv rw rx r r, r- rR r0 r r r � index_open� �" � ����r{ ry c C rt )u� .. versionadded:: 2017.7.0 Close specified index. index Index to be closed allow_no_indices Whether to ignore if a wildcard indices expression resolves into no concrete indices. (This includes _all string or when no indices have been specified) expand_wildcards Whether to expand wildcard expression to concrete indices that are open, closed or both., default ‘open’, valid choices are: ‘open’, ‘closed’, ‘none’, ‘all’ ignore_unavailable Whether specified concrete indices should be ignored when unavailable (missing or closed) CLI Example: .. code-block:: bash salt myminion elasticsearch.index_close testindex ru rM Fz>Cannot close index {}, server returned code {} with message {}N) r/ rO �closer' r r* r r+ r2 r3 rz r r r � index_close r| r~ c K s� t | |�}|�� }|D ] }|�d�r|�|� q z |jjdi |��W S tjjy. Y dS tj yE } z t d� ||j |j ���d}~ww )u� .. versionadded:: 3000 Check for the existence of an index and if it exists, return its settings http://www.elastic.co/guide/en/elasticsearch/reference/current/indices-get-settings.html index (Optional, string) A comma-separated list of index names; use _all or empty string for all indices. Defaults to '_all'. name (Optional, string) The name of the settings that should be included allow_no_indices (Optional, boolean) Whether to ignore if a wildcard indices expression resolves into no concrete indices. (This includes _all string or when no indices have been specified) expand_wildcards (Optional, string) Whether to expand wildcard expression to concrete indices that are open, closed or both. Valid choices are: ‘open’, ‘closed’, ‘none’, ‘all’ flat_settings (Optional, boolean) Return settings in flat format ignore_unavailable (Optional, boolean) Whether specified concrete indices should be ignored when unavailable (missing or closed) include_defaults (Optional, boolean) Whether to return all default setting for each of the indices. local (Optional, boolean) Return local information, do not retrieve the state from master node The defaults settings for the above parameters depend on the API version being used. CLI Example: .. code-block:: bash salt myminion elasticsearch.index_get_settings index=testindex �__NzJCannot retrieve index settings {}, server returned code {} with message {}r )r/ �copy� startswithr rO rA r r) rU r* r r+ r2 r3 )r r, r r- �filtered_kwargs�kr0 r r r �index_get_settingsL s$ # � ����r� c K s� t ||�}|r| rd}t|��|r td |t�dd�d�} |�� }|D ] }|�d�r/|�|� q#z|jj d d| i|��} | �dd �W S t j j yN Y d S t j ye } z td �|| j| j���d } ~ ww ) u+ .. versionadded:: 3000 Update existing index settings https://www.elastic.co/guide/en/elasticsearch/reference/current/indices-update-settings.html body The index settings to be updated. source URL to file specifying index definition. Cannot be used in combination with ``body``. index (Optional, string) A comma-separated list of index names; use _all or empty string to perform the operation on all indices allow_no_indices (Optional, boolean) Whether to ignore if a wildcard indices expression resolves into no concrete indices. (This includes _all string or when no indices have been specified) expand_wildcards (Optional, string) Whether to expand wildcard expression to concrete indices that are open, closed or both. Valid choices are: ‘open’, ‘closed’, ‘none’, ‘all’ flat_settings (Optional, boolean) Return settings in flat format (default: false) ignore_unavailable (Optional, boolean) Whether specified concrete indices should be ignored when unavailable (missing or closed) master_timeout (Optional, time units) Explicit operation timeout for connection to master node preserve_existing (Optional, boolean) Whether to update existing settings. If set to true existing settings on an index remain unchanged, the default is false The defaults settings for the above parameters depend on the API version being used. .. note:: Elasticsearch time units can be found here: https://www.elastic.co/guide/en/elasticsearch/reference/current/common-options.html#time-units CLI Example: .. code-block:: bash salt myminion elasticsearch.index_put_settings index=testindex body='{"settings" : {"index" : {"number_of_replicas" : 2}}}' rG rH rI rJ rK r rC rM FNzHCannot update index settings {}, server returned code {} with message {}r )r/ r r% rN r' r� r� r rO rD r r) rU r* r r+ r2 r3 ) rC r r, rQ r r- rE r� r� rR r0 r r r �index_put_settings� s4 ( � � ����r� c C s� t ||�}|r|rd}t|��|r td |t�dd�d�}z|jj| ||d�}|�dd�W S tjyE } z t d � | | j | j ���d } ~ ww ) aA Create a mapping in a given index index Index for the mapping doc_type Name of the document type body Mapping definition as specified in https://www.elastic.co/guide/en/elasticsearch/reference/current/indices-put-mapping.html source URL to file specifying mapping definition. Cannot be used in combination with ``body``. CLI Example: .. code-block:: bash salt myminion elasticsearch.mapping_create testindex user '{ "user" : { "properties" : { "message" : {"type" : "string", "store" : true } } } }' rG rH rI rJ rK )r; r[ rC rM FzACannot create mapping {}, server returned code {} with message {}N) r/ r r% rN r' rO Z put_mappingr r* r r+ r2 r3 ) r; r[ rC r r, rQ r- rE rR r0 r r r �mapping_create� s& � ����r� c C s� t ||�}z|jj| |d�}|�dd�W S tjjy Y dS tjy7 } z td� | |j |j ���d}~w t yA td��w )a2 Delete a mapping (type) along with its data. As of Elasticsearch 5.0 this is no longer available. index Index for the mapping doc_type Name of the document type CLI Example: .. code-block:: bash salt myminion elasticsearch.mapping_delete testindex user �r; r[ rM FTzACannot delete mapping {}, server returned code {} with message {}Nz/Method is not applicable for Elasticsearch 5.0+) r/ rO Zdelete_mappingr' r r) rU r* r r+ r2 r3 �AttributeError)r; r[ r r, r- rR r0 r r r �mapping_delete� s ��� �r� c C sd t ||�}z |jj| |d�W S tjjy Y dS tjy1 } z td�| |j |j ���d}~ww )a Retrieve mapping definition of index or index/type index Index for the mapping doc_type Name of the document type CLI Example: .. code-block:: bash salt myminion elasticsearch.mapping_get testindex user r� NzCCannot retrieve mapping {}, server returned code {} with message {}) r/ rO Z get_mappingr r) rU r* r r+ r2 r3 )r; r[ r r, r- r0 r r r � mapping_get s ����r� c C s� t ||�}|r|rd}t|��|r td |t�dd�d�}z|jj| |d�}|�dd�W S tjyD } z t d � | |j |j ���d }~ww ) a Create an index template name Index template name body Template definition as specified in http://www.elastic.co/guide/en/elasticsearch/reference/current/indices-templates.html source URL to file specifying template definition. Cannot be used in combination with ``body``. CLI Example: .. code-block:: bash salt myminion elasticsearch.index_template_create testindex_templ '{ "template": "logstash-*", "order": 1, "settings": { "number_of_shards": 1 } }' rG rH rI rJ rK )rL rC rM FzBCannot create template {}, server returned code {} with message {}N) r/ r r% rN r' rO � put_templater r* r r+ r2 r3 ) rL rC r r, rQ r- rE rR r0 r r r �index_template_create+ s& � ����r� c C rj )z� Delete an index template (type) along with its data name Index template name CLI Example: .. code-block:: bash salt myminion elasticsearch.index_template_delete testindex_templ user �rL rM FTzBCannot delete template {}, server returned code {} with message {}N) r/ rO �delete_templater' r r) rU r* r r+ r2 r3 �rL r r, r- rR r0 r r r �index_template_deleteQ s ����r� c C sL t ||�}z|jj| d�W S tjy% } z td�| |j|j���d}~ww )z� Return a boolean indicating whether given index template exists name Index template name CLI Example: .. code-block:: bash salt myminion elasticsearch.index_template_exists testindex_templ r� �DCannot retrieve template {}, server returned code {} with message {}N) r/ rO Zexists_templater r* r r+ r2 r3 �rL r r, r- r0 r r r �index_template_existsm s ����r� c C rq )z� Retrieve template definition of index or index/type name Index template name CLI Example: .. code-block:: bash salt myminion elasticsearch.index_template_get testindex_templ r� Nr� ) r/ rO � get_templater r) rU r* r r+ r2 r3 r� r r r �index_template_get� rp r� c C st t ||�}z|jj| d�W S tjy Y dS tjy/ } z td�| |j|j ���d}~w t y9 td��w )z� .. versionadded:: 2017.7.0 Retrieve Ingest pipeline definition. Available since Elasticsearch 5.0. id Pipeline id CLI Example: .. code-block:: bash salt myminion elasticsearch.pipeline_get mypipeline �r\ N�BCannot create pipeline {}, server returned code {} with message {}�0Method is applicable only for Elasticsearch 5.0+) r/ �ingestZ get_pipeliner rU r* r r+ r2 r3 r� �r\ r r, r- r0 r r r � pipeline_get� s ��� �r� c C s� t ||�}z|jj| d�}|�dd�W S tjy Y dS tjy5 } z td�| |j |j ���d}~w t y? td��w )z� .. versionadded:: 2017.7.0 Delete Ingest pipeline. Available since Elasticsearch 5.0. id Pipeline id CLI Example: .. code-block:: bash salt myminion elasticsearch.pipeline_delete mypipeline r� rM FTzBCannot delete pipeline {}, server returned code {} with message {}Nr� ) r/ r� Zdelete_pipeliner' r rU r* r r+ r2 r3 r� )r\ r r, r- �retr0 r r r �pipeline_delete� s ��� �r� c C sn t ||�}z|jj| |d�}|�dd�W S tjy, } z td�| |j|j ���d}~w t y6 td��w )a .. versionadded:: 2017.7.0 Create Ingest pipeline by supplied definition. Available since Elasticsearch 5.0. id Pipeline id body Pipeline definition as specified in https://www.elastic.co/guide/en/elasticsearch/reference/master/pipeline.html CLI Example: .. code-block:: bash salt myminion elasticsearch.pipeline_create mypipeline '{"description": "my custom pipeline", "processors": [{"set" : {"field": "collector_timestamp_millis", "value": "{{_ingest.timestamp}}"}}]}' �r\ rC rM Fr� Nr� ) r/ r� Z put_pipeliner' r r* r r+ r2 r3 r� )r\ rC r r, r- �outr0 r r r �pipeline_create� s ��� �r� c C sd t ||�}z |jj| ||d�W S tjy' } z td�| |j|j���d}~w t y1 td��w )aq .. versionadded:: 2017.7.0 Simulate existing Ingest pipeline on provided data. Available since Elasticsearch 5.0. id Pipeline id body Pipeline definition as specified in https://www.elastic.co/guide/en/elasticsearch/reference/master/pipeline.html verbose Specify if the output should be more verbose CLI Example: .. code-block:: bash salt myminion elasticsearch.pipeline_simulate mypipeline '{"docs":[{"_index":"index","_type":"type","_id":"id","_source":{"foo":"bar"}},{"_index":"index","_type":"type","_id":"id","_source":{"foo":"rab"}}]}' verbose=True )r\ rC �verbosezDCannot simulate pipeline {}, server returned code {} with message {}Nr� ) r/ r� Zsimulater r* r r+ r2 r3 r� )r\ rC r� r r, r- r0 r r r �pipeline_simulate� s ��� �r� c C s^ t ||�}z|j| d�W S tjy Y dS tjy. } z td�| |j|j���d}~ww )z� .. versionadded:: 2017.7.0 Obtain existing search template definition. id Template ID CLI Example: .. code-block:: bash salt myminion elasticsearch.search_template_get mytemplate r� NzICannot obtain search template {}, server returned code {} with message {}) r/ r� r rU r* r r+ r2 r3 r� r r r �search_template_get s ����r� c C sX t ||�}z|j| |d�}|�dd�W S tjy+ } z td�| |j|j���d}~ww )aR .. versionadded:: 2017.7.0 Create search template by supplied definition id Template ID body Search template definition CLI Example: .. code-block:: bash salt myminion elasticsearch.search_template_create mytemplate '{"template":{"query":{"match":{"title":"{{query_string}}"}}}}' r� rM FzICannot create search template {}, server returned code {} with message {}N) r/ r� r' r r* r r+ r2 r3 )r\ rC r r, r- rR r0 r r r �search_template_create; s ����r� c C sj t ||�}z |j| d�}|�dd�W S tjy Y dS tjy4 } z td�| |j|j ���d}~ww )z� .. versionadded:: 2017.7.0 Delete existing search template definition. id Template ID CLI Example: .. code-block:: bash salt myminion elasticsearch.search_template_delete mytemplate r� rM FTzICannot delete search template {}, server returned code {} with message {}N) r/ r� r' r rU r* r r+ r2 r3 )r\ r r, r- rR r0 r r r �search_template_deleteZ s ����r� c C sb t ||�}z |jj| |d�W S tjy Y dS tjy0 } z td�| |j|j ���d}~ww )a .. versionadded:: 2017.7.0 Get existing repository details. name Repository name local Retrieve only local information, default is false CLI Example: .. code-block:: bash salt myminion elasticsearch.repository_get testrepo )� repositoryr= NzDCannot obtain repository {}, server returned code {} with message {}) r/ �snapshotZget_repositoryr rU r* r r+ r2 r3 )rL r= r r, r- r0 r r r �repository_gety s ����r� c C sZ t ||�}z|jj| |d�}|�dd�W S tjy, } z td�| |j|j ���d}~ww )a .. versionadded:: 2017.7.0 Create repository for storing snapshots. Note that shared repository paths have to be specified in path.repo Elasticsearch configuration option. name Repository name body Repository definition as in https://www.elastic.co/guide/en/elasticsearch/reference/current/modules-snapshots.html CLI Example: .. code-block:: bash salt myminion elasticsearch.repository_create testrepo '{"type":"fs","settings":{"location":"/tmp/test","compress":true}}' )r� rC rM FzDCannot create repository {}, server returned code {} with message {}N) r/ r� Zcreate_repositoryr' r r* r r+ r2 r3 )rL rC r r, r- rR r0 r r r �repository_create� s ����r� c C sl t ||�}z|jj| d�}|�dd�W S tjy Y dS tjy5 } z td�| |j |j ���d}~ww )z� .. versionadded:: 2017.7.0 Delete existing repository. name Repository name CLI Example: .. code-block:: bash salt myminion elasticsearch.repository_delete testrepo �r� rM FTzDCannot delete repository {}, server returned code {} with message {}N) r/ r� Zdelete_repositoryr' r rU r* r r+ r2 r3 r� r r r �repository_delete� s ����r� c C s` t ||�}z|jj| d�W S tjy Y dS tjy/ } z td�| |j|j ���d}~ww )a .. versionadded:: 2017.7.0 Obtain list of cluster nodes which successfully verified this repository. name Repository name CLI Example: .. code-block:: bash salt myminion elasticsearch.repository_verify testrepo r� NzDCannot verify repository {}, server returned code {} with message {}) r/ r� Zverify_repositoryr rU r* r r+ r2 r3 r� r r r �repository_verify� s ����r� c C r: )aw .. versionadded:: 2017.7.0 Obtain status of all currently running snapshots. repository Particular repository to look for snapshots snapshot Snapshot name ignore_unavailable Ignore unavailable snapshots CLI Example: .. code-block:: bash salt myminion elasticsearch.snapshot_status ignore_unavailable=True �r� r� rx zFCannot obtain snapshot status, server returned code {} with message {}N) r/ r� �statusr r* r r+ r2 r3 �r� r� rx r r, r- r0 r r r �snapshot_status� s �����r� c C sR t ||�}z |jj| ||d�W S tjy( } z td�|| |j|j���d}~ww )a� .. versionadded:: 2017.7.0 Obtain snapshot residing in specified repository. repository Repository name snapshot Snapshot name, use _all to obtain all snapshots in specified repository ignore_unavailable Ignore unavailable snapshots CLI Example: .. code-block:: bash salt myminion elasticsearch.snapshot_get testrepo testsnapshot r� z^Cannot obtain details of snapshot {} in repository {}, server returned code {} with message {}N) r/ r� r' r r* r r+ r2 r3 r� r r r � snapshot_get s � ����r� c C �^ t ||�}z|jj| ||d�}|�dd�W S tjy. } z td�|| |j|j ���d}~ww )a .. versionadded:: 2017.7.0 Create snapshot in specified repository by supplied definition. repository Repository name snapshot Snapshot name body Snapshot definition as in https://www.elastic.co/guide/en/elasticsearch/reference/current/modules-snapshots.html CLI Example: .. code-block:: bash salt myminion elasticsearch.snapshot_create testrepo testsnapshot '{"indices":"index_1,index_2","ignore_unavailable":true,"include_global_state":false}' �r� r� rC �acceptedFzSCannot create snapshot {} in repository {}, server returned code {} with message {}N) r/ r� rh r' r r* r r+ r2 r3 �r� r� rC r r, r- �responser0 r r r �snapshot_create> � ����r� c C r� )a .. versionadded:: 2017.7.0 Restore existing snapshot in specified repository by supplied definition. repository Repository name snapshot Snapshot name body Restore definition as in https://www.elastic.co/guide/en/elasticsearch/reference/current/modules-snapshots.html CLI Example: .. code-block:: bash salt myminion elasticsearch.snapshot_restore testrepo testsnapshot '{"indices":"index_1,index_2","ignore_unavailable":true,"include_global_state":true}' r� r� FzTCannot restore snapshot {} in repository {}, server returned code {} with message {}N) r/ r� Zrestorer' r r* r r+ r2 r3 r� r r r �snapshot_restore` r� r� c C sp t ||�}z|jj| |d�}|�dd�W S tjy Y dS tjy7 } z td�|| |j |j ���d}~ww )a .. versionadded:: 2017.7.0 Delete snapshot from specified repository. repository Repository name snapshot Snapshot name CLI Example: .. code-block:: bash salt myminion elasticsearch.snapshot_delete testrepo testsnapshot )r� r� rM FTzUCannot delete snapshot {} from repository {}, server returned code {} with message {}N) r/ r� r^ r' r rU r* r r+ r2 r3 )r� r� r r, r- rR r0 r r r �snapshot_delete� s ���r� c K sH t | |�}z|j�|�W S tjy# } z td�|j|j���d}~ww )ao .. versionadded:: 3000 Perform a normal flush, then add a generated unique marker (sync_id) to all shards. http://www.elastic.co/guide/en/elasticsearch/reference/current/indices-synced-flush.html index (Optional, string) A comma-separated list of index names; use _all or empty string for all indices. Defaults to '_all'. ignore_unavailable (Optional, boolean) If true, missing or closed indices are not included in the response. Defaults to false. allow_no_indices (Optional, boolean) If true, the request does not return an error if a wildcard expression or _all value retrieves only missing or closed indices. This parameter also applies to index aliases that point to a missing or closed index. expand_wildcards (Optional, string) Controls what kind of indices that wildcard expressions can expand to. Valid values are:: all - Expand to open and closed indices. open - Expand only to open indices. closed - Expand only to closed indices. none - Wildcard expressions are not accepted. The defaults settings for the above parameters depend on the API being used. CLI Example: .. code-block:: bash salt myminion elasticsearch.flush_synced index='index1,index2' ignore_unavailable=True allow_no_indices=True expand_wildcards='all' z<Cannot flush synced, server returned code {} with message {}N) r/ rO � flush_syncedr r* r r+ r2 r3 )r r, r r- r0 r r r r� � s #����r� )NN)FNN)NFNN)Nr9 FNN)NNN)FFNN)NNNN)NNNNN)ra NN)Trs TNN)Try TNN)NNFNN)?�__doc__�loggingZsalt.exceptionsr r � getLoggerr �logr r �setLevel�CRITICALr � ImportErrorr r/ r1 r( r8 r> r? rB rF rS rW rY rZ r] r_ rf rg ri rl ro rr r{ r~ r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r r r r �<module> s� 2 � N � " # % $ � ( * �1 � / 7 D ' & �& � & " "
| ver. 1.4 |
Github
|
.
| PHP 8.2.30 | Generation time: 0 |
proxy
|
phpinfo
|
Settings