`tests.system.elasticsearch.example_elasticsearch_query`¶

Elasticsearch 查詢的範例 Airflow DAG。

模組內容¶

`show_tables`()	show_tables 查詢 elasticsearch 以列出可用的表格
`use_elasticsearch_hook`()	使用 ElasticSearchPythonHook 印出本機 Elasticsearch 的結果

tests.system.elasticsearch.example_elasticsearch_query.DAG_ID = 'elasticsearch_dag'[原始碼]¶

tests.system.elasticsearch.example_elasticsearch_query.CONN_ID = 'elasticsearch_default'[原始碼]¶

tests.system.elasticsearch.example_elasticsearch_query.show_tables()[原始碼]¶: show_tables 查詢 elasticsearch 以列出可用的表格

tests.system.elasticsearch.example_elasticsearch_query.use_elasticsearch_hook()[原始碼]¶: 使用 ElasticSearchPythonHook 印出本機 Elasticsearch 的結果