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

从 Salesforce Marketing Cloud 实体中读取

先决条件

您要从中读取内容的 Salesforce Marketing Cloud 对象。您将需要 Activity 或 Campaigns 等对象名称。下表显示支持的实体。

源支持的实体：

实体 接口 可以筛选 支持限制 支持排序依据 支持 SELECT * 支持分区
事件通知回调 REST 否 否 否 是 否
种子列表 REST 否 是 否 是 否
设置 REST 支持 是 否 是 否
域验证 REST 支持 是 是 是 否
对象嵌套标签 REST 是 否 否 是 否
联系人 REST 否 是 否 是 否
事件通知订阅 REST 否 否 否 是 否
消息收发 REST 否 是 否 是 否
活动 SOAP 否 否 否 是 是
退回事件 SOAP 否 否 否 是 是
单击事件 SOAP 否 否 否 是 是
内容区域 SOAP 否 否 否 是 是
数据扩展 SOAP 否 是 否 是 是
电子邮件 SOAP 否 是 否 是 是
转发的电子邮件事件 SOAP 否 是 否 是 是
转发电子邮件选择加入事件 SOAP 否 是 否 是 是
链接 SOAP 否 是 否 是 是
链接发送 SOAP 否 是 否 是 是
列表 SOAP 否 是 否 是 是
列出订阅用户 SOAP 否 是 否 是 是
未发送的事件 SOAP 否 是 否 是 是
公开事件 SOAP 否 是 否 是 是
发送 SOAP 否 是 否 是 是
已发送事件 SOAP 否 是 否 是 是
订阅者 SOAP 否 是 否 是 是
调查事件 SOAP 否 是 否 是 是
取消订阅事件 SOAP 否 是 否 是 是
审计事件 REST 否 是 是 是 否
市场活动 REST 否 是 是 是 否
交互 REST 否 是 是 是 否
内容素材 REST 否 是 是 是 否

REST 的示例：

