본문 바로가기
728x90
반응형

데이터파이프라인2

스프링 클라우드 데이터 플로우(SCDF)를 활용한 무중단 서비스 구축: 소스, 프로세서, 싱크 어플리케이션 스트림 통합 및 배포 (3) 이제 SCDF 서버로 다시 돌아와서 지금까지 만들었던 어플리케이션을 스트림 구조를 활용하여 무중단 서비스를 만들어 봅시다. add applications 클릭 1. 하나의 어플리케이션 등록 클릭 2. name , type , URI 설정 -. type에는 source, processor, sink 에 맞게 골라 주세요 -. URI에는 메이븐 리파지토리에 올린 본인의 jar를 추가해 주는데 다음과 같은 형식으로 올리면 됩니다. maven://그룹아이디:네임:버전 위와 같이 source, processor, sink를 올려주면 본인이 올린 어플리케이션들을 확인 할 수 있습니다. 이제 Streams 탭을 클릭하고 create streams를 클릭합니다. 우리가 만든 어플리케이션을 왼쪽에서 찾아 드래그 하여 담.. 2023. 6. 12.
스프링 클라우드 데이터 플로우 (SCDF)를 활용한 실시간 데이터 파이프라인 구축 - 소스, 프로세서, 싱크 어플리케이션 개발 및 통합 실습 (2) 우리는 로컬 SCDF 서버를 띄우는데 성공했습니다. 이제 여기서 뭘 할 수 있을까요?? 위의 어플리케이션 타입을 보면 source , processor, sink를 확인 할 수 있습니다. 이 세가지 어플리케이션은 각각 데이터 제공, 데이터 가공, 데이터 처리의 역할을 할 수 있습니다. 바로 실습해 봅시다. 먼저 source 어플리케이션을 만듭니다. https://start.spring.io/ 1. spring.io 로 이동하여 test source 프로젝트를 만들어줍니다. 저는 롬복과 래빗엠큐를 의존성으로 주입하여 만들었습니다. 이 프로젝트는 5초에 한번씩 hello, SCDF! 라는 메시지 데이터를 제공합니다. (1). app입니다. package com.example.scdfsource; import.. 2023. 6. 12.
728x90
반응형