EDA（Event Driven Architecture）出現の背景と真のEDA活⽤⽅法
Vantiq株式会社 代表取締役社⻑
EDAコンソーシアム 運営委員⻑
川北 潤
May. 2021h"ps://eda-consor/um.jp/

EDA出現の背景

1. データの量、性質の変化
リアルタイムデータ量と全データ中のシェア（グローバル）

DB中⼼のシステム設計の場合...
⭕ ビッグデータ解析❌ リアルタイムアプリケーション
全体に対する％

リアルタイムデータ量

EDA出現の背景

2. データの発⽣源、利⽤形態の変化

SMART CITY••

データベース セントリック
マルチテナント••

ソフトウェア エブリウェア（エッジからクラウドまで）
マルチステイクホルダー / ダイバシティ❌ DB共有⭕ イベント共有EDA出現の背景
3. ビジネス形態の変化

所有固定サービス

IoTAI
フォ ントース マ リ ティ
モビ

シェアリングエコノミー
オンデマンドDX成功の秘訣

細かくデマンドが変化 → リアルタイムなサービス
売上げ

例1: エアコンを買う（1台）→ ⼼地よい空気を買う（ON/OFF）
例2: ⾞１台の定額保険 → その時の乗⾞⼈数の保険
ロングテイルの振動

ロングテイル
商 品 / サービス

EDA出現の背景
4. スマート化への対応①交差点の例

これまでと違って、何がスマートなのか︖

ダイナミックな状況判断とリアルタイムな切り替え

スタティックな切り替え
交通量データ

分析

例︓ 信号機・交差点編

今はAの⽅が流れが悪い、A⽅向を⻑めにしよう

信号機切り替えタ
イミング
リスト

交通量調査
リスト
時間帯1：A:20秒、B:30秒
時間帯2：A:25秒、B:25秒
時間帯3：A:30秒、B:20秒：：

事故が発⽣したので、⼀般⾞両を迂回させよう

⾞椅⼦がいるので、渡り終えるまで⾞を⽌めようEDA出現の背景
4. スマート化への対応②災害対策

これまでと違って、何がスマートなのか︖
スタティックな避難指⽰

例︓ 避難勧告・指⽰編
ダイナミックな状況判断とリアルタイムな避難指⽰
避難場所２の近くで⼤規模⽕災、２以外へ避難指⽰

天気予報の⾵
向きにより、A地区へも避難勧告
自宅から一番近い避難場所を、予め案内しておく

B市⺠の携帯端末へ、D地区経由で避難場所４への避難ルート
案内

衛星のモバイル空間情報を⾒るとB地区に⼤勢の⼈がいるEDAの出現と新たな課題 環境の変化への対応
リクエスト・ドリブン
逐次処理/密結合

イベントドリブン・アーキテクチャ（EDA）
APP

Alert: 30度以上

並列処理/疎結合
Topic

Pub

Call
Call
Call

APP

APP

・１つの複合処理<これまで>
リクエストドリブンな逐次処理のシステム
では、IoT時代の突然・不定期に発⽣するイベントに対応するリアルタイムアプリ
ケーションの構築は困難。

温度

EventBroker

Pub
Pub

Sub

様々なイベント

湿度Action
Alert: 50%以上

Sub

ActionAlert: 気温差3度以上

外気温

Sub

Action

・新たな課題︓ 同時多発イベントの複合化＜EDA＞
イベントが発⽣し続ける中で、必要なデータだけをトピックとして取得し、予め設定した条件に合致するとアラートが上がる。アラー
トが上がったらアクション。
→ 次の課題︓トピックスを複合化してアクションするには︖
例題: 気温30度以上かつ湿度50%以上が60秒以上続いたらエアコンのスイッチをONにする。更に、外気と室温の差が3度以上だったら...

Vantiqの特徴 ①同時多発イベントの複合化 / メッセージバス + ルールエンジン
例題: 気温30度以上かつ湿度50%以上が60秒以上続いたらエアコンのスイッチをONにする。
更に外気と室温の差が3度以上だったら...
⼀般的なEDA
Vantiq30度以上
センサーから得る
タイムスタンプ

Sub

温度

EventBroker

30度以上

湿度

Sub
EventBroker

Sub
気温差3度以上

