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

此条目有帮助吗?