フロー実行通知
Adobe Experience Platform では、外部ソースからデータを取り込むと同時に、Platform サービスを使用して受信データの構造化、ラベル付け、および拡張を行うことができます。アドビのアプリケーション、クラウドベースのストレージ、データベースなど、様々なソースからデータを取り込むことができます。
Flow Service API を使用すると、様々な異なるソースから顧客データを収集し、Platform で一元化できます。 このサービスは、ユーザーインターフェイスと RESTful API を提供し、サポートされているすべてのソースを接続できます。
Adobe I/Oイベントを使用すると、イベントを登録し、Webhook を使用して、フロー実行のステータスに関する通知を受け取ることができます。 これらの通知には、フロー実行の成功や、実行の失敗に貢献したエラーに関する情報が含まれています。
このドキュメントでは、イベントの購読、Webhook の登録、フロー実行のステータスに関する情報を含む通知の受信を行う手順を説明します。
はじめに
このチュートリアルでは、フロー実行を監視するソース接続が既に 1 つ以上作成されていることを前提としています。 ソース接続をまだ設定していない場合は、まず ソースの概要にアクセスして選択したソースを設定してから、このガイドに戻ってください。
このドキュメントでは、Webhook と、あるアプリケーションから別のアプリケーションに Webhook を接続する方法についての実践的な理解も必要です。 Webhook の概要については、I/O Events ドキュメントを参照してください。
フロー実行通知の Webhook を登録
フロー実行通知を受け取るには、Adobe Developer Consoleを使用して、Experience Platform 統合に Webhook を登録する必要があります。
これを実現する方法の手順について詳しくは、I/O イベント 通知のサブスクライブに関するチュートリアルに従ってください。
- Experience PlatformSourceのフロー実行に成功しました
- Experience PlatformSourceのフロー実行に失敗しました
フロー実行通知を受信
Webhook が接続され、イベント購読が完了したら、Webhook ダッシュボードからフロー実行通知の受信を開始できます。
通知が返す情報には、取り込みジョブの実行回数、ファイルサイズ、エラーなどがあります。 また、通知は、フロー実行に関連付けられたペイロードを JSON 形式で返します。 応答ペイロードは、sources_flow_run_success
または sources_flow_run_failure
のいずれかに分類できます。
sources_flow_run_success
としてマークされます。 正常なフロー実行にエラーが含まれている場合、これらのエラーは引き続きリターンペイロードの一部として含まれます。成功
応答が成功すると、特定のフロー実行の特性を定義し、データの変換方法の概要を activities
す一連の metrics
が返されます。
{
"event_id": "aec55616-1715-487f-8044-ba648cc8ffee",
"event": {
"createdAt": 1597213529158,
"updatedAt": 1597213530760,
"createdBy": "{CREATED_BY}",
"updatedBy": "{UPDATED_BY}",
"createdClient": "{CREATED_CLIENT}",
"updatedClient": "{UPDATED_CLIENT}",
"sandboxId": "7127a4f0-def8-11e9-83ce-e79494b1c2a5",
"sandboxName": "prod",
"imsOrgId": "{ORG_ID}",
"id": "933cf9f4-cf01-4d75-bcf9-f4cf010d750a",
"flowId": "1c6f1047-dcaf-48fe-af10-47dcaf08feaf",
"providerRefId": "test1234",
"etag": "\"5100ec97-0000-0200-0000-5f338b5b0000\"",
"metrics": {
"durationSummary": {
"startedAtUTC": 1590512053,
"completedAtUTC": 1590512053
},
"sizeSummary": {
"inputBytes": 2048,
"outputBytes": 1024
},
"recordSummary": {
"inputRecordCount": 100,
"outputRecordCount": 70
},
"fileSummary": {
"inputFileCount": 10,
"outputFileCount": 10
},
"statusSummary": {
"status": "success"
}
},
"activities": [
{
"id": "copyActivity",
"updatedAtUTC": 87473822,
"durationSummary": {
"startedAtUTC": 1590512053,
"completedAtUTC": 1590512053
},
"sizeSummary": {
"inputBytes": 2048,
"outputBytes": 1098
},
"recordSummary": {
"inputRecordCount": 100,
"outputRecordCount": 100
},
"fileSummary": {
"inputFileCount": 10,
"outputFileCount": 10
},
"statusSummary": {
"status": "success",
"extensions": {
"adf/pipeline/id": "abcd",
"adf/run/id": "1234"
}
},
"sourceInfo": [
{
"id": "sourceConnectionId1",
"type": "SourceConnection",
"reference": {
"type": "AdfRunId"
}
}
]
},
{
"id": "promotionActivity",
"updatedAtUTC": 87473822,
"durationSummary": {
"completedAtUTC": 1590512053
},
"sizeSummary": {
"inputBytes": 1098,
"outputBytes": 1024
},
"recordSummary": {},
"fileSummary": {
"inputFileCount": 10,
"outputFileCount": 10,
"extensions": {
"manifest": {
"fileInfo": "https://platform.adobe.io/data/foundation/export/batches/01E4TSJNM2H5M74J0XB8MFWDHK/meta?path=input_files"
}
}
},
"statusSummary": {
"status": "success",
"extensions": {
"batchId": "b1",
"acp_request_id": "1234"
}
},
"targetInfo": [
{
"id": "targetConnectionId1",
"type": "TargetConnection",
"reference": {
"type": "batch"
}
}
]
}
],
"slaCreatedAt": 1597213531124,
"processStartTime": 1597213531213,
"header": {
"_adobeio": {
"imsOrgId": "{ORG_ID}",
"providerMetadata": "platform_notifications",
"eventCode": "sources_flow_run_success"
}
},
"transformedTime": 1597213531214
}
}
metrics
activities
durationSummary
sizeSummary
recordSummary
fileSummary
fileInfo
statusSummary
失敗
次の応答は、コピーされたデータの処理時にエラーが発生して失敗したフロー実行の例です。 ソースからのデータのコピー中にエラーが発生する場合もあります。 失敗したフロー実行には、エラーや説明など、実行の失敗に貢献したエラーに関する情報が含まれます。
[
{
"messages": [
{
"msgType": "eventNotification",
"version": "1.0",
"timestamp": 1597434157622,
"imsOrgId": "{ORG_ID}",
"schema": {
"name": "run-notification",
"version": "1.0"
},
"provider": "FlowService",
"_eventNotificationMeta": {
"category": "Platform Notifications",
"type": "sources_flow_run_failed"
},
"value": {
"createdAt": 1597434147259,
"updatedAt": 1597434157567,
"createdBy": "{CREATED_BY}",
"updatedBy": "{UPDATED_BY}",
"createdClient": "{CREATED_CLIENT}",
"updatedClient": "{UPDATED_CLIENT}",
"sandboxId": "e49ebb00-d0fa-11e9-b164-ed6a398c8b35",
"sandboxName": "prod",
"imsOrgId": "{ORG_ID}",
"id": "d9024c32-2174-4271-824c-322174627101",
"flowId": "cf4fce79-8822-456d-8fce-798822556dc6",
"etag": "\"0c003dbf-0000-0200-0000-5f36e92d0000\"",
"metrics": {
"durationSummary": {
"startedAtUTC": 1597434147190
},
"sizeSummary": {
"inputBytes": -1
},
"fileSummary": {
"inputFileCount": -1
},
"statusSummary": {
"status": "failed",
"errors": [
{
"code": "CONNECTOR-2001-500",
"message": "Error in processing (parsing, validation or transformation) the copied data."
}
]
}
},
"activities": [
{
"id": "promotionActivity",
"updatedAtUTC": 1597434157529,
"durationSummary": {
"startedAtUTC": 1597434147190,
"completedAtUTC": 1597434157212
},
"sizeSummary": {
"inputBytes": -1
},
"recordSummary": {},
"fileSummary": {
"inputFileCount": -1,
"extensions": {
"manifest": {
"fileInfo": "https://platform-stage.adobe.io/data/foundation/export/batches/6f6a900f-e40d-4f0e-9bb9-b614436c3465/meta?path=input_files"
}
}
},
"statusSummary": {
"status": "failed",
"errors": [
{
"code": "CONNECTOR-2001-500",
"message": "Error in processing (parsing, validation or transformation) the copied data."
}
],
"extensions": {
"errors": [
{
"code": "133",
"message": "We are unable to locate any files uploaded for this batch. Please upload files to ingest."
}
]
}
},
"targetInfo": [
{
"id": "e88737aa-27b8-4795-8737-aa27b8f7959e",
"type": "TargetConnection",
"reference": {
"type": "Batch",
"ids": [
"6f6a900f-e40d-4f0e-9bb9-b614436c3465"
]
}
}
]
}
]
}
}
]
}
]
fileInfo
次の手順
フロー実行ステータスに関するリアルタイム通知を受け取ることができるイベントを登録できるようになりました。 フロー実行とソースについて詳しくは、 ソースの概要を参照してください。
付録
次の節では、フロー実行通知の操作に関する追加情報を示します。
エラーメッセージについて errors
取り込みエラーは、データがソースからコピーされているとき、またはコピーされたデータが Platform に処理されているときに発生する可能性があります。 特定のエラーについて詳しくは、次の表を参照してください。
CONNECTOR-1001-500
CONNECTOR-2001-500