从 Twilio 实体读取内容 - AWS Glue
对查询进行分区

从 Twilio 实体读取内容

先决条件

要从中读取内容的 Twilio 对象。您将需要 SMS-Message 或 SMS-CountryPricing 等对象名称。

源支持的实体：

实体 接口 可以筛选 支持限制 支持排序依据 支持 Select * 支持分区
SMS-消息 REST 支持 是 否 是 是
SMS-国家定价 REST 否 否 否 是 否
语音-呼叫 REST 支持 是 否 是 否
语音-应用程序 REST 支持 是 否 是 否
语音-主叫方 ID REST 支持 是 否 是 否
语音-队列 REST 支持 是 否 是 否
对话-对话 REST 支持 是 否 是 否
对话-用户 REST 否 是 否 是 否
对话-角色 REST 否 是 否 是 否
对话-配置 REST 否 否 否 是 否
对话-地址配置 REST 支持 是 否 是 否
对话-Webhook 配置 REST 否 否 否 是 否
对话-参与者对话 REST 否 否 否 是 否
对话-凭证 REST 否 是 否 是 否
对话-对话服务 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-消息 account_sid 字符串 不适用
api_version 字符串 不适用
body 字符串 不适用
date_created 日期时间 不适用
date_sent 日期时间 >=, <=, =
date_updated 日期时间 不适用
方向 字符串 不适用
error_code 整数 不适用
error_message 字符串 不适用
from 整数 =
messaging_service_sid 字符串 不适用
num_media 字符串 不适用
num_segments 字符串 不适用
价格 字符串 不适用
price_unit 结构体 不适用
sid 整数 不适用
状态 字符串 不适用
subresource_uris Map 不适用
到 整数 =
uri 日期时间 不适用
SMS-国家定价 country 字符串 不适用
iso_country 字符串 不适用
url 字符串 不适用
outbound_sms_prices 列表 不适用
inbound_sms_prices 列表 不适用
price_unit 字符串 不适用
语音-呼叫 account_sid 字符串 不适用
annotation 字符串 不适用
answered_by 字符串 不适用
api_version 字符串 不适用
caller_name 字符串 不适用
date_created 日期时间 不适用
date_updated 日期时间 不适用
方向 字符串 不适用
duration 字符串 不适用
end_time 日期时间 >=, <=, =
forwarded_from 字符串 不适用
from 字符串 =
from_formatted 字符串 不适用
group_sid 字符串 不适用
parent_call_sid 字符串 不适用
phone_number_sid 字符串 不适用
价格 字符串 不适用
price_unit 字符串 不适用
sid 字符串 不适用
start_time 日期时间 >=, <=, =
状态 字符串 =
subresource_uris 字符串 不适用
到 字符串 =
to_formatted 字符串 不适用
trunk_sid 字符串 不适用
uri 字符串 不适用
queue_time 字符串 不适用
语音-应用程序 account_sid 字符串 不适用
api_version 字符串 不适用
date_created 日期时间 不适用
date_updated 日期时间 不适用
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 布尔值 不适用
语音-主叫方 ID sid 字符串 不适用
date_created 日期时间 不适用
date_updated 日期时间 不适用
account_sid 字符串 不适用
friendly_name 字符串 =
phone_number 字符串 =
uri 字符串 不适用
语音-队列 date_created 日期时间 不适用
date_updated 日期时间 不适用
current_size 整数 不适用
friendly_name 字符串 不适用
uri 字符串 不适用
account_sid 字符串 不适用
average_wait_time 整数 不适用
sid 字符串 不适用
max_size 整数 不适用
对话-对话 account_sid 字符串 不适用
chat_service_sid 字符串 不适用
messaging_service_sid 字符串 不适用
sid 字符串 不适用
friendly_name 字符串 不适用
unique_name 字符串 不适用
属性 字符串 不适用
状态 字符串 =
date_created 日期时间 不适用
date_updated 日期时间 不适用
计时器 结构体 不适用
url 字符串 不适用
links 结构体 不适用
绑定 结构体 不适用
start_date 日期时间 =
end_date 日期时间 =
Timers.DateInactive 字符串 不适用
Timers.DateClosed 字符串 不适用
对话-用户 sid 字符串 不适用
account_sid 字符串 不适用
chat_service_sid 字符串 不适用
role_sid 字符串 不适用
identity 字符串 不适用
friendly_name 字符串 不适用
属性 字符串 不适用
is_online 布尔值 不适用
is_notifiable 布尔值 不适用
date_created 日期时间 不适用
date_updated 日期时间 不适用
url 字符串 不适用
links 结构体 不适用
对话-角色 sid 字符串 不适用
account_sid 字符串 不适用
chat_service_sid 字符串 不适用
friendly_name 字符串 不适用
type 字符串 不适用
权限 字符串 不适用
date_created 日期时间 不适用
date_updated 日期时间 不适用
url 字符串 不适用
对话-配置 account_sid 长整型 不适用
default_chat_service_sid 字符串 不适用
default_messaging_service_sid 字符串 不适用
default_inactive_timer 字符串 不适用
default_closed_timer 字符串 不适用
url 字符串 不适用
links Map 不适用
对话-地址配置 sid 字符串 不适用
account_sid 字符串 不适用
type 字符串 不适用
地址 字符串 不适用
friendly_name 字符串 不适用
auto_creation 结构体 不适用
date_created 日期时间 不适用
date_updated 日期时间 不适用
url 字符串 不适用
address_country 字符串 不适用
AutoCreation.Enabled 布尔值 不适用
AutoCreation.Type 字符串 不适用
AutoCreation.ConversationServiceSid 字符串 不适用
AutoCreation.WebhookUrl 字符串 不适用
AutoCreation.WebhookMethod 字符串 不适用
AutoCreation.WebhookFilters 列表 不适用
AutoCreation.StudioFlowSid 字符串 不适用
AutoCreation.StudioRetryCount 整数 不适用
对话-Webhook 配置 account_sid 字符串 不适用
method 字符串 不适用
filters 列表 不适用
pre_webhook_url 字符串 不适用
post_webhook_url 字符串 不适用
target 字符串 不适用
url 字符串 不适用
对话-参与者对话 account_sid 字符串 不适用
chat_service_sid 字符串 不适用
participant_sid 字符串 不适用
participant_user_sid 字符串 不适用
participant_identity 字符串 不适用
participant_messaging_binding 结构体 不适用
Conversation_sid 字符串 不适用
conversation_unique_name 字符串 不适用
conversation_friendly_name 字符串 不适用
conversation_attributes 字符串 不适用
conversation_date_created 日期时间 不适用
conversation_date_updated 日期时间 不适用
conversation_created_by 字符串 不适用
conversation_state 字符串 不适用
conversation_timers 结构体 不适用
links Map 不适用
地址 字符串 =
identity 字符串 =
对话-凭证 sid 字符串 不适用
account_sid 字符串 不适用
friendly_name 字符串 不适用
type 字符串 不适用
沙盒 字符串 不适用
date_created 日期时间 不适用
dated_updated 日期时间 不适用
url 字符串 不适用
证书 字符串 不适用
private_key 字符串 不适用
api_key 字符串 不适用
secret 字符串 不适用
对话-对话服务 sid 字符串 不适用
account_sid 字符串 不适用
friendly_name 字符串 不适用
date_created 日期时间 不适用
date_updated 日期时间 不适用
url 字符串 不适用
links Map 不适用

对查询进行分区

支持分区的字段：

在 Twilio 中，“日期时间”数据类型字段支持基于字段的分区。

如果您想在 Spark 中利用并发，可以提供其他 Spark 选项：PARTITION_FIELD、LOWER_BOUND、UPPER_BOUND 和 NUM_PARTITIONS。使用这些参数，原始查询将被拆分为 NUM_PARTITIONS 个子查询，这些子查询可以由 Spark 任务同时执行。

  • PARTITION_FIELD：用于对查询进行分区的字段的名称。

  • LOWER_BOUND：所选分区字段的包含下限值。

    对于“日期时间”字段，我们接受 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"
    }