다음 Azure Event Hubs 소스는 Real-time Customer Data Platform Ultimate를 구매한 사용자에게 소스 카탈로그에서 사용할 수 있습니다.
이 자습서에서는 연결하는 단계를 안내합니다 Azure Event Hubs (이하 "라고 한다) Event Hubs") Experience Platform 대상, 사용 Flow Service API.
이 안내서를 사용하려면 Adobe Experience Platform의 다음 구성 요소에 대해 이해하고 있어야 합니다.
다음 섹션은 성공적으로 연결하기 위해 알아야 하는 추가 정보를 제공합니다 Event Hubs 를 사용하여 플랫폼으로 Flow Service API.
주문 Flow Service 을(를) 사용하여 Event Hubs 계정, 다음 연결 속성에 대한 값을 제공해야 합니다.
자격 증명 | 설명 |
---|---|
sasKeyName |
SAS 키 이름이라고도 하는 인증 규칙의 이름입니다. |
sasKey |
의 기본 키 Event Hubs 네임스페이스입니다. 다음 sasPolicy 해당 sasKey 은(는) 다음을 포함해야 합니다. manage 에 대해 순서대로 구성된 권한 Event Hubs 채울 목록입니다. |
namespace |
의 네임스페이스 Event Hubs 에 액세스하고 있습니다. An Event Hubs 네임스페이스는 하나 이상을 만들 수 있는 고유한 범위 컨테이너를 제공합니다 Event Hubs. |
connectionSpec.id |
연결 사양은 기본 및 소스 연결 만들기와 관련된 인증 사양을 포함하여 소스의 커넥터 속성을 반환합니다. 다음 Event Hubs 연결 사양 ID: bf9f5905-92b7-48bf-bf20-455bc6b60a4e . |
이러한 값에 대한 자세한 내용은 이 이벤트 허브 문서.
Platform API를 성공적으로 호출하는 방법에 대한 자세한 내용은 의 안내서를 참조하십시오. platform API 시작하기.
소스 연결을 만드는 첫 번째 단계는 Event Hubs 소스 및 기본 연결 ID 생성. 기본 연결 ID를 사용하면 소스 내에서 파일을 탐색 및 탐색하고 데이터 유형 및 형식에 대한 정보를 포함하여 수집할 특정 항목을 식별할 수 있습니다.
POST 기본 연결 ID를 만들려면 /connections
을(를) 제공하는 동안 엔드포인트 Event Hubs 요청 매개 변수의 일부로 인증 자격 증명을 사용합니다.
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": "Azure Event Hubs connection",
"description": "Connector for Azure Event Hubs",
"auth": {
"specName": "Azure EventHub authentication credentials",
"params": {
"sasKeyName": "{SAS_KEY_NAME}",
"sasKey": "{SAS_KEY}",
"namespace": "{NAMESPACE}"
}
},
"connectionSpec": {
"id": "bf9f5905-92b7-48bf-bf20-455bc6b60a4e",
"version": "1.0"
}
}'
속성 | 설명 |
---|---|
auth.params.sasKeyName |
SAS 키 이름이라고도 하는 인증 규칙의 이름입니다. |
auth.params.sasKey |
생성된 공유 액세스 서명입니다. |
auth.params.namespace |
의 네임스페이스 Event Hubs 에 액세스하고 있습니다. |
connectionSpec.id |
다음 Event Hubs 연결 사양 ID: bf9f5905-92b7-48bf-bf20-455bc6b60a4e |
응답
성공한 응답은 고유 식별자를 포함하여 새로 생성된 기본 연결의 세부 정보를 반환합니다(id
). 다음 단계에서 소스 연결을 만들려면 이 연결 ID가 필요합니다.
{
"id": "4cdbb15c-fb1e-46ee-8049-0f55b53378fe",
"etag": "\"6507cfd8-0000-0200-0000-5e18fc600000\""
}
An Event Hubs 소비자 그룹은 주어진 시간에 단일 흐름에만 사용할 수 있습니다.
소스 연결은 데이터가 수집되는 외부 소스와의 연결을 만들고 관리합니다. 소스 연결은 데이터 소스, 데이터 형식 및 데이터 흐름을 만드는 데 필요한 소스 연결 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": "{EVENTHUB_NAME}",
"dataType": "raw",
"reset": "latest",
"consumerGroup": "{CONSUMER_GROUP}"
}
}'
속성 | 설명 |
---|---|
name |
소스 연결의 이름입니다. 소스 연결에 대한 정보를 조회할 때 소스 연결의 이름이 설명적인지 확인합니다. |
description |
소스 연결에 대한 자세한 정보를 포함하도록 제공할 수 있는 선택적 값입니다. |
baseConnectionId |
의 연결 ID Event Hubs 이전 단계에서 생성된 소스. |
connectionSpec.id |
의 고정 연결 사양 ID Event Hubs. 이 ID는 bf9f5905-92b7-48bf-bf20-455bc6b60a4e . |
data.format |
형식 Event Hubs 수집할 데이터. 현재 지원되는 데이터 형식은 json . |
params.eventHubName |
에 대한 이름 Event Hubs 소스. |
params.dataType |
이 매개 변수는 수집되는 데이터의 유형을 정의합니다. 지원되는 데이터 유형은 다음과 같습니다. raw 및 xdm . |
params.reset |
이 매개 변수는 데이터를 읽는 방법을 정의합니다. 사용 latest 최신 데이터에서 읽기를 시작하고 earliest 스트림에서 사용 가능한 첫 번째 데이터에서 읽기를 시작합니다. 이 매개 변수는 선택 사항이며 기본값은 입니다. earliest 제공되지 않는 경우 |
params.consumerGroup |
에 사용할 게시 또는 구독 메커니즘 Event Hubs. 이 매개 변수는 선택 사항이며 기본값은 입니다. $Default 제공되지 않는 경우 다음을 참조하십시오. Event Hubs 이벤트 소비자에 대한 안내서 추가 정보. 참고: 안 Event Hubs 소비자 그룹은 주어진 시간에 단일 흐름에만 사용할 수 있습니다. |
이 자습서를 따라 Event Hubs 를 사용한 소스 연결 Flow Service API. 다음 자습서에서 이 소스 연결 ID를 사용하여 다음을 수행할 수 있습니다. 다음을 사용하여 스트리밍 데이터 흐름 만들기 Flow Service API.