공개 미리 보기의 Atlas Stream Processing
Atlas Stream Processing은 문서 모델과 쿼리 API를 사용하여 스트리밍 데이터를 처리하는 MongoDB 네이티브 방식입니다.
연결을 구성하세요
Apache® Kafka®용 공식 MongoDB 커넥터 는 MongoDB에서 개발 및 지원하며 Confluent에서 검증했습니다. 커넥터를 통해 MongoDB를 Apache Kafka의 싱크와 소스로 구성할 수 있습니다.
애플리케이션과 서비스 간에 거의 실시간으로 이벤트를 스트림하는 강력한 반응형 데이터 파이프라인을 쉽게 구축할 수 있습니다.
MongoDB와 Apache Kafka를 선택하는 이유
MongoDB와 Kafka는 최신 데이터 아키텍처의 핵심입니다. Kafka는 이벤트를 순차적으로 커밋 로그에 기록하는 무한한 데이터 스트림을 위해 설계되어 서비스 간 지연 시간이 짧은 데이터 이동을 가능하게 합니다.
싱크로 구성
Kafka 토픽에서 MongoDB collection으로 직접 이벤트를 손쉽게 매핑하고 지속하세요. Kafka 토픽에서 MongoDB collection으로 직접 이벤트를 수집하여 효율적인 쿼리, 보강 및 분석을 위해 데이터를 서비스에 노출할 수 있습니다.
소스로 구성
MongoDB의 데이터 변경 사항을 Kafka 토픽으로 게시하여 사용 중인 앱으로 스트리밍하세요. 데이터는 MongoDB cluster 내의 Change Streams를 통해 캡처되어 Kafka 토픽에 게시됩니다. 이렇게 하면 사용 중인 앱이 이벤트 기반 프로그래밍 스타일을 사용하여 실시간으로 데이터 변경 사항에 반응할 수 있습니다.
MongoDB를 선택하는 이유
MongoDB 고객은 광범위한 산업과 기업에서 다양한 사용 사례에 걸쳐 Kafka connector를 활용하여 성공을 거두었습니다.
eCommerce 및 고객 Single View
선도적인 온라인 전기 소매업체인 ao.com은 Kafka를 사용하여 소스 데이터베이스의 모든 데이터 변경 사항을 MongoDB Atlas로 푸시합니다. 이를 통해 모든 고객 데이터에 대한 단일 정보 소스를 생성하여 고객 서비스, 사기 탐지, GDPR 규정 준수 등 새롭고 향상된 애플리케이션과 비즈니스 프로세스를 추진할 수 있습니다. 적절한 권한이 있는 직원은 사용하기 쉬운 하나의 운영 데이터 계층에서 고객 데이터에 액세스할 수 있습니다.
IoT
인도에서 10만 명 이상의 사람들을 저렴한 스마트 홈에 수용하는 프로젝트에 참여하고 있는 Josh Software는 수백만 개의 센서에서 수집한 데이터를 Kafka로 푸시하여 Apache Spark에서 처리하고 그 결과를 운영 및 분석 데이터에 연결되는 MongoDB에 기록하는 작업을 수행합니다. 이 프로젝트는 수백만 개의 센서에서 거의 실시간으로 데이터를 스트리밍하여 진정한 스마트 홈을 만들고 있으며, 시민들은 모바일 앱을 통해 데이터에 액세스하여 집을 더 잘 관리할 수 있습니다.
금융 서비스
세계 최대의 헤지 펀드 투자 회사 중 하나인 The Man Group의 자회사인 AHL은 MongoDB를 사용하여 모든 금융 데이터를 위한 단일 플랫폼을 만들었습니다. 이 시스템은 여러 금융 소스에서 초당 최대 150,000개의 틱 데이터를 수신하여 Kafka에 기록합니다. Kafka는 이벤트가 데이터를 분석할 수 있는 MongoDB에 저장되기 전에 이벤트 통합과 버퍼링을 모두 제공합니다.
의견 및 투표
비슷한 생각을 가진 사람들을 연결하는 지능형 오피니언 네트워크인 State는 설문조사 데이터를 MongoDB에 기록하고, MongoDB Change Streams를 활용하여 데이터베이스 변경 사항을 사용자 추천 엔진에서 소비되는 Kafka 토픽으로 푸시합니다. 이 엔진은 잠재적으로 관심 있는 사용자를 제안하고 사용자가 새로운 의견을 제공하는 즉시 업데이트합니다.
주요 리소스
