Lesen aus Twilio-Entitäten - AWS Glue
Partitionieren von Abfragen

Lesen aus Twilio-Entitäten

Voraussetzung

Ein Twilio-Objekt, aus dem gelesen werden soll. Sie benötigen den Objektnamen wie SMS-Message oder SMS-CountryPricing.

Unterstützte Entitäten für Quelle:

Entität Schnittstelle Kann gefiltert werden Unterstützt Limit Unterstützt „Sortieren nach“ Unterstützt „* auswählen“ Unterstützt Partitionierung
SMS-Message REST Ja Ja Nein Ja Ja
SMS-CountryPricing REST Nein Nein Nein Ja Nein
Voice-Call REST Ja Ja Nein Ja Nein
Voice-Application REST Ja Ja Nein Ja Nein
Voice-OutgoingCallerID REST Ja Ja Nein Ja Nein
Voice-Queue REST Ja Ja Nein Ja Nein
Conversations-Conversation REST Ja Ja Nein Ja Nein
Conversations-User REST Nein Ja Nein Ja Nein
Conversations-Role REST Nein Ja Nein Ja Nein
Conversations-Configuration REST Nein Nein Nein Ja Nein
Conversations-AddressConfiguration REST Ja Ja Nein Ja Nein
Conversations-WebhookConfiguration REST Nein Nein Nein Ja Nein
Conversations-ParticipantConversation REST Nein Nein Nein Ja Nein
Conversations-Credential REST Nein Ja Nein Ja Nein
Conversations-ConversationService REST Nein Ja Nein Ja Nein

Beispiel:

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

Twilio-Entitäts- und Felddetails

