OpenSearch

apache-airflow-providers-opensearch

OpenSearch

Works with Airflow 3.0+
1.6K
Monthly Downloads
5
Total Modules
View Docs Source
Install:
pip install apache-airflow-providers-opensearch==1.14.0

Airflow

3.0+

Python

>=3.11

Dependencies (3)

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

Connections (1)

URI Schemes (1)

Schemes this release registers in provider.yaml, grouped by the Airflow feature that routes them to the provider.

Remote logging
opensearch://

Modules

O

OpenSearchAddDocumentOperator

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

airflow.providers.opensearch.operators.opensearch.OpenSearchAddDocumentOperator
View Docs Source
O

OpenSearchCreateIndexOperator

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

airflow.providers.opensearch.operators.opensearch.OpenSearchCreateIndexOperator
View Docs Source
O

OpenSearchQueryOperator

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

airflow.providers.opensearch.operators.opensearch.OpenSearchQueryOperator
View Docs Source
H

OpenSearchHook

Provide a thin wrapper around the OpenSearch client.

airflow.providers.opensearch.hooks.opensearch.OpenSearchHook
View Docs Source
L

OpensearchTaskHandler

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

airflow.providers.opensearch.log.os_task_handler.OpensearchTaskHandler
View Docs Source