class_docstr: Interacts with Elasticsearch. This hook uses the official Elasticsearch Python Client.
  
  :param hosts: list: A list of a single or many Elasticsearch instances. Example: ["http://localhost:9200"]
  :param es_conn_args: dict: Additional arguments you might need to enter to connect to Elasticsearch.
                              Example: {"ca_cert":"/path/to/cert", "basic_auth": "(user, pass)"}
class_docstr_tok: ["Interacts","with","Elasticsearch",".","This","hook","uses","the","official","Elasticsearch","Python","Client",".",":","param","hosts",":","list",":","A","list","of","a","single","or","many","Elasticsearch","instances",".","Example",":","[","``","http",":","\/\/localhost:9200","''","]",":","param","es_conn_args",":","dict",":","Additional","arguments","you","might","need","to","enter","to","connect","to","Elasticsearch",".","Example",":","{","``","ca_cert","''",":","''","\/path\/to\/cert","''",",","``","basic_auth","''",":","``","(","user",",","pass",")","''","}"]
code: def __init__(
      self, hosts: list[Any], es_conn_args: dict | None = None, **kwargs
  ):
      super().__init__(**kwargs)
      self.hosts = hosts
      self.es_conn_args = es_conn_args or {}
  
imports: from __future__ import annotations
  import warnings
  from functools import cached_property
  from typing import TYPE_CHECKING, Any
  from urllib import parse
  from elasticsearch import Elasticsearch
  from airflow.exceptions import AirflowProviderDeprecationWarning
  from airflow.hooks.base import BaseHook
  from airflow.providers.common.sql.hooks.sql import DbApiHook
label_desc: Use image node_id 1 to create a new ElasticsearchPythonHook object from inherited base classes: BaseHook with example: obj = ElasticsearchPythonHook(hosts, es_conn_args)