tests.system.elasticsearch.example_elasticsearch_query
Example Airflow DAG for Elasticsearch Query.
Functions
show_tables()
|
show_tables queries elasticsearch to list available tables |
use_elasticsearch_hook()
|
Use ElasticSearchPythonHook to print results from a local Elasticsearch |
Module Contents
-
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 = True[source]
-
tests.system.elasticsearch.example_elasticsearch_query.test_run[source]