OpenSearch

apache-airflow-providers-opensearch

OpenSearch

Works with Airflow 2.11+
345K
Monthly Downloads
5
Total Modules
View Docs Source
Install:
pip install apache-airflow-providers-opensearch==1.8.4

Airflow

2.11+

Python

>=3.10

Dependencies (3)

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

Connections (1)

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 and writes logs to OpenSearch.

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