Twilio エンティティからの読み取り - AWS Glue
パーティショニングクエリ

Twilio エンティティからの読み取り

前提条件

読み取り元の Twilio オブジェクト。SMS-Message または SMS-CountryPricing などのオブジェクト名が必要です。

ソースに対応するエンティティ:

エンティティ インターフェイス フィルタリング可能 制限をサポートする Order By をサポートする Select * をサポートする パーティション分割をサポートする
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 文字列 該当なし
api_version 文字列 該当なし
本文 文字列 該当なし
date_created Datetime 該当なし
date_sent Datetime >=, <=, =
date_updated Datetime 該当なし
direction 文字列 該当なし
error_code 整数 該当なし
error_message 文字列 該当なし
送信元 整数 =
messaging_service_sid 文字列 該当なし
num_media 文字列 該当なし
num_segments 文字列 該当なし
料金 文字列 該当なし
price_unit Struct 該当なし
sid 整数 該当なし
ステータス 文字列 該当なし
subresource_uris マッピング 該当なし
次のように変更します。 整数 =
uri Datetime 該当なし
SMS-CountryPricing country 文字列 該当なし
iso_country 文字列 該当なし
url 文字列 該当なし
outbound_sms_prices リスト 該当なし
inbound_sms_prices リスト 該当なし
price_unit 文字列 該当なし
Voice-Call account_sid 文字列 該当なし
注釈 文字列 該当なし
answered_by 文字列 該当なし
api_version 文字列 該当なし
caller_name 文字列 該当なし
date_created Datetime 該当なし
date_updated Datetime 該当なし
direction 文字列 該当なし
duration 文字列 該当なし
end_time Datetime >=, <=, =
forwarded_from 文字列 該当なし
送信元 文字列 =
from_formatted 文字列 該当なし
group_sid 文字列 該当なし
parent_call_sid 文字列 該当なし
phone_number_sid 文字列 該当なし
料金 文字列 該当なし
price_unit 文字列 該当なし
sid 文字列 該当なし
start_time Datetime >=, <=, =
ステータス 文字列 =
subresource_uris 文字列 該当なし
次のように変更します。 文字列 =
to_formatted 文字列 該当なし
trunk_sid 文字列 該当なし
uri 文字列 該当なし
queue_time 文字列 該当なし
Voice-Application account_sid 文字列 該当なし
api_version 文字列 該当なし
date_created Datetime 該当なし
date_updated Datetime 該当なし
friendly_name 文字列 =
message_status_callback 文字列 該当なし
sid 文字列 該当なし
sms_fallback_method 文字列 該当なし
sms_fallback_url 文字列 該当なし
sms_method 文字列 該当なし
sms_status_callback 文字列 該当なし
sms_url 文字列 該当なし
status_callback 文字列 該当なし
status_callback_method 文字列 該当なし
uri 文字列 該当なし
voice_caller_id_lookup ブール値 該当なし
voice_fallback_method 文字列 該当なし
voice_fallback_url 文字列 該当なし
voice_method 文字列 該当なし
voice_url 文字列 該当なし
public_application_connect_enabled ブール値 該当なし
Voice-OutgoingCallerID sid 文字列 該当なし
date_created Datetime 該当なし
date_updated Datetime 該当なし
account_sid 文字列 該当なし
friendly_name 文字列 =
phone_number 文字列 =
uri 文字列 該当なし
Voice-Queue date_created Datetime 該当なし
date_updated Datetime 該当なし
current_size 整数 該当なし
friendly_name 文字列 該当なし
uri 文字列 該当なし
account_sid 文字列 該当なし
average_wait_time 整数 該当なし
sid 文字列 該当なし
max_size 整数 該当なし
Conversations-Conversation account_sid 文字列 該当なし
chat_service_sid 文字列 該当なし
messaging_service_sid 文字列 該当なし
sid 文字列 該当なし
friendly_name 文字列 該当なし
unique_name 文字列 該当なし
属性 文字列 該当なし
state 文字列 =
date_created Datetime 該当なし
date_updated Datetime 該当なし
タイマー Struct 該当なし
url 文字列 該当なし
links Struct 該当なし
バインディング Struct 該当なし
start_date Datetime =
end_date Datetime =
Timers.DateInactive 文字列 該当なし
Timers.DateClosed 文字列 該当なし
Conversations-User sid 文字列 該当なし
account_sid 文字列 該当なし
chat_service_sid 文字列 該当なし
role_sid 文字列 該当なし
identity 文字列 該当なし
friendly_name 文字列 該当なし
属性 文字列 該当なし
is_online ブール値 該当なし
is_notable ブール値 該当なし
date_created Datetime 該当なし
date_updated Datetime 該当なし
url 文字列 該当なし
links Struct 該当なし
Conversations-Role sid 文字列 該当なし
account_sid 文字列 該当なし
chat_service_sid 文字列 該当なし
friendly_name 文字列 該当なし
type 文字列 該当なし
アクセス許可 文字列 該当なし
date_created Datetime 該当なし
date_updated Datetime 該当なし
url 文字列 該当なし
Conversations-Configuration account_sid Long 該当なし
default_chat_service_sid 文字列 該当なし
default_messaging_service_sid 文字列 該当なし
default_inactive_timer 文字列 該当なし
default_closed_timer 文字列 該当なし
url 文字列 該当なし
links マッピング 該当なし
Conversations-AddressConfiguration sid 文字列 該当なし
account_sid 文字列 該当なし
type 文字列 該当なし
アドレス 文字列 該当なし
friendly_name 文字列 該当なし
auto_creation Struct 該当なし
date_created Datetime 該当なし
date_updated Datetime 該当なし
url 文字列 該当なし
address_country 文字列 該当なし
AutoCreation.Enabled ブール値 該当なし
AutoCreation.Type 文字列 該当なし
AutoCreation.ConversationServiceSid 文字列 該当なし
AutoCreation.WebhookUrl 文字列 該当なし
AutoCreation.WebhookMethod 文字列 該当なし
AutoCreation.WebhookFilters リスト 該当なし
AutoCreation.StudioFlowSid 文字列 該当なし
ｑAutoCreation.StudioRetryCount 整数 該当なし
Conversations-WebhookConfiguration account_sid 文字列 該当なし
method 文字列 該当なし
フィルター リスト 該当なし
pre_webhook_url 文字列 該当なし
post_webhook_url 文字列 該当なし
target 文字列 該当なし
url 文字列 該当なし
Converations-ParticipantConversation account_sid 文字列 該当なし
chat_service_sid 文字列 該当なし
participant_sid 文字列 該当なし
Participant_user_sid 文字列 該当なし
participant_identity 文字列 該当なし
Participant_messaging_binding Struct 該当なし
Conversation_sid 文字列 該当なし
conversation_unique_name 文字列 該当なし
conversation_friendly_name 文字列 該当なし
conversation_attributes 文字列 該当なし
conversation_date_created Datetime 該当なし
conversation_date_updated Datetime 該当なし
conversation_created_by 文字列 該当なし
conversation_state 文字列 該当なし
conversation_timers Struct 該当なし
links マッピング 該当なし
アドレス 文字列 =
identity 文字列 =
Conversation-Credentials sid 文字列 該当なし
account_sid 文字列 該当なし
friendly_name 文字列 該当なし
type 文字列 該当なし
サンドボックス 文字列 該当なし
date_created Datetime 該当なし
dated_updated Datetime 該当なし
url 文字列 該当なし
証明書 文字列 該当なし
private_key 文字列 該当なし
api_key 文字列 該当なし
シークレット 文字列 該当なし
Conversations-ConversationService sid 文字列 該当なし
account_sid 文字列 該当なし
friendly_name 文字列 該当なし
date_created Datetime 該当なし
date_updated Datetime 該当なし
url 文字列 該当なし
links マッピング 該当なし

パーティショニングクエリ

パーティション分割をサポートするフィールド:

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