从 Adobe Marketo Engage 实体中读取 - Amazon Glue
对查询进行分区
Amazon Web Services 文档中描述的 Amazon Web Services 服务或功能可能因区域而异。要查看适用于中国区域的差异，请参阅 中国的 Amazon Web Services 服务入门 (PDF)。

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