o gZh٫@sLddlZddlmZmZddlmZddlmZm Z m Z GdddeZ dS)N)HeadApiResponseObjectApiResponse)NamespacedClient) SKIP_IN_PATH_quote_rewrite_parametersc%@s eZdZeddddddddddddd dejedejedejejeej efdejed ejed ejed ejed ejed ejedeje de ej fddZ eddddddddejeej efdejedejejeej efdejedejejddefd ejedejejddefde ej fddZedddddddejedejejeej efdejed ejedejede ej f ddZeddddddddejeej efdejedejejeej efdejedejedejejddefd ejedefd d!Zedddddddddd" dejedejedejejeej efd#ejedejed$ejedejedejejddefd ejede ej fd%d&Zeddddddddd'dejedejejeej efd#ejedejed$ejedejejddefd ejedejejddefde ej fd(d)Zeddddddddddddddddd*d ejejeej efdejed+ejejej ejd,efejd,effdejejeej efdejed-ejejd.efdejedejejddefd ejedejejddefd/ejeje ejd0effd1ejejd2efd3ejed4ejed5ejeje efd6ejejd7efde ej f"d8d9Zeddddd:d;ejej ejdZeddddddddejedejejeej efdejedejedejejddefd ejede ej fd?d@ZeddddddddAdejedejejeej efdejedBejejeej efdCejejeej efd ejedejejddefde ej fdDdEZeddFdGidHddddddddddI dedJejeej fdKejedLejedejedejejeej efdejedejejddefdGejejeej fd ejedMeje de ej fdNdOZeddddddddddddP dejedejejeej efd#ejedejedejejddefdQejejeej fd ejedejejddefdRejejeej fde ej fdSdTZeddddd:dejedejejeej efdejed ejede ej f dUdVZeddddddddddddddW dXejej ejeej fdYejedejedZejedejejeej efdejedejejddefd[ejejeej efd ejed\ejedejejddefde ej fd]d^Zeddddddddddddddd_d[ejejeej efd ejejeej efd`ejedejed+ejejej ejd,efejd,effdejejeej efd#ejedejedaejedejedejejddefd ejedbeje dcejejddefde ej fdddeZeddddddddfdgejejeej efdejedejejeej efd#ejedejed ejedejejddefde ej fdhdiZdS)j ClusterClientT) body_fieldsN) current_node error_trace filter_pathhumaninclude_disk_infoinclude_yes_decisionsindexprettyprimaryshardr r r rrrrrrrreturnc Csd} i} i} |dur|| d<|dur|| d<|dur|| d<|dur&|| d<|dur.|| d<|dur6|| d<|dur>|| d <|durF|| d <| durN| | d <| durV| | d <| sZd} d di}| durfd|d<|jd| | || dS)a\ Provides explanations for shard allocations in the cluster. ``_ :param current_node: Specifies the node ID or the name of the node to only explain a shard that is currently located on the specified node. :param include_disk_info: If true, returns information about disk usage and shard sizes. :param include_yes_decisions: If true, returns YES decisions in explanation. :param index: Specifies the name of the index that you would like an explanation for. :param primary: If true, returns explanation for the primary shard for the given shard ID. :param shard: Specifies the ID of the shard that you would like an explanation for. z/_cluster/allocation/explainNr r r rrrrrrracceptapplication/json content-typePOSTparamsheadersbodyperform_request)selfr r r rrrrrrr_ClusterClient__path_ClusterClient__body_ClusterClient__query_ClusterClient__headersr%Y/var/www/html/lang_env/lib/python3.10/site-packages/elasticsearch/_sync/client/cluster.pyallocation_explains>" z ClusterClient.allocation_explain)r r rmaster_timeoutrtimeoutnamer(z t.Literal[-1]z t.Literal[0]r)c C|tvrtddt|}i} |dur|| d<|dur!|| d<|dur)|| d<|dur1|| d<|dur9|| d<|durA|| d <d d i} |jd || | d S)a Deletes a component template ``_ :param name: Comma-separated list or wildcard expression of component template names used to limit the request. :param master_timeout: Period to wait for a connection to the master node. If no response is received before the timeout expires, the request fails and returns an error. :param timeout: Period to wait for a response. If no response is received before the timeout expires, the request fails and returns an error. 'Empty value passed for parameter 'name'/_component_template/Nr r rr(rr)rrDELETErrr ValueErrorrr) r r*r r rr(rr)r!r#r$r%r%r&delete_component_template]s(z'ClusterClient.delete_component_template)r r rrwait_for_removalr3c Csrd}i}|dur ||d<|dur||d<|dur||d<|dur$||d<|dur,||d<dd i}|jd |||d S) a Clears cluster voting config exclusions. ``_ :param wait_for_removal: Specifies whether to wait for all excluded nodes to be removed from the cluster before clearing the voting configuration exclusions list. Defaults to true, meaning that all excluded nodes must be removed from the cluster before this API takes any action. If set to false then the voting configuration exclusions list is cleared even if some excluded nodes are still in the cluster. "/_cluster/voting_config_exclusionsNr r rrr3rrr.r/r) r r r rrr3r!r#r$r%r%r&delete_voting_config_exclusionss z-ClusterClient.delete_voting_config_exclusions)r r rlocalr(rr6c Cr+)a Returns information about whether a particular component template exist ``_ :param name: Comma-separated list of component template names used to limit the request. Wildcard (*) expressions are supported. :param local: If true, the request retrieves information from the local node only. Defaults to false, which means information is retrieved from the master node. :param master_timeout: Period to wait for a connection to the master node. If no response is received before the timeout expires, the request fails and returns an error. r,r-Nr r rr6r(rrrHEADr/r0) r r*r r rr6r(rr!r#r$r%r%r&exists_component_templates(z'ClusterClient.exists_component_template) r*r r flat_settingsrinclude_defaultsr6r(rr9r:c Cs|tvr dt|} nd} i} |dur|| d<|dur || d<|dur(|| d<|dur0|| d<|dur8|| d<|dur@|| d <|durH|| d <| durP| | d <d d i} |jd| | | dS)ao Returns one or more component templates ``_ :param name: Comma-separated list of component template names used to limit the request. Wildcard (`*`) expressions are supported. :param flat_settings: If `true`, returns settings in flat format. :param include_defaults: Return all default configurations for the component template (default: false) :param local: If `true`, the request retrieves information from the local node only. If `false`, information is retrieved from the master node. :param master_timeout: Period to wait for a connection to the master node. If no response is received before the timeout expires, the request fails and returns an error. r-z/_component_templateNr r r9rr:r6r(rrrGETr/rrr) r r*r r r9rr:r6r(rr!r#r$r%r%r&get_component_templates0 z$ClusterClient.get_component_template)r r r9rr:r(rr)c Csd} i} |dur || d<|dur|| d<|dur|| d<|dur$|| d<|dur,|| d<|dur4|| d<|dur<|| d <|durD|| d <d d i} |jd | | | dS)a Returns cluster settings. ``_ :param flat_settings: If `true`, returns settings in flat format. :param include_defaults: If `true`, returns default cluster settings from the local node. :param master_timeout: Period to wait for a connection to the master node. If no response is received before the timeout expires, the request fails and returns an error. :param timeout: Period to wait for a response. If no response is received before the timeout expires, the request fails and returns an error. /_cluster/settingsNr r r9rr:r(rr)rrr;r/r) r r r r9rr:r(rr)r!r#r$r%r%r& get_settingss,zClusterClient.get_settings)rr expand_wildcardsr rlevelr6r(rr)wait_for_active_shardswait_for_eventswait_for_no_initializing_shardswait_for_no_relocating_shardswait_for_nodeswait_for_statusr@z4t.Literal['all', 'closed', 'hidden', 'none', 'open']rAz)t.Literal['cluster', 'indices', 'shards']rBz!t.Literal['all', 'index-setting']rCzDt.Literal['high', 'immediate', 'languid', 'low', 'normal', 'urgent']rDrErFrGz#t.Literal['green', 'red', 'yellow']cCs*|tvr dt|}nd}i}|dur||d<|dur ||d<|dur(||d<|dur0||d<|dur8||d<|dur@||d <|durH||d <| durP| |d <| durX| |d <| dur`| |d <| durh| |d<| durp| |d<|durx||d<|dur||d<|dur||d<ddi}|jd|||dS)a Returns basic information about the health of the cluster. ``_ :param index: Comma-separated list of data streams, indices, and index aliases used to limit the request. Wildcard expressions (*) are supported. To target all data streams and indices in a cluster, omit this parameter or use _all or *. :param expand_wildcards: Whether to expand wildcard expression to concrete indices that are open, closed or both. :param level: Can be one of cluster, indices or shards. Controls the details level of the health information returned. :param local: If true, the request retrieves information from the local node only. Defaults to false, which means information is retrieved from the master node. :param master_timeout: Period to wait for a connection to the master node. If no response is received before the timeout expires, the request fails and returns an error. :param timeout: Period to wait for a response. If no response is received before the timeout expires, the request fails and returns an error. :param wait_for_active_shards: A number controlling to how many active shards to wait for, all to wait for all shards in the cluster to be active, or 0 to not wait. :param wait_for_events: Can be one of immediate, urgent, high, normal, low, languid. Wait until all currently queued events with the given priority are processed. :param wait_for_no_initializing_shards: A boolean value which controls whether to wait (until the timeout provided) for the cluster to have no shard initializations. Defaults to false, which means it will not wait for initializing shards. :param wait_for_no_relocating_shards: A boolean value which controls whether to wait (until the timeout provided) for the cluster to have no shard relocations. Defaults to false, which means it will not wait for relocating shards. :param wait_for_nodes: The request waits until the specified number N of nodes is available. It also accepts >=N, <=N, >N and yellow > red. By default, will not wait for any status. z/_cluster/health/z/_cluster/healthNr r@r rrAr6r(rr)rBrCrDrErFrGrrr;r/r<)r rr r@r rrAr6r(rr)rBrCrDrErFrGr!r#r$r%r%r&healthSsLPzClusterClient.health)r r rrtargetz`_ :param target: Limits the information returned to the specific target. Supports a comma-separated list, such as http,ingest. z)Empty value passed for parameter 'target'z/_info/Nr r rrrrr;r/r0) r rIr r rrr!r#r$r%r%r&infos zClusterClient.infoc Csd}i}|dur ||d<|dur||d<|dur||d<|dur$||d<|dur,||d<|dur4||d<d d i} |jd ||| d S) ar Returns a list of any cluster-level changes (e.g. create index, update mapping, allocate or fail shard) which have not yet been executed. ``_ :param local: If `true`, the request retrieves information from the local node only. If `false`, information is retrieved from the master node. :param master_timeout: Period to wait for a connection to the master node. If no response is received before the timeout expires, the request fails and returns an error. z/_cluster/pending_tasksNr r rr6r(rrrr;r/r) r r r rr6r(rr!r#r$r%r%r& pending_taskss$zClusterClient.pending_tasks)r r rnode_ids node_namesrr)rLrMc Csd}i} |dur || d<|dur|| d<|dur|| d<|dur$|| d<|dur,|| d<|dur4|| d<|dur<|| d <d d i} |jd || | d S)a{ Updates the cluster voting config exclusions by node ids or node names. ``_ :param node_ids: A comma-separated list of the persistent ids of the nodes to exclude from the voting configuration. If specified, you may not also specify node_names. :param node_names: A comma-separated list of the names of the nodes to exclude from the voting configuration. If specified, you may not also specify node_ids. :param timeout: When adding a voting configuration exclusion, the API waits for the specified nodes to be excluded from the voting configuration before returning. If the timeout expires before the appropriate condition is satisfied, the request fails and returns an error. r4Nr r rrLrMrr)rrrr/r) r r r rrLrMrr)r!r#r$r%r%r&post_voting_config_exclusions#s(z+ClusterClient.post_voting_config_exclusions_metameta)r Zparameter_aliases) allow_auto_createcreater r rr(rPrversiontemplaterQrRrSc Cs|tvrtd|durtddt|} i} i}|dur#|| d<|dur+|| d<|dur3||d<|dur;||d<|durC||d <|durK||d <|durS||d <| dur[| | d <| durc| |d <| durk| | d<ddd}|jd| ||| dS)uc Creates or updates a component template ``_ :param name: Name of the component template to create. Elasticsearch includes the following built-in component templates: `logs-mappings`; 'logs-settings`; `metrics-mappings`; `metrics-settings`;`synthetics-mapping`; `synthetics-settings`. Elastic Agent uses these templates to configure backing indices for its data streams. If you use Elastic Agent and want to overwrite one of these templates, set the `version` for your replacement template higher than the current version. If you don’t use Elastic Agent and want to disable all built-in component and index templates, set `stack.templates.enabled` to `false` using the cluster update settings API. :param template: The template to be applied which includes mappings, settings, or aliases configuration. :param allow_auto_create: This setting overrides the value of the `action.auto_create_index` cluster setting. If set to `true` in a template, then indices can be automatically created using that template even if auto-creation of indices is disabled via `actions.auto_create_index`. If set to `false` then data streams matching the template must always be explicitly created. :param create: If `true`, this request cannot replace or update existing component templates. :param master_timeout: Period to wait for a connection to the master node. If no response is received before the timeout expires, the request fails and returns an error. :param meta: Optional user metadata about the component template. May have any contents. This map is not automatically generated by Elasticsearch. This information is stored in the cluster state, so keeping it short is preferable. To unset `_meta`, replace the template without specifying this information. :param version: Version number used to manage component templates externally. This number isn't automatically generated or incremented by Elasticsearch. To unset a version, replace the template without specifying a version. r,Nz+Empty value passed for parameter 'template'r-rTrQrRr r rr(rOrrSrrrPUTrr0)r r*rTrQrRr r rr(rPrrSr!r"r#r$r%r%r&put_component_templateSs>7  z$ClusterClient.put_component_template) r r r9rr( persistentrr) transientrXrYc Csd} i} i} |dur|| d<|dur|| d<|dur|| d<|dur&|| d<|dur.|| d<|dur6|| d<|dur>|| d <|durF|| d <| durN| | d <d d d } |jd| | | | dS)a Updates the cluster settings. ``_ :param flat_settings: Return settings in flat format (default: false) :param master_timeout: Explicit operation timeout for connection to master node :param persistent: :param timeout: Explicit operation timeout :param transient: r>Nr r r9rr(rXrr)rYrrUrVrr)r r r r9rr(rXrr)rYr!r#r"r$r%r%r& put_settingss2  zClusterClient.put_settingscCsbd}i}|dur ||d<|dur||d<|dur||d<|dur$||d<ddi}|jd |||d S) z Returns the information about configured remote clusters. ``_ z /_remote/infoNr r rrrrr;r/r)r r r rrr!r#r$r%r%r& remote_infoszClusterClient.remote_info) commandsdry_runr explainr rr(metricr retry_failedr)r\r]r^r_r`c Csd} i} i}|dur|| d<|dur||d<|dur||d<|dur&||d<|dur.||d<|dur6||d<|dur>||d <|durF||d <| durN| |d <| durV| |d <| dur^| |d <| sbd} ddi}| durnd|d<|jd| ||| dS)aN Allows to manually change the allocation of individual shards in the cluster. ``_ :param commands: Defines the commands to perform. :param dry_run: If true, then the request simulates the operation only and returns the resulting state. :param explain: If true, then the response contains an explanation of why the commands can or cannot be executed. :param master_timeout: Period to wait for a connection to the master node. If no response is received before the timeout expires, the request fails and returns an error. :param metric: Limits the information returned to the specified metrics. :param retry_failed: If true, then retries allocation of shards that are blocked due to too many subsequent allocation failures. :param timeout: Period to wait for a response. If no response is received before the timeout expires, the request fails and returns an error. z/_cluster/rerouteNr\r]r r^r rr(r_rr`r)rrrrrr)r r\r]r r^r rr(r_rr`r)r!r"r#r$r%r%r&reroutesB' zClusterClient.reroute)r_rallow_no_indicesr r@r r9rignore_unavailabler6r(rwait_for_metadata_versionwait_for_timeoutrbrcrdrecCs<|tvr|tvrdt|dt|}n|tvr!dt|}n|tvr-dt|}nd}i}|dur9||d<|durA||d<|durI||d<|durQ||d <|durY||d <|dura||d <| duri| |d <| durq| |d <| dury| |d<| dur| |d<| dur| |d<|dur||d<ddi}|jd|||dS)a Returns a comprehensive information about the state of the cluster. ``_ :param metric: Limit the information returned to the specified metrics :param index: A comma-separated list of index names; use `_all` or empty string to perform the operation on all indices :param 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) :param expand_wildcards: Whether to expand wildcard expression to concrete indices that are open, closed or both. :param flat_settings: Return settings in flat format (default: false) :param ignore_unavailable: Whether specified concrete indices should be ignored when unavailable (missing or closed) :param local: Return local information, do not retrieve the state from master node (default: false) :param master_timeout: Specify timeout for connection to master :param wait_for_metadata_version: Wait for the metadata version to be equal or greater than the specified metadata version :param wait_for_timeout: The maximum time to wait for wait_for_metadata_version before timing out z/_cluster/state//z/_cluster/state/_all/z/_cluster/stateNrbr r@r r9rrcr6r(rrdrerrr;r/r<)r r_rrbr r@r r9rrcr6r(rrdrer!r#r$r%r%r&stateGsH6zClusterClient.state)node_idr r r9rrr)rhc Cs|tvr dt|}nd}i} |dur|| d<|dur || d<|dur(|| d<|dur0|| d<|dur8|| d<|dur@|| d <d d i} |jd || | d S)u Returns high-level overview of cluster statistics. ``_ :param node_id: Comma-separated list of node filters used to limit returned information. Defaults to all nodes in the cluster. :param flat_settings: If `true`, returns settings in flat format. :param timeout: Period to wait for each node to respond. If a node does not respond before its timeout expires, the response does not include its stats. However, timed out nodes are included in the response’s `_nodes.failed` property. Defaults to no timeout. z/_cluster/stats/nodes/z/_cluster/statsNr r r9rrr)rrr;r/r<) r rhr r r9rrr)r!r#r$r%r%r&statss(zClusterClient.stats)__name__ __module__ __qualname__rtOptionalstrboolUnionSequenceintrAnyr'r2r5rr8r=r?rHrJrKrNMappingrWrZr[rargrir%r%r%r&r s2     ?   / &  0    9   3    !"#$ ' w  +  +  /     S     4     F   [  r ) typingrmZelastic_transportrr_baserutilsrrrr r%r%r%r&s