message queue와 apache storm 연동 관련 질문드립니다.

Question

실시간 IOT Bigdata를 분석하는 프로젝트를 진행 중 message queue(rabbitmq)와 apache storm 연동 로직에 개념이 잡히지 않아 개발 선배님들께 의견을 여쭙고 싶습니다. 전체적인 플로우는 다음과 같습니다.1. 라즈베리파이로 부터 센서값을 mqtt protocol로 받고 해당 데이터를 message queue에 적재한다.2. message queue에서 데이터(tuple)를 꺼내온다. - Apache Storm의 spout 이용3. 꺼내온 데이터(tuple)를 조건에 따라 처리하여 mongodb에 적재한다. - Apache Storm의 bolt 이용4. mongodb에 적재된 값을 이용하여 display한다. -Node-red, Apache Zeppelin 이용 제가 궁금한 점은 message queue에 적재하는 과정과 Apache storm으로 데이터를 분석(처리)하여 mongodb에 적재하는 과정을 하나의 vm만 띄워서 실행해야 할지 아니면, 두 개의 vm을 띄워 적재하는 과정과 분석하는 과정을 나누어 구현해야할 지 어느 것이 맞는 가입니다. 개발쪽 지식이 미숙한 신입이라 설명이 부족한 점 죄송하네요..

message queue와 apache storm 연동 관련 질문드립니다.

0개의 답변

#bigdata 목록