스프링 클라우드 데이터 플로우(SCDF)를 활용한 무중단 서비스 구축: 소스, 프로세서, 싱크 어플리케이션 스트림 통합 및 배포 (3)

 

 

 

 

 

이제 SCDF 서버로 다시 돌아와서 

 

지금까지 만들었던 어플리케이션을 스트림 구조를 활용하여 무중단 서비스를 만들어 봅시다.

 

 

 

 

add applications 클릭

 

 

 

 

 

1. 하나의 어플리케이션 등록 클릭

 

2. name , type , URI 설정

 -. type에는 source, processor, sink 에 맞게 골라 주세요

 -. URI에는 메이븐 리파지토리에 올린 본인의 jar를 추가해 주는데 다음과 같은 형식으로 올리면 됩니다.

    maven://그룹아이디:네임:버전

 

 

 

 

위와 같이 source, processor, sink를 올려주면 

 

 

본인이 올린 어플리케이션들을 확인 할 수 있습니다.

 

 

 

 

이제 Streams 탭을 클릭하고 create streams를 클릭합니다.

 

 

 

 

 

우리가 만든 어플리케이션을 왼쪽에서 찾아 드래그 하여 담아주고 선으로 이어줍니다.

 

마지막으로 create streams 클릭해주세요

 

 

 

stream 이름을 설정하고 create streams 클릭

 

 

 

 

스트림을 생성하였다면 해당 스트림을 클릭합니다.

 

 

배포를 클릭

 

 

 

 

 

여기는 배포할때 설정을 하는 부분인데 아직 익숙치 않아 글로벌에 512, 4코어 100mb 씩 할당하여 

 

배포하였습니다. 이 부분은 처음이라 아직 저도 미숙한 부분이니 좀더 공부가 필요합니다.

 

어쨋든 밑에 배포를 선택하면 

 

스트림이 배포 됩니다.

 

해당 스트림을 배포하면 각각의 어플리케이션 별 로그를 확인할 수 있습니다.

 

또한 제 오라클에 데이터가 이렇게 저장되는 모습을 볼 수 있죠

 

 

5초마다 한번씩 저장됩니다.

 

이런 방식으로 SCDF를 활용할 수 있는 가장 간단한 예제를 작성해 보았습니다.

 

SCDF를 사용하여 메타데이터 가공 및 저장 프로젝트를 진행할 예정인데 확장 가능성 및 관리가 용이해 보입니다.

 

지금까지 간단한 SCDF 실습을 진행하였습니다.

 

 

감사합니다.