Snowflake 連線¶

Snowflake 連線類型啟用與 Snowflake 的整合。

驗證 Snowflake¶

使用 Snowflake Python 連接器預設驗證來驗證 Snowflake。

預設連線 ID¶

與 Snowflake 相關的 Hook、運算子和感測器預設使用 snowflake_default。

設定連線¶

登入

指定 Snowflake 使用者名稱。

密碼

指定 Snowflake 密碼。對於公鑰驗證，請使用私鑰的密碼。

Schema（選填）

指定要使用的 Snowflake Schema。

額外參數（選填）

指定可用於 Snowflake 連線的額外參數（以 JSON 字典形式）。以下參數皆為選填

account：Snowflake 帳戶名稱。
database：Snowflake 資料庫名稱。
region：Warehouse 區域。
warehouse：Snowflake Warehouse 名稱。
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 進行本機測試）。

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