Snowflake 连接¶

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

向 Snowflake 验证身份¶

使用 Snowflake Python 连接器默认身份验证向 Snowflake 验证身份。

默认连接 ID¶

与 Snowflake 相关的钩子、操作符和传感器默认使用 snowflake_default。

配置连接¶

登录名

指定 Snowflake 用户名。

密码

指定 Snowflake 密码。对于公钥身份验证，请输入私钥的密码。

模式（可选）

指定要使用的 Snowflake 模式。

额外参数（可选）

指定可以在 Snowflake 连接中使用的额外参数（作为 JSON 字典）。以下参数都是可选的

account：Snowflake 帐户名。
database：Snowflake 数据库名称。
region：仓库区域。
warehouse：Snowflake 仓库名称。
role：Snowflake 角色。
authenticator：要使用 OAuth 连接，请将此参数设置为 oauth。
refresh_token：指定 OAuth 连接的刷新令牌。
private_key_file：指定私钥文件的路径。
private_key_content：指定私钥文件的内容。
session_parameters：指定会话级别参数。
insecure_mode：关闭 OCSP 证书检查。有关详细信息，请参阅：如何在 Snowflake 客户端驱动程序中关闭 OCSP 检查 - Snowflake 社区。

URI 格式示例¶

如果使用 Airflow URI 进行序列化

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

在 2.3.0 之前的 Airflow 版本中，当将连接指定为环境变量时，您需要使用 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"
    }
}'