구현 해보는 기능

Intro.

• 필수 기능

  • 주기적으로 일괄 처리가 가능해야함
  • 동시에 일괄 처리가 가능해야함 → 병렬 처리
  • 실패 후 수동 또는 예약된 후 처리 (다시 시작)
  • 레코드 건너 뛰기 (부분 처리 or 롤백 시 처리)

• 목표

  • 배치 개발에 필요한건 spring batch에 맡기고, 비지니스 로직에 집중 할 수 있도록 한다.
  • 인프라 계층에 영향을 주지 않는다.
  • 계층 분리를 확실히 한다
  • 배치가 잘 처리되어야 한다.

용어.

• Job : Spring Batch에서 배치 작업을 정의하고 실행하기 위한 최상위 개념.
  • 하나 이상의 Step을 포함하고 있으며, 전체 배치 작업의 설정과 실행을 관리하는 역할.
• JobInstance : Job 실행에 대한 실제 인스턴스.
  • Job의 실행 단위가 되며, 실행 시점의 시간 정보와 함께 Job Parameter를 가지고 있다.
• JobExecution : JobInstance의 실행에 대한 정보를 담고 있는 객체.
  • Job 실행 시점의 정보를 가지고 있으며, 실행 결과에 대한 정보도 포함한다.

<aside> 💡 JobInstance 를 얻지 못하는 경우

잡을 처음 실행하면 새로운 JobInstance 및 JobExecution 을 얻게된다. 실행에 실패한 이후 재실행하면, 해당 실행은 여전히 동일한 파라미터로 실행된 잡이므로 새 JobInstance 를 얻지 못한다. 그 대신, 실제 실행을 추적하기 위한 새로운 JobExecution 을 얻게된다.

</aside>

• JobRepository : Spring Batch 내에서 Job 및 Step 실행 정보를 관리하는 데 사용.
  • 실행 중인 Job 및 Step의 상태, 파라미터, 실행 히스토리 등을 추적하고 관리합니다.

• Step : Job 내에서 구체적인 배치 작업을 정의. 각 스텝은 Job을 구성하는 독립적인 작업 단위이다. Step에는 Tasklet, Chunk 기반으로 2가지가 있다.

  • Tasklet : Step 내에서 특정 작업을 실행하고자 할 때 사용됩니다
    • 배치 작업을 실행하는 데 사용됩니다. 비즈니스 로직을 포함하거나 커스텀 작업을 처리하는 데 유용합니다.
  • Chunk : Step 내에서 데이터 처리 단위를 정의하는 데 사용됩니다.
    • 큰 데이터 세트를 작은 "청크"로 분할하여 처리하며, 이렇게 분할된 청크는 ItemReader로 읽고 ItemProcessor 및 ItemWriter로 전달됩니다.
  • ItemReader : Step에 사용될 데이터를 읽어오는 역할을 하는 인터페이스.
    • 데이터 소스로부터 데이터를 읽어와 하나씩 배치 작업에 전달한다.
  • ItemProcessor : Step에 의해 읽어들인 데이터에 대해 처리하는 인터페이스.
    • 읽어들인 데이터를 가공하거나, 필터링하는 등의 작업을 수행한다.
  • ItemWriter : Step에서 처리된 데이터를 저장하는 역할을 하는 인터페이스.
    • 데이터를 저장하는 방식에 따라 다양한 구현체가 제공된다.

• StepExecution : Step 실행에 대한 실제 실행을 의미