Aus Zoho-CRM-Entitäten lesen - AWS Glue
Partitionierung von Abfragen

Aus Zoho-CRM-Entitäten lesen

Voraussetzung

Zoho-CRM-Objekte, aus denen gelesen werden soll. Sie benötigen den Objektnamen.

Unterstützte Entitäten für Synchronisierungsquelle:

Entität Kann gefiltert werden Unterstützt Limit Unterstützt „Sortieren nach“ Unterstützt „* auswählen“ Unterstützt Partitionierung
Produkt Ja Ja Ja Ja Ja
Angebot Ja Ja Ja Ja Ja
Bestellungen Ja Ja Ja Ja Ja
Lösung Ja Ja Ja Ja Ja
Rufen Sie Ja Ja Ja Ja Ja
Aufgabe Ja Ja Ja Ja Ja
Ereignis Ja Ja Ja Ja Ja
Rechnung Ja Ja Ja Ja Ja
Account Ja Ja Ja Ja Ja
Kontakt Ja Ja Ja Ja Ja
Hersteller Ja Ja Ja Ja Ja
Kampagne Ja Ja Ja Ja Ja
Geschäft Ja Ja Ja Ja Ja
Lead Ja Ja Ja Ja Ja
Benutzerdefiniertes Modul Ja Ja Ja Ja Ja
Kundenauftrag Ja Ja Ja Ja Ja
Preislisten Ja Ja Ja Ja Ja
Case Ja Ja Ja Ja Ja

Beispiel:

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

Unterstützte Entitäten für die Async-Quelle:

Entität Kann gefiltert werden Unterstützt Limit Unterstützt „Sortieren nach“ Unterstützt „* auswählen“ Unterstützt Partitionierung
Produkt Ja Nein Nein Ja Nein
Angebot Ja Nein Nein Ja Nein
Bestellungen Ja Nein Nein Ja Nein
Lösung Ja Nein Nein Ja Nein
Rufen Sie Ja Nein Nein Ja Nein
Aufgabe Ja Nein Nein Ja Nein
Ereignis Ja Nein Nein Ja Nein
Rechnung Ja Nein Nein Ja Nein
Account Ja Nein Nein Ja Nein
Kontakt Ja Nein Nein Ja Nein
Hersteller Ja Nein Nein Ja Nein
Kampagne Ja Nein Nein Ja Nein
Geschäft Ja Nein Nein Ja Nein
Lead Ja Nein Nein Ja Nein
Benutzerdefiniertes Modul Ja Nein Nein Ja Nein
Kundenauftrag Ja Nein Nein Ja Nein
Preislisten Ja Nein Nein Ja Nein
Case Ja Nein Nein Ja Nein

Beispiel:

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

Zoho-CRM-Felddetails:

Zoho CRM bietet Endpunkte zum dynamischen Abrufen von Metadaten für unterstützte Entitäten. Daher wird die Bedienerunterstützung auf der Datentypebene erfasst.

Entität Datentyp Unterstützte Operatoren
Zoho-Entitäten (alle Entitäten) Ganzzahl !=, =, <, <=, >, >=, BETWEEN
String Like, =, !=
BigInteger !=, =, <, <=, >, >=, BETWEEN
Boolesch =
Double !=, =, <, <=, >, >=, BETWEEN
BigDecimal !=, =, <, <=, >, >=, BETWEEN
Datum !=, =, <, <=, >, >=, BETWEEN
DateTime !=, =, <, <=, >, >=, BETWEEN
Struct N/A
Auflisten N/A

Partitionierung von Abfragen

Partitionierung wird im Async-Modus nicht unterstützt.

Filterbasierte Partitionierung (Sync-Modus):

Sie können die zusätzlichen Spark-Optionen PARTITION_FIELD,LOWER_BOUND, UPPER_BOUND und NUM_PARTITIONS angeben, wenn Sie Parallelität in Spark nutzen möchten. Mit diesen Parametern würde die ursprüngliche Abfrage in NUM_PARTITIONS Unterabfragen aufgeteilt, die von Spark-Aufgaben gleichzeitig ausgeführt werden können.

  • PARTITION_FIELD: der Name des Feldes, das zur Partitionierung der Abfrage verwendet werden soll.

  • LOWER_BOUND: ein inklusiver Untergrenzwert des ausgewählten Partitionsfelds.

    Für das DateTime-Feld akzeptieren wir das Spark-Zeitstempelformat, das in Spark-SQL-Abfragen verwendet wird.

    Beispiele für gültigen Wert:

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

  • UPPER_BOUND: ein exklusiver Obergrenzwert des ausgewählten Partitionsfelds.

  • NUM_PARTITIONS: die Anzahl der Partitionen.

Beispiel:

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