連線到 Iceberg

Iceberg 連線型別允許連線到 Iceberg REST 目錄,以請求一個短時令牌來訪問 Apache Iceberg 表。此令牌可以作為環境變數注入,用於 Trino、Spark、Flink 或任何你喜歡的支援 Apache Iceberg 的查詢引擎。

在你的 Airflow 環境中安裝 Iceberg 提供程式後,相應的連線型別 iceberg 將可用。

預設連線 ID

Iceberg Hook 使用引數 iceberg_conn_id 作為連線 ID,引數的預設值為 iceberg_default。你可以建立多個連線,以便在不同環境之間切換。

配置連線

客戶端 ID

OAuth2 客戶端 ID

客戶端金鑰

OAuth2 客戶端金鑰

主機

設定 Tabular 環境的 URL。預設情況下 https://api.tabulardata.io/ws/v1

這篇文章有幫助嗎?