创建 Amazon Kinesis 使用流服务API的源连接
本教程将指导您完成连接的步骤 Amazon Kinesis (以下简称“Kinesis“)Experience Platform,使用 Flow Service API.
快速入门
本指南要求您对 Adobe Experience Platform 的以下组件有一定了解:
以下部分提供成功连接时需要了解的其他信息 Kinesis 到平台,使用 Flow Service API。
收集所需的凭据
为了 Flow Service 以与您的 Amazon Kinesis 帐户,您必须提供以下连接属性的值:
accessKeyId
secretKey
region
connectionSpec.id
86043421-563b-46ec-8e6c-e23184711bf6
.有关的详细信息 Kinesis 访问密钥以及如何生成它们,请参阅此 AWS 管理IAM用户的访问密钥指南.
使用平台API
有关如何成功调用Platform API的信息,请参阅 Platform API快速入门.
创建基本连接
创建源连接的第一步是验证您的 Kinesis 并生成基本连接ID。 基本连接ID允许您浏览和浏览源中的文件,并识别要摄取的特定项目,包括有关其数据类型和格式的信息。
POST要创建基本连接ID,请向 /connections
端点,同时提供 Kinesis 作为请求参数一部分的身份验证凭据。
API格式
POST /connections
请求
curl -X POST \
'https://platform.adobe.io/data/foundation/flowservice/connections' \
-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 '{
"name": "Amazon Kinesis connection",
"description": "Connector for Amazon Kinesis",
"providerId": "521eee4d-8cbe-4906-bb48-fb6bd4450033",
"auth": {
"specName": "Aws Kinesis authentication credentials",
"params": {
"accessKeyId": "{ACCESS_KEY_ID}",
"secretKey": "{SECRET_KEY}",
"region": "{REGION}"
}
},
"connectionSpec": {
"id": "86043421-563b-46ec-8e6c-e23184711bf6",
"version": "1.0"
}
}'
auth.params.accessKeyId
auth.params.secretKey
auth.params.region
connectionSpec.id
86043421-563b-46ec-8e6c-e23184711bf6
响应
成功的响应会返回新创建的基本连接的详细信息,包括其唯一标识符(id
)。 在下一步创建源连接时需要此ID。
{
"id": "4cb0c374-d3bb-4557-b139-5712880adc55",
"etag": "\"6507cfd8-0000-0200-0000-5e18fc600000\""
}
创建源连接 source
源连接创建和管理与摄取数据的外部源的连接。 源连接由数据源、数据格式和创建数据流所需的源连接ID等信息组成。 源连接实例特定于租户和组织。
POST要创建源连接,请向 /sourceConnections
的端点 Flow Service API。
API格式
POST /sourceConnections
请求
curl -X POST \
'https://platform.adobe.io/data/foundation/flowservice/sourceConnections' \
-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 '{
"name": "AWS Kinesis source connection",
"description": "A source connection for AWS Kinesis",
"baseConnectionId": "4cb0c374-d3bb-4557-b139-5712880adc55",
"connectionSpec": {
"id": "86043421-563b-46ec-8e6c-e23184711bf6",
"version": "1.0"
},
"data": {
"format": "json"
},
"params": {
"stream": "{STREAM}",
"dataType": "raw",
"reset": "latest"
}
}'
name
description
baseConnectionId
connectionSpec.id
86043421-563b-46ec-8e6c-e23184711bf6
data.format
json
.params.stream
params.dataType
raw
和 xdm
.params.reset
latest
以开始读取最新数据,并使用 earliest
以开始读取流中的第一个可用数据。响应
成功的响应将返回唯一标识符(id
)。 在下一个教程中,创建数据流时需要此ID。
{
"id": "e96d6135-4b50-446e-922c-6dd66672b6b2",
"etag": "\"66013508-0000-0200-0000-5f6e2ae70000\""
}
后续步骤
在本教程之后,您已创建一个 Kinesis 源连接使用 Flow Service API。 您可以在下一教程中使用此源连接ID 使用创建流数据流 Flow Service API.