Lecture à partir d’entités Mailchimp
Prérequis
Un objet Mailchimp à partir duquel vous souhaitez lire. Reportez-vous au tableau des entités prises en charge ci-dessous pour vérifier les entités disponibles.
Entités prises en charge
| Entité | Peut être filtré | Limit prise en charge | Order by prise en charge | Select prise en charge* | Partitionnement pris en charge |
|---|---|---|---|---|---|
| Automatisation | Oui | Oui | Oui | Oui | Oui |
| Campagnes | Non | Non | Non | Non | Non |
| Listes | Oui | Oui | Non | Oui | Oui |
| Reports Abuse | Non | Oui | Non | Oui | Oui |
| Reports Open | Non | Oui | Non | Oui | Oui |
| Reports Click | Oui | Oui | Non | Oui | Oui |
| Reports Unsubscribe | Non | Oui | Non | Oui | Oui |
| Segment | Non | Oui | Non | Oui | Oui |
| Segment Members | Oui | Oui | Non | Oui | Non |
| Stores | Oui | Oui | Oui | Oui | Non |
Exemple
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" })
Détails des entités et des champs Mailchimp
Requêtes de partitionnement
Vous pouvez indiquer les options Spark supplémentaires PARTITION_FIELD, LOWER_BOUND, UPPER_BOUND et NUM_PARTITIONS si vous souhaitez utiliser la simultanéité dans Spark. Avec ces paramètres, la requête d’origine serait divisée en NUM_PARTITIONS nombres de sous-requêtes pouvant être exécutées simultanément par les tâches Spark.
PARTITION_FIELD: le nom du champ à utiliser pour partitionner la requête.LOWER_BOUND: une valeur limite inférieure inclusive du champ de partition choisi.Pour le champ DateTime, nous acceptons la valeur au format ISO.
Exemple de valeur valide :
"2024-07-01T00:00:00.000Z"UPPER_BOUND: une valeur limite supérieure exclusive du champ de partition choisi.NUM_PARTITIONS: le nombre de partitions.
Le tableau suivant décrit les détails de prise en charge dans les champs de partitionnement d’entités :
| Nom de l’entité | Champs de partitionnement | Type de données |
|---|---|---|
Exemple :
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" }