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についての具体的な紹介を行う。

Chinoba
Intelligence as Relationship
Research Platform
founded by
Masao Watanabe
AI Systems Architecture
Decision Trace
Human–AI Coordination
Algorithmic Governance
Related Research
この記事は Chinoba Knowledge Base の一部です。

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