Entität Feld Datentyp Unterstützte Operatoren
SMS-Message account_sid String N/A
api_version String N/A
body String N/A
date_created DateTime N/A
date_sent DateTime >=, <=, =
date_updated DateTime N/A
direction String N/A
error_code Ganzzahl N/A
error_message String N/A
from Ganzzahl =
messaging_service_sid String N/A
num_media String N/A
num_segments String N/A
price String N/A
price_unit Struct N/A
sid Ganzzahl N/A
Status String N/A
subresource_uris Zuordnung N/A
to Ganzzahl =
uri DateTime N/A
SMS-CountryPricing country String N/A
iso_country String N/A
URL String N/A
outbound_sms_prices Auflisten N/A
inbound_sms_prices Auflisten N/A
price_unit String N/A
Voice-Call account_sid String N/A
Anmerkung String N/A
answered_by String N/A
api_version String N/A
caller_name String N/A
date_created DateTime N/A
date_updated DateTime N/A
direction String N/A
duration String N/A
end_time DateTime >=, <=, =
forwarded_from String N/A
from String =
from_formatted String N/A
group_sid String N/A
parent_call_sid String N/A
phone_number_sid String N/A
price String N/A
price_unit String N/A
sid String N/A
start_time DateTime >=, <=, =
Status String =
subresource_uris String N/A
to String =
to_formatiert String N/A
trunk_sid String N/A
uri String N/A
queue_time String N/A
Voice-Application account_sid String N/A
api_version String N/A
date_created DateTime N/A
date_updated DateTime N/A
friendly_name String =
message_status_callback String N/A
sid String N/A
sms_fallback_method String N/A
sms_fallback_url String N/A
sms_method String N/A
sms_status_callback String N/A
sms_url String N/A
status_callback String N/A
status_callback_method String N/A
uri String N/A
voice_caller_id_lookup Boolesch N/A
voice_fallback_method String N/A
voice_fallback_url String N/A
voice_method String N/A
voice_url String N/A
public_application_connect_enabled Boolesch N/A
Voice-OutgoingCallerID sid String N/A
date_created DateTime N/A
date_updated DateTime N/A
account_sid String N/A
friendly_name String =
phone_number String =
uri String N/A
Voice-Queue date_created DateTime N/A
date_updated DateTime N/A
current_size Ganzzahl N/A
friendly_name String N/A
uri String N/A
account_sid String N/A
average_wait_time Ganzzahl N/A
sid String N/A
max_size Ganzzahl N/A
Conversations-Conversation account_sid String N/A
chat_service_sid String N/A
messaging_service_sid String N/A
sid String N/A
friendly_name String N/A
unique_name String N/A
Attribute String N/A
state String =
date_created DateTime N/A
date_updated DateTime N/A
timers Struct N/A
URL String N/A
links Struct N/A
bindings Struct N/A
start_date DateTime =
end_date DateTime =
Timers.DateInactive String N/A
Timers.DateClosed String N/A
Conversations-User sid String N/A
account_sid String N/A
chat_service_sid String N/A
role_sid String N/A
Identitäts String N/A
friendly_name String N/A
Attribute String N/A
is_online Boolesch N/A
is_notifiable Boolesch N/A
date_created DateTime N/A
date_updated DateTime N/A
URL String N/A
links Struct N/A
Conversations-Role sid String N/A
account_sid String N/A
chat_service_sid String N/A
friendly_name String N/A
Typ String N/A
permissions String N/A
date_created DateTime N/A
date_updated DateTime N/A
URL String N/A
Conversations-Configuration account_sid Long N/A
default_chat_service_sid String N/A
default_messaging_service_sid String N/A
default_inactive_timer String N/A
default_closed_timer String N/A
URL String N/A
links Zuordnung N/A
Conversations-AddressConfiguration sid String N/A
account_sid String N/A
Typ String N/A
address String N/A
friendly_name String N/A
auto_creation Struct N/A
date_created DateTime N/A
date_updated DateTime N/A
URL String N/A
address_country String N/A
AutoCreation.Enabled Boolesch N/A
AutoCreation.Type String N/A
AutoCreation.ConversationServiceSid String N/A
AutoCreation.WebhookUrl String N/A
AutoCreation.WebhookMethod String N/A
AutoCreation.WebhookFilters Auflisten N/A
AutoCreation.StudioFlowSid String N/A
AutoCreation.StudioRetryCount Ganzzahl N/A
Conversations-WebhookConfiguration account_sid String N/A
Methode String N/A
-Filter Auflisten N/A
pre_webhook_url String N/A
post_webhook_url String N/A
Ziel String N/A
URL String N/A
Converations-ParticipantConversation account_sid String N/A
chat_service_sid String N/A
participant_sid String N/A
participant_user_sid String N/A
participant_identity String N/A
participant_messaging_binding Struct N/A
Conversation_sid String N/A
conversation_unique_name String N/A
conversation_friendly_name String N/A
conversation_attributes String N/A
conversation_date_created DateTime N/A
conversation_date_updated DateTime N/A
conversation_created_by String N/A
conversation_state String N/A
conversation_timers Struct N/A
links Zuordnung N/A
address String =
Identitäts String =
Conversation-Credentials sid String N/A
account_sid String N/A
friendly_name String N/A
Typ String N/A
Sandbox String N/A
date_created DateTime N/A
dated_updated DateTime N/A
URL String N/A
Zertifikat String N/A
private_key String N/A
api_key String N/A
Secret String N/A
Conversations-ConversationService sid String N/A
account_sid String N/A
friendly_name String N/A
date_created DateTime N/A
date_updated DateTime N/A
URL String N/A
links Zuordnung N/A

Partitionieren von Abfragen

Felder, die Partitionierung unterstützen:

In Twilio unterstützen die Datentypfelder „DateTime“ die feldbasierte Partitionierung.

Sie können die zusätzlichen Spark-Optionen PARTITION_FIELD, LOWER_BOUND, UPPER_BOUND und NUM_PARTITIONS angeben, wenn Sie Parallelität in Spark nutzen möchten. Mit diesen Parametern wird die ursprüngliche Abfrage in NUM_PARTITIONS Unterabfragen aufgeteilt, die von Spark-Aufgaben gleichzeitig ausgeführt werden können.

  • PARTITION_FIELD: der Name des Feldes, das zur Partitionierung der Abfrage verwendet werden soll.

  • LOWER_BOUND: ein inklusiver Untergrenzwert des ausgewählten Partitionsfelds.

    Für das DateTime-Feld akzeptieren wir das Spark-Zeitstempelformat, das in Spark-SQL-Abfragen verwendet wird.

    Beispiele für gültigen Wert:

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

  • UPPER_BOUND: ein exklusiver Obergrenzwert des ausgewählten Partitionsfelds.

  • NUM_PARTITIONS: die Anzahl der Partitionen.

Beispiel:

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