Skip to main content

Spring Batch를 활용한 서비스 구현

Turaco 서비스 아키텍처 메뉴에서 대량의 데이터 처리를 제공하는 Spring Batch 서비스를 제공합니다.

Spring Batch - 데이터 처리 사용방법​

Turaco 서비스에서는 Kafka To DB, DB To DB 두가지 방법의 데이터 처리방법을 제공합니다. 데이터 이동을 처리하기위해서 아키텍처 서비스를 통해 만들어진 SpringBoot에서 생성되는 테이블을 이용하고 있습니다.

Database 연결 종류

Database는 MariaDB, Mysql, PostgreSQL 만 연결이 가능합니다.

애플리케이션 배포순서
  1. Database, Kafka
  2. Spring Boot
  3. Spring Batch

Spring Boot 배포시 생성되는 기본 테이블​

스프링배치 디비 테이블

Spring Batch - Kafka To DB​

Spring Batch에서 카프카에 저장된 데이터를 읽어서 연결된 DB에 저장하는 로직을 수행합니다.

Kafka에서 DB로 데이터 전달을 위해 producer에서 주입할 데이터 형식​

{
 "id": "1",
 "content": "내용",
 "post": "N"
}
스프링배치 카프카

Spring Batch - DB To DB​

Spring Batch에서 연결된 DB에서 데이터를 읽어서 연결된 DB에 저장하는 로직을 수행합니다.

같은 DB만 연결이 가능하며 연결된 SpringBoot 배포시 생성되는 기본 Table을 사용합니다.

스프링배치 디비

Spring Batch - DB/ 단독 사용​

Spring Batch에 기본 동작이 수행되는 기본 서비스입니다. DB연결 또는 DB 연결없이 단독으로 사용이 가능합니다.