用于 Elasticsearch 查询的示例 Airflow DAG。
模块内容
属性
-
tests.system.elasticsearch.example_elasticsearch_query.ENV_ID[源代码]
-
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 打印结果
-
tests.system.elasticsearch.example_elasticsearch_query.execute_query[源代码]
-
tests.system.elasticsearch.example_elasticsearch_query.test_run[源代码]