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

Module Contents¶

Classes¶

ElasticsearchHook

Interact with Elasticsearch through the elasticsearch-dbapi.

class airflow.providers.elasticsearch.hooks.elasticsearch.ElasticsearchHook(schema='http', connection=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 -- 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]¶

Extract the URI from the connection.

Returns: the extracted uri.
Return type: str

Was this entry helpful?