Lettura da entità Freshsales - AWS Glue
Query di partizionamento

Lettura da entità Freshsales

Prerequisito

Un oggetto Freshsales da cui si desidera leggere. È necessario il nome dell'oggetto.

Entità supportate come origine:

Entità Può essere filtrato Supporta limite Supporta Ordina per Supporta Seleziona * Supporta il partizionamento
Account Sì Sì Sì Sì Sì
Contatti Sì Sì Sì Sì Sì

Esempio:

freshSales_read = glueContext.create_dynamic_frame.from_options(
     connection_type="freshsales",
     connection_options={
         "connectionName": "connectionName",
         "ENTITY_NAME": "entityName",
         "API_VERSION": "v1.0"
     }

Dettagli dell'entità e del campo di Freshsales:

Freshsales fornisce endpoint per recuperare i metadati in modo dinamico per le entità supportate. Di conseguenza, il supporto dell'operatore viene acquisito a livello di tipo di dati.

Entità Tipo di dati Operatori supportati
Entità Freshsale (tutte) Numero intero !=,=,<,<=,>,>=,BETWEEN
Stringa Like, =, !=
BigInteger !=,=,<,<=,>,>=,BETWEEN
Booleano =
Doppio !=,=,<,<=,>,>=,BETWEEN
BigDecimal !=,=,<,<=,>,>=,BETWEEN
Data !=,=,<,<=,>,>=,BETWEEN
DateTime !=,=,<,<=,>,>=,BETWEEN
Struct N/D
Elenco N/D

Query di partizionamento

Partizionamento basato su filtri:

È possibile fornire le opzioni Spark aggiuntive PARTITION_FIELD, LOWER_BOUND, UPPER_BOUND e NUM_PARTITIONS se si desidera utilizzare la simultaneità in Spark. 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 il campo Datetime, accettiamo il valore in formato ISO.

    Esempi di valori validi:

    "2024-09-30T01:01:01.000Z"

  • UPPER_BOUND: un valore limite superiore esclusivo del campo di partizione scelto.

  • NUM_PARTITIONS: il numero di partizioni.

Esempio:

freshSales_read = glueContext.create_dynamic_frame.from_options(
     connection_type="freshsales",
     connection_options={
         "connectionName": "connectionName",
         "ENTITY_NAME": "entityName",
         "API_VERSION": "v1",
         "PARTITION_FIELD": "Created_Time"
         "LOWER_BOUND": " 2024-10-15T21:16:25Z"
         "UPPER_BOUND": " 2024-10-20T21:25:50Z"
         "NUM_PARTITIONS": "10"
     }