從 Salesforce Commerce Cloud 實體中讀取 - AWS Glue

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

從 Salesforce Commerce Cloud 實體中讀取

先決條件

  • 您想要從中讀取的 Salesforce Commerce Cloud Object。請參閱以下支援的實體表格,以檢查可用實體。

支援的實體

實體 可以篩選 支援限制 支援排序依據 支援選取 * 支援分區
Assignments (指派)
行銷活動
目錄
類別
優惠券
禮品券
產品
促銷活動
來源碼群組

範例

salesforce_commerce_cloud_read = glueContext.create_dynamic_frame.from_options( connection_type="SalesforceCommerceCloud", connection_options={ "connectionName": "connectionName", "ENTITY_NAME": "campaign", "API_VERSION": "v1" } )

Salesforce Commerce Cloud 實體和欄位詳細資訊

實體清單:

分區查詢

如果想要在 Spark 中使用並行,可以提供其他 Spark 選項 PARTITION_FIELDLOWER_BOUNDUPPER_BOUNDNUM_PARTITIONS。使用這些參數,原始查詢會分區為可由 Spark 任務並行執行的子查詢的 NUM_PARTITIONS 數目。

  • PARTITION_FIELD:用來分區查詢的欄位名稱。

  • LOWER_BOUND:所選分區欄位的包含下限值。

    對於日期,我們接受 Spark SQL 查詢中使用的 Spark 日期格式。有效值的範例:"2024-02-06"

  • UPPER_BOUND:所選分區欄位的唯一上限值。

  • NUM_PARTITIONS:分區數目。

實體分區欄位支援詳細資訊如下表所示:

實體 分區欄位 DataType
行銷活動 lastModified DateTime
行銷活動 startDate DateTime
行銷活動 endDate DateTime
目錄 creationDate DateTime
類別 creatiionDate DateTime
禮品券 merchantId String
禮品券 creatiionDate DateTime
產品 creatiionDate DateTime
產品 lastModified DateTime
來源碼群組 creationDate DateTime
來源碼群組 startTime DateTime
來源碼群組 endTime DateTime

範例

salesforceCommerceCloud_read = glueContext.create_dynamic_frame.from_options( connection_type="SalesforceCommerceCloud", connection_options={ "connectionName": "connectionName", "ENTITY_NAME": "coupons", "API_VERSION": "v1", "PARTITION_FIELD": "creationDate", "LOWER_BOUND": "2020-05-01T20:55:02.000Z", "UPPER_BOUND": "2024-07-11T20:55:02.000Z", "NUM_PARTITIONS": "10" } )