Stream Reasoningアーキテクチャ(概要)

機械学習技術 人工知能技術 デジタルトランスフォーメーション技術. センサーデータ&IOT ICT技術 ストリームデータの処理と機械学習 ICTインフラ技術 本ブログのナビ
Stream Reasoningアーキテクチャ(概要)

Stream Resoning技術とはリアルタイムで、複数の、異種の、巨大な、必然的にノイズの多いストリームデータを用いて、極めて多数の同時ユーザーの意思決定プロセスをサポートするためにデータに意味づけを行うシステムとなる。

基本的な動作例を以下に示す。2の部屋(red-roomとblue-room)があり、(1)Aliceが時間T1にRed roomにいることをSensortagによってセンシング(Sensor:Redsensor、Room:RedRoom、Person:Alice、Time-stamp:T1)、(2)Bobが時刻T2にBlueRoomに入ったことをセンサーで検知(Person:Bob、ChecksIn:BlueRoom、Time-stamp:T2)、(3)フェイスブックの記録によりCarlは時刻T2にBobと一緒にいて(Person:Carl、With:Bob、time-stamp:T2)、Davidも時刻T3にElenaと一緒にRedRoomにいる(Person:David、IsIn:RedRoom、WIth:Elena、Time-stamp:T3)とする。

上記の状態を図示したものを以下に示す。

このような状態の中で例えば「今Aliceと同じ部屋にいる人は?」とか「Aliceの隣の部屋にいる人は何時からそこにいるのか?」等のフレキシブルな質問に対して答えを出せるようにしたものがStream Reasoningシステムの特徴となる。

このシステムの従来のDSMS/CEPシステムの相違点は、クエリに対する柔軟性にある。例えばここで登場する情報ソースはセンサータグと、チェックインを見るセンサー、及びフェイスブックの3つとなるが、従来のDSMS/CEPシステムでも、それぞれのセンサーのスキーマを固定すれば、決まった(固定した)クエリに対する答えを得ることはできる。しかしながら現実世界では、必要となるシチュエーション/コンテキストには様々なバリエーションがあり、その場その場でそれぞれに合わせた切り口でデータを利用する必要がある。

このような課題は、ある特定の目的だけにIOTを利用しようとしても、それらを設置する費用と得られる効果のバランスが取りにくいという、IOT技術がビジネスとして成り立ちにくいという課題とも関連する。

Stream Reasoning技術はこのような課題に対して、設置された様々なセンサーデータあるいは入手可能なデータ(SNS等)をフレキシブルに組み合わせて、オントロジー等のセマンティックウェブ技術を用いて様々なコンテキストに合わせたクエリーに対応させようという技術となる。

Stream Resoning技術として市販されているシステムは現在のところ存在せず、以下のような各種システムが報告されているのもとなる。

名前 出典
Streaming SPARQL
AndreBolles,MarcoGrawunder,JonasJacobi:Streaming SPARQL – Extending SPARQL to Process Data Streams. ESWC 2008: 448-462
C-SPARQL
DavideFrancescoBarbieri,DanieleBraga,StefanoCeri, Emanuele Della Valle, Michael Grossniklaus: Querying RDF streams with C-SPARQL. SIGMOD Record 39(1): 20-26 (2010)
CQELS
DanhLePhuoc,MinhDao-Tran,JosianeXavierParreira,Manfred Hauswirth: A Native and Adaptive Approach for Unified Processing of Linked Streams and Linked Data. International Semantic Web Conference (1) 2011: 370-388
INSTANS
Rinne,M.,Nuutila,E.,Törma,S.:
INSTANS: High-Performance Event Processing with Standard RDF and SPARQL. Poster in ISWC2012
Streaming Linked Data
MarcoBalduini,EmanueleDellaValle,DanieleDell’Aglio,Mikalai Tsytsarau, Themis Palpanas, Cristian Confalonieri: Social listening of City Scale Events using the Streaming Linked Data Framework. ISWC 2013
TEF-SPARQL
ShenGao,ThomasScharrenbach,AbrahamBernstein:The CLOCK Data-Aware Eviction Approach: Towards Processing Linked Data Streams with Limited Resources. ESWC 2014: 6-20
Streaming Knowledge Base
Walavalkar,O.,Joshi,A.,Finin,T.,Yesha,Y.,2008.Streaming knowl- edge bases. In: In International Workshop on Scalable Semantic Web Knowledge Base Systems
IMaRS
DavideFrancescoBarbieri,DanieleBraga,StefanoCeri, Emanuele Della Valle, Michael Grossniklaus: Incremental Reasoning on Streams and Rich Background Knowledge. ESWC (1) 2010: 1-15
TrOWL
YuanRen,JeffZ.Pan:Optimisingontologystreamreasoning with truth maintenance system. CIKM 2011: 831-836
ETALIS
DarkoAnicic,PaulFodor,SebastianRudolph,NenadStojanovic: EP-SPARQL: a unified language for event processing and stream reasoning. WWW 2011: 635-644
sparkwave
Srdjan Komazec, Davide Cerri, Dieter Fensel: Sparkwave: continuous schema-enhanced pattern matching over RDF data streams. DEBS 2012: 58-68
SR based on Answer Set Programming
Martin Gebser, Torsten Grote, Roland Kaminski, Philipp Obermeier, Orkunt Sabuncu, Torsten Schaub: Stream Reasoning with Answer Set Programming: Preliminary Report. KR 2012
parallerising Stream Reasoning
Jacopo Urbani, Alessandro Margara, Ceriel J. H. Jacobs, Frank van Harmelen, Henri E. Bal: DynamiTE: Parallel Materialization of Dynamic RDF Data. International Semantic Web Conference (1) 2013: 657-672
STARQL
ÖL Özçep, R Möller, C Neuenstadt, “A Stream-Temporal Query Language for Ontology Based Data Access”. Description Logics, 2014

基本的な構成は大きく分けて以下の3つのものがある。

Data-Driven type (frontward reasoning)

Query-Driven type (query rewriting)

Query-Driven Type (backward reasoning)

次回以降、個別のStream Reasoningについての具体的な紹介を行う。

コメント

  1. […] これらを解決する為、オントロジーベースデータアクセスシステムとDSMS/CEPの特徴を備え持つシステムとしてStream Reasoningと呼ばれる技術が提案された。これは様々なストリームデータをフレキシブルに組み合わせて、様々なコンテキストに合わせたクエリーに対応させようという技術となる。 […]

  2. […] Stream Reasoningアーキテクチャ(概要) […]

モバイルバージョンを終了
タイトルとURLをコピーしました