Cómo leer datos de entidades de PayPal - AWS Glue
Consultas de particionamiento

Cómo leer datos de entidades de PayPal

Requisito previo

Un objeto de PayPal desde el que desea leer. Necesitará el nombre del objeto, transaction.

Entidades compatibles como origen:

Entidad Se puede filtrar Admite límite Admite Ordenar por Admite Seleccionar * Admite partición
transacción Sí Sí No Sí Sí

Ejemplo:

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

Detalles de entidades y campos de PayPal:

Entidades con metadatos estáticos:

Entidad Campo Tipo de datos: Operadores admitidos
transacción transaction_initiation_date DateTime Entre
last_refreshed_datetime Cadena N/A
payment_instrument_type Cadena =
balance_affecting_records_only Cadena =
id_tienda Cadena =
terminal_id Cadena =
transaction_currency Cadena =
transaction_id Cadena N/A
transaction_status Cadena N/A
transaction_type Cadena N/A
transaction_info Struct N/A
payer_info Struct N/A
shipping_info Struct N/A
cart_info Struct N/A
store_info Struct N/A
auction_info Struct N/A
incentive_info Struct N/A

Consultas de particionamiento

Puede proporcionar las opciones adicionales de Spark PARTITION_FIELD, LOWER_BOUND, UPPER_BOUND y NUM_PARTITIONS si quiere utilizar la simultaneidad en Spark. Con estos parámetros, la consulta original se dividiría en un número NUM_PARTITIONS de subconsultas que las tareas de Spark pueden ejecutar simultáneamente.

  • PARTITION_FIELD: el nombre del campo que se utilizará para particionar la consulta.

  • LOWER_BOUND: un valor de límite inferior inclusivo del campo de partición elegido.

    En el campo Datetime, aceptamos el valor en formato ISO.

    Ejemplos de valor válido:

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

  • UPPER_BOUND: un valor límite superior exclusivo del campo de partición elegido.

  • NUM_PARTITIONS: el número de particiones.

Se admite el siguiente campo para la partición por entidades:

Nombre de la entidad Campos de partición Tipo de datos:
transacción transaction_initiation_date DateTime

Ejemplo:

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