Structure des données des évènements Kafka
Dans cet exemple, lorsqu'une tâche est en transition vers le statut Resolved, un historique d'évènements est envoyé dans le sujet data-history et suivi par un consommateur Kafka.
Cet historique d'évènements fournit les informations générales liées au changement de statut d'une tâche, y compris les noms d'identification de l'utilisateur ou de l'utilisatrice et de la tâche, le nom d'identification de la transaction et les paramètres mis à jour listés dans detail. Pour suivre des actions en particulier, vous devez filtrer ces informations lorsque vous configurez le consommateur Java de Kafka.
Vous trouverez ci-dessous un exemple de structure des données dans l'historique d'évènements, concernant une tâche en transition vers le statut 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
}]
}Vous trouverez ci-dessous un autre exemple de structure de données dans l'historique d'évènements, lorsque la priorité d'une tâche est mise à jour :
{
"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
}
]
}