text: from __future__ import unicode_literals
  import logging
  
  from ..transport import Transport
  from ..exceptions import TransportError
  from ..compat import string_types, urlparse, unquote
  from .indices import IndicesClient
  from .ingest import IngestClient
  from .cluster import ClusterClient
  from .cat import CatClient
  from .nodes import NodesClient
  from .remote import RemoteClient
  from .snapshot import SnapshotClient
  from .tasks import TasksClient
  from .xpack import XPackClient
  from .utils import query_params, _make_path, SKIP_IN_PATH
  
  logger = logging.getLogger("elasticsearch")
  
  
  def _normalize_hosts(hosts):
      """
      Helper function to transform hosts argument to
      :class:`~elasticsearch.Elasticsearch` to a list of dicts.
      """
      # if hosts are empty, just defer to defaults down the line
      if hosts is None:
          return [{}]
  
      # passed in just one string
      if isinstance(hosts, string_types):
          hosts = [hosts]
  
      out = []
      # normalize hosts to dicts
      for host in hosts:
          if isinstance(host, string_types):
              if "://" not in host:
                  host = "//%s" % host
  
              parsed_url = urlparse(host)
              h = {"host": parsed_url.hostname}
  
              if parsed_url.port:
                  h["port"] = parsed_url.port
  
              if parsed_url.scheme == "https":
                  h["port"] = parsed_url.port or 443
                  h["use_ssl"] = True
  
              if parsed_url.username or parsed_url.password:
                  h["http_auth"] = "%s:%s" % (
                      unquote(parsed_url.username),
                      unquote(parsed_url.password),
                  )
  
              if parsed_url.path and parsed_url.path != "/":
                  h["url_prefix"] = parsed_url.path
  
              out.append(h)
          else:
              out.append(host)
      return out
  
  
  class Elasticsearch(object):
      """
      Elasticsearch low-level client. Provides a straightforward mapping from
      Python to ES REST endpoints.
  
      The instance has attributes ``cat``, ``cluster``, ``indices``, ``ingest``,
      ``nodes``, ``snapshot`` and ``tasks`` that provide access to instances of
      :class:`~elasticsearch.client.CatClient`,
      :class:`~elasticsearch.client.ClusterClient`,
      :class:`~elasticsearch.client.IndicesClient`,
      :class:`~elasticsearch.client.IngestClient`,
      :class:`~elasticsearch.client.NodesClient`,
      :class:`~elasticsearch.client.SnapshotClient` and
      :class:`~elasticsearch.client.TasksClient` respectively. This is the
      preferred (and only supported) way to get access to those classes and their
      methods.
  
      You can specify your own connection class which should be used by providing
      the ``connection_class`` parameter::
  
          # create connection to localhost using the ThriftConnection
          es = Elasticsearch(connection_class=ThriftConnection)
  
      If you want to turn on :ref:`sniffing` you have several options (described
      in :class:`~elasticsearch.Transport`)::
  
          # create connection that will automatically inspect the cluster to get
          # the list of active nodes. Start with nodes running on 'esnode1' and
          # 'esnode2'
          es = Elasticsearch(
              ['esnode1', 'esnode2'],
              # sniff before doing anything
              sniff_on_start=True,
              # refresh nodes after a node fails to respond
              sniff_on_connection_fail=True,
              # and also every 60 seconds
              sniffer_timeout=60
          )
  
      Different hosts can have different parameters, use a dictionary per node to
      specify those::
  
          # connect to localhost directly and another node using SSL on port 443
          # and an url_prefix. Note that ``port`` needs to be an int.
          es = Elasticsearch([
              {'host': 'localhost'},
              {'host': 'othernode', 'port': 443, 'url_prefix': 'es', 'use_ssl': True},
          ])
  
      If using SSL, there are several parameters that control how we deal with
      certificates (see :class:`~elasticsearch.Urllib3HttpConnection` for
      detailed description of the options)::
  
          es = Elasticsearch(
              ['localhost:443', 'other_host:443'],
              # turn on SSL
              use_ssl=True,
              # make sure we verify SSL certificates
              verify_certs=True,
              # provide a path to CA certs on disk
              ca_certs='/path/to/CA_certs'
          )
  
      If using SSL, but don't verify the certs, a warning message is showed
      optionally (see :class:`~elasticsearch.Urllib3HttpConnection` for
      detailed description of the options)::
  
          es = Elasticsearch(
              ['localhost:443', 'other_host:443'],
              # turn on SSL
              use_ssl=True,
              # no verify SSL certificates
              verify_certs=False,
              # don't show warnings about ssl certs verification
              ssl_show_warn=False
          )
  
      SSL client authentication is supported
      (see :class:`~elasticsearch.Urllib3HttpConnection` for
      detailed description of the options)::
  
          es = Elasticsearch(
              ['localhost:443', 'other_host:443'],
              # turn on SSL
              use_ssl=True,
              # make sure we verify SSL certificates
              verify_certs=True,
              # provide a path to CA certs on disk
              ca_certs='/path/to/CA_certs',
              # PEM formatted SSL client certificate
              client_cert='/path/to/clientcert.pem',
              # PEM formatted SSL client key
              client_key='/path/to/clientkey.pem'
          )
  
      Alternatively you can use RFC-1738 formatted URLs, as long as they are not
      in conflict with other options::
  
          es = Elasticsearch(
              [
                  'http://user:secret@localhost:9200/',
                  'https://user:secret@other_host:443/production'
              ],
              verify_certs=True
          )
  
      By default, `JSONSerializer
      <https://github.com/elastic/elasticsearch-py/blob/master/elasticsearch/serializer.py#L24>`_
      is used to encode all outgoing requests.
      However, you can implement your own custom serializer::
  
          from elasticsearch.serializer import JSONSerializer
  
          class SetEncoder(JSONSerializer):
              def default(self, obj):
                  if isinstance(obj, set):
                      return list(obj)
                  if isinstance(obj, Something):
                      return 'CustomSomethingRepresentation'
                  return JSONSerializer.default(self, obj)
  
          es = Elasticsearch(serializer=SetEncoder())
  
      """
  
      def __init__(self, hosts=None, transport_class=Transport, **kwargs):
          """
          :arg hosts: list of nodes we should connect to. Node should be a
              dictionary ({"host": "localhost", "port": 9200}), the entire dictionary
              will be passed to the :class:`~elasticsearch.Connection` class as
              kwargs, or a string in the format of ``host[:port]`` which will be
              translated to a dictionary automatically.  If no value is given the
              :class:`~elasticsearch.Urllib3HttpConnection` class defaults will be used.
  
          :arg transport_class: :class:`~elasticsearch.Transport` subclass to use.
  
          :arg kwargs: any additional arguments will be passed on to the
              :class:`~elasticsearch.Transport` class and, subsequently, to the
              :class:`~elasticsearch.Connection` instances.
          """
          self.transport = transport_class(_normalize_hosts(hosts), **kwargs)
  
          # namespaced clients for compatibility with API names
          self.indices = IndicesClient(self)
          self.ingest = IngestClient(self)
          self.cluster = ClusterClient(self)
          self.cat = CatClient(self)
          self.nodes = NodesClient(self)
          self.remote = RemoteClient(self)
          self.snapshot = SnapshotClient(self)
          self.tasks = TasksClient(self)
          self.xpack = XPackClient(self)
  
      def __repr__(self):
          try:
              # get a list of all connections
              cons = self.transport.hosts
              # truncate to 5 if there are too many
              if len(cons) > 5:
                  cons = cons[:5] + ["..."]
              return "<{cls}({cons})>".format(cls=self.__class__.__name__, cons=cons)
          except:
              # probably operating on custom transport and connection_pool, ignore
              return super(Elasticsearch, self).__repr__()
  
      def _bulk_body(self, body):
          # if not passed in a string, serialize items and join by newline
          if not isinstance(body, string_types):
              body = "\n".join(map(self.transport.serializer.dumps, body))
  
          # bulk body must end with a newline
          if not body.endswith("\n"):
              body += "\n"
  
          return body
  
      @query_params()
      def ping(self, params=None):
          """
          Returns True if the cluster is up, False otherwise.
          `<http://www.elastic.co/guide/>`_
          """
          try:
              return self.transport.perform_request("HEAD", "/", params=params)
          except TransportError:
              return False
  
      @query_params()
      def info(self, params=None):
          """
          Get the basic info from the current cluster.
          `<http://www.elastic.co/guide/>`_
          """
          return self.transport.perform_request("GET", "/", params=params)
  
      @query_params(
          "parent",
          "pipeline",
          "refresh",
          "routing",
          "timeout",
          "timestamp",
          "ttl",
          "version",
          "version_type",
          "wait_for_active_shards",
      )
      def create(self, index, id, body, doc_type="_doc", params=None):
          """
          Adds a typed JSON document in a specific index, making it searchable.
          Behind the scenes this method calls index(..., op_type='create')
          `<http://www.elastic.co/guide/en/elasticsearch/reference/current/docs-index_.html>`_
  
          :arg index: The name of the index
          :arg id: Document ID
          :arg body: The document
          :arg parent: ID of the parent document
          :arg pipeline: The pipeline id to preprocess incoming documents with
          :arg refresh: If `true` then refresh the affected shards to make this
              operation visible to search, if `wait_for` then wait for a refresh
              to make this operation visible to search, if `false` (the default)
              then do nothing with refreshes., valid choices are: 'true', 'false',
              'wait_for'
          :arg routing: Specific routing value
          :arg timeout: Explicit operation timeout
          :arg timestamp: Explicit timestamp for the document
          :arg ttl: Expiration time for the document
          :arg version: Explicit version number for concurrency control
          :arg version_type: Specific version type, valid choices are: 'internal',
              'external', 'external_gte', 'force'
          :arg wait_for_active_shards: Sets the number of shard copies that must
              be active before proceeding with the index operation. Defaults to 1,
              meaning the primary shard only. Set to `all` for all shard copies,
              otherwise set to any non-negative value less than or equal to the
              total number of copies for the shard (number of replicas + 1)
          """
          for param in (index, id, body):
              if param in SKIP_IN_PATH:
                  raise ValueError("Empty value passed for a required argument.")
          return self.transport.perform_request(
              "PUT", _make_path(index, doc_type, id, "_create"), params=params, body=body
          )
  
      @query_params(
          "if_seq_no",
          "if_primary_term",
          "op_type",
          "parent",
          "pipeline",
          "refresh",
          "routing",
          "timeout",
          "timestamp",
          "ttl",
          "version",
          "version_type",
          "wait_for_active_shards",
      )
      def index(self, index, body, doc_type="_doc", id=None, params=None):
          """
          Adds or updates a typed JSON document in a specific index, making it searchable.
          `<http://www.elastic.co/guide/en/elasticsearch/reference/current/docs-index_.html>`_
  
          :arg index: The name of the index
          :arg body: The document
          :arg id: Document ID
          :arg if_primary_term: only perform the index operation if the last
              operation that has changed the document has the specified primary
              term
          :arg if_seq_no: only perform the index operation if the last operation
              that has changed the document has the specified sequence number
          :arg doc_type: Document type, defaults to `_doc`. Not used on ES 7 clusters.
          :arg op_type: Explicit operation type, default 'index', valid choices
              are: 'index', 'create'
          :arg parent: ID of the parent document
          :arg pipeline: The pipeline id to preprocess incoming documents with
          :arg refresh: If `true` then refresh the affected shards to make this
              operation visible to search, if `wait_for` then wait for a refresh
              to make this operation visible to search, if `false` (the default)
              then do nothing with refreshes., valid choices are: 'true', 'false',
              'wait_for'
          :arg routing: Specific routing value
          :arg timeout: Explicit operation timeout
          :arg timestamp: Explicit timestamp for the document
          :arg ttl: Expiration time for the document
          :arg version: Explicit version number for concurrency control
          :arg version_type: Specific version type, valid choices are: 'internal',
              'external', 'external_gte', 'force'
          :arg wait_for_active_shards: Sets the number of shard copies that must
              be active before proceeding with the index operation. Defaults to 1,
              meaning the primary shard only. Set to `all` for all shard copies,
              otherwise set to any non-negative value less than or equal to the
              total number of copies for the shard (number of replicas + 1)
          """
          for param in (index, body):
              if param in SKIP_IN_PATH:
                  raise ValueError("Empty value passed for a required argument.")
          return self.transport.perform_request(
              "POST", _make_path(index, doc_type, id), params=params, body=body
          )
  
      @query_params(
          "_source",
          "_source_excludes",
          "_source_includes",
          "parent",
          "preference",
          "realtime",
          "refresh",
          "routing",
          "stored_fields",
          "version",
          "version_type",
      )
      def exists(self, index, id, doc_type="_doc", params=None):
          """
          Returns a boolean indicating whether or not given document exists in Elasticsearch.
          `<http://www.elastic.co/guide/en/elasticsearch/reference/current/docs-get.html>`_
  
          :arg index: The name of the index
          :arg id: The document ID
          :arg _source: True or false to return the _source field or not, or a
              list of fields to return
          :arg _source_excludes: A list of fields to exclude from the returned
              _source field
          :arg _source_includes: A list of fields to extract and return from the
              _source field
          :arg parent: The ID of the parent document
          :arg preference: Specify the node or shard the operation should be
              performed on (default: random)
          :arg realtime: Specify whether to perform the operation in realtime or
              search mode
          :arg refresh: Refresh the shard containing the document before
              performing the operation
          :arg routing: Specific routing value
          :arg stored_fields: A comma-separated list of stored fields to return in
              the response
          :arg version: Explicit version number for concurrency control
          :arg version_type: Specific version type, valid choices are: 'internal',
              'external', 'external_gte', 'force'
          """
          for param in (index, id):
              if param in SKIP_IN_PATH:
                  raise ValueError("Empty value passed for a required argument.")
          return self.transport.perform_request(
              "HEAD", _make_path(index, doc_type, id), params=params
          )
  
      @query_params(
          "_source",
          "_source_excludes",
          "_source_includes",
          "parent",
          "preference",
          "realtime",
          "refresh",
          "routing",
          "version",
          "version_type",
      )
      def exists_source(self, index, id, doc_type=None, params=None):
          """
          `<http://www.elastic.co/guide/en/elasticsearch/reference/master/docs-get.html>`_
  
          :arg index: The name of the index
          :arg id: The document ID
          :arg _source: True or false to return the _source field or not, or a
              list of fields to return
          :arg _source_excludes: A list of fields to exclude from the returned
              _source field
          :arg _source_includes: A list of fields to extract and return from the
              _source field
          :arg parent: The ID of the parent document
          :arg preference: Specify the node or shard the operation should be
              performed on (default: random)
          :arg realtime: Specify whether to perform the operation in realtime or
              search mode
          :arg refresh: Refresh the shard containing the document before
              performing the operation
          :arg routing: Specific routing value
          :arg version: Explicit version number for concurrency control
          :arg version_type: Specific version type, valid choices are: 'internal',
              'external', 'external_gte', 'force'
          """
          for param in (index, id):
              if param in SKIP_IN_PATH:
                  raise ValueError("Empty value passed for a required argument.")
          return self.transport.perform_request(
              "HEAD", _make_path(index, doc_type, id, "_source"), params=params
          )
  
      @query_params(
          "_source",
          "_source_excludes",
          "_source_includes",
          "parent",
          "preference",
          "realtime",
          "refresh",
          "routing",
          "stored_fields",
          "version",
          "version_type",
      )
      def get(self, index, id, doc_type="_doc", params=None):
          """
          Get a typed JSON document from the index based on its id.
          `<http://www.elastic.co/guide/en/elasticsearch/reference/current/docs-get.html>`_
  
          :arg index: The name of the index
          :arg id: The document ID
          :arg _source: True or false to return the _source field or not, or a
              list of fields to return
          :arg _source_excludes: A list of fields to exclude from the returned
              _source field
          :arg _source_includes: A list of fields to extract and return from the
              _source field
          :arg parent: The ID of the parent document
          :arg preference: Specify the node or shard the operation should be
              performed on (default: random)
          :arg realtime: Specify whether to perform the operation in realtime or
              search mode
          :arg refresh: Refresh the shard containing the document before
              performing the operation
          :arg routing: Specific routing value
          :arg stored_fields: A comma-separated list of stored fields to return in
              the response
          :arg version: Explicit version number for concurrency control
          :arg version_type: Specific version type, valid choices are: 'internal',
              'external', 'external_gte', 'force'
          """
          for param in (index, id):
              if param in SKIP_IN_PATH:
                  raise ValueError("Empty value passed for a required argument.")
          return self.transport.perform_request(
              "GET", _make_path(index, doc_type, id), params=params
          )
  
      @query_params(
          "_source",
          "_source_excludes",
          "_source_includes",
          "parent",
          "preference",
          "realtime",
          "refresh",
          "routing",
          "version",
          "version_type",
      )
      def get_source(self, index, id, doc_type="_doc", params=None):
          """
          Get the source of a document by it's index, type and id.
          `<http://www.elastic.co/guide/en/elasticsearch/reference/current/docs-get.html>`_
  
          :arg index: The name of the index
          :arg id: The document ID
          :arg _source: True or false to return the _source field or not, or a
              list of fields to return
          :arg _source_excludes: A list of fields to exclude from the returned
              _source field
          :arg _source_includes: A list of fields to extract and return from the
              _source field
          :arg parent: The ID of the parent document
          :arg preference: Specify the node or shard the operation should be
              performed on (default: random)
          :arg realtime: Specify whether to perform the operation in realtime or
              search mode
          :arg refresh: Refresh the shard containing the document before
              performing the operation
          :arg routing: Specific routing value
          :arg version: Explicit version number for concurrency control
          :arg version_type: Specific version type, valid choices are: 'internal',
              'external', 'external_gte', 'force'
          """
          for param in (index, id):
              if param in SKIP_IN_PATH:
                  raise ValueError("Empty value passed for a required argument.")
          return self.transport.perform_request(
              "GET", _make_path(index, doc_type, id, "_source"), params=params
          )
  
      @query_params(
          "_source",
          "_source_excludes",
          "_source_includes",
          "preference",
          "realtime",
          "refresh",
          "routing",
          "stored_fields",
      )
      def mget(self, body, doc_type=None, index=None, params=None):
          """
          Get multiple documents based on an index, type (optional) and ids.
          `<http://www.elastic.co/guide/en/elasticsearch/reference/current/docs-multi-get.html>`_
  
          :arg body: Document identifiers; can be either `docs` (containing full
              document information) or `ids` (when index and type is provided in
              the URL.
          :arg index: The name of the index
          :arg _source: True or false to return the _source field or not, or a
              list of fields to return
          :arg _source_excludes: A list of fields to exclude from the returned
              _source field
          :arg _source_includes: A list of fields to extract and return from the
              _source field
          :arg preference: Specify the node or shard the operation should be
              performed on (default: random)
          :arg realtime: Specify whether to perform the operation in realtime or
              search mode
          :arg refresh: Refresh the shard containing the document before
              performing the operation
          :arg routing: Specific routing value
          :arg stored_fields: A comma-separated list of stored fields to return in
              the response
          """
          if body in SKIP_IN_PATH:
              raise ValueError("Empty value passed for a required argument 'body'.")
          return self.transport.perform_request(
              "GET", _make_path(index, doc_type, "_mget"), params=params, body=body
          )
  
      @query_params(
          "_source",
          "_source_excludes",
          "_source_includes",
          "fields",
          "if_seq_no",
          "if_primary_term",
          "lang",
          "parent",
          "refresh",
          "retry_on_conflict",
          "routing",
          "timeout",
          "timestamp",
          "ttl",
          "version",
          "version_type",
          "wait_for_active_shards",
      )
      def update(self, index, id, doc_type="_doc", body=None, params=None):
          """
          Update a document based on a script or partial data provided.
          `<http://www.elastic.co/guide/en/elasticsearch/reference/current/docs-update.html>`_
  
          :arg index: The name of the index
          :arg id: Document ID
          :arg body: The request definition using either `script` or partial `doc`
          :arg _source: True or false to return the _source field or not, or a
              list of fields to return
          :arg _source_excludes: A list of fields to exclude from the returned
              _source field
          :arg _source_includes: A list of fields to extract and return from the
              _source field
          :arg fields: A comma-separated list of fields to return in the response
          :arg if_seq_no:
          :arg if_primary_term:
          :arg lang: The script language (default: painless)
          :arg parent: ID of the parent document. Is is only used for routing and
              when for the upsert request
          :arg refresh: If `true` then refresh the effected shards to make this
              operation visible to search, if `wait_for` then wait for a refresh
              to make this operation visible to search, if `false` (the default)
              then do nothing with refreshes., valid choices are: 'true', 'false',
              'wait_for'
  	:arg retry_on_conflict: Specify how many times should the operation be
              retried when a conflict occurs (default: 0)
          :arg routing: Specific routing value
          :arg timeout: Explicit operation timeout
          :arg timestamp: Explicit timestamp for the document
          :arg ttl: Expiration time for the document
          :arg version: Explicit version number for concurrency control
          :arg version_type: Specific version type, valid choices are: 'internal',
              'force'
          :arg wait_for_active_shards: Sets the number of shard copies that must
              be active before proceeding with the update operation. Defaults to
              1, meaning the primary shard only. Set to `all` for all shard
              copies, otherwise set to any non-negative value less than or equal
              to the total number of copies for the shard (number of replicas + 1)
          """
          for param in (index, id):
              if param in SKIP_IN_PATH:
                  raise ValueError("Empty value passed for a required argument.")
          return self.transport.perform_request(
              "POST", _make_path(index, doc_type, id, "_update"), params=params, body=body
          )
  
      @query_params(
          "_source",
          "_source_excludes",
          "_source_includes",
          "allow_no_indices",
          "allow_partial_search_results",
          "analyze_wildcard",
          "analyzer",
          "batched_reduce_size",
          "ccs_minimize_roundtrips",
          "default_operator",
          "df",
          "docvalue_fields",
          "expand_wildcards",
          "explain",
          "from_",
          "ignore_throttled",
          "ignore_unavailable",
          "lenient",
          "max_concurrent_shard_requests",
          "pre_filter_shard_size",
          "preference",
          "q",
          "rest_total_hits_as_int",
          "request_cache",
          "routing",
          "scroll",
          "search_type",
          "seq_no_primary_term",
          "size",
          "sort",
          "stats",
          "stored_fields",
          "suggest_field",
          "suggest_mode",
          "suggest_size",
          "suggest_text",
          "terminate_after",
          "timeout",
          "track_scores",
          "track_total_hits",
          "typed_keys",
          "version",
      )
      def search(self, index=None, body=None, params=None):
          """
          Execute a search query and get back search hits that match the query.
          `<http://www.elastic.co/guide/en/elasticsearch/reference/current/search-search.html>`_
  
          :arg index: A list of index names to search, or a string containing a
              comma-separated list of index names to search; use `_all`
              or empty string to perform the operation on all indices
          :arg body: The search definition using the Query DSL
          :arg _source: True or false to return the _source field or not, or a
              list of fields to return
          :arg _source_excludes: A list of fields to exclude from the returned
              _source field
          :arg _source_includes: A list of fields to extract and return from the
              _source field
          :arg 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)
          :arg allow_partial_search_results: Set to false to return an overall
              failure if the request would produce partial results. Defaults to
              True, which will allow partial results in the case of timeouts or
              partial failures
          :arg analyze_wildcard: Specify whether wildcard and prefix queries
              should be analyzed (default: false)
          :arg analyzer: The analyzer to use for the query string
          :arg batched_reduce_size: The number of shard results that should be
              reduced at once on the coordinating node. This value should be used
              as a protection mechanism to reduce the memory overhead per search
              request if the potential number of shards in the request can be
              large., default 512
          :arg ccs_minimize_roundtrips: Indicates whether network round-trips
              should be minimized as part of cross-cluster search requests
              execution, default 'true'
          :arg default_operator: The default operator for query string query (AND
              or OR), default 'OR', valid choices are: 'AND', 'OR'
          :arg df: The field to use as default where no field prefix is given in
              the query string
          :arg docvalue_fields: A comma-separated list of fields to return as the
              docvalue representation of a field for each hit
          :arg 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'
          :arg explain: Specify whether to return detailed information about score
              computation as part of a hit
          :arg from\\_: Starting offset (default: 0)
          :arg ignore_unavailable: Whether specified concrete indices should be
              ignored when unavailable (missing or closed)
          :arg lenient: Specify whether format-based query failures (such as
              providing text to a numeric field) should be ignored
          :arg max_concurrent_shard_requests: The number of concurrent shard
              requests this search executes concurrently. This value should be
              used to limit the impact of the search on the cluster in order to
              limit the number of concurrent shard requests, default 'The default
              grows with the number of nodes in the cluster but is at most 256.'
          :arg pre_filter_shard_size: A threshold that enforces a pre-filter
              roundtrip to prefilter search shards based on query rewriting if
              the number of shards the search request expands to exceeds the
              threshold. This filter roundtrip can limit the number of shards
              significantly if for instance a shard can not match any documents
              based on it's rewrite method ie. if date filters are mandatory to
              match but the shard bounds and the query are disjoint., default 128
          :arg preference: Specify the node or shard the operation should be
              performed on (default: random)
          :arg q: Query in the Lucene query string syntax
          :arg rest_total_hits_as_int: This parameter is used to restore the total hits as a number
              in the response. This param is added version 6.x to handle mixed cluster queries where nodes
              are in multiple versions (7.0 and 6.latest)
          :arg request_cache: Specify if request cache should be used for this
              request or not, defaults to index level setting
          :arg routing: A comma-separated list of specific routing values
          :arg scroll: Specify how long a consistent view of the index should be
              maintained for scrolled search
          :arg search_type: Search operation type, valid choices are:
              'query_then_fetch', 'dfs_query_then_fetch'
          :arg size: Number of hits to return (default: 10)
          :arg sort: A comma-separated list of <field>:<direction> pairs
          :arg stats: Specific 'tag' of the request for logging and statistical
              purposes
          :arg stored_fields: A comma-separated list of stored fields to return as
              part of a hit
          :arg suggest_field: Specify which field to use for suggestions
          :arg suggest_mode: Specify suggest mode, default 'missing', valid
              choices are: 'missing', 'popular', 'always'
          :arg suggest_size: How many suggestions to return in response
          :arg suggest_text: The source text for which the suggestions should be
              returned
          :arg terminate_after: The maximum number of documents to collect for
              each shard, upon reaching which the query execution will terminate
              early.
          :arg timeout: Explicit operation timeout
          :arg track_scores: Whether to calculate and return scores even if they
              are not used for sorting
          :arg track_total_hits: Indicate if the number of documents that match
              the query should be tracked
          :arg typed_keys: Specify whether aggregation and suggester names should
              be prefixed by their respective types in the response
          :arg version: Specify whether to return document version as part of a
              hit
          """
          # from is a reserved word so it cannot be used, use from_ instead
          if "from_" in params:
              params["from"] = params.pop("from_")
  
          if not index:
              index = "_all"
          return self.transport.perform_request(
              "GET", _make_path(index, "_search"), params=params, body=body
          )
  
      @query_params(
          "_source",
          "_source_excludes",
          "_source_includes",
          "allow_no_indices",
          "analyze_wildcard",
          "analyzer",
          "conflicts",
          "default_operator",
          "df",
          "expand_wildcards",
          "from_",
          "ignore_unavailable",
          "lenient",
          "pipeline",
          "preference",
          "q",
          "refresh",
          "request_cache",
          "requests_per_second",
          "routing",
          "scroll",
          "scroll_size",
          "search_timeout",
          "search_type",
          "size",
          "slices",
          "sort",
          "stats",
          "terminate_after",
          "timeout",
          "version",
          "version_type",
          "wait_for_active_shards",
          "wait_for_completion",
      )
      def update_by_query(self, index, body=None, params=None):
          """
          Perform an update on all documents matching a query.
          `<https://www.elastic.co/guide/en/elasticsearch/reference/current/docs-update-by-query.html>`_
  
          :arg index: A list of index names to search, or a string containing a
              comma-separated list of index names to search; use `_all` or the
              empty string to perform the operation on all indices
          :arg body: The search definition using the Query DSL
          :arg _source: True or false to return the _source field or not, or a
              list of fields to return
          :arg _source_excludes: A list of fields to exclude from the returned
              _source field
          :arg _source_includes: A list of fields to extract and return from the
              _source field
          :arg 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)
          :arg analyze_wildcard: Specify whether wildcard and prefix queries
              should be analyzed (default: false)
          :arg analyzer: The analyzer to use for the query string
          :arg conflicts: What to do when the update by query hits version
              conflicts?, default 'abort', valid choices are: 'abort', 'proceed'
          :arg default_operator: The default operator for query string query (AND
              or OR), default 'OR', valid choices are: 'AND', 'OR'
          :arg df: The field to use as default where no field prefix is given in
              the query string
          :arg 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'
          :arg from\\_: Starting offset (default: 0)
          :arg ignore_unavailable: Whether specified concrete indices should be
              ignored when unavailable (missing or closed)
          :arg lenient: Specify whether format-based query failures (such as
              providing text to a numeric field) should be ignored
          :arg pipeline: Ingest pipeline to set on index requests made by this
              action. (default: none)
          :arg preference: Specify the node or shard the operation should be
              performed on (default: random)
          :arg q: Query in the Lucene query string syntax
          :arg refresh: Should the effected indexes be refreshed?
          :arg request_cache: Specify if request cache should be used for this
              request or not, defaults to index level setting
          :arg requests_per_second: The throttle to set on this request in sub-
              requests per second. -1 means no throttle., default 0
          :arg routing: A comma-separated list of specific routing values
          :arg scroll: Specify how long a consistent view of the index should be
              maintained for scrolled search
          :arg scroll_size: Size on the scroll request powering the
              update_by_query
          :arg search_timeout: Explicit timeout for each search request. Defaults
              to no timeout.
          :arg search_type: Search operation type, valid choices are:
              'query_then_fetch', 'dfs_query_then_fetch'
          :arg size: Number of hits to return (default: 10)
          :arg slices: The number of slices this task should be divided into.
              Defaults to 1 meaning the task isn't sliced into subtasks., default
              1
          :arg sort: A comma-separated list of <field>:<direction> pairs
          :arg stats: Specific 'tag' of the request for logging and statistical
              purposes
          :arg terminate_after: The maximum number of documents to collect for
              each shard, upon reaching which the query execution will terminate
              early.
          :arg timeout: Time each individual bulk request should wait for shards
              that are unavailable., default '1m'
          :arg version: Specify whether to return document version as part of a
              hit
          :arg version_type: Should the document increment the version number
              (internal) on hit or not (reindex)
          :arg wait_for_active_shards: Sets the number of shard copies that must
              be active before proceeding with the update by query operation.
              Defaults to 1, meaning the primary shard only. Set to `all` for all
              shard copies, otherwise set to any non-negative value less than or
              equal to the total number of copies for the shard (number of
              replicas + 1)
          :arg wait_for_completion: Should the request should block until the
              update by query operation is complete., default True
          """
          if index in SKIP_IN_PATH:
              raise ValueError("Empty value passed for a required argument 'index'.")
          return self.transport.perform_request(
              "POST", _make_path(index, "_update_by_query"), params=params, body=body
          )
  
      @query_params("requests_per_second")
      def update_by_query_rethrottle(self, task_id, params=None):
          """
          `<https://www.elastic.co/guide/en/elasticsearch/reference/current/docs-update-by-query.html>`_
  
          :arg task_id: The task id to rethrottle
          :arg requests_per_second: The throttle to set on this request in
              floating sub-requests per second. -1 means set no throttle.
          """
          if task_id in SKIP_IN_PATH:
              raise ValueError("Empty value passed for a required argument 'task_id'.")
          return self.transport.perform_request(
              "POST",
              _make_path("_update_by_query", task_id, "_rethrottle"),
              params=params,
          )
  
      @query_params(
          "refresh",
          "requests_per_second",
          "slices",
          "scroll",
          "timeout",
          "wait_for_active_shards",
          "wait_for_completion",
      )
      def reindex(self, body, params=None):
          """
          Reindex all documents from one index to another.
          `<https://www.elastic.co/guide/en/elasticsearch/reference/current/docs-reindex.html>`_
  
          :arg body: The search definition using the Query DSL and the prototype
              for the index request.
          :arg refresh: Should the effected indexes be refreshed?
          :arg requests_per_second: The throttle to set on this request in sub-
              requests per second. -1 means no throttle., default 0
          :arg slices: The number of slices this task should be divided into.
              Defaults to 1 meaning the task isn't sliced into subtasks., default
              1
          :arg scroll: Control how long to keep the search context alive, default
              '5m'
          :arg timeout: Time each individual bulk request should wait for shards
              that are unavailable., default '1m'
          :arg wait_for_active_shards: Sets the number of shard copies that must
              be active before proceeding with the reindex operation. Defaults to
              1, meaning the primary shard only. Set to `all` for all shard
              copies, otherwise set to any non-negative value less than or equal
              to the total number of copies for the shard (number of replicas + 1)
          :arg wait_for_completion: Should the request should block until the
              reindex is complete., default True
          """
          if body in SKIP_IN_PATH:
              raise ValueError("Empty value passed for a required argument 'body'.")
          return self.transport.perform_request(
              "POST", "/_reindex", params=params, body=body
          )
  
      @query_params("requests_per_second")
      def reindex_rethrottle(self, task_id=None, params=None):
          """
          Change the value of ``requests_per_second`` of a running ``reindex`` task.
          `<https://www.elastic.co/guide/en/elasticsearch/reference/current/docs-reindex.html>`_
  
          :arg task_id: The task id to rethrottle
          :arg requests_per_second: The throttle to set on this request in
              floating sub-requests per second. -1 means set no throttle.
          """
          return self.transport.perform_request(
              "POST", _make_path("_reindex", task_id, "_rethrottle"), params=params
          )
  
      @query_params(
          "_source",
          "_source_excludes",
          "_source_includes",
          "allow_no_indices",
          "analyze_wildcard",
          "analyzer",
          "conflicts",
          "default_operator",
          "df",
          "expand_wildcards",
          "from_",
          "ignore_unavailable",
          "lenient",
          "preference",
          "q",
          "refresh",
          "request_cache",
          "requests_per_second",
          "routing",
          "scroll",
          "scroll_size",
          "search_timeout",
          "search_type",
          "size",
          "slices",
          "sort",
          "stats",
          "terminate_after",
          "timeout",
          "version",
          "wait_for_active_shards",
          "wait_for_completion",
      )
      def delete_by_query(self, index, body, params=None):
          """
          Delete all documents matching a query.
          `<https://www.elastic.co/guide/en/elasticsearch/reference/current/docs-delete-by-query.html>`_
  
          :arg index: A list of index names to search, or a string containing a
              comma-separated list of index names to search; use `_all` or the
              empty string to perform the operation on all indices
          :arg body: The search definition using the Query DSL
          :arg _source: True or false to return the _source field or not, or a
              list of fields to return
          :arg _source_excludes: A list of fields to exclude from the returned
              _source field
          :arg _source_includes: A list of fields to extract and return from the
              _source field
          :arg 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)
          :arg analyze_wildcard: Specify whether wildcard and prefix queries
              should be analyzed (default: false)
          :arg analyzer: The analyzer to use for the query string
          :arg conflicts: What to do when the delete-by-query hits version
              conflicts?, default 'abort', valid choices are: 'abort', 'proceed'
          :arg default_operator: The default operator for query string query (AND
              or OR), default 'OR', valid choices are: 'AND', 'OR'
          :arg df: The field to use as default where no field prefix is given in
              the query string
          :arg 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'
          :arg from\\_: Starting offset (default: 0)
          :arg ignore_unavailable: Whether specified concrete indices should be
              ignored when unavailable (missing or closed)
          :arg lenient: Specify whether format-based query failures (such as
              providing text to a numeric field) should be ignored
          :arg preference: Specify the node or shard the operation should be
              performed on (default: random)
          :arg q: Query in the Lucene query string syntax
          :arg refresh: Should the effected indexes be refreshed?
          :arg request_cache: Specify if request cache should be used for this
              request or not, defaults to index level setting
          :arg requests_per_second: The throttle for this request in sub-requests
              per second. -1 means no throttle., default 0
          :arg routing: A comma-separated list of specific routing values
          :arg scroll: Specify how long a consistent view of the index should be
              maintained for scrolled search
          :arg scroll_size: Size on the scroll request powering the
              update_by_query
          :arg search_timeout: Explicit timeout for each search request. Defaults
              to no timeout.
          :arg search_type: Search operation type, valid choices are:
              'query_then_fetch', 'dfs_query_then_fetch'
          :arg size: Number of hits to return (default: 10)
          :arg slices: The number of slices this task should be divided into.
              Defaults to 1 meaning the task isn't sliced into subtasks., default
              1
          :arg sort: A comma-separated list of <field>:<direction> pairs
          :arg stats: Specific 'tag' of the request for logging and statistical
              purposes
          :arg terminate_after: The maximum number of documents to collect for
              each shard, upon reaching which the query execution will terminate
              early.
          :arg timeout: Time each individual bulk request should wait for shards
              that are unavailable., default '1m'
          :arg version: Specify whether to return document version as part of a
              hit
          :arg wait_for_active_shards: Sets the number of shard copies that must
              be active before proceeding with the delete by query operation.
              Defaults to 1, meaning the primary shard only. Set to `all` for all
              shard copies, otherwise set to any non-negative value less than or
              equal to the total number of copies for the shard (number of
              replicas + 1)
          :arg wait_for_completion: Should the request should block until the
              delete-by-query is complete., default True
          """
          for param in (index, body):
              if param in SKIP_IN_PATH:
                  raise ValueError("Empty value passed for a required argument.")
          return self.transport.perform_request(
              "POST", _make_path(index, "_delete_by_query"), params=params, body=body
          )
  
      @query_params("requests_per_second")
      def delete_by_query_rethrottle(self, task_id, params=None):
          """
          `<https://www.elastic.co/guide/en/elasticsearch/reference/current/docs-delete-by-query.html>`_
  
          :arg task_id: The task id to rethrottle
          :arg requests_per_second: The throttle to set on this request in
              floating sub-requests per second. -1 means set no throttle.
          """
          if task_id in SKIP_IN_PATH:
              raise ValueError("Empty value passed for a required argument 'task_id'.")
          return self.transport.perform_request(
              "POST",
              _make_path("_delete_by_query", task_id, "_rethrottle"),
              params=params,
          )
  
      @query_params(
          "allow_no_indices",
          "expand_wildcards",
          "ignore_unavailable",
          "local",
          "preference",
          "routing",
      )
      def search_shards(self, index=None, params=None):
          """
          The search shards api returns the indices and shards that a search
          request would be executed against. This can give useful feedback for working
          out issues or planning optimizations with routing and shard preferences.
          `<http://www.elastic.co/guide/en/elasticsearch/reference/current/search-shards.html>`_
  
          :arg index: A list of index names to search, or a string containing a
              comma-separated list of index names to search; use `_all` or the
              empty string to perform the operation on all indices
          :arg 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)
          :arg 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'
          :arg ignore_unavailable: Whether specified concrete indices should be
              ignored when unavailable (missing or closed)
          :arg local: Return local information, do not retrieve the state from
              master node (default: false)
          :arg preference: Specify the node or shard the operation should be
              performed on (default: random)
          :arg routing: Specific routing value
          """
          return self.transport.perform_request(
              "GET", _make_path(index, "_search_shards"), params=params
          )
  
      @query_params(
          "allow_no_indices",
          "ccs_minimize_roundtrips",
          "expand_wildcards",
          "explain",
          "ignore_unavailable",
          "preference",
          "profile",
          "routing",
          "rest_total_hits_as_int",
          "scroll",
          "search_type",
          "typed_keys",
      )
      def search_template(self, index=None, body=None, params=None):
          """
          A query that accepts a query template and a map of key/value pairs to
          fill in template parameters.
          `<http://www.elastic.co/guide/en/elasticsearch/reference/current/search-template.html>`_
  
          :arg index: A list of index names to search, or a string containing a
              comma-separated list of index names to search; use `_all` or the
              empty string to perform the operation on all indices
          :arg body: The search definition template and its params
          :arg 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)
          :arg ccs_minimize_roundtrips: Indicates whether network round-trips
              should be minimized as part of cross-cluster search requests
              execution, default 'true'
          :arg 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'
          :arg explain: Specify whether to return detailed information about score
              computation as part of a hit
          :arg ignore_unavailable: Whether specified concrete indices should be
              ignored when unavailable (missing or closed)
          :arg preference: Specify the node or shard the operation should be
              performed on (default: random)
          :arg profile: Specify whether to profile the query execution
          :arg routing: A comma-separated list of specific routing values
          :arg rest_total_hits_as_int: Indicates whether hits.total should be
              rendered as an integer or an object in the rest search response,
              default False
          :arg scroll: Specify how long a consistent view of the index should be
              maintained for scrolled search
          :arg search_type: Search operation type, valid choices are:
              'query_then_fetch', 'query_and_fetch', 'dfs_query_then_fetch',
              'dfs_query_and_fetch'
          :arg typed_keys: Specify whether aggregation and suggester names should
              be prefixed by their respective types in the response
          """
          return self.transport.perform_request(
              "GET", _make_path(index, "_search", "template"), params=params, body=body
          )
  
      @query_params(
          "_source",
          "_source_excludes",
          "_source_includes",
          "analyze_wildcard",
          "analyzer",
          "default_operator",
          "df",
          "lenient",
          "parent",
          "preference",
          "q",
          "routing",
          "stored_fields",
      )
      def explain(self, index, id, doc_type="_doc", body=None, params=None):
          """
          The explain api computes a score explanation for a query and a specific
          document. This can give useful feedback whether a document matches or
          didn't match a specific query.
          `<http://www.elastic.co/guide/en/elasticsearch/reference/current/search-explain.html>`_
  
          :arg index: The name of the index
          :arg id: The document ID
          :arg body: The query definition using the Query DSL
          :arg _source: True or false to return the _source field or not, or a
              list of fields to return
          :arg _source_excludes: A list of fields to exclude from the returned
              _source field
          :arg _source_includes: A list of fields to extract and return from the
              _source field
          :arg analyze_wildcard: Specify whether wildcards and prefix queries in
              the query string query should be analyzed (default: false)
          :arg analyzer: The analyzer for the query string query
          :arg default_operator: The default operator for query string query (AND
              or OR), default 'OR', valid choices are: 'AND', 'OR'
          :arg df: The default field for query string query (default: _all)
          :arg lenient: Specify whether format-based query failures (such as
              providing text to a numeric field) should be ignored
          :arg parent: The ID of the parent document
          :arg preference: Specify the node or shard the operation should be
              performed on (default: random)
          :arg q: Query in the Lucene query string syntax
          :arg routing: Specific routing value
          :arg stored_fields: A comma-separated list of stored fields to return in
              the response
          """
          for param in (index, id):
              if param in SKIP_IN_PATH:
                  raise ValueError("Empty value passed for a required argument.")
          return self.transport.perform_request(
              "GET", _make_path(index, doc_type, id, "_explain"), params=params, body=body
          )
  
      @query_params("scroll", "rest_total_hits_as_int")
      def scroll(self, body=None, scroll_id=None, params=None):
          """
          Scroll a search request created by specifying the scroll parameter.
          `<http://www.elastic.co/guide/en/elasticsearch/reference/current/search-request-scroll.html>`_
  
          :arg scroll_id: The scroll ID
          :arg body: The scroll ID if not passed by URL or query parameter.
          :arg scroll: Specify how long a consistent view of the index should be
              maintained for scrolled search
          :arg rest_total_hits_as_int: This parameter is used to restore the total hits as a number
              in the response. This param is added version 6.x to handle mixed cluster queries where nodes
              are in multiple versions (7.0 and 6.latest)
          """
          if scroll_id in SKIP_IN_PATH and body in SKIP_IN_PATH:
              raise ValueError("You need to supply scroll_id or body.")
          elif scroll_id and not body:
              body = {"scroll_id": scroll_id}
          elif scroll_id:
              params["scroll_id"] = scroll_id
  
          return self.transport.perform_request(
              "GET", "/_search/scroll", params=params, body=body
          )
  
      @query_params()
      def clear_scroll(self, scroll_id=None, body=None, params=None):
          """
          Clear the scroll request created by specifying the scroll parameter to
          search.
          `<http://www.elastic.co/guide/en/elasticsearch/reference/current/search-request-scroll.html>`_
  
          :arg scroll_id: A comma-separated list of scroll IDs to clear
          :arg body: A comma-separated list of scroll IDs to clear if none was
              specified via the scroll_id parameter
          """
          if scroll_id in SKIP_IN_PATH and body in SKIP_IN_PATH:
              raise ValueError("You need to supply scroll_id or body.")
          elif scroll_id and not body:
              body = {"scroll_id": [scroll_id]}
          elif scroll_id:
              params["scroll_id"] = scroll_id
  
          return self.transport.perform_request(
              "DELETE", "/_search/scroll", params=params, body=body
          )
  
      @query_params(
          "if_seq_no",
          "if_primary_term",
          "parent",
          "refresh",
          "routing",
          "timeout",
          "version",
          "version_type",
          "wait_for_active_shards",
      )
      def delete(self, index, id, doc_type="_doc", params=None):
          """
          Delete a typed JSON document from a specific index based on its id.
          `<http://www.elastic.co/guide/en/elasticsearch/reference/current/docs-delete.html>`_
  
          :arg index: The name of the index
          :arg id: The document ID
          :arg if_primary_term: only perform the delete operation if the last
              operation that has changed the document has the specified primary
              term
          :arg if_seq_no: only perform the delete operation if the last operation
              that has changed the document has the specified sequence number
          :arg parent: ID of parent document
          :arg refresh: If `true` then refresh the effected shards to make this
              operation visible to search, if `wait_for` then wait for a refresh
              to make this operation visible to search, if `false` (the default)
              then do nothing with refreshes., valid choices are: 'true', 'false',
              'wait_for'
          :arg routing: Specific routing value
          :arg timeout: Explicit operation timeout
          :arg version: Explicit version number for concurrency control
          :arg version_type: Specific version type, valid choices are: 'internal',
              'external', 'external_gte', 'force'
          :arg wait_for_active_shards: Sets the number of shard copies that must
              be active before proceeding with the delete operation. Defaults to
              1, meaning the primary shard only. Set to `all` for all shard
              copies, otherwise set to any non-negative value less than or equal
              to the total number of copies for the shard (number of replicas + 1)
          """
          for param in (index, id):
              if param in SKIP_IN_PATH:
                  raise ValueError("Empty value passed for a required argument.")
          return self.transport.perform_request(
              "DELETE", _make_path(index, doc_type, id), params=params
          )
  
      @query_params(
          "allow_no_indices",
          "analyze_wildcard",
          "analyzer",
          "default_operator",
          "df",
          "expand_wildcards",
          "ignore_unavailable",
          "ignore_throttled",
          "lenient",
          "min_score",
          "preference",
          "q",
          "routing",
          "terminate_after",
      )
      def count(self, doc_type=None, index=None, body=None, params=None):
          """
          Execute a query and get the number of matches for that query.
          `<http://www.elastic.co/guide/en/elasticsearch/reference/current/search-count.html>`_
  
          :arg index: A list of index names or a string containing a
              comma-separated list of index names to restrict the results to
          :arg body: A query to restrict the results specified with the Query DSL
              (optional)
          :arg 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)
          :arg analyze_wildcard: Specify whether wildcard and prefix queries
              should be analyzed (default: false)
          :arg analyzer: The analyzer to use for the query string
          :arg default_operator: The default operator for query string query (AND
              or OR), default 'OR', valid choices are: 'AND', 'OR'
          :arg df: The field to use as default where no field prefix is given in
              the query string
          :arg 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'
          :arg ignore_unavailable: Whether specified concrete indices should be
              ignored when unavailable (missing or closed)
          :arg ignore_throttled: Whether specified concrete, expanded or aliased
              indices should be ignored when throttled
          :arg lenient: Specify whether format-based query failures (such as
              providing text to a numeric field) should be ignored
          :arg min_score: Include only documents with a specific `_score` value in
              the result
          :arg preference: Specify the node or shard the operation should be
              performed on (default: random)
          :arg q: Query in the Lucene query string syntax
          :arg routing: Specific routing value
          """
          if not index:
              index = "_all"
  
          return self.transport.perform_request(
              "GET", _make_path(index, doc_type, "_count"), params=params, body=body
          )
  
      @query_params(
          "_source",
          "_source_excludes",
          "_source_includes",
          "fields",
          "pipeline",
          "refresh",
          "routing",
          "timeout",
          "wait_for_active_shards",
      )
      def bulk(self, body, doc_type=None, index=None, params=None):
          """
          Perform many index/delete operations in a single API call.
  
          See the :func:`~elasticsearch.helpers.bulk` helper function for a more
          friendly API.
          `<http://www.elastic.co/guide/en/elasticsearch/reference/current/docs-bulk.html>`_
  
          :arg body: The operation definition and data (action-data pairs),
              separated by newlines
          :arg index: Default index for items which don't provide one
          :arg _source: True or false to return the _source field or not, or
              default list of fields to return, can be overridden on each sub-
              request
          :arg _source_excludes: Default list of fields to exclude from the
              returned _source field, can be overridden on each sub-request
          :arg _source_includes: Default list of fields to extract and return from
              the _source field, can be overridden on each sub-request
          :arg fields: Default comma-separated list of fields to return in the
              response for updates, can be overridden on each sub-request
          :arg pipeline: The pipeline id to preprocess incoming documents with
          :arg refresh: If `true` then refresh the effected shards to make this
              operation visible to search, if `wait_for` then wait for a refresh
              to make this operation visible to search, if `false` (the default)
              then do nothing with refreshes., valid choices are: 'true', 'false',
              'wait_for'
          :arg routing: Specific routing value
          :arg timeout: Explicit operation timeout
          :arg wait_for_active_shards: Sets the number of shard copies that must
              be active before proceeding with the bulk operation. Defaults to 1,
              meaning the primary shard only. Set to `all` for all shard copies,
              otherwise set to any non-negative value less than or equal to the
              total number of copies for the shard (number of replicas + 1)
          """
          if body in SKIP_IN_PATH:
              raise ValueError("Empty value passed for a required argument 'body'.")
          return self.transport.perform_request(
              "POST",
              _make_path(index, doc_type, "_bulk"),
              params=params,
              body=self._bulk_body(body),
              headers={"content-type": "application/x-ndjson"},
          )
  
      @query_params(
          "ccs_minimize_roundtrips",
          "max_concurrent_searches",
          "max_concurrent_shard_requests",
          "pre_filter_shard_size",
          "rest_total_hits_as_int",
          "search_type",
          "typed_keys",
      )
      def msearch(self, body, index=None, params=None):
          """
          Execute several search requests within the same API.
          `<http://www.elastic.co/guide/en/elasticsearch/reference/current/search-multi-search.html>`_
  
          :arg body: The request definitions (metadata-search request definition
              pairs), separated by newlines
          :arg index: A list of index names, or a string containing a
              comma-separated list of index names, to use as the default
          :arg ccs_minimize_roundtrips: Indicates whether network round-trips
              should be minimized as part of cross-cluster search requests
              execution, default 'true'
          :arg max_concurrent_searches: Controls the maximum number of concurrent
              searches the multi search api will execute
          :arg pre_filter_shard_size: A threshold that enforces a pre-filter
              roundtrip to prefilter search shards based on query rewriting if
              the number of shards the search request expands to exceeds the
              threshold. This filter roundtrip can limit the number of shards
              significantly if for instance a shard can not match any documents
              based on it's rewrite method ie. if date filters are mandatory to
              match but the shard bounds and the query are disjoint., default 128
          :arg search_type: Search operation type, valid choices are:
              'query_then_fetch', 'query_and_fetch', 'dfs_query_then_fetch',
              'dfs_query_and_fetch'
          :arg typed_keys: Specify whether aggregation and suggester names should
              be prefixed by their respective types in the response
          """
          if body in SKIP_IN_PATH:
              raise ValueError("Empty value passed for a required argument 'body'.")
          return self.transport.perform_request(
              "GET",
              _make_path(index, "_msearch"),
              params=params,
              body=self._bulk_body(body),
              headers={"content-type": "application/x-ndjson"},
          )
  
      @query_params(
          "field_statistics",
          "fields",
          "offsets",
          "parent",
          "payloads",
          "positions",
          "preference",
          "realtime",
          "routing",
          "term_statistics",
          "version",
          "version_type",
      )
      def termvectors(self, index, doc_type="_doc", id=None, body=None, params=None):
          """
          Returns information and statistics on terms in the fields of a
          particular document. The document could be stored in the index or
          artificially provided by the user (Added in 1.4). Note that for
          documents stored in the index, this is a near realtime API as the term
          vectors are not available until the next refresh.
          `<http://www.elastic.co/guide/en/elasticsearch/reference/current/docs-termvectors.html>`_
  
          :arg index: The index in which the document resides.
          :arg id: The id of the document, when not specified a doc param should
              be supplied.
          :arg body: Define parameters and or supply a document to get termvectors
              for. See documentation.
          :arg field_statistics: Specifies if document count, sum of document
              frequencies and sum of total term frequencies should be returned.,
              default True
          :arg fields: A comma-separated list of fields to return.
          :arg offsets: Specifies if term offsets should be returned., default
              True
          :arg parent: Parent id of documents.
          :arg payloads: Specifies if term payloads should be returned., default
              True
          :arg positions: Specifies if term positions should be returned., default
              True
          :arg preference: Specify the node or shard the operation should be
              performed on (default: random).
          :arg realtime: Specifies if request is real-time as opposed to near-
              real-time (default: true).
          :arg routing: Specific routing value.
          :arg term_statistics: Specifies if total term frequency and document
              frequency should be returned., default False
          :arg version: Explicit version number for concurrency control
          :arg version_type: Specific version type, valid choices are: 'internal',
              'external', 'external_gte', 'force'
          """
          for param in (index,):
              if param in SKIP_IN_PATH:
                  raise ValueError("Empty value passed for a required argument.")
          return self.transport.perform_request(
              "GET",
              _make_path(index, doc_type, id, "_termvectors"),
              params=params,
              body=body,
          )
  
      @query_params(
          "field_statistics",
          "fields",
          "ids",
          "offsets",
          "parent",
          "payloads",
          "positions",
          "preference",
          "realtime",
          "routing",
          "term_statistics",
          "version",
          "version_type",
      )
      def mtermvectors(self, doc_type=None, index=None, body=None, params=None):
          """
          Multi termvectors API allows to get multiple termvectors based on an
          index, type and id.
          `<http://www.elastic.co/guide/en/elasticsearch/reference/current/docs-multi-termvectors.html>`_
  
          :arg index: The index in which the document resides.
          :arg body: Define ids, documents, parameters or a list of parameters per
              document here. You must at least provide a list of document ids. See
              documentation.
          :arg field_statistics: Specifies if document count, sum of document
              frequencies and sum of total term frequencies should be returned.
              Applies to all returned documents unless otherwise specified in body
              "params" or "docs"., default True
          :arg fields: A comma-separated list of fields to return. Applies to all
              returned documents unless otherwise specified in body "params" or
              "docs".
          :arg ids: A comma-separated list of documents ids. You must define ids
              as parameter or set "ids" or "docs" in the request body
          :arg offsets: Specifies if term offsets should be returned. Applies to
              all returned documents unless otherwise specified in body "params"
              or "docs"., default True
          :arg parent: Parent id of documents. Applies to all returned documents
              unless otherwise specified in body "params" or "docs".
          :arg payloads: Specifies if term payloads should be returned. Applies to
              all returned documents unless otherwise specified in body "params"
              or "docs"., default True
          :arg positions: Specifies if term positions should be returned. Applies
              to all returned documents unless otherwise specified in body
              "params" or "docs"., default True
          :arg preference: Specify the node or shard the operation should be
              performed on (default: random) .Applies to all returned documents
              unless otherwise specified in body "params" or "docs".
          :arg realtime: Specifies if requests are real-time as opposed to near-
              real-time (default: true).
          :arg routing: Specific routing value. Applies to all returned documents
              unless otherwise specified in body "params" or "docs".
          :arg term_statistics: Specifies if total term frequency and document
              frequency should be returned. Applies to all returned documents
              unless otherwise specified in body "params" or "docs"., default
              False
          :arg version: Explicit version number for concurrency control
          :arg version_type: Specific version type, valid choices are: 'internal',
              'external', 'external_gte', 'force'
          """
          return self.transport.perform_request(
              "GET",
              _make_path(index, doc_type, "_mtermvectors"),
              params=params,
              body=body,
          )
  
      @query_params("master_timeout", "timeout")
      def put_script(self, id, body, context=None, params=None):
          """
          Create a script in given language with specified ID.
          `<http://www.elastic.co/guide/en/elasticsearch/reference/current/modules-scripting.html>`_
  
          :arg id: Script ID
          :arg body: The document
          :arg master_timeout: Specify timeout for connection to master
  	:arg timeout: Explicit operation timeout
  	"""
          for param in (id, body):
              if param in SKIP_IN_PATH:
                  raise ValueError("Empty value passed for a required argument.")
          return self.transport.perform_request(
              "PUT", _make_path("_scripts", id, context), params=params, body=body
          )
  
      @query_params("allow_no_indices", "expand_wildcards", "ignore_unavailable")
      def rank_eval(self, body, index=None, params=None):
          """
          `<https://www.elastic.co/guide/en/elasticsearch/reference/master/search-rank-eval.html>`_
  
          :arg body: The ranking evaluation search definition, including search
              requests, document ratings and ranking metric definition.
          :arg index: A comma-separated list of index names to search; use `_all`
              or empty string to perform the operation on all indices
          :arg 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)
          :arg 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'
          :arg ignore_unavailable: Whether specified concrete indices should be
              ignored when unavailable (missing or closed)
          """
          if body in SKIP_IN_PATH:
              raise ValueError("Empty value passed for a required argument 'body'.")
          return self.transport.perform_request(
              "GET", _make_path(index, "_rank_eval"), params=params, body=body
          )
  
      @query_params("master_timeout")
      def get_script(self, id, params=None):
          """
          Retrieve a script from the API.
          `<http://www.elastic.co/guide/en/elasticsearch/reference/master/modules-scripting.html>`_
  
          :arg id: Script ID
          :arg master_timeout: Specify timeout for connection to master
          """
          if id in SKIP_IN_PATH:
              raise ValueError("Empty value passed for a required argument 'id'.")
          return self.transport.perform_request(
              "GET", _make_path("_scripts", id), params=params
          )
  
      @query_params("master_timeout", "timeout")
      def delete_script(self, id, params=None):
          """
          Remove a stored script from elasticsearch.
          `<http://www.elastic.co/guide/en/elasticsearch/reference/master/modules-scripting.html>`_
  
          :arg id: Script ID
          :arg master_timeout: Specify timeout for connection to master
          :arg timeout: Explicit operation timeout        """
          if id in SKIP_IN_PATH:
              raise ValueError("Empty value passed for a required argument 'id'.")
          return self.transport.perform_request(
              "DELETE", _make_path("_scripts", id), params=params
          )
  
      @query_params()
      def render_search_template(self, id=None, body=None, params=None):
          """
          `<http://www.elasticsearch.org/guide/en/elasticsearch/reference/current/search-template.html>`_
  
          :arg id: The id of the stored search template
          :arg body: The search definition template and its params
          """
          return self.transport.perform_request(
              "GET", _make_path("_render", "template", id), params=params, body=body
          )
  
      @query_params("context")
      def scripts_painless_context(self, params=None):
          """
          `<>`_
  
          :arg context: Select a specific context to retrieve API information
              about
          """
          return self.transport.perform_request(
              "GET", "/_scripts/painless/_context", params=params
          )
  
      @query_params()
      def scripts_painless_execute(self, body=None, params=None):
          """
          `<https://www.elastic.co/guide/en/elasticsearch/painless/master/painless-execute-api.html>`_
  
          :arg body: The script to execute
          """
          return self.transport.perform_request(
              "GET", "/_scripts/painless/_execute", params=params, body=body
          )
  
      @query_params(
          "ccs_minimize_roundtrips",
          "max_concurrent_searches",
          "search_type",
          "typed_keys",
      )
      def msearch_template(self, body, index=None, params=None):
          """
          The /_search/template endpoint allows to use the mustache language to
          pre render search requests, before they are executed and fill existing
          templates with template parameters.
          `<http://www.elastic.co/guide/en/elasticsearch/reference/current/search-template.html>`_
  
          :arg body: The request definitions (metadata-search request definition
              pairs), separated by newlines
          :arg index: A list of index names, or a string containing a
              comma-separated list of index names, to use as the default
          :arg ccs_minimize_roundtrips: Indicates whether network round-trips
              should be minimized as part of cross-cluster search requests
              execution, default 'true'
          :arg max_concurrent_searches: Controls the maximum number of concurrent
              searches the multi search api will execute
          :arg search_type: Search operation type, valid choices are:
              'query_then_fetch', 'query_and_fetch', 'dfs_query_then_fetch',
              'dfs_query_and_fetch'
          :arg typed_keys: Specify whether aggregation and suggester names should
              be prefixed by their respective types in the response
          """
          if body in SKIP_IN_PATH:
              raise ValueError("Empty value passed for a required argument 'body'.")
          return self.transport.perform_request(
              "GET",
              _make_path(index, "_msearch", "template"),
              params=params,
              body=self._bulk_body(body),
              headers={"content-type": "application/x-ndjson"},
          )
  
      @query_params(
          "allow_no_indices",
          "expand_wildcards",
          "fields",
          "ignore_unavailable",
          "include_unmapped",
      )
      def field_caps(self, index=None, body=None, params=None):
          """
          The field capabilities API allows to retrieve the capabilities of fields among multiple indices.
          `<http://www.elastic.co/guide/en/elasticsearch/reference/current/search-field-caps.html>`_
  
          :arg index: A list of index names, or a string containing a
              comma-separated list of index names; use `_all` or the empty string
              to perform the operation on all indices
          :arg body: Field json objects containing an array of field names
          :arg 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)
          :arg 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'
          :arg fields: A comma-separated list of field names
          :arg ignore_unavailable: Whether specified concrete indices should be
              ignored when unavailable (missing or closed)
          :arg include_unmapped: Indicates whether unmapped fields should be
              included in the response., default False
          """
          return self.transport.perform_request(
              "GET", _make_path(index, "_field_caps"), params=params, body=body
          )
  