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

Example Airflow DAG for Elasticsearch Query.

Module Contents¶

Functions¶

show_tables()

show_tables queries elasticsearch to list available tables

Attributes¶

`ENV_ID`
`DAG_ID`
`CONN_ID`
`execute_query`
`test_run`

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.execute_query[source]¶

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

Was this entry helpful?