外気温

温度50%以上

Sub
Topic発⽣

60秒以上
Action

湿度50%以上

Sub
気温差3度以上

外気温

Sub
60秒以上

Action・複合化のためにステイトフル環境が必要

・揮発性のステイトフル環境＜⼀般的なEDA = メッセージキュー + マイクロバッチ ＞
ストリーム上にいつトピックスが発⽣するか分からないため、⼀旦データ（タイムスタンプ含む）を蓄積してから複合化し、アクションする。
トピックを追加すると、ロジック全体を作り直し。

＜Vantiq = メッセージバス + ルールエンジン＞
ストリーム処理上に、揮発性のステイトフル環境および独⾃のタイムマネージメント機能をもち、複合化を実現。
蓄積型のデータベースに頼らずリアルタイムにアクション。
データベース主体のシステム設計と異なり、新たなトピックをアジャイルに追加可能。

Vantiqの特徴 ②ダイナミックイベントとスタティク情報のリアルタイムな紐付け
例題: 各部屋ごとに、気温30度以上かつ湿度50%以上が60秒以上続いたらエアコンのスイッチをONにする。
更に外気と室温の差が3度以上だったら...
⼀般的なEDA
Vantiq
30度以上

A B C

計測する部屋が複数ある

A,B,C

Sub

温度

Event
Broker

湿度50%以上

A B C

Sub
気温差3度以上

外気温

A B C

Sub
Topic発⽣

A
A
A

B
B
B

CCC

Aの部屋で60秒以上

ActionSubA
BCSubA
BC

SubA
B
C

温度
EventBroker

湿度

外気温

30度以上

A A A A A A A A A A

50%以上

A A A A A A A

気温差3度以上A A A A A A A

A・複合化のためにステイトフル環境が必要

・揮発性のステイトフル環境＜⼀般的なEDA = メッセージキュー + マイクロバッチ ＞
ストリーム上に発⽣するトピックスの属性が分からないため、⼀旦データを蓄積してから同じ属性同⼠を複合化し、アクションする。

＜Vantiq = メッセージバス + ルールエンジン＞

同⼠

60秒以上

Actionストリーム処理上に、揮発性のステイトフル環境および独⾃のタイムマネージメント機能をもち、複合化を実現。
蓄積型のデータベースに頼らずリアルタイムにアクション。

⼀般的なEDAの設計例

イベントとアプリケーションの関係が1対1、複合化は個々のデータベース（マイクロバッチ）を連携させる
これでは複雑なリアルタイムアプリケーションの構築は困難

EDA関連プロダクトマップ
イベントブローカー

Azure
Event Hubs

FaaS

バッチベースのストリーム処理

ネイティブなストリーム処理

分散ストレージ

Amazon KinesisData Analytics

Amazon S3

ローコード
開発ツール

デバイスマネジメント

Amazon MQ
Google Cloud
DataﬂowAWS IoT Core

Azure IoT Hub

Azure Blob

DBセントリック
開発環境

Vantiqのリアルタイム複合処理
⼀般的なEDAでは複合アプリケーションの構築が困難なため、マイクロバッチと連携する。その結果、I/Oやバッチ起動で遅延が積み重なる。
⼀⽅Vantiqはマイクロバッチの代わりにメッセージバスを提供し、その上に豊富なアクティビティを組み合わせてルール（複合アプリケーション）を設定できる。
EDA（メッセージキュー）+ マイクロバッチ

EDA（メッセージキュー） + Vantiq（メッセージバス + GUI）

Microbatch（毎回起動）

Message bus
IoT
platform

IoT
platform

Real-time multiple event processing

EventBroker
Topic

ActionEventBroker

I/O

Microservice
Microservice

Activitiy
ActionTopic

Low-Colode or No-Code

JVM

Activitiy

豊富なアクティビティ

ActivitiyRule典型的なEDA関連プロジェクトアーキテクチャ
Devices

Analysis

Input

OutputHot Path
Amazon Kinesis
Data Analytics

デバイス

Amazon MQ

Azure
Event Hubs

BIツール
Google Cloud
Dataflow

IoT GWAWS IoT Core
Azure IoT Hub

Web/Mobileアプリ
Cold Path

Amazon S3

Azure Blob

