创建 Google PubSub 使用流服务API的源连接
本教程将指导您完成连接的步骤 Google PubSub (以下简称“PubSub“)Experience Platform,使用 [Flow Service API] (https://www.adobe.io/experience-platform-apis/references/flow-service/).
快速入门
本指南要求您对 Adobe Experience Platform 的以下组件有一定了解:
以下部分提供成功连接时需要了解的其他信息 PubSub 到平台,使用 Flow Service API。
收集所需的凭据
为了 Flow Service 以连接到 PubSub中,您必须提供以下连接属性的值:
table 0-row-2 1-row-2 2-row-2 3-row-2 | |
---|---|
凭据 | 描述 |
projectId |
验证时需要项目ID PubSub. |
credentials |
身份验证所需的凭据 PubSub. 您必须确保从凭据中删除空格后放入完整的JSON文件。 |
connectionSpec.id |
连接规范返回源的连接器属性,包括与创建基础和源目标连接相关的身份验证规范。 此 PubSub 连接规范ID为: 70116022-a743-464a-bbfe-e226a7f8210c . |
table 0-row-2 1-row-2 2-row-2 3-row-2 4-row-2 | |
---|---|
凭据 | 描述 |
credentials |
身份验证所需的凭据 PubSub. 您必须确保从凭据中删除空格后放入完整的JSON文件。 |
topicName |
表示消息馈送的资源名称。 如果要提供对特定数据流的访问权限,您必须指定主题名称。 PubSub 源。 主题名称格式为: projects/{PROJECT_ID}/topics/{TOPIC_ID} . |
subscriptionName |
您的名称 PubSub 订阅。 在 PubSub,订阅允许您通过订阅消息已发布到的主题来接收消息。 注意:单个 PubSub 订阅只能用于一个数据流。 要创建多个数据流,您必须有多个订阅。 订阅名称格式为: projects/{PROJECT_ID}/subscriptions/{SUBSCRIPTION_ID} . |
connectionSpec.id |
连接规范返回源的连接器属性,包括与创建基础和源目标连接相关的身份验证规范。 此 PubSub 连接规范ID为: 70116022-a743-464a-bbfe-e226a7f8210c . |
有关这些值的更多信息,请参阅此 PubSub 身份验证 文档。 要使用基于服务帐户的身份验证,请参阅此 PubSub 创建服务帐户指南 以了解有关如何生成凭据的步骤。
使用平台API
有关如何成功调用Platform API的信息,请参阅 Platform API快速入门.
创建基本连接
创建源连接的第一步是验证您的 PubSub 并生成基本连接ID。 基本连接ID允许您浏览和浏览源中的文件,并识别要摄取的特定项目,包括有关其数据类型和格式的信息。
POST要创建基本连接ID,请向 /connections
端点,同时提供 PubSub 作为请求参数一部分的身份验证凭据。
此 PubSub 源允许您指定在身份验证期间允许的访问类型。 您可以将帐户设置为具有超级用户访问权限或限制对特定用户的访问权限 PubSub 主题和订阅。
API格式
POST /connections
POST要创建基于项目的身份验证的基本连接,请向 /connections
端点并提供您的 projectId
和 credentials
请求正文中。
accordion | ||||||||||||
---|---|---|---|---|---|---|---|---|---|---|---|---|
请求 | ||||||||||||
|
accordion | ||
---|---|---|
响应 | ||
成功的响应会返回新创建连接的详细信息,包括其唯一标识符(
|
POST要创建与主题和基于订阅的身份验证的基本连接,请向 /connections
端点并提供您的 credentials
, topicName
、和 subscriptionName
请求正文中。
accordion | ||||||||||||||
---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|
请求 | ||||||||||||||
|
accordion | ||
---|---|---|
响应 | ||
成功的响应会返回新创建连接的详细信息,包括其唯一标识符(
|
创建源连接 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 '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": "Google PubSub source connection",
"description": "A source connection for Google PubSub",
"baseConnectionId": "4cb0c374-d3bb-4557-b139-5712880adc55",
"connectionSpec": {
"id": "70116022-a743-464a-bbfe-e226a7f8210c",
"version": "1.0"
},
"data": {
"format": "json"
},
"params": {
"topicName": "projects/{PROJECT_ID}/topics/{TOPIC_ID}",
"subscriptionName": "projects/{PROJECT_ID}/subscriptions/{SUBSCRIPTION_ID}",
"dataType": "raw"
}
}'
name
description
baseConnectionId
connectionSpec.id
70116022-a743-464a-bbfe-e226a7f8210c
data.format
json
.params.topicName
params.subscriptionName
params.dataType
raw
和 xdm
.响应
成功的响应将返回唯一标识符(id
)。 在下一个教程中,创建数据流时需要此ID。
{
"id": "e96d6135-4b50-446e-922c-6dd66672b6b2",
"etag": "\"66013508-0000-0200-0000-5f6e2ae70000\""
}
后续步骤
在本教程之后,您已创建一个 PubSub 源连接使用 Flow Service API。 您可以在下一教程中使用此源连接ID 使用创建流数据流 Flow Service API.