Job Parameters - Spring Batch Part 4

By -
If you try rerunning your Spring Batch application from Part 3 blogpost, you will see that you are not able to do it. Why? Spring Batch utilizes the Job Repositories table and knows that the job has run already.

You have a Corporate Gift Shop., you want to continuously run the batch job so it picks up the orders placed and packages them and ships them. How do you rerun job?

The answer is simple, create different Jobs each time you want to run them by passing Job Parameters.


In intellij this is how I do, by editing run time parameters:

Rerun, and you should be able to see the output. Check the db tables, and you should see new entries.

Its very important that you are able to read the Job Parameters as they may have some important information you want to use while running your Job or Logging purpose.

If you want to package your gifts in a specific gift wrapper, you could specify like this:
@Bean
public Step packageStep() {
   return this.stepBuilderFactory.get("packageStep").tasklet(new Tasklet() {
      @Override
      public RepeatStatus execute(StepContribution contribution, ChunkContext chunkContext) throws Exception {
         String giftWrapper = chunkContext.getStepContext().getJobParameters().get("giftWrapper").toString();
         System.out.println("Packaging the gift with " + giftWrapper);
         return RepeatStatus.FINISHED;
      }
   }).build();
}
Your code will look for a Job Property of giftWrapper using the Chunk Context and make it available for your step to use.

Lets run with "giftWrapper=Golden Box" as our Job Parameter.

2020-07-18 00:03:01.072  INFO 6488 --- [           main] c.r.s.SpringbootdemoApplication          : Started SpringbootdemoApplication in 3.444 seconds (JVM running for 4.251)
2020-07-18 00:03:01.080  INFO 6488 --- [           main] o.s.b.a.b.JobLauncherApplicationRunner   : Running default command line with: [giftWrapper=Golden Box]
2020-07-18 00:03:01.214  INFO 6488 --- [           main] o.s.b.c.l.support.SimpleJobLauncher      : Job: [SimpleJob: [name=giftShopJob]] launched with the following parameters: [{giftWrapper=Golden Box}]
2020-07-18 00:03:01.280  INFO 6488 --- [           main] o.s.batch.core.job.SimpleStepHandler     : Executing step: [readOrderStep]
Order Received
2020-07-18 00:03:01.314  INFO 6488 --- [           main] o.s.batch.core.step.AbstractStep         : Step: [readOrderStep] executed in 34ms
2020-07-18 00:03:01.329  INFO 6488 --- [           main] o.s.batch.core.job.SimpleStepHandler     : Executing step: [packageStep]
Packaging the gift with Golden Box
2020-07-18 00:03:01.345  INFO 6488 --- [           main] o.s.batch.core.step.AbstractStep         : Step: [packageStep] executed in 16ms
2020-07-18 00:03:01.364  INFO 6488 --- [           main] o.s.batch.core.job.SimpleStepHandler     : Executing step: [deliveryStep]
Package out for delivery
2020-07-18 00:03:01.379  INFO 6488 --- [           main] o.s.batch.core.step.AbstractStep         : Step: [deliveryStep] executed in 15ms
2020-07-18 00:03:01.388  INFO 6488 --- [           main] o.s.b.c.l.support.SimpleJobLauncher      : Job: [SimpleJob: [name=giftShopJob]] completed with the following parameters: [{giftWrapper=Golden Box}] and the following status: [COMPLETED] in 126ms
2020-07-18 00:03:01.396  INFO 6488 --- [extShutdownHook] com.zaxxer.hikari.HikariDataSource       : HikariPool-1 - Shutdown initiated...
2020-07-18 00:03:01.415  INFO 6488 --- [extShutdownHook] com.zaxxer.hikari.HikariDataSource       : HikariPool-1 - Shutdown completed.


You can also package your application into a jar and run it as follows:
java -jar <jarname>.jar "jobParameter=value"

Tip: You could use current date to make your Jobs Unique!

You can check the parameters passed to your Job by looking at the table BATCH_JOB_EXECUTION_PARAMS



Comments

Post a Comment

Popular posts from this blog

Writing your own ejabberd Module

By -
Coming soon: What is ejabberd? What is erlang? Installation details. I will start with writing the ejabberd module first. Once you have done all the installations: sudo make sudo make install sudo ejabberdctl start sudo ejabberdctl stop You can check the status using: sudo ejabberdctl status You can locate logs at: (With default installation) /var/log/ejabberd All config related changes will be mainly done at: /etc/ejabberd/ejabberd.yml You will need a basic understanding of erlang. You can take a short crash course at: http://www.erlang.org/course/course.html This is a good reference. Go to your ejabberd-15.07/src directory. This is where you will write the hook for your ejabberd server. Create a file, say mod_changeBody.erl. Your module name and file name should be same. Add the following basic contents into your erl file: -module(mod_changeBody). -behavior(gen_mod). -include("ejabberd.hrl"). -include("logger.hrl"). -expo
Read more

npm ECONNREFUSED error

By -
If you face error which says ECONNREFUSED while doing npm install <<package name>>, you are probably behind a proxy which is not allowing you to connect to the server and download the packages required. Just follow the below steps: npm config set proxy  http://your_proxy_name:port npm config set https-proxy https://your_proxy_name:port And then try npm install How to get npm config? npm get proxy will do the work :)
Read more

Conditional Flow - Spring Batch Part 6

By -
Jump to Conditional Flow using Custom Status There can be muliple scenario where you want your jobs to proceed depending on the outcome of your steps. For example, in case of our Corporate gifts shop, in case the automatic packaging of the gifts fails, we want some manual intervention to be done i.e. somebody should manually package the item.  IF-ELSE IF loop for packaging:     if packageStep fails                              then manualPackageStep                         else if packageStep executes successfully                              then sendOutForDelivery Entire code available at git repo:   https://github.com/ricsr/spring-batch-demo/tree/exercise_06 Using SpringBatch you can achieve it as follows: Create you manualPackageStep, which is very similar to your packageStep, except that it does the packaging manually. @Bean public Step manualPackageStep () { return this . stepBuilderFactory .get( "manualPackageStep" ).tasklet( new Tasklet() { @Override pu
Read more