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

Snowflake 連線

您可以使用 AWS Glue for Spark 從 AWS Glue 4.0 及更新版本中的 Snowflake 讀取和寫入資料表。您可以使用 SQL 查詢從 Snowflake 讀取。您可以使用使用者和密碼連線至 Snowflake。您可以透過 AWS Glue Data Catalog 參考存放在 AWS Secrets Manager 中的 Snowflake 憑證。AWS Glue for Spark 的 Data Catalog Snowflake 憑證會與爬蟲程式的 Data Catalog Snowflake 憑證分開存放。您必須選擇 SNOWFLAKE 類型連線，而不是設定為連線至 Snowflake 的 JDBC 類型連線。

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

設定 Snowflake 連線

透過網際網路連線到可用的 Snowflake 資料庫沒有 AWS 先決條件。

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

在下列情況下，您可能需要滿足以下條件：

從 Snowflake 資料表讀取

先決條件：您想要讀取的 Snowflake 資料表。您需要 Snowflake 資料表名稱 tableName。您需要 Snowflake url snowflakeUrl、使用者名稱 snowflakeUser 和密碼 snowflakePassword。如果您的 Snowflake 使用者沒有預設的命名空間集，您將需要 Snowflake 資料庫名稱 databaseName 和結構描述名稱 schemaName。此外，如果您的 Snowflake 使用者沒有預設的倉儲集，您將需要倉儲名稱 warehouseName。

例如：

其他先決條件：完成步驟使用 AWS Glue 管理您的連線憑證，以設定 SnowFlakeURL、snowflakeUsername 和 snowflakePassword。若要檢閱這些步驟，請參閱上一節 設定 Snowflake 連線。若要選取要連線的其他網路連線，我們將使用 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 url snowflakeUrl、使用者名稱 snowflakeUser 和密碼 snowflakePassword。如果您的 Snowflake 使用者沒有預設的命名空間集，您將需要 Snowflake 資料庫名稱 databaseName 和結構描述名稱 schemaName。此外，如果您的 Snowflake 使用者沒有預設的倉儲集，您將需要倉儲名稱 warehouseName。

例如：

其他先決條件：完成步驟使用 AWS Glue 管理您的連線憑證，以設定 SnowFlakeURL、snowflakeUsername 和 snowflakePassword。若要檢閱這些步驟，請參閱上一節 設定 Snowflake 連線。若要選取要連線的其他網路連線，我們將使用 connectionName 參數。

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

Snowflake 連線選項參考

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

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

您可以從 AWS Secrets Manager 機密 (sfUser、sfPassword) 擷取本節中的某些參數，在這種情況下，您不需要提供它們。機密必須提供 sfUser 和 sfPassword 索引鍵下的內容。您可以提供參數 secretId 來完成此操作。

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

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

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

Snowflake 連接器限制

透過 AWS Glue for Spark 連線到 Snowflake 會受到以下限制。