使用流摄取API的流记录数据

本教程将帮助您开始使用流摄取API，这是Adobe Experience Platform Data Ingestion Service API的一部分。

快速入门

本教程需要对各种Adobe Experience Platform服务有一定的工作知识。在开始本教程之前，请查阅以下服务的文档：

Experience Data Model (XDM):用于组织体验数据 Platform 的标准化框架。
- 架构注册开发人员指南:一个全面的指南，涵盖API的每个可用端 Schema Registry 点以及如何对其进行调用。这包括了解您的{TENANT_ID}（在本教程中的调用中显示），以及了解如何创建模式（用于创建用于摄取的数据集）。
Real-time Customer Profile:根据来自多个来源的汇总数据，实时提供统一的消费者用户档案。

以下部分提供了成功调用流摄取API所需了解的其他信息。

读取示例API调用

本指南提供了示例API调用，以演示如何设置请求的格式。这包括路径、所需标头以及格式正确的请求负载。还提供了API响应中返回的示例JSON。有关示例API调用文档中使用的惯例的信息，请参阅Experience Platform疑难解答指南中如何阅读示例API调用一节。

收集所需标题的值

要调用Platform API，您必须先完成身份验证教程。完成身份验证教程可为所有Experience Platform API调用中每个所需标头的值，如下所示：

授权：载体{ACCESS_TOKEN}
x-api-key: {API_KEY}
x-gw-ims-org-id: {IMS_ORG}

Experience Platform中的所有资源均与特定虚拟沙箱隔离。对Platform API的所有请求都需要一个标头来指定操作将在其中进行的沙盒的名称：

x-sandbox-name: {SANDBOX_NAME}

注意

有关Platform中沙箱的更多信息，请参阅沙盒概述文档。

所有包含有效负载(POST、PUT、PATCH)的请求都需要额外的标头：

Content-Type:application/json

基于XDM Individual Profile类编写架构

要创建数据集，您首先需要创建一个实施XDM Individual Profile类的新架构。有关如何创建模式的更多信息，请阅读模式注册API开发人员指南。

API格式

POST /schemaregistry/tenant/schemas

请求

curl -X POST https://platform.adobe.io/data/foundation/schemaregistry/tenant/schemas \
  -H 'Authorization: Bearer {ACCESS_TOKEN}' \
  -H 'Content-Type: application/json' \
  -H 'x-api-key: {API_KEY}' \
  -H 'x-gw-ims-org-id: {IMS_ORG}' \
  -H 'x-sandbox-name: {SANDBOX_NAME}' \
  -d '{
    "type": "object",
    "title": "Sample schema",
    "description": "Sample description",
    "allOf": [
        {
            "$ref": "https://ns.adobe.com/xdm/context/profile"
        },
        {
            "$ref": "https://ns.adobe.com/xdm/context/profile-person-details"
        },
        {
            "$ref": "https://ns.adobe.com/xdm/context/profile-work-details"
        }
    ],
    "meta:immutableTags": [
        "union"
    ]
  }'

属性	描述
`title`	要用于架构的名称。此名称必须唯一。
`description`	对要创建的架构进行有意义的描述。
`meta:immutableTags`	在此示例中，使用`union`标记将数据保留到Real-time Customer Profile中。

响应

成功响应会返回HTTP状态201，其中包含新创建架构的详细信息。

