ElasticsearchPythonHook
ElasticsearchInteracts with Elasticsearch. This hook uses the official Elasticsearch Python Client.
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
hostslist: A list of a single or many Elasticsearch instances. Example: [”http://localhost:9200”]
es_conn_argsdict: Additional arguments you might need to enter to connect to Elasticsearch. Example: {“ca_cert”:”/path/to/cert”, “basic_auth”: “(user, pass)”}
Documentation
Interacts with Elasticsearch. This hook uses the official Elasticsearch Python Client.