Drasi - イベント駆動システム向け Microsoft のオープンソースデータ処理プラットフォーム

• 重要なイベントの検知と即時対応を簡素化することで、リアルタイムのイベントベースアーキテクチャを強化するデータ処理プラットフォーム
• システムログと特定イベントの変更フィードを追跡し、それを評価して自動的に適切な反応を開始する包括的なソリューションを提供
• 複数のデータソースを統合し、関連する変更を継続的に監視し、スマートで自動化された対応をトリガーすることで、プロセス全体を簡素化
• 変更検知のために複雑なシステムを構築したり、大規模なデータレイクを管理したり、既存のエコシステムに最新の検知ソフトウェアを統合したりする必要がない
• IoT 統合、セキュリティプロトコルの改善、高度なアプリケーション管理など、イベント駆動型シナリオ全般で活用できる
• 概要
  • 従来のデータ処理手法の負担なしに、リアルタイムで実行可能なインサイトを提供する。
  • データをデータレイクにコピーしたり、データソースに繰り返しクエリを送ったりすることなく、システムの変更やイベントを追跡する
  • クエリを使って流入するデータ変更を継続的に評価
  • 変更内容がクエリで指定した基準や条件に一致すると、クエリの結果セットが更新される
  • これらの更新は、特定の要件に合わせたコンテキスト認識型の反応を引き起こす
• Drasi は 3 つのコンポーネントで構成される:
  • Sources: ソフトウェアシステム内のデータストアに接続し、ログとフィードを監視してデータ変更を追跡する。
  • Continuous Queries: 監視された変更に事前定義された基準と条件を適用して、重要な変更を識別・評価する。Drasi では Cypher Query Language を使って継続クエリを作成する。
  • Reactions: 継続クエリの結果セットに対する更新に基づいて、自動化された反応を実行する
• オンライン注文サービスの配送システムを例に、Drasi がイベントを解釈して適切な反応を引き起こす方法を説明すると
  • 注文状態の変更を監視するために注文管理システムにソースを構成し、ドライバーが配達準備完了になったことを検知するための 2 つ目のソースを構成
  • 2 つのソースのデータを結合して、集荷準備ができた注文と利用可能なドライバーをマッチングする継続クエリを作成
  • ドライバーに通知を送り、集荷エリアへ移動するよう知らせる反応を定義
  • この簡素化された設定により、ドライバーは迅速に情報を受け取り、配送プロセスを最適化できる

GN⁺のまとめ

• Drasi はデータ変化の検知と即時アクションを簡素化するプラットフォームであり、リアルタイムなデータ統合と自動化された反応によって効率を高める。
• Cypher Query Language を用いて継続クエリを作成し、システムログとイベントを監視して重要な変更を識別する。
• 初期リリースとして、コミュニティがプラットフォームを学び実験できるようにし、貢献とフィードバックを促している。
• 類似機能を持つプロジェクトとして、Apache Kafka のようなリアルタイムデータストリーミングプラットフォームがある。