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.

This hook uses the Elasticsearch conn_id.

Parameters

elasticsearch_conn_id (str) – The ElasticSearch connection id used for Elasticsearch credentials.

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?