[Ultimate]{class="badge positive"}
创建 Azure Event Hubs 源连接使用 Flow Service API
本教程提供了创建 Azure Event Hubs (以下简称“Event Hubs“)Experience Platform,使用 Flow Service API.
快速入门
本指南要求您对 Adobe Experience Platform 的以下组件有一定了解:
以下部分提供成功连接时需要了解的其他信息 Event Hubs 到平台,使用 Flow Service API。
收集所需的凭据
为了 Flow Service 以与您的 Event Hubs 帐户,您必须提供以下连接属性的值:
table 0-row-2 1-row-2 2-row-2 3-row-2 4-row-2 | |
---|---|
凭据 | 描述 |
sasKeyName |
授权规则的名称,也称为SAS密钥名称。 |
sasKey |
的主键 Event Hubs 命名空间。 此 sasPolicy 该 sasKey 对应于必须具有 manage 权限已配置,用于 Event Hubs 要填充的列表。 |
namespace |
的命名空间 Event Hubs 您正在访问。 An Event Hubs namespace提供了一个唯一的范围容器,您可以在其中创建一个或多个 Event Hubs. |
connectionSpec.id |
连接规范返回源的连接器属性,包括与创建基础连接和源连接相关的验证规范。 此 Event Hubs 连接规范ID为: bf9f5905-92b7-48bf-bf20-455bc6b60a4e . |
table 0-row-2 1-row-2 2-row-2 3-row-2 4-row-2 5-row-2 | |
---|---|
凭据 | 描述 |
sasKeyName |
授权规则的名称,也称为SAS密钥名称。 |
sasKey |
的主键 Event Hubs 命名空间。 此 sasPolicy 该 sasKey 对应于必须具有 manage 权限已配置,用于 Event Hubs 要填充的列表。 |
namespace |
的命名空间 Event Hubs 您正在访问。 An Event Hubs namespace提供了一个唯一的范围容器,您可以在其中创建一个或多个 Event Hubs. |
eventHubName |
您的名称 Event Hubs 源。 |
connectionSpec.id |
连接规范返回源的连接器属性,包括与创建基础连接和源连接相关的验证规范。 此 Event Hubs 连接规范ID为: bf9f5905-92b7-48bf-bf20-455bc6b60a4e . |
有关这些值的更多信息,请参阅 此事件中心文档.
使用平台API
有关如何成功调用Platform API的信息,请参阅 Platform API快速入门.
创建基本连接
创建源连接的第一步是验证您的 Event Hubs 并生成基本连接ID。 基本连接ID允许您浏览和浏览源中的文件,并识别要摄取的特定项目,包括有关其数据类型和格式的信息。
POST要创建基本连接ID,请向 /connections
端点,同时提供 Event Hubs 作为请求参数一部分的身份验证凭据。
API格式
POST /connections
POST要使用标准身份验证创建帐户,请向 /connections
端点,同时为提供值 sasKeyName
, sasKey
、和 namespace
.
accordion | ||||||||||||||
---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|
请求 | ||||||||||||||
|
accordion | ||
---|---|---|
响应 | ||
成功的响应会返回新创建的基本连接的详细信息,包括其唯一标识符(
|
POST要使用SAS身份验证创建帐户,请向 /connections
端点,同时为提供值 sasKeyName
, sasKey
,namespace
、和 eventHubName
.
accordion | ||||||||||||||||
---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|
请求 | ||||||||||||||||
|
accordion | ||
---|---|---|
响应 | ||
成功的响应会返回新创建的基本连接的详细信息,包括其唯一标识符(
|
创建源连接
源连接创建和管理与摄取数据的外部源的连接。 源连接由数据源、数据格式和创建数据流所需的源连接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 '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": "Azure Event Hubs source connection",
"description": "A source connection for Azure Event Hubs",
"baseConnectionId": "4cdbb15c-fb1e-46ee-8049-0f55b53378fe",
"connectionSpec": {
"id": "bf9f5905-92b7-48bf-bf20-455bc6b60a4e",
"version": "1.0"
},
"data": {
"format": "json"
},
"params": {
"eventHubName": "{EVENT_HUB_NAME}",
"dataType": "raw",
"reset": "latest",
"consumerGroup": "{CONSUMER_GROUP}"
}
}'
name
description
baseConnectionId
connectionSpec.id
bf9f5905-92b7-48bf-bf20-455bc6b60a4e
.data.format
json
.params.eventHubName
params.dataType
raw
和 xdm
.params.reset
latest
以开始读取最新数据,并使用 earliest
以开始读取流中的第一个可用数据。 此参数为可选参数,默认为 earliest
如果未提供。params.consumerGroup
$Default
如果未提供。 请参阅此 Event Hubs 事件使用者指南 以了解更多信息。 注意:一个 Event Hubs 使用者组只能在给定时间用于单个流。后续步骤
在本教程之后,您已创建一个 Event Hubs 源连接使用 Flow Service API。 您可以在下一教程中使用此源连接ID 使用创建流数据流 Flow Service API.