[KAFKA] 대용량 센서데이터 저장 처리 - MongoDB 연동

이번엔 지금까지 받은 데이터를 MongoDB에 저장하도록 한다.Docker에 MongoDB 설치프로젝트폴더> docker run -d --name mongodb -p 27017:27017 mongo현재 Docker에서는 mongodb와 kafka관련 항목이 실행 중이어야한다.이제 이전에 작성했던 kafka_consumer_server.py 파일을 수정한다. kafka_consumer_server.py 일부 수정...app = FastAPI() # FastAPI 인스턴스 생성mongo_client = MongClient("mongodb://localhost:27017/") # MongoDB 클라이언트 생성mongo_db = mongo_client["sensor_database"] # MongoDB 데이..

2025.05.27