Kafkaイベントのデータ構造
この例では、タスクがResolved状態に移行すると、履歴イベントがdata-historyトピックに送信され、Kafkaコンシューマーによって追跡されます。
この履歴イベントは、ユーザーおよびタスクID、トランザクションID、およびdetailの下にリストされている更新の詳細など、タスク状況の変更に関連するすべてのものに関する一般情報を提供します。特定のアクションを追跡するためには、Kafka Javaコンシューマーを設定する時にそのような情報をフィルタリングする必要があります。
以下は、[Resolved] (解決済み)状態に移行したタスクに関する履歴イベントのデータ構造の例です。いる更新の詳細など、タスクの状態の変更に関連するすべての情報が提供します:
{
"id": null,
"timestamp": 1546524809436,
"resourceType": "org.talend.datasteward.tasks.model.Task",
"resourceId": "5c26474248f8a60001270599",
"type": "UPDATE",
"userId": "3836ef07-e6f6-4b13-9579-85afcce18328",
"transaction": "dac7ab47-687e-43df-b20f-a30ae5a13f62",
"action": "transition",
"actionParameters": {
"system_campaignId": "5c26474148f8a60001270595",
"system_state": "To validate",
"transitionName": "Accept"
},
"detail": [{
"path": "assignee",
"type": "DELETE",
"previousValue": "3836ef07-e6f6-4b13-9579-85afcce18328",
"newValue": null
}, {
"path": "completed",
"type": "UPDATE",
"previousValue": false,
"newValue": true
}, {
"path": "currentState",
"type": "UPDATE",
"previousValue": "To validate",
"newValue": "Resolved"
}, {
"path": "targetState",
"type": "DELETE",
"previousValue": "Resolved",
"newValue": null
}, {
"path": "targetTransition",
"type": "DELETE",
"previousValue": "Accept",
"newValue": null
}]
}以下は、タスクの優先順位が更新された時の履歴イベントのデータ構造の別の例です:
{
"id": null,
"timestamp": 1546598273434,
"resourceType": "org.talend.datasteward.tasks.model.Task",
"resourceId": "task1",
"type": "UPDATE",
"userId": "user1",
"transaction": "91440277-ea7f-4803-9f39-c7c2969e4714",
"action": "editPriority",
"actionParameters": {
"system_campaignId": "c1",
"system_state": "Inprogress",
"priority": 3
},
"detail": [
{
"path": "priority",
"type": "UPDATE",
"previousValue": 1,
"newValue": 3
}
]
}