[Ultimate]{class="badge positive"}
の作成 Azure Event Hubs を使用したソース接続 Flow Service API
このチュートリアルでは、 Azure Event Hubs (以下「」という。)Event Hubs") をExperience Platformに、 Flow Service API.
はじめに
このガイドでは、Adobe Experience Platform の次のコンポーネントに関する十分な知識が必要です。
以下の節では、Flow Service API を使用して Event Hubs を Platform に正しく接続するために必要な追加情報を示します。
必要な資格情報の収集
次の条件を満たすため 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 名前空間。 The sasPolicy この sasKey 必ず~に対応する manage 次に対して設定された権限: Event Hubs リストに値を入力します。 |
namespace |
の名前空間 Event Hubs にアクセスしています。 An Event Hubs 名前空間は、1 つ以上のスコーピングコンテナを作成できる一意のスコーピングコンテナを提供します。 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 名前空間。 The sasPolicy この sasKey 必ず~に対応する manage 次に対して設定された権限: Event Hubs リストに値を入力します。 |
namespace |
の名前空間 Event Hubs にアクセスしています。 An Event Hubs 名前空間は、1 つ以上のスコーピングコンテナを作成できる一意のスコーピングコンテナを提供します。 Event Hubs. |
eventHubName |
の名前 Event Hubs ソース。 |
connectionSpec.id |
接続仕様は、ベース接続とソース接続の作成に関連する認証仕様などの、ソースのコネクタプロパティを返します。Event Hubs 接続仕様 ID は bf9f5905-92b7-48bf-bf20-455bc6b60a4e です。 |
これらの値について詳しくは、 この Event Hubs ドキュメント.
Platform API の使用
Platform API への呼び出しを正常に実行する方法について詳しくは、Platform API の概要を参照してください。
ベース接続の作成
ソース接続を作成する最初の手順は、Event Hubs ソースを認証し、ベース接続 ID を生成することです。ベース接続 ID を使用すると、ソース内を移動してファイルを探索し、データのタイプや形式に関する情報など、取り込みたい特定の項目を識別できます。
ベース接続 ID を作成するには、/connections
エンドポイントに対して POST リクエストを実行し、その際に Event Hubs 認証資格情報をリクエストパラメーターの一部として指定します。
API 形式
POST /connections
標準の認証を使用してアカウントを作成するには、 /connections
エンドポイントを使用して sasKeyName
, sasKey
、および namespace
.
accordion | ||||||||||||||
---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|
リクエスト | ||||||||||||||
|
accordion | ||
---|---|---|
応答 | ||
リクエストが成功した場合は、一意の ID(
|
SAS 認証を使用してアカウントを作成するには、 /connections
エンドポイントを使用して sasKeyName
, sasKey
,namespace
、および eventHubName
.
accordion | ||||||||||||||||
---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|
リクエスト | ||||||||||||||||
|
accordion | ||
---|---|---|
応答 | ||
リクエストが成功した場合は、一意の ID(
|
ソース接続の作成
ソース接続は、データの取り込み元となる外部ソースへの接続を作成および管理します。ソース接続は、データソース、データ形式、データフローの作成に必要なソース接続 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": "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 消費者グループは、特定の時間に 1 つのフローに対してのみ使用できます。次の手順
このチュートリアルに従って、 Event Hubs を使用したソース接続 Flow Service API. 次のチュートリアルでは、このソース接続 ID を使用して、 Flow Service API を使用したストリーミングデータフローの作成を行います。