{
    "$id": "https://ns.adobe.com/{TENANT_ID}/schemas/{SCHEMA_ID}",
    "meta:altId": "_{TENANT_ID}.schemas.{SCHEMA_ID}",
    "meta:resourceType": "schemas",
    "version": "1.0",
    "type": "object",
    "title": "Sample schema",
    "description": "Sample description",
    "allOf": [
        {
            "$ref": "https://ns.adobe.com/xdm/context/profile"
        },
        {
            "$ref": "https://ns.adobe.com/xdm/context/profile-person-details"
        },
        {
            "$ref": "https://ns.adobe.com/xdm/context/profile-work-details"
        }
    ],
    "meta:class": "https://ns.adobe.com/xdm/context/profile",
    "meta:abstract": false,
    "meta:extensible": false,
    "meta:extends": [
        "https://ns.adobe.com/xdm/context/profile",
        "https://ns.adobe.com/xdm/data/record",
        "https://ns.adobe.com/xdm/cpmtext/identitymap",
        "https://ns.adobe.com/xdm/common/extensible",
        "https://ns.adobe.com/xdm/common/auditable",
        "https://ns.adobe.com/xdm/context/profile-person-details",
        "https://ns.adobe.com/xdm/context/profile-work-details"
    ],
    "meta:immutableTags": [
        "union"
    ],
    "meta:containerId": "tenant",
    "imsOrg": "{IMS_ORG}",
    "meta:xdmType": "object",
    "meta:registryMetadata": {
        "repo:createDate": 1551376506996,
        "repo:lastModifiedDate": 1551376506996,
        "xdm:createdClientId": "{CLIENT_ID}",
        "xdm:repositoryCreatedBy": "{CREATED_BY}"
    }
}

属性	描述
`{TENANT_ID}`	此ID用于确保您创建的资源具有正确命名空间，并包含在您的IMS组织内。有关租户ID的详细信息，请阅读架构注册指南。

请注意$id和version属性，因为创建数据集时将同时使用这两个属性。

为架构设置主标识描述符

接下来，使用工作电子邮件地址属性作为主标识符，将标识描述符添加到上面创建的架构中。这样做将导致两项更改：

工作电子邮件地址将成为必填字段。这意味着在未使用此字段的情况下发送的消息将验证失败且不会被摄取。
Real-time Customer Profile 将使用工作电子邮件地址作为标识符，以帮助拼合有关该个人的更多信息。

请求

curl -X POST https://platform.adobe.io/data/foundation/schemaregistry/tenant/descriptors \
  -H 'Authorization: Bearer {ACCESS_TOKEN}' \
  -H 'Content-Type: application/json' \
  -H 'x-api-key: {API_KEY}' \
  -H 'x-gw-ims-org-id: {IMS_ORG}' \
  -H 'x-sandbox-name: {SANDBOX_NAME}' \
  -d '{
    "@type":"xdm:descriptorIdentity",
    "xdm:sourceProperty":"/workEmail/address",
    "xdm:property":"xdm:code",
    "xdm:isPrimary":true,
    "xdm:namespace":"Email",
    "xdm:sourceSchema":"{SCHEMA_REF_ID}",
    "xdm:sourceVersion":1
}

属性	描述
`{SCHEMA_REF_ID}`	您之前在构建架构时收到的`$id`。它应该如下所示：`"https://ns.adobe.com/{TENANT_ID}/schemas/{SCHEMA_ID}"`

注意

身份命名空间代码

请确保代码有效 — 以上示例使用“email”（标准身份命名空间）。其他常用的标准身份命名空间可以在Identity服务常见问题解答中找到。

如果要创建自定义命名空间，请按照标识命名空间概述中所述的步骤操作。

响应

成功响应返回HTTP状态201，其中包含有关新创建的架构主标识描述符的信息。

{
    "xdm:property": "xdm:code",
    "xdm:sourceSchema": "https://ns.adobe.com/{TENANT_ID}/schemas/{SCHEMA_ID}",
    "xdm:namespace": "Email",
    "@type": "xdm:descriptorIdentity",
    "xdm:sourceVersion": 1,
    "xdm:isPrimary": true,
    "xdm:sourceProperty": "/workEmail/address",
    "@id": "17aaebfa382ce8fc0a40d3e43870b6470aab894e1c368d16",
    "meta:containerId": "tenant",
    "version": "1",
    "imsOrg": "{IMS_ORG}"
}

为记录数据创建数据集

创建架构后，您将需要创建一个数据集以摄取记录数据。

注意

将为Real-time Customer Profile和Identity Service启用此数据集。

