使用Flow Service API创建HTTP API流连接
流量服务用于收集和集中Adobe Experience Platform中来自不同来源的客户数据。 该服务提供了一个用户界面和RESTful API,所有受支持的源均可从该API连接。
本教程使用Flow Service API引导您完成使用Flow Service API创建流连接的步骤。
快速入门
本指南要求您对 Adobe Experience Platform 的以下组件有一定了解:
- Experience Data Model (XDM): Platform用于组织体验数据的标准化框架。
- Real-Time Customer Profile:根据来自多个源的汇总数据,实时提供统一的使用者配置文件。
此外,创建流连接需要您具有目标XDM架构和数据集。 要了解如何创建这些数据,请阅读有关流式处理记录数据的教程或有关流式处理时间序列数据的教程。
使用平台API
有关如何成功调用平台API的信息,请参阅平台API快速入门指南。
创建基本连接
基本连接指定源,并包含使流与流摄取API兼容所需的信息。 创建基本连接时,您可以选择创建未经身份验证和经过身份验证的连接。
未经身份验证的连接
未经身份验证的连接是标准的流连接,当您想要将数据流式传输到Platform中时,可以创建。
要创建未经身份验证的基本连接,请在提供连接的名称、数据类型和HTTP API连接规范ID的同时向/connections
端点发出POST请求。 此ID为bc7b00d6-623a-4dfc-9fdb-f1240aeadaeb
。
API格式
POST /flowservice/connections
请求
以下请求为HTTP API创建基本连接。
code language-shell |
---|
|
code language-shell |
---|
|
name
description
connectionSpec.id
bc7b00d6-623a-4dfc-9fdb-f1240aeadaeb
。auth.params.dataType
xdm
和raw
。auth.params.name
响应
成功的响应返回HTTP状态201,其中包含新创建的连接的详细信息,包括其唯一标识符(id
)。
{
"id": "a59d368a-1152-4673-a46e-bd52e8cdb9a9",
"etag": "\"f50185ed-0000-0200-0000-637e8fad0000\""
}
id
id
。etag
已验证的连接
当您需要区分来自受信任来源和不受信任来源的记录时,应使用经过身份验证的连接。 用户如果希望发送包含个人身份信息(PII)的信息,则应在将信息流式传输到Platform时创建一个经过身份验证的连接。
要创建经过身份验证的基本连接,您必须在请求中包含authenticationRequired
参数,并将其值指定为true
。 在此步骤中,您还可以为已验证的基本连接提供源ID。 此参数是可选的,如果未提供,它将使用与name
属性相同的值。
API格式
POST /flowservice/connections
请求
以下请求为HTTP API创建经过身份验证的基本连接。
code language-shell |
---|
|
code language-shell |
---|
|
auth.params.sourceId
name
属性相同的值。auth.params.authenticationRequired
authenticationRequired
设置为true
,则必须为流连接提供身份验证。 如果authenticationRequired
设置为false
,则不需要身份验证。响应
成功的响应返回HTTP状态201,其中包含新创建的连接的详细信息,包括其唯一标识符(id
)。
{
"id": "a59d368a-1152-4673-a46e-bd52e8cdb9a9",
"etag": "\"f50185ed-0000-0200-0000-637e8fad0000\""
}
获取流端点URL
在创建基本连接后,您现在可以检索流端点URL。
API格式
GET /flowservice/connections/{BASE_CONNECTION_ID}
{BASE_CONNECTION_ID}
id
值。请求
curl -X GET https://platform.adobe.io/data/foundation/flowservice/connections/{BASE_CONNECTION_ID} \
-H 'Authorization: Bearer {ACCESS_TOKEN}' \
-H 'x-gw-ims-org-id: {ORG_ID}' \
-H 'x-api-key: {API_KEY}' \
-H 'x-sandbox-name: {SANDBOX_NAME}'
响应
成功的响应返回HTTP状态200,其中包含有关所请求连接的详细信息。 流端点URL自动创建连接,可以使用inletUrl
值检索。
{
"items": [
{
"id": "a59d368a-1152-4673-a46e-bd52e8cdb9a9",
"createdAt": 1669238699119,
"updatedAt": 1669238699119,
"createdBy": "acme@AdobeID",
"updatedBy": "acme@AdobeID",
"createdClient": "{CREATED_CLIENT}",
"updatedClient": "{UPDATED_CLIENT}",
"sandboxId": "{SANDBOX_ID}",
"sandboxName": "{SANDBOX_NAME}",
"imsOrgId": "{ORG_ID}",
"name": "ACME Streaming Connection XDM Data",
"description": "ACME streaming connection for customer data",
"connectionSpec": {
"id": "bc7b00d6-623a-4dfc-9fdb-f1240aeadaeb",
"version": "1.0"
},
"state": "enabled",
"auth": {
"specName": "Streaming Connection",
"params": {
"sourceId": "ACME Streaming Connection XDM Data",
"inletUrl": "https://dcs.adobedc.net/collection/667b41cf2dbf3509927da1ebf7e93c20afa727cc8d8373e51da18b62e1b985ec",
"authenticationRequired": false,
"inletId": "667b41cf2dbf3509927da1ebf7e93c20afa727cc8d8373e51da18b62e1b985ec",
"dataType": "xdm",
"name": "ACME Streaming Connection XDM Data"
}
},
"version": "\"f50185ed-0000-0200-0000-637e8fad0000\"",
"etag": "\"f50185ed-0000-0200-0000-637e8fad0000\""
}
]
}
创建源连接 source
要创建源连接,请在提供基本连接ID的同时向/sourceConnections
端点发出POST请求。
API格式
POST /flowservice/sourceConnections
请求
curl -X POST \
'https://platform.adobe.io/data/foundation/flowservice/sourceConnections' \
-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": "ACME Streaming Source Connection for Customer Data",
"description": "A streaming source connection for ACME XDM Customer Data",
"baseConnectionId": "a59d368a-1152-4673-a46e-bd52e8cdb9a9",
"connectionSpec": {
"id": "bc7b00d6-623a-4dfc-9fdb-f1240aeadaeb",
"version": "1.0"
}
}'
响应
成功的响应返回HTTP状态201,其中包含新创建的源连接的详细信息,包括其唯一标识符(id
)。
{
"id": "34ece231-294d-416c-ad2a-5a5dfb2bc69f",
"etag": "\"d505125b-0000-0200-0000-637eb7790000\""
}
创建目标XDM架构 target-schema
为了在Platform中使用源数据,必须创建目标架构,以根据您的需求构建源数据。 然后,使用目标架构创建包含源数据的Platform数据集。
通过向架构注册表API执行POST请求,可以创建目标XDM架构。
有关如何创建目标XDM架构的详细步骤,请参阅有关使用API 创建架构的教程。
创建目标数据集 target-dataset
可以通过向目录服务API执行POST请求,在有效负载中提供目标架构的ID来创建目标数据集。
有关如何创建目标数据集的详细步骤,请参阅有关使用API创建数据集的教程。
创建目标连接 target
目标连接表示与所摄取数据所登陆的目标之间的连接。 要创建目标连接,请在为目标数据集和目标XDM架构提供ID时向/targetConnections
发出POST请求。 在此步骤中,您还必须提供数据湖连接规范ID。 此ID为c604ff05-7f1a-43c0-8e18-33bf874cb11c
。
API格式
POST /flowservice/targetConnections
请求
curl -X POST \
'https://platform.adobe.io/data/foundation/flowservice/targetConnections' \
-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": "ACME Streaming Target Connection",
"description": "ACME Streaming Target Connection",
"data": {
"schema": {
"id": "https://ns.adobe.com/{TENANT}/schemas/7f682c29f887512a897791e7161b90a1ae7ed3dd07a177b1",
"version": "application/vnd.adobe.xed-full+json;version=1.0"
}
},
"params": {
"dataSetId": "637eb7fadc8a211b6312b65b"
},
"connectionSpec": {
"id": "c604ff05-7f1a-43c0-8e18-33bf874cb11c",
"version": "1.0"
}
}'
响应
成功的响应返回HTTP状态201,其中包含新创建的目标连接的详细信息,包括其唯一标识符(id
)。
{
"id": "07f2f6ff-1da5-4704-916a-c615b873cba9",
"etag": "\"340680f7-0000-0200-0000-637eb8730000\""
}
创建映射 mapping
要将源数据摄取到目标数据集中,必须首先将其映射到目标数据集所遵循的目标架构。
要创建映射集,请在提供目标XDM架构$id
和要创建的映射集的详细信息时,向Data Prep API的mappingSets
端点发出POST请求。
API格式
POST /mappingSets
请求
curl -X POST \
'https://platform.adobe.io/data/foundation/mappingSets' \
-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}' \
-H 'Content-Type: application/json' \
-d '{
"version": 0,
"xdmSchema": "https://ns.adobe.com/{TENANT}/schemas/7f682c29f887512a897791e7161b90a1ae7ed3dd07a177b1",
"xdmVersion": "1.0",
"mappings": [
{
"destinationXdmPath": "person.name.firstName",
"sourceAttribute": "firstName",
"identity": false,
"version": 0
},
{
"destinationXdmPath": "person.name.lastName",
"sourceAttribute": "lastName",
"identity": false,
"version": 0
}
]
}'
xdmSchema
$id
。响应
成功的响应返回新创建的映射的详细信息,包括其唯一标识符(id
)。 此ID是稍后步骤创建数据流所必需的。
{
"id": "79a623960d3f4969835c9e00dc90c8df",
"version": 0,
"createdDate": 1669249214031,
"modifiedDate": 1669249214031,
"createdBy": "acme@AdobeID",
"modifiedBy": "acme@AdobeID"
}
创建数据流
创建源和目标连接后,您现在可以创建数据流。 数据流负责从源中计划和收集数据。 您可以通过对/flows
端点执行POST请求来创建数据流。
API格式
POST /flows
请求
以下请求为HTTP API创建流式数据流,而不进行数据转换。
code language-shell |
---|
|
以下请求为HTTP API创建一个流数据流,并将映射转换应用于您的数据。
创建包含转换的数据流时,无法更改name
参数。 此值必须始终设置为Mapping
。
code language-shell |
---|
|
name
description
flowSpec.id
c1a19761-d2c7-4702-b9fa-fe91f0613e81
。 要创建不含转换的数据流,请使用d8a6f005-7eaf-4153-983e-e8574508b877
。sourceConnectionIds
targetConnectionIds
transformations.params.mappingId
响应
成功的响应返回HTTP状态201,其中包含新创建的数据流的详细信息,包括其唯一标识符(id
)。
{
"id": "f2ae0194-8bd8-4a40-a4d9-f07bdc3e6ce2",
"etag": "\"dc0459ae-0000-0200-0000-637ebaec0000\""
}
要引入到Platform的Post数据 ingest-data
现在您已经创建了流,接下来可以将JSON消息发送到之前创建的流端点。
API格式
POST /collection/{INLET_URL}
{INLET_URL}
/connections
端点发出GET请求,以检索此URL。{FLOW_ID}
请求
code language-shell |
---|
|
在发送原始数据时,您可以将流ID指定为查询参数或HTTP标头的一部分。 以下示例将流ID指定为HTTP标头。
code language-shell |
---|
|
在发送原始数据时,您可以将流ID指定为查询参数或HTTP标头。 以下示例将流ID指定为查询参数。
code language-shell |
---|
|
响应
成功的响应返回HTTP状态200以及新摄取信息的详细信息。
{
"inletId": "{BASE_CONNECTION_ID}",
"xactionId": "1584479347507:2153:240",
"receivedTimeMs": 1584479347507
}
{BASE_CONNECTION_ID}
xactionId
receivedTimeMs
后续步骤
通过学习本教程,您已创建一个流HTTP连接,从而能够使用流端点将数据摄取到Platform。 有关在UI中创建流连接的说明,请参阅创建流连接教程。
要了解如何将数据流式传输到Platform,请阅读有关流式传输时间序列数据的教程或有关流式传输记录数据的教程。
附录
本节提供有关使用API创建流连接的补充信息。
向经过身份验证的流连接发送消息
如果流连接启用了身份验证,则客户端需要将Authorization
标头添加到其请求中。
如果Authorization
标头不存在,或发送了无效/过期的访问令牌,则将返回HTTP 401未授权响应,其响应如下所示:
响应
{
"type": "https://ns.adobe.com/adobecloud/problem/data-collection-service-authorization",
"status": "401",
"title": "Authorization",
"report": {
"message": "[id] Ims service token is empty"
}
}