Spring Batch emplea una técnica llamada 'procesamiento chunk' para la ejecución de un proceso. El reader lee una porción de datos y los convierte en chunk (una entidad/objeto). Si existe un processor, ese chunk pasa al processor para que lo trate. Después el writer se encargará de guardar la información tratada.
En el anterios post vimos los componentes principales del Batch Domain Language. El JobRepository se encargará de la persistencia de los datos (de alguna fuente como archivos TXT, CSV, BD, etc.). El JobLauncher lanzará procesos suministrando los parámetros de entrada deseados. El Job servirá de proceso, un contenedor de Steps. Cada Step es un elemento independiente dentro de un Job. Además cada Step se compone de tres elementos:
En esa base de datos se crearán 6 tablas y éstas son:
En el anterios post vimos los componentes principales del Batch Domain Language. El JobRepository se encargará de la persistencia de los datos (de alguna fuente como archivos TXT, CSV, BD, etc.). El JobLauncher lanzará procesos suministrando los parámetros de entrada deseados. El Job servirá de proceso, un contenedor de Steps. Cada Step es un elemento independiente dentro de un Job. Además cada Step se compone de tres elementos:
- ItemReader: responsable de leer los datos de una fuente.
- ItemProcessor: encargado de procesar la información.
- ItemWriter: encargado de guardar la información leída por el writer y procesada por el processor. Si hay un reader debe haber un writer.
Spring Batch utiliza la base de datos para mantener el estado durante una sola ejecución y desde la ejecución hasta
ejecución. Se registra información sobre la instancia de trabajo, los parámetros pasados, los resultados de la
ejecución, y los resultados de cada paso.
En esa base de datos se crearán 6 tablas y éstas son:
- BATCH_JOB_EXECUTION
- BATCH_JOB_EXECUTION_CONTEXT
- BATCH_JOB_EXECUTION_PARAMS
- BATCH_JOB_INSTANCE
- BATCH_STEP_EXECUTION
- BATCH_STEP_EXECUTION_CONTEXT
Básicamente esas tablas contienen la información de los Job y Steps en una aplicación batch.
Para poder crear éstas tablas debemos tener éstos parámetros en nuestro application.properties.
-- Nos muestra el status, exit_code, etc. -- Si se completó el batch, COMPLETED -- Si hubo alguna falla, FAILED SELECT * FROM public.batch_job_execution; -- Nos muestra el id del Job en ejecución, etc. SELECT * FROM public.batch_job_execution_context; -- Nos muestra el tipo de parámetro, su id, etc. -- Ejemplo: LONG SELECT * FROM public.batch_job_execution_params; -- Nos muestra el nombre del Job a cargar, etc. -- Ejemplo: ETL-load SELECT * FROM public.batch_job_instance; -- Nos muestra el nombre del Step, start_time,etc. -- Ejemplo: ETL-file-load SELECT * FROM public.batch_step_execution; -- Nos muestra el short_context, etc. SELECT * FROM public.batch_step_execution_context;
Para poder crear éstas tablas debemos tener éstos parámetros en nuestro application.properties.
#BATCH spring.batch.job.enabled=false spring.batch.initialize-schema=always
En siguientes post veremos más detalles de Spring Batch.
Comentarios
Publicar un comentario