Flow Service API を使用したオンデマンド取り込み用のフロー実行の作成
フロー実行は、フロー実行のインスタンスを表します。 例えば、フローが 1 時間ごとに午前 9:00、午前 10:00、午前 11:00 に実行されるようにスケジュールされている場合、フロー実行の 3 つのインスタンスが存在します。 フロー実行は、特定の組織に固有です。
オンデマンド取り込みでは、特定のデータフローに対してフロー実行を作成できます。 これにより、ユーザーは、指定されたパラメーターに基づいてフロー実行を作成し、サービストークンなしで取り込みサイクルを作成できます。 オンデマンド取り込みのサポートは、バッチソースでのみ使用できます。
このチュートリアルでは、Flow Service API を使用して、オンデマンド取り込みを使用し、フロー実行を作成する手順を説明します。
はじめに
このチュートリアルは、Adobe Experience Platform の次のコンポーネントを実際に利用および理解しているユーザーを対象としています。
Platform API の使用
Platform API を正常に呼び出す方法について詳しくは、Platform API の概要のガイドを参照してください。
テーブルベースのソースのフロー実行の作成
テーブルベースのソースのフローを作成するには、Flow Service API に対してPOSTリクエストを行い、実行を作成するフローの ID と、開始時刻、終了時刻、差分列の値を指定します。
API 形式
POST /runs/
リクエスト
次のリクエストは、フロー ID 3abea21c-7e36-4be1-bec1-d3bad0e3e0de
のフロー実行を作成します。
deltaColumn
を指定するだけで済みます。 その後、deltaColumn
れはフローの変換の一部としてパッチ copy
適用され、信頼できる情報源として扱われます。 フロー実行パラメーターを使用して deltaColumn
値を変更しようとすると、エラーが発生します。curl -X POST \
'https://platform.adobe.io/data/foundation/flowservice/runs' \
-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 '{
"flowId": "3abea21c-7e36-4be1-bec1-d3bad0e3e0de",
"params": {
"startTime": "1663735590",
"windowStartTime": "1651584991",
"windowEndTime": "16515859567",
"deltaColumn": {
"name": "DOB"
}
}
}'
flowId
params.startTime
params.windowStartTime
params.windowEndTime
params.deltaColumn
deltaColumn
は、最初のフロー実行を作成する場合にのみ必要です。params.deltaColumn.name
応答
応答が成功すると、一意の実行 id
など、新しく作成されたフロー実行の詳細が返されます。
{
"items": [
{
"id": "3fb0418e-1804-45d6-8d56-dd51f05c0baf",
"etag": "\"1100c53e-0000-0200-0000-627138980000\""
}
]
}
id
etag
ファイルベースのソースのフロー実行の作成
ファイルベースのソースのフローを作成するには、Flow Service API にPOSTリクエストを行い、実行を作成するフローの ID と、開始時刻および終了時刻の値を指定します。
API 形式
POST /runs/
リクエスト
次のリクエストは、フロー ID 3abea21c-7e36-4be1-bec1-d3bad0e3e0de
のフロー実行を作成します。
curl -X POST \
'https://platform.adobe.io/data/foundation/flowservice/runs' \
-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 '{
"flowId": "3abea21c-7e36-4be1-bec1-d3bad0e3e0de",
"params": {
"startTime": "1663735590",
"windowStartTime": "1651584991",
"windowEndTime": "16515859567"
}
}'
flowId
params.startTime
params.windowStartTime
params.windowEndTime
応答
応答が成功すると、一意の実行 id
など、新しく作成されたフロー実行の詳細が返されます。
{
"items": [
{
"id": "3fb0418e-1804-45d6-8d56-dd51f05c0baf",
"etag": "\"1100c53e-0000-0200-0000-627138980000\""
}
]
}
id
etag
フロー実行の監視
フロー実行が作成されると、それを通じて取り込まれるデータを監視し、フロー実行、完了ステータスおよびエラーに関する情報を確認できます。 API を使用してフローの実行を監視するには、API でのデータフローの監視に関するチュートリアルを参照してください。 Platform UI を使用してフローの実行を監視するには、 モニタリングダッシュボードを使用したソースデータフローのモニタリングに関するガイドを参照してください。