Lettura dalle entità Zoho CRM - AWS Glue
Query di partizionamento

Lettura dalle entità Zoho CRM

Prerequisito

Oggetti Zoho CRM da cui si desidera leggere. Sarà necessario il nome dell'oggetto.

Entità supportate per origine sincrona:

Entità Può essere filtrata Supporta Limite Supporta Ordina per Supporta Seleziona * Supporta il partizionamento
Product Sì Sì Sì Sì Sì
Quote Sì Sì Sì Sì Sì
Ordine di acquisto Sì Sì Sì Sì Sì
Soluzione Sì Sì Sì Sì Sì
Esegui una chiamata a Sì Sì Sì Sì Sì
Attività Sì Sì Sì Sì Sì
Evento Sì Sì Sì Sì Sì
Fattura Sì Sì Sì Sì Sì
Account Sì Sì Sì Sì Sì
Contatti Sì Sì Sì Sì Sì
Vendor Sì Sì Sì Sì Sì
Campagna Sì Sì Sì Sì Sì
Offerta Sì Sì Sì Sì Sì
Lead Sì Sì Sì Sì Sì
Modulo personalizzato Sì Sì Sì Sì Sì
Ordine di vendita Sì Sì Sì Sì Sì
Prezzari Sì Sì Sì Sì Sì
Caso Sì Sì Sì Sì Sì

Esempio:

zoho_read = glueContext.create_dynamic_frame.from_options(
    connection_type="ZOHO",
    connection_options={
        "connectionName": "connectionName",
        "ENTITY_NAME": "entityName",
        "API_VERSION": "v7",
        "INSTANCE_URL": "https://www.zohoapis.in/"
    }

Entità supportate per l'origine asincrona:

Entità Può essere filtrata Supporta Limite Supporta Ordina per Supporta Seleziona * Supporta il partizionamento
Product Sì No No Sì No
Quote Sì No No Sì No
Ordine di acquisto Sì No No Sì No
Soluzione Sì No No Sì No
Esegui una chiamata a Sì No No Sì No
Attività Sì No No Sì No
Evento Sì No No Sì No
Fattura Sì No No Sì No
Account Sì No No Sì No
Contatti Sì No No Sì No
Vendor Sì No No Sì No
Campagna Sì No No Sì No
Offerta Sì No No Sì No
Lead Sì No No Sì No
Modulo personalizzato Sì No No Sì No
Ordine di vendita Sì No No Sì No
Prezzari Sì No No Sì No
Caso Sì No No Sì No

Esempio:

zoho_read = glueContext.create_dynamic_frame.from_options(
    connection_type="ZOHO",
    connection_options={
        "connectionName": "connectionName",
        "ENTITY_NAME": "entityName",
        "API_VERSION": "v7",
        "INSTANCE_URL": "https://www.zohoapis.in/",
        "TRANSFER_MODE": "ASYNC"
    }

Dettagli del campo Zoho CRM:

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

Entità Tipo di dati Operatori supportati
Entità Zoho (tutte le entità) 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

Il partizionamento non è supportato in modalità asincrona.

Partizionamento basato su filtri (modalità sincrona):

È possibile fornire le opzioni Spark aggiuntive PARTITION_FIELD, LOWER_BOUND, UPPER_BOUND e NUM_PARTITIONS se si desidera utilizzare la concorrenza in Spark. Con questi parametri, la query originale verrebbe suddivisa in un numero di NUM_PARTITIONS di sottoquery 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 formato di timestamp Spark utilizzato nelle query SQL di Spark.

    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:

zoho_read = glueContext.create_dynamic_frame.from_options(
    connection_type="zohocrm",
    connection_options={
        "connectionName": "connectionName",
        "ENTITY_NAME": "entityName",
        "API_VERSION": "v7",
        "PARTITION_FIELD": "Created_Time"
        "LOWER_BOUND": "2022-01-01T01:01:01.000Z"
        "UPPER_BOUND": "2024-01-01T01:01:01.000Z"
        "NUM_PARTITIONS": "10"
    }