本文為英文版的機器翻譯版本,如內容有任何歧義或不一致之處,概以英文版為準。
從 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 實體和欄位詳細資訊
實體清單:
-
指派:https://developer.salesforce.com/docs/commerce/commerce-api/references/assignments
-
行銷活動:https://developer.salesforce.com/docs/commerce/commerce-api/references/campaigns
-
型錄:https://developer.salesforce.com/docs/commerce/commerce-api/references/catalogs
-
禮品券:https://https://developer.salesforce.com/docs/commerce/commerce-api/references/gift-certificates
-
產品:https://developer.salesforce.com/docs/commerce/commerce-api/references/products
-
促銷活動:https://developer.salesforce.com/docs/commerce/commerce-api/references/promotions
-
原始程式碼群組:https://developer.salesforce.com/docs/commerce/commerce-api/references/source-code-groups
分區查詢
如果想要在 Spark 中使用並行,可以提供其他 Spark 選項 PARTITION_FIELD、LOWER_BOUND、UPPER_BOUND、NUM_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" } )