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:elasticsearchpassword@elastic.co: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