从 Adobe Marketo Engage 实体中读取
先决条件
您要从中读取内容的 Adobe Marketo Engage 对象。您将需要潜在客户、活动或自定义对象等对象名称。下表显示支持的实体。
源支持的实体（同步）：
| 实体 | 可以筛选 | 支持限制 | 支持排序依据 | 支持 Select * | 支持分区 |
|---|---|---|---|---|---|
| 潜在客户 | 是 | 是 | 否 | 是 | 否 |
| 活动 | 是 | 是 | 否 | 是 | 否 |
| 自定义对象 | 是 | 是 | 否 | 是 | 否 |
源支持的实体（异步）：
| 实体 | 可以筛选 | 支持限制 | 支持排序依据 | 支持 Select * | 支持分区 |
|---|---|---|---|---|---|
| 潜在客户 | 是 | 否 | 否 | 是 | 是 |
| 活动 | 是 | 否 | 否 | 是 | 否 |
| 自定义对象 | 是 | 否 | 否 | 是 | 是 |
示例：
adobe-marketo-engage_read = glueContext.create_dynamic_frame.from_options( connection_type="adobe-marketo-engage", connection_options={ "connectionName": "connectionName", "ENTITY_NAME": "leads", "API_VERSION": "v2", "INSTANCE_URL": "https://539-t**-6**.mktorest.com" }
Adobe Marketo Engage 实体和字段详细信息：
具有静态元数据的实体：
| 实体 | 字段 | 数据类型 | 支持的运算符 |
|---|---|---|---|
| 活动 | sinceDatetime（仅在同步模式下支持） | 日期时间 | >=（仅适用于同步模式） |
| createdAt（仅在异步模式下支持） | 日期时间 | between（仅适用于异步模式） | |
| activitiesTypeId | 整数 | = | |
| adobe-marketo-engageGUID | 长整型 | =（仅适用于同步模式） | |
| leadId | 长整型 | 不适用 | |
| activityDate | 日期时间 | 不适用 | |
| campaignId | 长整型 | 不适用 | |
| primaryAttributeValueId | 整数 | 不适用 | |
| primaryAttributeValue | 字符串 | 不适用 | |
| 属性 | 字符串 | 不适用 |
具有动态元数据的实体：
对于以下实体，Adobe Marketo Engage 提供用于动态获取元数据的端点，以便在每个实体的数据类型级别捕获运算符支持。
| 实体 | 数据类型 | 支持的运算符 |
|---|---|---|
| 潜在客户 | 整数 | =（仅适用于同步模式） |
| 日期时间 | between（仅适用于异步模式） | |
| 字符串 | =（仅适用于同步模式） | |
| 长整型 | 不适用 | |
| 布尔值 | 不适用 | |
| 日期 | 不适用 | |
| 浮点型 | 不适用 | |
| 自定义对象 | 整数 | 不适用 |
| 日期时间 | between（仅适用于异步模式） | |
| 字符串 | =（仅适用于同步模式） | |
| 日期 | 不适用 | |
| 长整型 | 不适用 | |
| 布尔值 | 不适用 | |
| 浮点型 | 不适用 |
对查询进行分区
如果您想在 Spark 中利用并发，可以提供其他 Spark 选项：PARTITION_FIELD、LOWER_BOUND、UPPER_BOUND 和 NUM_PARTITIONS。使用这些参数，原始查询将被拆分为 NUM_PARTITIONS 个子查询，这些子查询可以由 Spark 任务同时执行。
PARTITION_FIELD：用于对查询进行分区的字段的名称。LOWER_BOUND：所选分区字段的包含下限值。对于日期时间字段，我们接受 ISO 格式的值。
有效值示例：
"2024-07-01T00:00:00.000Z"UPPER_BOUND：所选分区字段的排除上限值。NUM_PARTITIONS：分区的数量。
下表描述实体分区字段支持详细信息：
| 实体名称 | 分区字段 | 数据类型 |
|---|---|---|
| 潜在客户 | createdAt | 日期时间 |
| updateAt | 日期时间 | |
| 自定义对象 | updatedAt | 日期时间 |
示例：
adobe-marketo-engage_read = glueContext.create_dynamic_frame.from_options( connection_type="adobe-marketo-engage", connection_options={ "connectionName": "connectionName", "ENTITY_NAME": "leads", "API_VERSION": "v1", "PARTITION_FIELD": "createdAt" "LOWER_BOUND": "2024-07-01T00:00:00.000Z" "UPPER_BOUND": "2024-07-02T00:00:00.000Z" "NUM_PARTITIONS": "10" }
