ElasticSearch 連線¶

啟用 ElasticSearch 整合的 ElasticSearch 連線。

ElasticSearch 認證¶

使用 ElasticSearch DBAPI 進行認證

預設連線 ID¶

一些與 ElasticSearch 相關的 hook 和 operator 預設使用 elasticsearch_default。

配置連線¶

使用者

指定用於初始連線的登入名

密碼

指定用於初始連線的 Elasticsearch API 金鑰

主機

指定用於初始連線的 Elasticsearch 主機

埠

指定用於初始連線的 Elasticsearch 埠

方案

指定 Elasticsearch API 的方案。預設為 http

Extra (可選)

指定可在 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