システム連携Vantiqの場合
Devices

Insights/Analysis

Data Flow

Actions

Hot Path
Amazon Kinesis
Data Analytics

デバイス

Amazon MQ

Azure
Event Hubs

BIツール
Google Cloud
Dataﬂow※ローコードでの開発

IoT GWAWS IoT CoreA zure IoT Hub

Web/Mobile アプリ
Cold Path

Amazon S3

Azure Blob

システム連携Vantiqの特徴 ③オールインワン / リアルタイムアプリケーション開発に必要な４要素に対応
VantiqAPP→B ehavi
or4G 5G→
tim e

AI︓ 画像認識や検出・例外処理・需要予測
ダイナ

業務システム
データベース

IoTデバイス・通信回線
ミック

スタテ

イベント
ドリブン

データ
ドリブン

Vantiq Platform

Webサービス

⼈︓ 適切な担当者

サービス
ドリブン

コラボレーション

ィック（＝リアルタイムアプリケーション開発・実⾏プラットフォーム）

Stateful Stream

ActionProceed Only
Edge

TopicsRules

Sources

Procedures

Types

Vantiqとは、ダイナミックデータ、スタティックデータ、Webサービス、⼈的リソースとコラボレーション、これらを連携させてビジネスロジックを完結するオールインワン型アプリケーション開発・実⾏プラットフォーム

Vantiqの特徴 ④アジャイル / ローコード開発
データ取得・処理Ext.
source

MQTT
Kafka
REST
Etc.

コラボレーションビルダー

可視化
クライアントビルダー

Enterprise Connectors withSDK

アプリケーションビルダー

アクション

数⼗種類のアクティビティ
•
データ統合
•
データ整形
•
統計の取得
•フィルタ
•
制限
•
データ追加など

数⼗種類のアクティビティ
•通知•
アサイン
•
位置追跡•
推奨•
会話•
エスカレーションなど

数⼗種類のウィジェット
•各種グラフ
•
各種ボタン
•
カメラ•
バーコード
•
Web/スマホ対応

Vantiqは短期間でアジャイルな開発を実現する、ローコード開発環境を提供します。

Vantiqの特徴 ⑤デプロイ
アプリケーションを開発後、適宜分割してクラウド、オンプレ、エッジなどへ展開し全体を１つのシステムとして実⾏
実⾏

AWS
AZURE
Private

実⾏展開

クラウド
実⾏

オンプレ展開

開発

エッジ展開
実⾏

Vantiqのポジショニング データ処理とイベント処理の連携
リアルタイムアプリケーションは、IoTプラットフォーム（デバイス連携）、データレイクやAI、現場の作業員、ロボットなどとの連携で実現します。
単⼀のIoTプラットフォームやデータレイクにデバイスやデータを集約するだけでは、リアルタイムアプリケーションは実現できません。

Real-time event processing- Multiple events- Action

IoTmplatform- Enterprise Connector

GW
GWRuleEventBroker

Rule- Action& collaboration- アドバンストイベント（複合結果）- 不要データ削除後- データ整形後

EventBroker
Dataanalysis
DirectRule- Action& collaboration- State data
Result of analysis- Machine learning- Analytics- Visualization- AI

Dataprocessing

Real-&me Business
Opera&ons Examples

Compliance, Safety,
and Security

Smart Manufacturing

Environmental
Monitoring &Response

Smart Ci/es

Financial Services
Orchestration

Supply Chain Control

Real-Time Field
ServiceManagement

MedicalDynamic Customer
ServiceReal-Time Fleet
ManagementServiceUSE
CASE

セキュリティ、警備カメラ（画像AI）連携、マンマシンコラボレーション

GLOTECH / 北京
アプリケーション: GLOTECHはビデオストリームから重要なデータを抽出するAI ビデオ画像認識システムを開発した。これに基づいてVantiqはマンマシンコラボレーションでリアルタイムアクションを発動できる。
Vantiq採⽤の理由: Vantiqは GLOTECHのAIアルゴリズムと連携し結果を取得。事故で⼈が密集している場所に最も近い警備員にリアルタイムに連絡し、所持品（鞄）のトラッキングや位置検出を⾏う。

