패스트캠퍼스 챌린지 21일차 - Spring Batch 3

📌 spring-batch 3

 

✔️ JobExecutionContext

• Step 간 데이터 공유를 위해 사용
  ex) job의 execution context 접근

  JobExecution jobExecution = stepExecution.getJobExecution();
  JobInstance jobInstance = jobExecution.getJobInstance();
  ExecutionContext jobExecutionExecutionContext = jobExecution.getExecutionContext();

 

✔️ StepExecutionContext

• 한 Step 내에서만 데이터 유효하다.
• Step 간 데이터를 공유하는 것이 아니다. ❌
  ex) step의 execution context 접근

  StepExecution stepExecution = contribution.getStepExecution();
  ExecutionContext stepExecutionExecutionContext = stepExecution.getExecutionContext();

 

✔️ 배치 처리 2가지 방법

Tasklet

• 비교적 쉽게 구현 가능하다.
• 대량 처리의 경우 오히려 더 복잡할 수 있다.
• 하나의 큰 덩어리를 나누어 처리하기는 부적합하다. (가능은 함)

Chunk

• 대량처리의 경우 Tasklet보다 쉽게 구현 가능하다.
  ex) 10000개 데이터를 1000개씩 10개 덩어리로 나누어 처리
  Tasklet으로 처리하면 10000개를 한번에 처리하거나 수동으로 1000개씩 분할

 

✔️ ChunkBasedStep

stepBuilderFactory.get("stepName")
    .<String, String>chunk(10) // 배치를 10번에 나누어 처리
    .reader(itemReader())
    .processor(itemProcessor())
    .writer(itemWriter())
    .build()

• itemReader() 에서 null을 반환할 때까지 step 반복한다.

✔️ TaskBasedStep

stepBuilderFactory.get("stepName")
    .tasklet()
    .build();

 

✔️ chunk 메서드
<input,output>chunk(int)

• itemReader에서 input 타입으로 리턴한다.
• itemProcessor에서 input 타입 데이터를 받아 output 타입으로 리턴한다.
• itemWriter는 itemProcessor로부터 output 타입 리스트를 받아 처리한다.
  • output타입 리스트의 크기가 chunk 사이즈
  • itemWriter에서 한 step에서 처리하는 크기 = chunk size

 

✔️ ListItemReader
생성자 파라미터로 List<T>를 받는다.

• 예제에서 ItemReader에서 List를 구성할 때 사용한다.

 

✔️ Task 기반 step에서 chunk 구현

• 코드로 chunk 사이즈를 지정하여 배치 데이터를 잘라서 구현한다.

StepExecution stepExecution = contribution.getStepExecution();

int chunkSize = 10;
int fromIdx = stepExecution.getReadCount();
int toIdx = fromIdx + chunkSize;

if (fromIdx >= testData.size()) return RepeatStatus.FINISHED;

log.info("(task) chunk size = {}", testData.subList(fromIdx, toIdx).size());

stepExecution.setReadCount(toIdx);

return RepeatStatus.CONTINUABLE;

 

✔️ Task 기반 step에서 chunk 구현 (JobParameters 사용)
실행시점에 파라미터에 대한 유연한 조작 가능하다.

StepExecution stepExecution = contribution.getStepExecution();
JobParameters jobParameters = stepExecution.getJobParameters();

int chunkSize = 
Integer.parseInt(jobParameters.getString("chunkSize", "0"));

 

✔️ 파라미터 지정
Edit Contribution - Program arguments
-chunkSize=20 --job.names=chunkProcessingJob

 

---

 

👍  수강인증

패스트캠퍼스 [직장인 실무교육]

본 포스팅은 패스트캠퍼스 환급 챌린지 참여를 위해 작성되었습니다.