OpenSearch

apache-airflow-providers-opensearch

OpenSearch

Works with Airflow 3.0+

Install:

pip install apache-airflow-providers-opensearch==1.9.1

Version:

3.0+

>=3.10

Show all Hide

apache-airflow>=3.0.0 apache-airflow-providers-common-compat>=1.12.0 opensearch-py>=2.2.0

Modules

Add a new document to a given Index or overwrite an existing one.

airflow.providers.opensearch.operators.opensearch.OpenSearchAddDocumentOperator

Create a new index on an OpenSearch cluster with a given index name.

airflow.providers.opensearch.operators.opensearch.OpenSearchCreateIndexOperator

Run a query search against a given index on an OpenSearch cluster and returns results.

airflow.providers.opensearch.operators.opensearch.OpenSearchQueryOperator

Provide a thin wrapper around the OpenSearch client.

airflow.providers.opensearch.hooks.opensearch.OpenSearchHook

OpensearchTaskHandler is a Python log handler that reads logs from OpenSearch.

airflow.providers.opensearch.log.os_task_handler.OpensearchTaskHandler