Snowflake 连接¶

Snowflake 连接类型支持与 Snowflake 集成。

对 Snowflake 进行身份验证¶

使用 Snowflake python 连接器默认身份验证对 Snowflake 进行身份验证。

默认连接 ID¶

与 Snowflake 相关的 Hook、操作符和 Sensor 默认使用 snowflake_default。

配置连接¶

登录

指定 Snowflake 用户名。

密码

指定 Snowflake 密码。对于公钥身份验证，这是私钥的密码。

Schema (可选)

指定要使用的 Snowflake Schema。

Extra (可选)

指定可在 Snowflake 连接中使用的额外参数（以 JSON 字典形式）。以下参数均为可选：

account：Snowflake 账户名称。
database：Snowflake 数据库名称。
region：仓库区域。
warehouse：Snowflake 仓库名称。
role：Snowflake 角色。
authenticator：要使用 OAuth 连接，请将此参数设置为 oauth。
refresh_token：指定 OAuth 连接的 refresh_token。
private_key_file：指定私钥文件的路径。
private_key_content：指定私钥文件的内容。
session_parameters：指定会话级别参数。
insecure_mode：关闭 OCSP 证书检查。详情请参阅：How To: Turn Off OCSP Checking in Snowflake Client Drivers - Snowflake Community。
host：要连接的目标 Snowflake 主机名（例如，使用 LocalStack 进行本地测试时）。
port：要连接的目标 Snowflake 端口（例如，使用 LocalStack 进行本地测试时）。
ocsp_fail_open：指定 ocsp_fail_open。

URI 格式示例¶

如果使用 Airflow URI 进行序列化

export AIRFLOW_CONN_SNOWFLAKE_DEFAULT='snowflake://user:password@/db-schema?account=account&database=snow-db&region=us-east&warehouse=snow-warehouse'

在 Airflow 2.3.0 之前的版本中，将连接指定为环境变量时，需要使用 URI 格式指定连接。

请注意，URI 的所有组成部分都应进行 URL 编码。

JSON 格式示例¶

如果使用 JSON 进行序列化

export AIRFLOW_CONN_SNOWFLAKE_DEFAULT='{
    "conn_type": "snowflake",
    "login": "user",
    "password": "password",
    "schema": "db-schema",
    "extra": {
        "account": "account",
        "database": "database",
        "region": "us-east",
        "warehouse": "snow-warehouse"
    }
}'