[Ultimate]{class="badge positive"}
흐름 서비스 API를 사용하여 Google PubSub Source 연결 만들기
이 자습서에서는 Flow Service API를 사용하여 Google PubSub (이하 "PubSub")을(를) Experience Platform에 연결하는 단계를 안내합니다.
시작하기
이 안내서를 사용하려면 Adobe Experience Platform의 다음 구성 요소에 대해 이해하고 있어야 합니다.
다음 섹션에서는 Flow Service API를 사용하여 PubSub을(를) 플랫폼에 성공적으로 연결하기 위해 알아야 할 추가 정보를 제공합니다.
필요한 자격 증명 수집
PubSub 계정을 Flow Service에 연결하려면 아래에 설명된 연결 속성에 대한 값을 제공해야 합니다. 인증 및 필수 구성 요소 설정에 대한 자세한 내용은 PubSub source 개요를 참조하세요.
table 0-row-2 1-row-2 2-row-2 3-row-2 | |
---|---|
자격 증명 | 설명 |
projectId |
PubSub을(를) 인증하는 데 필요한 프로젝트 ID입니다. |
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 서비스 계정 만들기에 대한 안내서를 읽어 보십시오.
Platform API 사용
Platform API를 성공적으로 호출하는 방법에 대한 자세한 내용은 Platform API 시작에 대한 안내서를 참조하십시오.
기본 연결 만들기
원본 연결을 만드는 첫 번째 단계는 PubSub 원본을 인증하고 기본 연결 ID를 생성하는 것입니다. 기본 연결 ID를 사용하면 소스 내에서 파일을 탐색 및 탐색하고 데이터 유형 및 형식에 대한 정보를 포함하여 수집할 특정 항목을 식별할 수 있습니다.
기본 연결 ID를 만들려면 PubSub 인증 자격 증명을 요청 매개 변수의 일부로 제공하는 동안 /connections
끝점에 POST 요청을 하십시오.
PubSub 원본에서 인증 중에 허용할 액세스 형식을 지정할 수 있습니다. 루트 액세스를 갖도록 계정을 설정하거나 특정 PubSub 주제 및 구독에 대한 액세스를 제한할 수 있습니다.
API 형식
POST /connections
프로젝트 기반 인증으로 기본 연결을 만들려면 /connections
끝점에 대한 POST 요청을 만들고 요청 본문에 projectId
및 credentials
을(를) 제공하십시오.
accordion | ||||||||||||
---|---|---|---|---|---|---|---|---|---|---|---|---|
요청 | ||||||||||||
|
accordion | ||
---|---|---|
응답 | ||
응답이 성공하면 고유 식별자(
|
주제 및 구독 기반 인증을 사용하여 기본 연결을 만들려면 /connections
끝점에 대한 POST 요청을 만들고 요청 본문에 credentials
, topicName
및 subscriptionName
을(를) 제공하십시오.
accordion | ||||||||||||||
---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|
요청 | ||||||||||||||
|
accordion | ||
---|---|---|
응답 | ||
응답이 성공하면 고유 식별자(
|
소스 연결 만들기 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 '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\""
}
다음 단계
이 자습서에 따라 Flow Service API를 사용하여 PubSub 소스 연결을 만들었습니다. 다음 자습서에서 이 원본 연결 ID를 사용하여 API를 사용하여 스트리밍 데이터 흐름을 만들 Flow Service 수 있습니다.