ElasticSearch 連線¶

ElasticSearch 連線啟用 ElasticSearch 整合功能。

ElasticSearch 驗證¶

使用 ElasticSearch DBAPI 進行驗證

預設連線 ID¶

一些與 ElasticSearch 相關的 hooks 和 operators 預設使用 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[source]

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