`airflow.providers.elasticsearch.hooks.elasticsearch`¶

Module Contents¶

class airflow.providers.elasticsearch.hooks.elasticsearch.ElasticsearchHook(schema: str = 'http', connection: Optional[AirflowConnection] = None, *args, **kwargs)[source]¶

Bases: airflow.hooks.dbapi.DbApiHook

Interact with Elasticsearch through the elasticsearch-dbapi.

conn_name_attr = elasticsearch_conn_id[source]¶

default_conn_name = elasticsearch_default[source]¶

conn_type = elasticsearch[source]¶

hook_name = Elasticsearch[source]¶

get_conn(self)[source]¶: Returns a elasticsearch connection object

get_uri(self)[source]¶

Was this entry helpful?