Drasi - 이벤트 구동 시스템을 위한 Microsoft의 오픈소스 데이터 처리 플랫폼

• 중요한 이벤트 감지와 즉각적인 대응을 단순화함으로써 실시간 이벤트 기반 아키텍처를 향상시키는 데이터 처리 플랫폼
• 시스템 로그와 특정 이벤트의 변경 피드를 추적하고, 이를 평가하여 자동으로 적절한 반응을 시작하는 포괄적인 솔루션을 제공
• 여러 데이터 소스를 통합하고, 관련 변경 사항을 지속적으로 모니터링하며, 스마트하고 자동화된 대응을 트리거함으로써 전체 프로세스를 간소화함
• 변경 사항 감지를 위해 복잡한 시스템을 구축하거나 대규모 데이터 레이크를 관리하거나 기존 에코시스템에 최신 감지 소프트웨어를 통합할 필요가 없음
• IoT 통합, 보안 프로토콜 개선, 정교한 애플리케이션 관리 등 이벤트 기반 시나리오 전반에서 활용할 수 있음
• 개요
  • 전통적인 데이터 처리 방법의 부담 없이 실시간으로 실행 가능한 통찰력을 제공함.
  • 데이터 레이크로 데이터를 복사하거나 데이터 소스를 반복적으로 쿼리할 필요 없이 시스템 변경 및 이벤트를 추적함
  • 쿼리를 사용하여 들어오는 데이터 변경을 지속적으로 평가
  • 변경 사항이 쿼리에서 지정한 기준 및 조건과 일치할 때, 쿼리의 결과 집합이 업데이트됨
  • 이러한 업데이트는 특정 요구 사항에 맞춘 맥락 인식 반응을 유발
• Drasi는 세 가지 구성 요소로 작동함:
  • Sources: 소프트웨어 시스템 내 데이터 저장소에 연결하여 로그와 피드를 모니터링하고 데이터 변경을 추적함.
  • Continuous Queries: 모니터링된 변경 사항에 사전 정의된 기준과 조건을 적용하여 중요한 변경 사항을 식별 및 평가함. Drasi에서는 Cypher Query Language를 사용하 여 지속 쿼리를 작성함.
  • Reactions: 지속 쿼리의 결과 집합에 대한 업데이트를 기반으로 자동화된 반응을 실행함
• 온라인 주문 서비스의 배송 시스템을 예로 들어, Drasi가 이벤트를 해석하고 적절한 반응을 유발하는 방법을 설명하면
  • 주문 상태 변경을 모니터링하기 위해 주문 관리 시스템에 소스를 구성하고, 드라이버가 배달 준비가 되었을 때를 감지하기 위한 두 번째 소스를 구성
  • 두 소스의 데이터를 결합하여 픽업 준비가 된 주문과 이용 가능한 드라이버를 일치시키는 지속 쿼리를 생성
  • 드라이버에게 알림을 보내 픽업 구역으로 이동하도록 알리는 반응을 정의
  • 이 간소화된 설정은 드라이버가 신속하게 정보를 받아 배송 프로세스를 최적화

GN⁺의 정리

• Drasi는 데이터 변화 감지와 즉각적인 조치를 간소화하는 플랫폼으로, 실시간 데이터 통합과 자동화된 반응을 통해 효율성을 높임.
• Cypher Query Language를 사용하여 지속 쿼리를 작성하며, 시스템 로그와 이벤트를 모니터링하여 중요한 변경 사항을 식별함.
• 초기 릴리스로 커뮤니티가 플랫폼을 배우고 실험할 수 있도록 하며, 기여와 피드백을 장려함.
• 유사한 기능을 가진 프로젝트로는 Apache Kafka와 같은 실시간 데이터 스트리밍 플랫폼이 있음.