メリット: 膨⼤な数の監視カメラ環境であったが、Vantiqにより限られたコスト(開発⼯数や運⽤スタッフ)で、AIと連携し安全性を⾼めることができた。

デジタルツイン

USE
CASE

予知保全、フィールドサービス、セキュリティ、セーフティ

INESA / 上海市政府
アプリケーション: Vantiqの中国パートナーは上海市のエレベーターの状態をリアルタイムに監視するアプリケーションを開発した。現在複数ベンダーのエレベータ数百台を監視し、最終的に上海の25万台全てのエレベータを監視する予定。
Vantiq採⽤の理由: 異なるエレベータからリアルタイムに異なったフォーマットのデータを取得する必要がある。 Vantiq を使い、データの整形、システムの拡張、予知保全を⾏うこことが簡単に実現できる。

https://vantiq.co.jp/testimonials/inesa/

メリット: 上海品質管理局は、このアプリケーションを使うことで、ビル管理者がエレベーターシステムの安全性とセキュリティを最⼤限に⾼め、上海全⼟でエレベーターの効率的な利⽤が可能となった。このシステムにより、ビル管理エンジニア1⼈あたり、5つのビルを監視・コントロールできるようになった。（従来は、2つのビルを管理。）

USECASE

スマートシティ、洪⽔警報システム

スマートシティ- / ベルギー
アプリケーション: InfoSquare は、Vantiqを使ってIoTセンサーのデータに基づいて緊急事態を監視、検知する洪⽔警報システムを開発した。緊急事態が確認された場合、市⺠は危険な状態にいることを知らせ、市⺠を救助するために救助隊を派遣する。
Vantiq採⽤の理由: Vantiqのマンマシンコラボレーション機能を使うことで、市⺠をリアルタイムに救助。被災者に最も近い避難所を伝え、最も安全な避難ルートに誘導できる。どんな状況でもAIを使いリアルタイムにチャットし、多⾔語でコミュニケーションできる。

メリット: 政府や市⺠は、洪⽔、⽕災や地震などの⾃然災害のリスクを最⼩限に抑えることができる。最⼩限のコストで、最⼤のメリットである⼈命救助を実現。

USE
CASE

セーフティ、事故防⽌Total（エネルギー） / フランス
アプリケーション: 重⼤な事故防⽌が最優先課題。最新技術を使い、以下の機能を実現する。
••

最新のセンサーを使った早期故障検知（例、機器故障やガス漏れなど）
⼤量データのリアルタイム取得、処理、分析•オペレータルームの作業員へデータ転送

Vantiq採⽤の理由:
施設に配置されたセンサーから連携されるイベントをリアルタイムに処理する必要があった。VantiqではEDAに基づいたリアルタイムアプリ
ケーションをローコードかつアジャイル型で迅速に開発・実⾏できデジタルツインによる施設の可視化で安全性の向上が⾒込めた。

メリット: 政府や市⺠は、洪⽔、⽕災や地震などの⾃然災害のリスクを最⼩限に抑えることができる。最⼩限のコストで、最⼤のメリットである⼈命救助を実現。

USE
CASE

セーフティ、事故防⽌

早期故障検知/チェック

⼤量データのリアルタイム取得、処理、分析オペレータールーム• アラートを受け取り問題を解決する
ため適切な対策を実施

コンテキストCONTEXTE• オペレーターは事故発⽣時にビデオ映像を確認

Contraintes
制約条件
RèglesMétierルール

AnalyseリアルタイムTemps-Réel
分析
Continue

Flux
データdeDonnées
ストリーム

⾳声センサーで疑いある問題を検知
センサー搭載ドローンを使い問題の検証
AIエンジンを使い異常の特定作業員が正確に判断できるよう情報を提供• ドローン⽀援ロボットが問題を検証• 将来 : ⼈が現場にいなくてもロボットが問題を解決• オペレータは問題解決ため、ドローン⽀援ロボットを派遣• システムは、問題と推定損害リスクの把握を⽀援• 気象状況に基づき適切な場所に避難誘導
AI/ML
AI/ML
Prédictions
予知

リアルタイム監視

採掘、精製、化学プラント
1.
2.
3.
4.

Actions
リアルタイムTemps-Réel
アクション

