柔軟性の高いストリームデータ処理により多彩なリアルタイムサービスを可能にする「Dracena」

IoT技術の急速な発展が続く今、各種センサーデバイスから取得した大量のデータをリアルタイムに分析・処理し、様々なサービスに素早く活用するというニーズがあらゆる業種業界で高まっています。特に自動車業界では、“CASE（Connected、Autonomous、Shared＆Service、Electric）”の潮流が押し寄せる中、自動車から取得した膨大なデータをリアルタイムに活用するコネクテッドカーの基盤構築に向けた動きが加速しています。例えば、速度・位置などのデータをリアルタイムに分析して処理し、道路の混雑状況を可視化して渋滞を回避したり、事故などの危険情報を知らせたりしてドライバーをアシストし、運転の安全性を高めることを可能にする基盤の設計・開発が進められています。

しかしながら、従来のデータ処理の方法には解決すべき課題が残されています。富士通研究所でIoTを含むCPS（Cyber-Physical System：サイバーフィジカルシステム）の研究開発をリードするスーパーミドルウェア・ユニット CPSプロジェクト シニアマネージャーの植木美和は、課題について次のように説明します。

このような課題を解決するために、富士通研究所 CPSプロジェクトでは新たに、大量のデータ処理を停止させることなくサービスを追加・変更できるストリームデータ処理アーキテクチャーの開発に取り組むことになります。しかし、植木は「当初は富士通研究所内のIoTシステムを研究していたグループがコンセプトを策定してこの課題にアプローチしましたが、最適な解が見つからず思うように進みませんでした」と当時の課題を振り返ります。

その突破口を開いたのは、同じく富士通研究所でソフトウェアを研究していたグループから紹介されたある技術でした。CPSプロジェクトの板倉宏太は次のように説明します。

Dracenaは、サービスを停止することなく、大量のリアルタイムデータ処理を続けながら、新たなデータ処理をプラグインとして動的に追加・変更することができる処理基盤です。従来のように、機能追加のために一度システムを停止したり、データ分析のためにバッチで処理を行ったりする必要がありません。サービス追加など開発における高い拡張性と柔軟性を持ったストリームデータ処理が可能になります。「特にセンサーデータなどを活用したサービスを実現するには、処理を変えたり、パラメーターを変えたりして結果を見ながら、試行錯誤を繰り返してアジャイルにサービスを開発していくことが重要です。こうしたアジャイルな開発とノンストップ運用を両立するDracenaはリアルタイムなデータ活用基盤として有効です」と植木氏は説明します。

さらに、実世界の多種多様なIoTデータは、これまで用途やシステムごとに収集されるケースが多く、サービスをまたがって高速にデータを連携させることが困難でした。一方Dracenaでは、ストリーム処理の中でデータを「ヒト・モノ・コト」などのオブジェクト単位で扱い処理結果をシェアできるよう、データの保持と処理の仕方を工夫することで様々なサービスでの利用性を向上させました。

富士通研究所は100万台の車両（オブジェクト）から速度・位置情報など秒ごとに膨大データが送られてくるというシステムに対してDracenaを適用した場合の、新しいサービスや機能（例：急ブレーキの車を検出するなど）を追加するケースを想定したシミュレーションを実施しました。その結果、データ処理中に別の新しいデータ処理が追加された場合でも、遅延増加が平均5ミリ秒以内でサービスを継続できるといった実効性を確認できました。

Dracenaは、それぞれ高い専門性を持った技術者によって研究開発が継続的に進められています。そのコアシステムの開発・実装作業の中心となるのが板倉です。

「Dracenaはあくまでリアルタイムのストリームデータ処理を実現する基盤ですので、データ処理の結果を活用するためには、その上で動くアプリケーションも重要になります。その際にアプリケーション開発者やひいてはエンドユーザーに使いやすい処理基盤であるために、アプリ開発を容易にするフレームワークや連携のAPI開発にも力を入れています」と、今後の活用を見据えた現在の取り組みを話します。

また別のアプローチからシステムの改良を行うのが、Ｊ.ミヒャエリスです。以前はデータベースやネットワークを専門にしていた技術者です。

また同じく、CPSプロジェクトの大西隆史もＪ.ミヒャエリスとともに日々テストを繰り返し、改良に取り組んでいます。「Dracenaによるデータ処理システムのパフォーマンス測定を常に行い、設定パラメーターを変更しながらチューニングを実施し、より大量のデータを高速に処理するための性能向上に取り組んでいます」と自身の取り組みを説明します。

従来のストリームデータ処理システムは、並列処理や連携、サービスの追加・変更することが難しいため、特定のサービスのみで分析結果のデータを活用するという垂直統合型のサイロ化されたシステムでした。しかしDracenaであれば、まずシンプルなデータ分析処理システムを構築し、その後に次々と新しいサービスを追加していくというアジャイルで柔軟な開発が可能になります。

Dracenaは、大量データのリアルタイム処理と無停止稼働、頻繁なサービスの追加・変更が想定される分野であるモビリティ領域を最初のターゲットに開発が進められ、現在では、富士通が提供する「Future Mobility Accelerator」を構成する技術として製品に組み込まれています。フォード系列のモビリティサービス会社の米Autonomic社との協業が始まり、また国内外の自動車メーカーにおいて有償のPoC（概念検証）も進められています。

コネクテッドカーでは、ハンドル操作データから飲酒運転の兆候を読み取るサービスから始め、地図データと組み合わせてトンネル出口の横風を検出したり、画像データと組み合わせて違法駐車車両の存在を検出したりといったサービスを追加するなど、様々な可能性を秘めています。

モビリティ領域への適用を狙うDracenaですが、当然のことながらそれ以外の分野にも適用が可能です。今後広範囲でIoT化が加速しつづけることが予測されますが、収集される膨大なデータを処理し、活用するためには課題が生まれ、今以上に頭を悩ませることになります。こうした状況を少しでも回避するためにも良質なデータを適切に集めながら処理する仕組みは、新たなデータ活用の契機になるでしょう。

「将来的には、家電製品のエコ利用サポート、介護が必要な高齢者の見守り、イベント時や災害発生時の行動誘導など、実社会で発生する問題に対応するあらゆるリアルタイムサービスに応用させていくことを目指しています」と植木は話を締めくくりました。