使用流式摄取API流式处理记录数据

本教程将帮助您开始使用Adobe Experience Platform中的流摄取API Data Ingestion Service API。

快速入门

本教程需要具备各种Adobe Experience Platform服务的实际操作知识。在开始本教程之前，请查看以下服务的文档：

Experience Data Model (XDM)：用于实现此目标的标准化框架 Platform 组织体验数据。
- Schema Registry开发人员指南：一份全面的指南，涵盖了 Schema Registry API以及如何对它们进行调用。这包括了解 {TENANT_ID}，本教程的调用中都会显示，并且了解如何创建架构，这用于创建摄取数据集。
Real-Time Customer Profile：根据来自多个源的聚合数据实时提供统一的用户配置文件。

使用平台API

有关如何成功调用Platform API的信息，请参阅 Platform API快速入门.

根据构建架构 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: {ORG_ID}' \
  -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": "{ORG_ID}",
    "meta:xdmType": "object",
    "meta:registryMetadata": {
        "repo:createDate": 1551376506996,
        "repo:lastModifiedDate": 1551376506996,
        "xdm:createdClientId": "{CLIENT_ID}",
        "xdm:repositoryCreatedBy": "{CREATED_BY}"
    }
}

属性	描述
`{TENANT_ID}`	此ID用于确保您创建的资源被正确命名并包含在您的组织中。有关租户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: {ORG_ID}' \
  -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}"`

注意

CJA 身份命名空间代码

请确保代码有效 — 上面的示例使用“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": "{ORG_ID}"
}

为记录数据创建数据集

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

注意

此数据集将启用 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: {ORG_ID}' \
  -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和一个数组，该数组包含格式中新创建的数据集的ID @/dataSets/{DATASET_ID}.

[
    "@/dataSets/5e30d7986c0cc218a85cee65
]

创建流连接

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

有关创建流连接的详细信息，请阅读创建流连接教程.

将记录数据摄取到流连接

利用数据集和流连接，您可以摄取XDM格式的JSON记录以将记录数据摄取到 Platform.

API格式

POST /collection/{CONNECTION_ID}?syncValidation=true

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

请求

可以将记录数据摄取到流连接，无论是否使用源名称。

下面的示例请求将缺少源名称的记录摄取到Platform。如果记录缺少源名称，它将从流连接定义中添加源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": "{ORG_ID}",
        "datasetId": "{DATASET_ID}",
        "flowId": "{FLOW_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": "{ORG_ID}",
        "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: {ORG_ID}' \
  -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。欲知更多信息，请阅读监测数据摄取指南。

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

Business.Adobe.com 资源

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

使用流式摄取API流式处理记录数据

快速入门

使用平台API

根据构建架构 XDM Individual Profile 类

为架构设置主标识描述符

请求

为记录数据创建数据集

创建流连接

将记录数据摄取到流连接

检索新摄取的记录数据

后续步骤

Business.Adobe.com 资源

在此页面上

查看下一个：

学习

文档

社区

技术支持

资源

Adobe 帐户

Adobe