本文為英文版的機器翻譯版本，如內容有任何歧義或不一致之處，概以英文版為準。

Snowflake 連線

您可以使用 AWS Glue for Spark 在 Glue 4.0 AWS 和更新版本中讀取和寫入 Snowflake 中的資料表。您可以使用 SQL 查詢從 Snowflake 讀取。您可以使用三種方法之一連線至 Snowflake：基本身分驗證 （使用使用者名稱和密碼）、OAuth 身分驗證或金鑰對身分驗證。您可以透過 Glue Data AWS Secrets Manager 連線參考存放在 中的 Snowflake AWS 登入資料。Glue for Spark 的 Data Connection Snowflake AWS 登入資料與爬蟲程式的 Data Catalog Snowflake 登入資料分開存放。您必須選擇 SNOWFLAKE 類型連線，而不是設定為連線至 Snowflake 的 JDBC 類型連線。

如需有關 Snowflake 的詳細資訊，請參閱 Snowflake 網站。如需 Snowflake on 的詳細資訊 AWS，請參閱 Amazon Web Services 上的 Snowflake Data Warehouse。

設定 Snowflake 連線

透過網際網路連線至 Snowflake 資料庫沒有 AWS 先決條件。

或者，您可以執行下列組態，以使用 Glue AWS 管理您的連線憑證。

對於在 Amazon VPC AWS 中託管於 的 Snowflake，您可能需要下列項目：

從 Snowflake 資料表讀取

先決條件：您想要讀取的 Snowflake 資料表。您需要 Snowflake 資料表名稱 tableName。如果您的 Snowflake 使用者沒有預設的命名空間集，您將需要 Snowflake 資料庫名稱 databaseName 和結構描述名稱 schemaName。此外，如果您的 Snowflake 使用者沒有預設的倉儲集，您將需要倉儲名稱 warehouseName。若要選取要連線的其他網路連線，請使用 connectionName 參數。

snowflake_read = glueContext.create_dynamic_frame.from_options(
  connection_type="snowflake",
  connection_options={
        "connectionName": "connectionName",
        "dbtable": "tableName",
        "sfDatabase": "databaseName",
        "sfSchema": "schemaName",
        "sfWarehouse": "warehouseName",
    }
)

此外，您可以使用 autopushdown 和 query 參數來讀取 Snowflake 資料表的一部分。這可能比在將結果載入 Spark 後篩選結果的方式更高效。考量一個範例，其中所有銷售額都存放在同一個資料表中，但您只需分析某個商店在假日的銷售額。如果該資訊存放在資料表中，則可以使用述詞下推來擷取結果，如下所示：

snowflake_node = glueContext.create_dynamic_frame.from_options(
    connection_type="snowflake",
    connection_options={
        "autopushdown": "on",
        "query": "select * from sales where store='1' and IsHoliday='TRUE'",
        "connectionName": "snowflake-glue-conn",
        "sfDatabase": "databaseName",
        "sfSchema": "schemaName",
        "sfWarehouse": "warehouseName",
    }
)

寫入 Snowflake 資料表

先決條件：您想要寫入的 Snowflake 資料庫。您需要最新的或所需的資料表名稱 tableName。如果您的 Snowflake 使用者沒有預設的命名空間集，您將需要 Snowflake 資料庫名稱 databaseName 和結構描述名稱 schemaName。此外，如果您的 Snowflake 使用者沒有預設的倉儲集，您將需要倉儲名稱 warehouseName。若要選取要連線的其他網路連線，請使用 connectionName 參數。

glueContext.write_dynamic_frame.from_options(
    connection_type="snowflake",
    connection_options={
        "connectionName": "connectionName",
        "dbtable": "tableName",
        "sfDatabase": "databaseName",
        "sfSchema": "schemaName",
        "sfWarehouse": "warehouseName",
    },
)

Snowflake 連線選項參考

Snowflake 連線類型採用下列連線選項：

您可以從 Glue AWS 連線 (sfUrl、sfUser、sfPassword) 擷取本節中的某些參數，在這種情況下，您不需要提供這些參數。您可以提供參數 connectionName 來完成此操作。

您可以使用 參數從 AWS Secrets Manager 秘密擷取連線secretId參數。使用 Secrets Manager 時，如果機密中存在下列 Spark 屬性，則可以自動擷取這些屬性：

屬性優先順序：在多個位置指定相同的屬性時， AWS Glue 會使用下列優先順序 （從最高到最低）：

連線到 Snowflake 時，通常使用以下參數。

以下選項用於在連線到 Snowflake 過程中設定特定行為。

此外，Glue AWS 可能支援 Snowflake Spark 連接器上的一些可用選項。如需有關 Snowflake Spark 連接器上可用選項的詳細資訊，請參閱 Snowflake 文件中的 Setting Configuration Options for the Connector。

Snowflake 身分驗證方法

AWS Glue 支援下列身分驗證方法來連線至 Snowflake：

完全支援這三種身分驗證方法，並且可以使用連線選項、Glue 連線或 AWS Secrets Manager 秘密的任意組合進行設定。

Snowflake 連接器限制

使用 Glue for Spark AWS 連線至 Snowflake 受下列限制約束。