salesforcemarketingcloud _read = glueContext.create_dynamic_frame.from_options(
    connection_type="salesforcemarketingcloud",
    connection_options={
        "connectionName": "connectionName",
        "ENTITY_NAME": "Campaigns",
        "API_VERSION": "v1",
        "INSTANCE_URL": "https://**********************.rest.marketingcloudapis.com"
    }

SOAP 的示例：

salesforcemarketingcloud _read = glueContext.create_dynamic_frame.from_options(
    connection_type="salesforcemarketingcloud",
    connection_options={
        "connectionName": "connectionName",
        "ENTITY_NAME": "Activity",
        "API_VERSION": "v1",
        "INSTANCE_URL": "https://**********************.soap.marketingcloudapis.com"
    }

Salesforce Marketing Cloud 实体和字段详细信息：

下表描述 Salesforce Marketing Cloud 实体。REST 实体具有静态元数据，而 SOAP 实体具有动态元数据。

具有静态元数据的 REST 实体：

实体 字段 数据类型 支持的运算符
事件通知回调 callbackId 字符串
callbackName 字符串
url 字符串
maxBatchSize 整数
状态 字符串
statusReason 字符串
种子列表 id 字符串
名称 字符串
description 字符串
activeSeedCount 整数
设置 customerKey 字符串
名称 字符串
description 字符串
locationType 字符串 '='
awsFileTransferLocation 结构体
域验证 enterpriseId 整数
状态 字符串 '='
domainType 字符串 '='
memberId 整数
emailSendTime 日期时间
域 字符串
isSendable 布尔值
对象嵌套标签 id 整数
modifiedDate 日期时间
tags 列表
名称 字符串
description 字符串
parentId 整数
联系人 values 列表
事件通知订阅 subscriptionName 字符串
callbackId 字符串
callbackName 字符串
eventCategoryTypes 列表
filters 列表
url 字符串
maxBatchSize 整数
subscriptionId 字符串
状态 字符串
statusReason 字符串
消息收发 deliveryTime 日期时间
id 字符串
messageId 字符串
状态 字符串
到 结构体
交互 状态 字符串 '='
id 字符串
键 字符串
名称 字符串
lastPublishedDate 日期时间
description 字符串
version 整数
workflowApiVersion 整数
createdDate 日期时间
modifiedDate 日期时间
goals 结构体
stats 结构体
entryMode 字符串
defaults 结构体
executionMode 结构体
definitionId 字符串
内容素材 id 整数
customerKey String
objectId 字符串
contentType 字符串
assetType 结构体
名称 字符串
description 字符串
owner 结构体
createdDate 日期时间
createdBy 结构体
modifiedDate 日期时间
modifiedBy 结构体
thumbnail 结构体
category 结构体
meta 结构体
视图 结构体
availableViews 结构体
数据 结构体
legacyData 结构体
modelVersion 整数
版本 整数
Locked（已锁定） 布尔值
FileProperties 结构体
标签 列表
内容 字符串
设计 字符串
SuperContent 字符串
CustomFields 结构体
数据块 结构体
MinBlocks 整数
MaxBlocks 整数
渠道 结构体
AllowedBlocks 列表
槽值 结构体
BusinessUnitAvailability 结构体
sharingProperties 结构体
sharingProperties.sharedWith 结构体
sharingProperties.sharingType 字符串
模板 结构体
文件 字符串
GenerateFrom 字符串
审计事件 id 整数
createdDate 日期时间
memberId 整数
enterpriseId 整数
employee 结构体
objectType 结构体
operation 结构体
object 结构体
transactionId 字符串
市场活动 id 整数
createdDate 日期时间
modifiedDate 日期时间
名称 字符串
description 字符串
campaignCode 字符串
color 字符串
favorite 布尔值

具有动态元数据的 SOAP 实体：

实体 数据类型 支持的运算符
活动 字符串 LIKE,!=,=
结构体
整数 !=,=,>=,<=,<,>
双精度 !=,=,>=,<=,<,>
布尔值 !=,=
日期时间 >=,<=,<,>,=,BETWEEN
退回事件 整数 !=,=,>=,<=,<,>
日期时间 >=,<=,<,>,=,BETWEEN
字符串 LIKE,!=,=
结构体
单击事件 整数 !=,=,>=,<=,<,>
日期时间 >=,<=,<,>,=,BETWEEN
字符串 LIKE,!=,=
结构体
内容区域 结构体
字符串 LIKE,!=,=
整数 !=,=,>=,<=,<,>
日期时间 >=,<=,<,>,=,BETWEEN
布尔值 !=,=
数据扩展 日期时间 >=,<=,<,>,=,BETWEEN
字符串 LIKE,!=,=
电子邮件 整数 !=,=,>=,<=,<,>
字符串 LIKE,!=,=
日期时间 >=,<=,<,>,=,BETWEEN
布尔值 !=,=
结构体
转发的电子邮件事件 整数 !=,=,>=,<=,<,>
字符串 LIKE,!=,=
日期时间 >=,<=,<,>,=,BETWEEN
结构体
转发的电子邮件选项 整数 !=,=,>=,<=,<,>
字符串 LIKE,!=,=
日期时间 >=,<=,<,>,=,BETWEEN
结构体
链接 整数 !=,=,>=,<=,<,>
链接发送 整数 !=,=,>=,<=,<,>
字符串 LIKE,!=,=
双精度 !=,=,>=,<=,<,>
列表 整数 !=,=,>=,<=,<,>
字符串 LIKE,!=,=
日期时间 >=,<=,<,>,=,BETWEEN
结构体
列出订阅用户 整数 !=,=,>=,<=,<,>
字符串 LIKE,!=,=
日期时间 >=,<=,<,>,=,BETWEEN
结构体
未发送的事件 整数 !=,=,>=,<=,<,>
字符串 LIKE,!=,=
日期时间 >=,<=,<,>,=,BETWEEN
结构体
公开事件 整数 !=,=,>=,<=,<,>
字符串 LIKE,!=,=
日期时间 >=,<=,<,>,=,BETWEEN
结构体
发送 整数 !=,=,>=,<=,<,>
字符串 LIKE,!=,=
日期时间 >=,<=,<,>,=,BETWEEN
布尔值 !=,=
结构体
已发送事件 整数 !=,=,>=,<=,<,>
字符串 LIKE,!=,=
日期时间 >=,<=,<,>,=,BETWEEN
结构体
订阅者 整数 !=,=,>=,<=,<,>
字符串 LIKE,!=,=
日期时间 >=,<=,<,>,=,BETWEEN
结构体
调查事件 整数 !=,=,>=,<=,<,>
字符串 LIKE,!=,=
日期时间 >=,<=,<,>,=,BETWEEN
结构体
取消订阅事件 整数 !=,=,>=,<=,<,>
字符串 LIKE,!=,=
日期时间 >=,<=,<,>,=,BETWEEN
布尔值 !=,=
结构体

对查询进行分区

在 Salesforce Marketing Cloud 中，整数和日期时间数据类型字段支持基于字段的分区。

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

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

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

    对于时间戳字段，我们接受 Spark SQL 查询中使用的 Spark 时间戳格式。

    有效值示例：

    “2024-05-07T02:03:00.00Z"

  • UPPER_BOUND：所选分区字段的排除上限值。

  • NUM_PARTITIONS：分区的数量。

示例：

salesforcemarketingcloud_read = glueContext.create_dynamic_frame.from_options(
    connection_type="salesforcemarketingcloud",
    connection_options={
        "connectionName": "connectionName",
        "ENTITY_NAME": "ListSubscriber",
        "API_VERSION": "v1",
        "PARTITION_FIELD": "CreatedDate"
        "LOWER_BOUND": "2023-09-07T02:03:00.000Z"
        "UPPER_BOUND": "2024-05-07T02:03:00.000Z"
        "NUM_PARTITIONS": "10"
    }