tests.system.elasticsearch.example_elasticsearch_query

Example Airflow DAG for Elasticsearch Query.

Module Contents

Functions

show_tables()

show_tables queries elasticsearch to list available tables

use_elasticsearch_hook()

Use ElasticSearchPythonHook to print results from a local Elasticsearch

Attributes

ENV_ID

DAG_ID

CONN_ID

execute_query

test_run

tests.system.elasticsearch.example_elasticsearch_query.ENV_ID[source]
tests.system.elasticsearch.example_elasticsearch_query.DAG_ID = 'elasticsearch_dag'[source]
tests.system.elasticsearch.example_elasticsearch_query.CONN_ID = 'elasticsearch_default'[source]
tests.system.elasticsearch.example_elasticsearch_query.show_tables()[source]

show_tables queries elasticsearch to list available tables

tests.system.elasticsearch.example_elasticsearch_query.use_elasticsearch_hook()[source]

Use ElasticSearchPythonHook to print results from a local Elasticsearch

tests.system.elasticsearch.example_elasticsearch_query.execute_query[source]
tests.system.elasticsearch.example_elasticsearch_query.test_run[source]

Was this entry helpful?