[Ultimate]{class="badge positive"}

使用流服务API创建Amazon Kinesis源连接

IMPORTANT
Amazon Kinesis源在源目录中可供已购买Real-time Customer Data Platform Ultimate的用户使用。

本教程将指导您完成使用Flow Service API将Amazon Kinesis(以下称为“Kinesis”)连接到Experience Platform的步骤。

快速入门

本指南要求您对 Adobe Experience Platform 的以下组件有一定了解:

  • :Experience Platform允许从各种源摄取数据,同时允许您使用Platform服务来构建、标记和增强传入数据。
  • 沙盒:Experience Platform提供了将单个Platform实例划分为多个单独的虚拟环境的虚拟沙盒,以帮助开发和改进数字体验应用程序。

以下部分提供了使用Flow Service API成功将Kinesis连接到Platform所需了解的其他信息。

收集所需的凭据

为了使Flow Service与您的Amazon Kinesis帐户连接,您必须提供以下连接属性的值:

凭据
描述
accessKeyId
访问密钥ID是用于Platform验证Kinesis帐户的访问密钥对的一半。
secretKey
访问密钥是访问密钥对的另一半,用于向Platform验证您的Kinesis帐户。
region
Kinesis帐户的地区。 有关地区的详细信息,请参阅将IP地址添加到允许列表指南。
connectionSpec.id
连接规范返回源的连接器属性,包括与创建基础连接和源连接相关的验证规范。 Kinesis连接规范ID为: 86043421-563b-46ec-8e6c-e23184711bf6

有关Kinesis访问密钥以及如何生成它们的详细信息,请参阅此AWS 有关管理IAM用户的访问密钥的指南

使用平台API

有关如何成功调用平台API的信息,请参阅平台API快速入门指南。

创建基本连接

创建源连接的第一步是验证您的Kinesis源并生成基本连接ID。 基本连接ID允许您浏览和浏览源中的文件,并识别要摄取的特定项目,包括有关其数据类型和格式的信息。

要创建基本连接ID,请在提供Kinesis身份验证凭据作为POST参数的一部分时,向/connections端点请求请求。

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
Kinesis帐户的访问密钥ID。
auth.params.secretKey
Kinesis帐户的访问密钥。
auth.params.region
Kinesis帐户的地区。
connectionSpec.id
Kinesis连接规范ID: 86043421-563b-46ec-8e6c-e23184711bf6

响应

成功的响应返回新创建的基本连接的详细信息,包括其唯一标识符(id)。 在下一步创建源连接时需要此ID。

{
    "id": "4cb0c374-d3bb-4557-b139-5712880adc55",
    "etag": "\"6507cfd8-0000-0200-0000-5e18fc600000\""
}

创建源连接 source

源连接创建和管理与摄取数据的外部源的连接。 源连接由数据源、数据格式和创建数据流所需的源连接ID等信息组成。 源连接实例特定于租户和组织。

要创建源连接,请向Flow Service API的/sourceConnections端点发出POST请求。

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
在上一步中生成的Kinesis源的基本连接ID。
connectionSpec.id
Kinesis的固定连接规范ID。 此ID为: 86043421-563b-46ec-8e6c-e23184711bf6
data.format
要摄取的Kinesis数据的格式。 当前,唯一支持的数据格式为json
params.stream
要从中提取记录的数据流的名称。
params.dataType
此参数定义正在摄取的数据的类型。 支持的数据类型包括: rawxdm
params.reset
此参数定义数据的读取方式。 使用latest开始读取最新数据,并使用earliest开始读取流中的第一个可用数据。

响应

成功的响应返回新创建的源连接的唯一标识符(id)。 在下一个教程中,创建数据流时需要此ID。

{
    "id": "e96d6135-4b50-446e-922c-6dd66672b6b2",
    "etag": "\"66013508-0000-0200-0000-5f6e2ae70000\""
}

后续步骤

通过学习本教程,您已使用Flow Service API创建了Kinesis源连接。 您可以在下一个教程中使用此源连接ID来使用 Flow Service API创建流式数据流。

recommendation-more-help
337b99bb-92fb-42ae-b6b7-c7042161d089