API格式

POST /catalog/dataSets

请求

curl -X POST https://platform.adobe.io/data/foundation/catalog/dataSets \
  -H 'Authorization: Bearer {ACCESS_TOKEN}' \
  -H 'Content-Type: application/json' \
  -H 'x-api-key: {API_KEY}' \
  -H 'x-gw-ims-org-id: {IMS_ORG}' \
  -H 'x-sandbox-name: {SANDBOX_NAME}' \
  -d ' {
    "name": "Dataset name",
    "description": "Dataset description",
    "schemaRef": {
        "id": "https://ns.adobe.com/{TENANT_ID}/schemas/{SCHEMA_ID},
        "contentType": "application/vnd.adobe.xed-full+json;version=1"
    },
    "tags": {
        "unifiedIdentity": ["enabled:true"],
        "unifiedProfile": ["enabled:true"]
    }
}'

响应

成功响应会返回HTTP状态201和一个数组，其中包含格式为@/dataSets/{DATASET_ID}的新创建数据集的ID。

[
    "@/dataSets/5e30d7986c0cc218a85cee65
]

创建流连接

创建架构和数据集后，您可以创建流连接

有关创建流连接的更多信息，请阅读创建流连接教程。

将记录数据摄取到流连接

在数据集和流连接就绪后，您可以摄取XDM格式的JSON记录，以将记录数据摄取到Platform中。

API格式

POST /collection/{CONNECTION_ID}?syncValidation=true

参数	描述
`{CONNECTION_ID}`	先前创建的流连接的`inletId`值。
`syncValidation`	用于开发目的的可选查询参数。如果设置为`true`，则可用于进行即时反馈以确定请求是否成功发送。默认情况下，此值设置为`false`。请注意，如果将此查询参数设置为`true`，则请求的速率将限制为每分钟60次`CONNECTION_ID`。

请求

可将记录数据摄取到流连接，可以使用源名称或不使用源名称来完成。

以下示例请求将源名称缺失的记录摄取到平台。如果记录缺少源名称，它将从流连接定义添加源ID。

注意

以下API调用不需要任何身份验证标头。

curl -X POST https://dcs.adobedc.net/collection/{CONNECTION_ID}?syncValidation=true \
  -H "Cache-Control: no-cache" \
  -H "Content-Type: application/json" \
  -d '{
    "header": {
        "schemaRef": {
            "id": "https://ns.adobe.com/{TENANT_ID}/schemas/{SCHEMA_ID}",
            "contentType": "application/vnd.adobe.xed-full+json;version=1"
        },
        "imsOrgId": "{IMS_ORG}",
        "datasetId": "{DATASET_ID}"
    },
    "body": {
        "xdmMeta": {
            "schemaRef": {
                "id": "https://ns.adobe.com/{TENANT_ID}/schemas/{SCHEMA_ID}",
                "contentType": "application/vnd.adobe.xed-full+json;version=1"
            }
        },
        "xdmEntity": {
            "person": {
                "name": {
                    "firstName": "Jane",
                    "middleName": "F",
                    "lastName": "Doe"
                },
                "birthDate": "1969-03-14",
                "gender": "female"
            },
            "workEmail": {
                "primary": true,
                "address": "janedoe@example.com",
                "type": "work",
                "status": "active"
            }
        }
    }
}'

如果要包含源名称，以下示例将显示如何包含该源名称。

    "header": {
        "schemaRef": {
            "id": "https://ns.adobe.com/{TENANT_ID}/schemas/{SCHEMA_ID}",
            "contentType": "application/vnd.adobe.xed-full+json;version=1"
        },
        "imsOrgId": "{IMS_ORG}",
        "datasetId": "{DATASET_ID}",
        "source": {
            "name": "Sample source name"
        }
    }

响应

成功的响应会返回HTTP状态200，其中包含新流式处理的Profile的详细信息。

{
    "inletId": "{CONNECTION_ID}",
    "xactionId": "1584479347507:2153:240",
    "receivedTimeMs": 1584479347507,
    "syncValidation": {
        "status": "pass"
    }
}

