Cómo leer de entidades de Twilio - AWS Glue
Consultas de partición

Cómo leer de entidades de Twilio

Requisito previo

Un objeto de Twilio desde el que desea leer. Necesitará el nombre del objeto, como SMS-Message o SMS-CountryPricing.

Entidades compatibles como origen:

Entidad Interfaz Se puede filtrar Admite límite Admite Ordenar por Admite Seleccionar * Admite partición
SMS-Message REST Sí Sí No Sí Sí
SMS-CountryPricing REST No No No Sí No
Voice-Call REST Sí Sí No Sí No
Voice-Application REST Sí Sí No Sí No
Voice-OutgoingCallerID REST Sí Sí No Sí No
Voice-Queue REST Sí Sí No Sí No
Conversations-Conversation REST Sí Sí No Sí No
Conversations-User REST No Sí No Sí No
Conversations-Role REST No Sí No Sí No
Conversations-Configuration REST No No No Sí No
Conversations-AddressConfiguration REST Sí Sí No Sí No
Conversations-WebhookConfiguration REST No No No Sí No
Conversations-ParticipantConversation REST No No No Sí No
Conversations-Credential REST No Sí No Sí No
Conversations-ConversationService REST No Sí No Sí No

Ejemplo:

twilio_read = glueContext.create_dynamic_frame.from_options(
    connection_type="twilio",
    connection_options={
        "connectionName": "connectionName",
        "ENTITY_NAME": "sms-message",
        "API_VERSION": "2010-04-01",
        "Edge_Location": "sydney.us1"
    }

Detalles de entidades y campos de Twilio:

Entidad Campo Tipo de datos: Operadores admitidos
SMS-Message account_sid Cadena N/A
api_version Cadena N/A
cuerpo Cadena N/A
date_created Fecha y hora N/A
date_sent Fecha y hora >=, <=, =
date_updated Fecha y hora N/A
direction Cadena N/A
error_code Entero N/A
error_message Cadena N/A
desde Entero =
messaging_service_sid Cadena N/A
num_media Cadena N/A
num_segments Cadena N/A
precio Cadena N/A
price_unit Struct N/A
sid Entero N/A
status Cadena N/A
subresource_uris Asignación N/A
a Entero =
uri Fecha y hora N/A
SMS-CountryPricing país Cadena N/A
iso_country Cadena N/A
url Cadena N/A
outbound_sms_prices Enumeración N/A
inbound_sms_prices Enumeración N/A
price_unit Cadena N/A
Voice-Call account_sid Cadena N/A
anotación Cadena N/A
answered_by Cadena N/A
api_version Cadena N/A
caller_name Cadena N/A
date_created Fecha y hora N/A
date_updated Fecha y hora N/A
direction Cadena N/A
Duración Cadena N/A
end_time Fecha y hora >=, <=, =
forwarded_from Cadena N/A
desde Cadena =
from_formatted Cadena N/A
group_sid Cadena N/A
parent_call_sid Cadena N/A
phone_number_sid Cadena N/A
precio Cadena N/A
price_unit Cadena N/A
sid Cadena N/A
start_time Fecha y hora >=, <=, =
status Cadena =
subresource_uris Cadena N/A
a Cadena =
to_formatted Cadena N/A
trunk_sid Cadena N/A
uri Cadena N/A
queue_time Cadena N/A
Voice-Application account_sid Cadena N/A
api_version Cadena N/A
date_created Fecha y hora N/A
date_updated Fecha y hora N/A
friendly_name Cadena =
message_status_callback Cadena N/A
sid Cadena N/A
sms_fallback_method Cadena N/A
sms_fallback_url Cadena N/A
sms_method Cadena N/A
sms_status_callback Cadena N/A
sms_url Cadena N/A
status_callback Cadena N/A
status_callback_method Cadena N/A
uri Cadena N/A
voice_caller_id_lookup Booleano N/A
voice_fallback_method Cadena N/A
voice_fallback_url Cadena N/A
voice_method Cadena N/A
voice_url Cadena N/A
public_application_connect_enabled Booleano N/A
Voice-OutgoingCallerID sid Cadena N/A
date_created Fecha y hora N/A
date_updated Fecha y hora N/A
account_sid Cadena N/A
friendly_name Cadena =
phone_number Cadena =
uri Cadena N/A
Voice-Queue date_created Fecha y hora N/A
date_updated Fecha y hora N/A
current_size Entero N/A
friendly_name Cadena N/A
uri Cadena N/A
account_sid Cadena N/A
average_wait_time Entero N/A
sid Cadena N/A
max_size Entero N/A
Conversations-Conversation account_sid Cadena N/A
chat_service_sid Cadena N/A
messaging_service_sid Cadena N/A
sid Cadena N/A
friendly_name Cadena N/A
unique_name Cadena N/A
atributos Cadena N/A
estado Cadena =
date_created Fecha y hora N/A
date_updated Fecha y hora N/A
temporizadores Struct N/A
url Cadena N/A
links Struct N/A
enlaces Struct N/A
start_date Fecha y hora =
end_date Fecha y hora =
Timers.DateInactive Cadena N/A
Timers.DateClosed Cadena N/A
Conversations-User sid Cadena N/A
account_sid Cadena N/A
chat_service_sid Cadena N/A
role_sid Cadena N/A
identidad Cadena N/A
friendly_name Cadena N/A
atributos Cadena N/A
is_online Booleano N/A
is_notifiable Booleano N/A
date_created Fecha y hora N/A
date_updated Fecha y hora N/A
url Cadena N/A
links Struct N/A
Conversations-Role sid Cadena N/A
account_sid Cadena N/A
chat_service_sid Cadena N/A
friendly_name Cadena N/A
type Cadena N/A
permisos Cadena N/A
date_created Fecha y hora N/A
date_updated Fecha y hora N/A
url Cadena N/A
Conversations-Configuration account_sid Largo N/A
default_chat_service_sid Cadena N/A
default_messaging_service_sid Cadena N/A
default_inactive_timer Cadena N/A
default_closed_timer Cadena N/A
url Cadena N/A
links Asignación N/A
Conversations-AddressConfiguration sid Cadena N/A
account_sid Cadena N/A
type Cadena N/A
dirección Cadena N/A
friendly_name Cadena N/A
auto_creation Struct N/A
date_created Fecha y hora N/A
date_updated Fecha y hora N/A
url Cadena N/A
address_country Cadena N/A
AutoCreation.Enabled Booleano N/A
AutoCreation.Type Cadena N/A
AutoCreation.ConversationServiceSid Cadena N/A
AutoCreation.WebhookUrl Cadena N/A
AutoCreation.WebhookMethod Cadena N/A
AutoCreation.WebhookFilters Enumeración N/A
AutoCreation.StudioFlowSid Cadena N/A
AutoCreation.StudioRetryCount Entero N/A
Conversations-WebhookConfiguration account_sid Cadena N/A
method Cadena N/A
filters Enumeración N/A
pre_webhook_url Cadena N/A
post_webhook_url Cadena N/A
destino Cadena N/A
url Cadena N/A
Converations-ParticipantConversation account_sid Cadena N/A
chat_service_sid Cadena N/A
participant_sid Cadena N/A
participant_user_sid Cadena N/A
participant_identity Cadena N/A
participant_messaging_binding Struct N/A
Conversation_sid Cadena N/A
conversation_unique_name Cadena N/A
conversation_friendly_name Cadena N/A
conversation_attributes Cadena N/A
conversation_date_created Fecha y hora N/A
conversation_date_updated Fecha y hora N/A
conversation_created_by Cadena N/A
conversation_state Cadena N/A
conversation_timers Struct N/A
links Asignación N/A
dirección Cadena =
identidad Cadena =
Conversation-Credentials sid Cadena N/A
account_sid Cadena N/A
friendly_name Cadena N/A
type Cadena N/A
entorno de prueba Cadena N/A
date_created Fecha y hora N/A
dated_updated Fecha y hora N/A
url Cadena N/A
certificado Cadena N/A
private_key Cadena N/A
api_key Cadena N/A
secreta Cadena N/A
Conversations-ConversationService sid Cadena N/A
account_sid Cadena N/A
friendly_name Cadena N/A
date_created Fecha y hora N/A
date_updated Fecha y hora N/A
url Cadena N/A
links Asignación N/A

Consultas de partición

Campos que admiten la partición:

En Twilio, los campos de tipo de datos DateTime admiten la partición basada en campos.

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 formato de marca de tiempo de Spark que se utiliza en las consultas SQL de Spark.

    Ejemplos de valor válido:

    "2024-05-01T20:55:02.000Z"

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

  • NUM_PARTITIONS: el número de particiones.

Ejemplo:

twilio_read = glueContext.create_dynamic_frame.from_options(
    connection_type="twilio",
    connection_options={
        "connectionName": "connectionName",
        "ENTITY_NAME": "sms-message",
        "API_VERSION": "2010-04-01",
        "PARTITION_FIELD": "date_sent"
        "LOWER_BOUND": "2024-05-01T20:55:02.000Z"
        "UPPER_BOUND": "2024-06-01T20:55:02.000Z"
        "NUM_PARTITIONS": "10"
    }