连接到 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

这篇文章有帮助吗?