Configuracion kafka

La configuración de ingestión de tareas por kafka está basada en una json el cuál tiene elementos que son expresiones de la herramienta jmespath.

"roadmap": {
   "result": "UNDEFINED",
   "status": "INPROGRESS",
   "taskId": "VERIDOMCOA",
   "roadmap": "{entityDescription: roadmap[?taskId=='VERIDOMCOA']|[0].entityDescription,passes: roadmap[?taskId=='VERIDOMCOA']|[0].passes,taskId:'VERIDOMCOA',taskType:roadmap[?taskId=='VERIDOMCOA']|[0].taskType,isDigital:roadmap[?taskId=='VERIDOMCOA']|[0].isDigital,result:'UNDEFINED',status:'INPROGRESS'}",
   "taskType": "VERIFICATION",
   "isDigital": false
 },
 "data_conf": {
   "data": "@",
   "status": "CREADA",
   "options": "{callback: 'https://me-solicitudes-service.maq-estados.calidad-architect.com/v1/message/kafka',data_request : @}",
   "tracking_data": "{idSolicitud: id, taskId: 'VERIDOMCOA'}",
   "task_identifier": "captura"
 },
 "validate_id": false,
 "data_expression": "roadmap[?taskId == 'VERIDOMCOA' && (status == 'NEW' || status == 'RETRY')].taskId"

Configuración

Validadores

• validate_id: Valor booleano para indicar si la tarea debe pasar por la validación de solicitud para evitar duplicados.

• data_expression: Expresión de jmespath para validar que la tarea a procesar coincide con lo especificado.

roadmap

• result: Indicador del resultado de la tarea, UNDEFINED hasta que tenga una resolución.

• status: Estado que se verá reflejado al actualizar en máquina de estados.

• taskId: Nombre de la tarea que se va a actualizar en el roadmap

• roadmap: Es una expresión de jmespath para obtener los datos de manera dinámica desde el mensaje.

• taskType: Tipo de tarea.

• isDigital: Bandera para identificar si es digital o no.

data_conf

• data: Expresión de jmespth para definir los datos de entrada.

• status: Estado con el que se ingresa la tarea a plataforma.

• options: Expresión de jmespath para definir las opciones de entrada

• tracking_data: Expresión de jmespth para definir los datos de seguimiento.

• task_identifier: Nombre con el que se va a publicar la tarea, debe existir dentro de plataforma.