Lettura dalle entità Salesforce Commerce Cloud - AWS Glue

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
Campagne
Cataloghi
Categories
Coupon
Certificati regalo
Prodotti
Promozioni
Gruppi di codice sorgente

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à:

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" } )