Kafkaイベントのデータ構造 - 7.2

Talend Data Stewardshipユーザーガイド

author
Talend Documentation Team
EnrichVersion
7.2
EnrichProdName
Talend Big Data
Talend Big Data Platform
Talend Data Fabric
Talend Data Integration
Talend Data Management Platform
Talend Data Services Platform
Talend ESB
Talend MDM Platform
Talend Real-Time Big Data Platform
task
データガバナンス > キャンペーンの管理
データガバナンス > タスクの割り当て
データガバナンス > データモデルの管理
データクオリティとプレパレーション > セマンティックタイプの管理
データクオリティとプレパレーション > タスク管理
管理と監視 > ユーザーの管理
EnrichPlatform
Talend Data Stewardship

この例では、タスクが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
            }
        ]
    }