airflow.providers.apache.iceberg.hooks.iceberg¶

属性¶

TOKENS_ENDPOINT

类¶

此 Hook 作为 Iceberg 服务的基类 Hook。

模块内容¶

airflow.providers.apache.iceberg.hooks.iceberg.TOKENS_ENDPOINT = 'oauth/tokens'[source]¶

class airflow.providers.apache.iceberg.hooks.iceberg.IcebergHook(iceberg_conn_id=default_conn_name)[source]¶

基类: airflow.hooks.base.BaseHook

此 Hook 作为 Iceberg 服务的基类 Hook。

它提供了生成临时、短期会话令牌的能力，以便在 Airflow 提交的任务中使用。

参数:: iceberg_conn_id (str) – 引用连接到 Iceberg 所需信息的 Iceberg 连接 ID>。

conn_name_attr = 'iceberg_conn_id'[source]¶

default_conn_name = 'iceberg_default'[source]¶

conn_type = 'iceberg'[source]¶

hook_name = 'Iceberg'[source]¶

classmethod get_ui_field_behaviour()[source]¶

返回 Iceberg 连接的自定义 UI 字段行为。

conn_id = 'iceberg_default'[source]¶

test_connection()[source]¶

测试 Iceberg 连接。

get_conn()[source]¶

通过 client_id 和 client_secret 获取短期访问令牌。

get_token_macro()[source]¶

此条目有帮助吗？