Lesen aus Freshsales-Einheiten - AWS Glue
Partitionierung von Abfragen

Lesen aus Freshsales-Einheiten

Voraussetzung

Ein Freshsale-Objekt, aus dem gelesen werden soll. Sie benötigen den Objektnamen.

Unterstützte Entitäten für Quelle:

Entität Kann gefiltert werden Unterstützt Limit Unterstützt „Sortieren nach“ Unterstützt „* auswählen“ Unterstützt Partitionierung
Konten Ja Ja Ja Ja Ja
Kontakte Ja Ja Ja Ja Ja

Beispiel:

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

Freshsales-Entität und Felddetails:

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

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

Partitionierung von Abfragen

Filterbasierte Partitionierung:

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 den Wert im ISO-Format.

    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:

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