tests.system.elasticsearch.example_elasticsearch_query

Elasticsearch 查询的 Airflow DAG 示例。

属性

ENV_ID

DAG_ID

CONN_ID

execute_query

test_run

函数

show_tables()

show_tables 查询 Elasticsearch 以列出可用的表

use_elasticsearch_hook()

使用 ElasticSearchPythonHook 打印本地 Elasticsearch 的结果

模块内容

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 查询 Elasticsearch 以列出可用的表

tests.system.elasticsearch.example_elasticsearch_query.use_elasticsearch_hook()[source]

使用 ElasticSearchPythonHook 打印本地 Elasticsearch 的结果

tests.system.elasticsearch.example_elasticsearch_query.execute_query = True[source]
tests.system.elasticsearch.example_elasticsearch_query.test_run[source]

此条目有帮助吗?