Lettura da entità di Mailchimp - AWS Glue
Query di partizionamento

Lettura da entità di Mailchimp

Prerequisiti

Un oggetto di Mailchimp da cui si desidera leggere. Consulta la tabella delle entità supportate qui di seguito per verificare le entità disponibili.

Entità supportate

Entità Può essere filtrato Supporta limite Supporta Ordina per Supporta Seleziona * Supporta Partizionamento
Automazione Sì Sì Sì Sì Sì
Campagne No No No No No
Elenchi Sì Sì No Sì Sì
Segnala un abuso No Sì No Sì Sì
Report aperti No Sì No Sì Sì
Report clic Sì Sì No Sì Sì
Report annullamento iscrizione No Sì No Sì Sì
Segmento No Sì No Sì Sì
Membri del segmento Sì Sì No Sì No
Archiviazioni Sì Sì Sì Sì No

Esempio 

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

Dettagli dell'entità e del campo di Mailchimp

Query di partizionamento

Puoi fornire le opzioni Spark aggiuntive PARTITION_FIELD, LOWER_BOUND, UPPER_BOUND e NUM_PARTITIONS se desideri utilizzare la concorrenza in Spark. Con questi parametri, la query originale viene suddivisa in NUM_PARTITIONS query secondarie 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 valore in formato ISO.

    Esempio di valore valido:

    "2024-07-01T00:00:00.000Z"

  • UPPER_BOUND: un valore limite superiore esclusivo del campo di partizione scelto.

  • NUM_PARTITIONS: il numero di partizioni.

Nella seguente tabella sono descritti i dettagli del campo di supporto del partizionamento delle entità:

Nome dell'entità Campi di partizionamento Tipo di dati

Esempio:

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