ElasticsearchSQLHook

Elasticsearch

Interact with Elasticsearch through the elasticsearch-dbapi.

View on GitHub

Last Updated: Oct. 23, 2022

Access Instructions

Install the Elasticsearch provider package into your Airflow environment.

Import the module into your DAG file and instantiate it with your desired params.

Parameters

elasticsearch_conn_idThe ElasticSearch connection id used for Elasticsearch credentials.

Documentation

Interact with Elasticsearch through the elasticsearch-dbapi.

This hook uses the Elasticsearch conn_id.

Was this page helpful?