Lettura da entità PayPal - AWS Glue
Query di partizionamento

Lettura da entità PayPal

Prerequisito

Un oggetto PayPal da cui si desidera leggere. È necessario il nome dell'oggetto, transaction.

Entità supportate come origine:

Entità Può essere filtrato Supporta Limite Supporta Ordina per Supporta Seleziona * Supporta il partizionamento
transaction Sì Sì No Sì Sì

Esempio:

paypal_read = glueContext.create_dynamic_frame.from_options(
    connection_type="paypal",
    connection_options={
        "connectionName": "connectionName",
        "ENTITY_NAME": "transaction",
        "API_VERSION": "v1",
        "INSTANCE_URL": "https://api-m.paypal.com"
    }

Dettagli dell'entità e del campo di PayPal

Entità con metadati statici:

Entità Campo Tipo di dati Operatori supportati
transaction transaction_initiation_date DateTime Tra
last_refreshed_datetime Stringa N/A
payment_instrument_type Stringa =
balance_affecting_records_only Stringa =
store_id Stringa =
terminal_id Stringa =
transaction_currency Stringa =
transaction_id Stringa N/A
transaction_status Stringa N/A
transaction_type Stringa N/A
transaction_info Struct N/D
payer_info Struct N/D
shipping_info Struct N/D
cart_info Struct N/D
store_info Struct N/D
auction_info Struct N/D
incentive_info Struct N/D

Query di partizionamento

È possibile fornire le opzioni Spark aggiuntive PARTITION_FIELD, LOWER_BOUND, UPPER_BOUND e NUM_PARTITIONS se si desidera utilizzare la simultaneità 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.

    Esempi di valori validi:

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

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

  • NUM_PARTITIONS: il numero di partizioni.

Il seguente campo è supportato per il partizionamento per entità:

Nome dell'entità Campi di partizionamento Tipo di dati
transaction transaction_initiation_date DateTime

Esempio:

paypal_read = glueContext.create_dynamic_frame.from_options(
    connection_type="paypal",
    connection_options={
        "connectionName": "connectionName",
        "ENTITY_NAME": "transaction",
        "API_VERSION": "v1",
        "PARTITION_FIELD": "transaction_initiation_date"
        "LOWER_BOUND": "2024-07-01T00:00:00.000Z"
        "UPPER_BOUND": "2024-07-02T00:00:00.000Z"
        "NUM_PARTITIONS": "10"
    }