本教程将帮助您开始使用Adobe Experience Platform中的流摄取API Data Ingestion Service API。
本教程需要具备各种Adobe Experience Platform服务的实际操作知识。 在开始本教程之前,请查看以下服务的文档:
{TENANT_ID}
,本教程的调用中都会显示,并且了解如何创建架构,这用于创建摄取数据集。有关如何成功调用Platform API的信息,请参阅 Platform API快速入门.
要创建数据集,您首先需要创建一个实施 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。 欲知更多信息,请阅读 监测数据摄取 指南。
有关一般流式摄取的更多信息,请阅读 流式摄取概述.