`tests.system.providers.elasticsearch.example_elasticsearch_query`¶

Example Airflow DAG for Elasticsearch Query.

Module Contents¶

`show_tables`()	show_tables queries elasticsearch to list available tables
`use_elasticsearch_hook`()	Use ElasticSearchPythonHook to print results from a local Elasticsearch

tests.system.providers.elasticsearch.example_elasticsearch_query.ENV_ID[source]¶

tests.system.providers.elasticsearch.example_elasticsearch_query.DAG_ID = elasticsearch_dag[source]¶

tests.system.providers.elasticsearch.example_elasticsearch_query.CONN_ID = elasticsearch_default[source]¶

tests.system.providers.elasticsearch.example_elasticsearch_query.show_tables()[source]¶: show_tables queries elasticsearch to list available tables

tests.system.providers.elasticsearch.example_elasticsearch_query.use_elasticsearch_hook()[source]¶: Use ElasticSearchPythonHook to print results from a local Elasticsearch

tests.system.providers.elasticsearch.example_elasticsearch_query.execute_query[source]¶

tests.system.providers.elasticsearch.example_elasticsearch_query.test_run[source]¶