7. Filtrar y agregar con Batch Step y Aggregator
En la clase de hoy vamos a aprender cómo filtrar y agregar con Batch Step y Aggregator. Un Batch Step solamente puede utilizarse si está dentro de un Batch Job, un Batch Aggregator reside dentro de un Batch Step. Por lo tanto, sin un Batch Job no puede existir un Batch Step y, sin un Batch Step no puede existir un Batch Aggregator.
Batch Step
Los Batch Jobs pueden contener 1 o muchos Batch Steps que se irán ejecutando de forma secuencial.
Cada Batch Step está dividido en Processors y Aggregators:
El apartado de Processors nos servirá para añadir los componentes que se ejecutaran en ese paso. Contendrá el procesamiento de los registros de cada elemento de la colección de datos del Batch Job.
Se podrá mejorar el Batch Job proporcionando filtros para limitar el procesamiento solo a los registros que se hayan elegido en el filtrado. En la clase podréis ver un ejemplo práctico explicado en detalle.
El componente Batch Step contiene los siguientes parámetros de configuración:
- Accept Expression: Expresión que se cumple para los registros de procesamiento, por ejemplo, #[payload.edad > 18].
- Accept Policy :
- NO_FAILURES (predeterminado): El Batch Step procesa únicamente aquellos registros que se procesaron correctamente en todos los pasos anteriores.
- ONLY_FAILURES: El Batch Step procesa únicamente aquellos registros que no se pudieron procesar en un Batch Step anterior.
- ALL: El Batch Step procesa todos los registros, independientemente de si no se pudieron procesar en un Batch Step anterior.
Batch Aggregator
En la sección derecha del Batch Step se encuentra Aggregator, es necesario utilizar el componente Batch Aggregator para poder añadir componentes dentro de esta sección.
En el Batch Step se ha añadido un componente en la sección Aggregator gracias a que se ha utilizado el componente Batch Aggregator. Si se intentase añadir el Set Variable directamente en el Batch Step 1, no sería posible.
La finalidad del componente Batch Aggregator os la explico en la clase de hoy, con el modo Debug siempre quedan las cosas más claras.
Sin más, Filtrar y agregar con Batch Step y Aggregator ¡dentro vídeo!
Clases del curso
- 1. Trigger de un evento Mule con archivos (28:12)
- 2. Sincronizar datos con Watermarks (37:01)
- 3. Sincronizar con Watermark y Object Store (58:54)
- 4. Manipular mensajes con JMS Active MQ (27:21)
- Punto de control 1
- 5. Procesar ítems con For Each (28:39)
- 6. Procesar datos con Batch Job (22:24)
- 7. Filtrar y agregar con Batch Step y Aggregator (13:38)
- Punto de control 2