Lettura dalle entità Salesforce Commerce Cloud
Prerequisiti
-
Un oggetto di Salesforce Commerce Cloud da cui si desidera leggere. Consultare la tabella delle entità supportate qui di seguito per verificare quelle disponibili.
Entità supportate
| Entità | Può essere Filtrato | Supporta Limite | Supporta Ordina per | Supporta Seleziona * | Supporta Partizionamento |
|---|---|---|---|---|---|
| Assegnazioni | Sì | Sì | Sì | Sì | Sì |
| Campagne | Sì | Sì | Sì | Sì | Sì |
| Cataloghi | Sì | Sì | Sì | Sì | Sì |
| Categories | Sì | Sì | Sì | Sì | Sì |
| Coupon | Sì | Sì | Sì | Sì | Sì |
| Certificati regalo | Sì | Sì | Sì | Sì | Sì |
| Prodotti | Sì | Sì | Sì | Sì | Sì |
| Promozioni | Sì | Sì | Sì | Sì | Sì |
| Gruppi di codice sorgente | Sì | Sì | Sì | Sì | Sì |
Esempio
salesforce_commerce_cloud_read = glueContext.create_dynamic_frame.from_options( connection_type="SalesforceCommerceCloud", connection_options={ "connectionName": "connectionName", "ENTITY_NAME": "campaign", "API_VERSION": "v1" } )
Dettagli dell'entità e del campo di Salesforce Commerce Cloud
Elenco delle entità:
-
Assegnazioni: https://developer.salesforce.com/docs/commerce/commerce-api/references/assignments
-
Campagne: https://developer.salesforce.com/docs/commerce/commerce-api/references/campaigns
-
Cataloghi: https://developer.salesforce.com/docs/commerce/commerce-api/references/catalogs
-
Certificati regalo: https://developer.salesforce.com/docs/commerce/commerce-api/references/gift-certificates
-
Prodotti: https://developer.salesforce.com/docs/commerce/commerce-api/references/products
-
Promozioni: https://developer.salesforce.com/docs/commerce/commerce-api/references/promotions
-
Gruppi di codice sorgente: https://developer.salesforce.com/docs/commerce/commerce-api/references/source-code-groups
Query di partizionamento
Se si desidera utilizzare la simultaneità in Spark, possono essere fornite opzioni Spark PARTITION_FIELD, LOWER_BOUND, UPPER_BOUND, NUM_PARTITIONS aggiuntive. Con questi parametri, la query originale viene suddivisa in NUM_PARTITIONS query secondarie che possono essere eseguite contemporaneamente dalle attività Spark.
-
PARTITION_FIELD: il nome del campo da utilizzare per partizionare la query. -
LOWER_BOUND: un valore limite inferiore inclusivo del campo di partizione scelto.Per la data, accettiamo il formato di data di Spark utilizzato nelle query di Spark SQL. Esempio di valori validi:
"2024-02-06". -
UPPER_BOUND: un valore limite superiore esclusivo del campo di partizione scelto. -
NUM_PARTITIONS: numero di partizioni.
I dettagli di supporto del campo di partizionamento per entità sono riportati nella tabella di seguito:
| Entità | Campo di partizionamento | DataType |
|---|---|---|
| Campagne | lastModified | DateTime |
| Campagne | startDate | DateTime |
| Campagne | endDate | DateTime |
| Cataloghi | creationDate | DateTime |
| Categories | creationDate | DateTime |
| Certificati regalo | merchantId | Stringa |
| Certificati regalo | creationDate | DateTime |
| Prodotti | creationDate | DateTime |
| Prodotti | lastModified | DateTime |
| Gruppi di codice sorgente | creationDate | DateTime |
| Gruppi di codice sorgente | startTime | DateTime |
| Gruppi di codice sorgente | endTime | DateTime |
Esempio
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" } )