從 Twilio 實體中讀取 - AWS Glue
分區查詢

從 Twilio 實體中讀取

必要條件

您要從中讀取的 Twilio 物件。您將需要物件名稱，例如 SMS-Message 或 SMS-CountryPricing。

來源的支援實體：

實體 介面 可以篩選 支援限制 支援排序依據 支援選取 * 支援分區
SMS-Message REST 是 是 否 是 是
SMS-CountryPricing REST 否 否 否 是 否
Voice-Call REST 是 是 否 是 否
Voice-Application REST 是 是 否 是 否
Voice-OutgoingCallerID REST 是 是 否 是 否
Voice-Queue REST 是 是 否 是 否
Conversations-Conversation REST 是 是 否 是 否
Conversations-User REST 否 是 否 是 否
Conversations-Role REST 否 是 否 是 否
Conversations-Configuration REST 否 否 否 是 否
Conversations-AddressConfiguration REST 是 是 否 是 否
Conversations-WebhookConfiguration REST 否 否 否 是 否
Conversations-ParticipantConversation REST 否 否 否 是 否
Conversations-Credential REST 否 是 否 是 否
Conversations-ConversationService REST 否 是 否 是 否

範例：

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 實體和欄位詳細資訊：

實體 欄位 資料類型 支援的運算子
SMS-Message account_sid String N/A
api_version String N/A
本文 String N/A
date_created 日期時間 N/A
date_sent 日期時間 >=, <=, =
date_updated 日期時間 N/A
direction String N/A
error_code Integer N/A
error_message String N/A
from Integer =
messaging_service_sid String N/A
num_media String N/A
num_segments String N/A
價格 String N/A
price_unit Struct N/A
sid Integer N/A
status String N/A
subresource_uris Map N/A
至 Integer =
uri 日期時間 N/A
SMS-CountryPricing 國家/地區 String N/A
iso_country String N/A
url String N/A
outbound_sms_prices 清單 N/A
inbound_sms_prices 清單 N/A
price_unit String N/A
Voice-Call account_sid String N/A
註釋 String N/A
answered_by String N/A
api_version String N/A
caller_name String N/A
date_created 日期時間 N/A
date_updated 日期時間 N/A
direction String N/A
duration String N/A
end_time 日期時間 >=, <=, =
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
價格 String N/A
price_unit String N/A
sid String N/A
start_time 日期時間 >=, <=, =
status String =
subresource_uris String N/A
至 String =
to_formatted 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 日期時間 N/A
date_updated 日期時間 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 Boolean 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 Boolean N/A
Voice-OutgoingCallerID sid String N/A
date_created 日期時間 N/A
date_updated 日期時間 N/A
account_sid String N/A
friendly_name String =
phone_number String =
uri String N/A
Voice-Queue date_created 日期時間 N/A
date_updated 日期時間 N/A
current_size Integer N/A
friendly_name String N/A
uri String N/A
account_sid String N/A
average_wait_time Integer N/A
sid String N/A
max_size Integer 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
屬性 String N/A
state String =
date_created 日期時間 N/A
date_updated 日期時間 N/A
timers Struct N/A
url String N/A
links Struct N/A
bindings Struct N/A
start_date 日期時間 =
end_date 日期時間 =
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
身分 String N/A
friendly_name String N/A
屬性 String N/A
is_online Boolean N/A
is_notifiable Boolean N/A
date_created 日期時間 N/A
date_updated 日期時間 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
type String N/A
許可 String N/A
date_created 日期時間 N/A
date_updated 日期時間 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 Map N/A
Conversations-AddressConfiguration sid String N/A
account_sid String N/A
type String N/A
address String N/A
friendly_name String N/A
auto_creation Struct N/A
date_created 日期時間 N/A
date_updated 日期時間 N/A
url String N/A
address_country String N/A
AutoCreation.Enabled Boolean N/A
AutoCreation.Type String N/A
AutoCreation.ConversationServiceSid String N/A
AutoCreation.WebhookUrl String N/A
AutoCreation.WebhookMethod String N/A
AutoCreation.WebhookFilters 清單 N/A
AutoCreation.StudioFlowSid String N/A
AutoCreation.StudioRetryCount Integer N/A
Conversations-WebhookConfiguration account_sid String N/A
方法 String N/A
篩選條件 清單 N/A
pre_webhook_url String N/A
post_webhook_url String N/A
目標 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 日期時間 N/A
conversation_date_updated 日期時間 N/A
conversation_created_by String N/A
conversation_state String N/A
conversation_timers Struct N/A
links Map N/A
address String =
身分 String =
Conversation-Credentials sid String N/A
account_sid String N/A
friendly_name String N/A
type String N/A
沙盒 String N/A
date_created 日期時間 N/A
dated_updated 日期時間 N/A
url String N/A
憑證 String N/A
private_key String N/A
api_key String N/A
秘密 String N/A
Conversations-ConversationService sid String N/A
account_sid String N/A
friendly_name String N/A
date_created 日期時間 N/A
date_updated 日期時間 N/A
url String N/A
links Map N/A

分區查詢

支援分區的欄位：

在 Twilio 中，DateTime 資料類型欄位支援欄位型分區。

如果想要在 Spark 中使用並行，可以提供其他 Spark 選項 PARTITION_FIELD、LOWER_BOUND、UPPER_BOUND 和 NUM_PARTITIONS。使用這些參數，原始查詢會分區為可由 Spark 任務並行執行的子查詢的 NUM_PARTITIONS 數目。

  • PARTITION_FIELD：用來分區查詢的欄位名稱。

  • LOWER_BOUND：所選分區欄位的包含下限值。

    對於 Datetime 欄位，我們接受 Spark SQL 查詢中使用的 Spark 時間戳記格式。

    有效值的範例：

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

  • UPPER_BOUND：所選分區欄位的唯一上限值。

  • NUM_PARTITIONS：分區數目。

範例：

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