• 圧⼒
• 温度
• ⼈の位置• 気象• 保守• 取得したデータに基づき機械学習(インシデント、フィードバック、環境など）• 作業⽅法や条件の改善

USE
CASE

IoTプラットフォームSoftBank / ⽇本

https://vantiq.co.jp/testimonials/softbank/Vantiqの役割: IoTプラットフォーム上で、⼀般的な技術による個々のアプリケーション設計開発⼯程を回避し、Vantiqをデータ中継基盤として効率的に構築。
アプリ/システム
アプリA

アプリB

データストア
トランザクション
DB

アプリC

システムA

データインテグレーション

Webサービス
AIサービス

時系列DB

ネットワーク
センサ/ゲートウェイ/AI

Sigfox

システムB

LoRa
WAN

PrivateLoRa

NB-IoT

EnOcean

MQTT

メッセージング
サービス
HTTPS
REST

USE
CASE

スマートビル 東京ポートシティ⽵芝

SoftBank / ⽇本
アプリケーション: ソフトンバンクは本社移転に伴い、Vantiqを活⽤し東京ポートシティ⽵芝をスマートビル化しました。従業員の位置情報把握、不審者/侵⼊者検知、テナント店舗/トイレの混雑把握、ダイナミックなクーポン配信など様々なアプリケーションを実現しています。
Vantiq採⽤の理由: 1,300を超えるカメラ/センサなどのデバイスと連携し、複雑なリアルタイムアプリケーションを構築するためにはVantiqが必要でした。 ビルの進化に伴いアジャイルに対応できることもVantiq採⽤の⼤きな理由です。

メリット: 2020年9⽉開業なので定量的な効果はこれからです。
オフィスワーカーと来館者向けには、施設利⽤体験の向上、警備/清掃向けには、業務効率化、テナントに向けては、客層把握によるスタッフ、および物品配置の最適化が⼤きな価値提供になっています。

USECASE

スマートショッピングカート

Cust2Mate / イスラエル
アプリケーション:
センサーを搭載したスマートショッピングカートを使いリアルタイムでかつパーソナライズされた買い物体験を提供•

消費者は買い物リストをあらかじめインポート。システムが最も効率的な動線を案内•

スマートショッピングカートはカメラとセンサーの情報から消費者の位置情報とカートの内容を把握•

店舗の場所に応じてパーソナライズされた広告やオススメ商品をレコメンド•

把握したカートの内容と重量センサーを使ってカートが退店したら会計を実施

Vantiq採⽤の理由:
ショッピングカートから連携されるイベントをリアルタイムに処理する必要があった。VantiqではEDAに基づいたリアルタイムアプリケーションをローコードかつアジャイル型で迅速に開発・実⾏できることと既存POSアプリケーションをイベントフローに連携することが容易であったことが採⽤の決め⼿となった

メリット: 8か⽉で1,000個のカートへアプリをデプロイ。顧客体験の向上と店員業務の効率化により最⼤75%の売上アップと顧客単価20%アップを実現。

USECASE

フィールドサービスシステム

ミツイワ・技術者⼿配システム / ⽇本
アプリケーション: ミツイワ様は、⾃社のコールセンターで富⼠通系機器のフィールドサービスを提供。インシデントの発⽣場所、スキルなど状況に応じて技術者をダイナミックにアサインするリアルタイムアプリケーションをVantiqで実現。
Vantiq採⽤の理由: リアルタイム処理に、フィールドサービスとのコラボレーション機能やレガシーシステムとの連携などを簡単に統合できる。

メリット: 技術者⼿配にかかる時間を10分の1に短縮し、オペレーションが効率化

サマリー- 無尽に発⽣するIoTデータのリアルタイム処理にDBは不向き → EDAの出現- ステイクホルダーが多いスマートシティでDB共有は困難 → イベント共有- DX成功の秘訣 → デマンドをセンシングしたら即座にサービスで呼応- 単なるインテリジェントとスマートの違い → ダイナミック & リアルタイム- EDAの⽋点 → 複合処理が困難なためマイクロバッチ（DB）と連携- EDA+マイクロバッチ → I/Oおよびバッチ起動による遅延、アジリティの⽋如- EDA+メッセージバス 「Vantiq」 の出現
ご静聴、ありがとうございました⼊会のお申し込みはこちらまで（無料）
https://eda-consortium.jp/