属性	描述
`{CONNECTION_ID}`	之前创建的流连接的ID。
`xactionId`	您刚刚发送的记录在服务器端生成的唯一标识符。此ID可帮助Adobe通过各种系统和调试来跟踪此记录的生命周期。
`receivedTimeMs`	时间戳（以毫秒为单位），显示收到请求的时间。
`syncValidation.status`	由于添加了查询参数`syncValidation=true`，因此将显示该值。如果验证成功，则状态将为`pass`。

检索新摄取的记录数据

要验证之前摄取的记录，可使用Profile Access API检索记录数据。

注意

如果未定义合并策略ID，且schema.name或relatedSchema.name为_xdm.context.profile，则Profile Access将获取所有相关标识。

API格式

GET /access/entities
GET /access/entities?{QUERY_PARAMETERS}
GET /access/entities?schema.name=_xdm.context.profile&entityId=janedoe@example.com&entityIdNS=email

参数	描述
`schema.name`	必需。您正在访问的架构的名称。
`entityId`	实体的ID。如果提供，则还必须提供实体命名空间。
`entityIdNS`	您尝试检索的ID的命名空间。

请求

您可以使用以下GET请求查看先前摄取的记录数据。

curl -X GET 'https://platform.adobe.io/data/core/ups/access/entities?schema.name=_xdm.context.profile&entityId=janedoe@example.com&entityIdNS=email'\
  -H 'Authorization: Bearer {ACCESS_TOKEN}' \
  -H 'x-api-key: {API_KEY}' \
  -H 'x-gw-ims-org-id: {IMS_ORG}' \
  -H 'x-sandbox-name: {SANDBOX_NAME}'

响应

成功响应会返回HTTP状态200，其中包含所请求实体的详细信息。如您所见，这与之前成功摄取的记录相同。

{
    "BVrqzwVv7o2p3naHvnsWpqZXv3KJgA": {
        "entityId": "BVrqzwVv7o2p3naHvnsWpqZXv3KJgA",
        "mergePolicy": {
            "id": "e161dae9-52f0-4c7f-b264-dc43dd903d56"
        },
        "sources": [
            "5e30d7986c0cc218a85cee65"
        ],
        "tags": [
            "1580346827274:2478:215"
        ],
        "identityGraph": [
            "BVrqzwVv7o2p3naHvnsWpqZXv3KJgA"
        ],
        "entity": {
            "person": {
                "name": {
                    "lastName": "Doe",
                    "middleName": "F",
                    "firstName": "Jane"
                },
                "gender": "female",
                "birthDate": "1969-03-14"
            },
            "workEmail": {
                "type": "work",
                "address": "janedoe@example.com",
                "status": "active",
                "primary": true
            },
            "identityMap": {
                "email": [
                    {
                        "id": "janedoe@example.com"
                    }
                ]
            }
        },
        "lastModifiedAt": "2020-01-30T01:13:59Z"
    }
}

后续步骤

通过阅读本文档，您现在可以了解如何使用流连接将记录数据摄取到Platform中。您可以尝试使用不同的值发起更多调用并检索更新的值。此外，您还可以通过Platform UI开始监控摄取的数据。有关更多信息，请阅读监测数据摄取指南。

有关流式摄取的更多一般信息，请阅读流式摄取概述。

adobe.com 上的资源

Digital Foundation Customer Intelligence Automated Onboarding Dynamic Forms Analytics Integration Enterprise Search Tools

使用流摄取API的流记录数据

快速入门

读取示例API调用

收集所需标题的值

基于XDM Individual Profile类编写架构

为架构设置主标识描述符

请求

为记录数据创建数据集

创建流连接

将记录数据摄取到流连接

检索新摄取的记录数据

后续步骤

adobe.com 上的资源

在此页面上

查看下一个：

学习

文档

社区

技术支持

资源

Adobe 帐户

Adobe