ElasticSearch 连接¶

启用 ElasticSearch 集成的 ElasticSearch 连接。

验证 ElasticSearch¶

使用 ElasticSearch DBAPI 进行身份验证

默认连接 ID¶

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

配置连接¶

用户

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

密码

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

主机

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

端口

指定用于初始连接的 Elasticsearch 端口

方案

指定 Elasticsearch API 的方案。默认为 http

额外参数（可选）

指定可在 Azure 连接中使用的额外参数（作为 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/providers/elasticsearch/example_elasticsearch_query.py[源代码]

es = ElasticsearchSQLHook(elasticsearch_conn_id=CONN_ID)

# Handle ES conn with context manager
with es.get_conn() as es_conn:
    tables = es_conn.execute("SHOW TABLES")
    for table, *_ in tables:
        print(f"table: {table}")
return True