ElasticSearch 连接¶

ElasticSearch 连接，启用 ElasticSearch 集成。

验证 ElasticSearch¶

使用 ElasticSearch DBAPI 进行身份验证

默认连接 ID¶

一些与 ElasticSearch 相关的钩子和运算符默认使用 elasticsearch_default。

配置连接¶

用户

指定用于初始连接的登录名

密码

指定用于初始连接的 Elasticsearch API 密钥

主机

指定用于初始连接的 Elasticsearch 主机

端口

指定初始连接的 Elasticsearch 端口

方案

指定 Elasticsearch API 的模式。默认为 http

额外（可选）

指定可在 Elasticsearch 连接中使用的额外参数（以 json 字典形式）。以下参数均为可选

http_compress: 指定是否使用 http_compress。默认为 False。
timeout: 指定 timeout 的时间范围。默认为 False。

在环境变量中指定连接时，应使用 URI 语法指定。

请注意，URI 的所有组成部分都应进行 URL 编码。

例如

export AIRFLOW_CONN_ELASTICSEARCH_DEFAULT='elasticsearch://elasticsearchlogin:[email protected]:80/http'

tests/system/elasticsearch/example_elasticsearch_query.py[源代码]

es = ElasticsearchSQLHook(elasticsearch_conn_id=CONN_ID)

es_connection = es.get_conn()
response = es_connection.execute_sql("SHOW TABLES")
for row in response["rows"]:
    print(f"row: {row}")
return True