Lesen aus Mailchimp-Entitäten
Voraussetzungen
Ein Mailchimp-Objekt, aus dem gelesen werden soll. In der folgenden Tabelle mit unterstützten Entitäten können Sie die verfügbaren Entitäten überprüfen.
Unterstützte Entitäten
| Entität | Kann gefiltert werden | Unterstützt Limit | Unterstützt „Sortieren nach“ | Unterstützt „* auswählen“ | Unterstützt Partitionierung |
|---|---|---|---|---|---|
| Automatisierung | Ja | Ja | Ja | Ja | Ja |
| Kampagnen | Nein | Nein | Nein | Nein | Nein |
| Listen | Ja | Ja | Nein | Ja | Ja |
| Meldet Missbrauch | Nein | Ja | Nein | Ja | Ja |
| Meldet Öffnung | Nein | Ja | Nein | Ja | Ja |
| Meldet Klick | Ja | Ja | Nein | Ja | Ja |
| Meldet Abmeldung | Nein | Ja | Nein | Ja | Ja |
| Segment | Nein | Ja | Nein | Ja | Ja |
| Segmentmitglieder | Ja | Ja | Nein | Ja | Nein |
| Stores | Ja | Ja | Ja | Ja | Nein |
Beispiel
mailchimp_read = glueContext.create_dynamic_frame.from_options( connection_type="mailchimp", connection_options={ "connectionName": "connectionName", "ENTITY_NAME": "stores", "INSTANCE_URL": "https://us14.api.mailchimp.com", "API_VERSION": "3.0" })
Mailchimp-Entitäts- und Felddetails
Partitionierung von Abfragen
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-07-01T00:00:00.000Z"UPPER_BOUND: ein exklusiver Obergrenzwert des ausgewählten Partitionsfelds.NUM_PARTITIONS: die Anzahl der Partitionen.
In der folgenden Tabelle sind Details zur Unterstützung der Partitionierung von Entitäten beschrieben:
| Entity-Name | Partitionierung von Feldern | Datentyp |
|---|---|---|
Beispiel:
read_read = glueContext.create_dynamic_frame.from_options( connection_type="mailchimp", connection_options={ "connectionName": "connectionName", "ENTITY_NAME": "automations", "API_VERSION": "3.0", "INSTANCE_URL": "https://us14.api.mailchimp.com", "PARTITION_FIELD": "create_time", "LOWER_BOUND": "2024-02-05T14:09:30.115Z", "UPPER_BOUND": "2024-06-07T13:30:00.134Z", "NUM_PARTITIONS": "3" }