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"
    }
}'