(57)【要約】【課題】複合イベント処理のためのイベント構成規則の動的更新システム及び方法を提供すること。【解決手段】イベント構成規則を分析して重複要素を新規な仮想規則ノードに変更し、前記新規な仮想規則ノードを非重複要素と組み合わせてイベント規則を生成する分析部と、前記新規な仮想規則ノードを既に格納された仮想規則ノードの集合と順次に比較し、その比較の結果に基づいて、前記新規な仮想規則ノードまたは仮想規則ノードの集合を分割及び再構成する更新部と、を備えることを特徴とする複合イベント処理のためのイベント構成規則の動的更新システム。【選択図】図１
2016081496.tif 000002
【特許請求の範囲】
【請求項１】
イベント構成規則を分析して重複要素を新規な仮想規則ノードに変更し、前記新規な仮想規則ノードを非重複要素と組み合わせてイベント規則を生成する分析部と、
前記新規な仮想規則ノードを既に格納された仮想規則ノードの集合と順次に比較し、その比較の結果に基づいて、前記新規な仮想規則ノードまたは仮想規則ノードの集合を分割及び再構成する更新部と、
を備えることを特徴とする複合イベント処理のためのイベント構成規則の動的更新システム。
【請求項２】
重複するイベント構成規則に対する仮想規則ノードが格納された仮想ノード格納部をさらに備えることを特徴とする請求項１に記載の複合イベント処理のためのイベント構成規則の動的更新システム。
【請求項３】
前記分析部は、イベント構成規則に関するグラフデータの各ノード別の隣接ノードの数及びＩＤに基づいて共通部分グラフを探索し、前記探索された共通部分グラフを重複要素とすることを特徴とする請求項１に記載の複合イベント処理のためのイベント構成規則の動的更新システム。
【請求項４】
前記更新部は、新規な仮想規則ノードが前記仮想規則ノードの集合に存在する場合に当該仮想規則ノードを分割及び再構成し、新規な仮想規則ノードが前記仮想規則ノードの集合に存在しない場合には前記新規な仮想規則ノードを前記仮想規則ノードの集合に追加することを特徴とする請求項１に記載の複合イベント処理のためのイベント構成規則の動的更新システム。
【請求項５】
（ａ）イベント構成規則を分析して重複要素を新規な仮想規則ノードに変更し、前記新規な仮想規則ノードを非重複要素と組み合わせてイベント規則を生成するステップと、
（ｂ）前記新規な仮想規則ノードを既に格納された仮想規則ノードの集合と順次に比較し、その比較の結果に基づいて、前記新規な仮想規則ノードまたは仮想規則ノードの集合を分割及び再構成するステップと、
を含むことを特徴とする複合イベント処理のためのイベント構成規則の動的更新方法。
【請求項６】
前記ステップ（ａ）は、
前記イベント構成規則に関するグラフデータの各ノード別の隣接ノードの数及びＩＤに基づいて共通部分グラフを探索し、前記探索された共通部分グラフを新規な仮想規則ノードに変更するステップと、
前記新規な仮想規則ノードと前記グラフデータの非重複要素とを組み合わせてイベント規則を生成するステップと、
を含むことを特徴とする請求項５に記載の複合イベント処理のためのイベント構成規則の動的更新方法。
【請求項７】
（ａ）イベント構成規則を分析して重複要素を新規な仮想規則ノードに変更し、前記新規な仮想規則ノードを非重複要素と組み合わせてイベント規則を生成するステップと、
（ｂ）前記新規な仮想規則ノードを既に格納された仮想規則ノードの集合と順次に比較し、その比較の結果に基づいて、前記新規な仮想規則ノードまたは仮想規則ノードの集合を分割及び再構成するステップと、
を含むことを特徴とする複合イベント処理のためのイベント構成規則の動的更新方法がプログラムとして書き込まれたコンピュータにて読み取り可能な記録媒体。
【発明の詳細な説明】
【技術分野】
【０００１】
本発明は、複合イベント処理のためのイベント構成規則の動的更新システム及び方法に係り、さらに詳しくは、複合イベント処理に使用されるイベント構成規則を再使用するために頻繁に使用されるイベント構成規則を仮想規則ノードにより構成してテンプレート化する複合イベント処理のためのイベント構成規則の動的更新システム及び方法に関する。
【背景技術】
【０００２】
スマートフォン、タブレットＰＣなど高性能プロセッシング機能を支援するデバイスが一般化され、且つ、このようなデバイスに対するソーシャル・ネットワーキング・サービス（ＳＮＳ：Ｓｏｃｉａｌ  Ｎｅｔｗｏｒｋｉｎｇ  Ｓｅｒｖｉｃｅ）、クラウド・コンピューティング（Ｃｌｏｕｄ  Ｃｏｍｐｕｔｉｎｇ）サービスなどの様々なサービスが活性化されることに伴い、大容量のデータをリアルタイムにて処理する技術への要求が高まりつつある。
【０００３】
リアルタイムイベント処理技術は、このような大容量のデータが生成される様々な分野における柔軟且つ迅速な意思決定の支援と複雑なデータパターンを通じてビジネス機会を捕捉するのに有効に活用されている。
【０００４】
一方、急増するデータを速やかに分析してその結果を即座で活用できるように様々なグラフ分析及び技法が導入されているが、漸増するデータの量及び複雑化しつつある分析技法の計算量をリアルタイムにて処理するための処理システムが未だに開発されていないのが現状である。
【０００５】
入力データから取り出したイベントを併合して速やかな計算を行うための複合イベント処理システムをビックデータに適用しようとする試みはあるが、急増するデータの量及び計算ロジックを克服できずにいる。なお、イベント処理規則を作成することも決して容易ではない。
【０００６】
このような問題点を克服して早い応答速度を保証するために、大容量のデータのうちユーザー質疑の処理に必要なデータのみを速やかに処理し、繰り返される質疑の結果を予め計算して重複処理を回避し、ユーザー質疑の追加に際しても動的に更新することのできる技術の開発が望まれている。
【０００７】
また、複合イベントを処理するに当たって、様々な資源から導き出されるイベントをユーザーのニーズに合わせて構成して使用するために、複雑なイベントをイベント構成者がイベント処理言語で作成することを余儀なくされるという不都合がある。
【０００８】
さらに、従来の技術による複合イベントの処理方法は、反復的な結果を再使用することができないため、再計算を毎回行う必要があるという欠点がある。
【０００９】
【特許文献１】大韓民国公開特許第２０１３−００５９７３１号（リアルタイムロジック処理フレームワークシステム、方法及びこれに対する記録媒体）
【発明の開示】
【発明が解決しようとする課題】
【００１０】
本発明の目的は、複合イベント処理に使用されるイベント構成規則を再使用するために頻繁に使用されるイベント構成規則を仮想規則ノードにより構成してテンプレート化する複合イベント処理のためのイベント構成規則の動的更新システム及び方法を提供するところにある。
【課題を解決するための手段】
【００１１】
上述した目的を達成するために、本発明の一側面によれば、イベント構成規則を分析して重複要素を新規な仮想規則ノードに変更し、前記新規な仮想規則ノードを非重複要素と組み合わせてイベント規則を生成する分析部と、前記新規な仮想規則ノードを既に格納された仮想規則ノードの集合と順次に比較し、その比較の結果に基づいて、前記新規な仮想規則ノードまたは仮想規則ノードの集合を分割及び再構成する更新部と、を備えることを特徴とする複合イベント処理のためのイベント構成規則の動的更新システムが提供される。
【００１２】
好ましくは、前記複合イベント処理のためのイベント構成規則の動的更新システムは、重複するイベント構成規則に対する仮想規則ノードが格納された仮想ノード格納部をさらに備える。
【００１３】
また、好ましくは、前記分析部は、イベント構成規則に関するグラフデータの各ノード別の隣接ノードの数及びＩＤに基づいて共通部分グラフを探索し、前記探索された共通部分グラフを重複要素とする。
【００１４】
さらに、好ましくは、前記更新部は、新規な仮想規則ノードが前記仮想規則ノードの集合に存在する場合に当該仮想規則ノードを分割及び再構成し、新規な仮想規則ノードが前記仮想規則ノードの集合に存在しない場合に前記新規な仮想規則ノードを前記仮想規則ノードの集合に追加する。
【００１５】
上述した目的を達成するために、本発明の他の側面によれば、（ａ）イベント構成規則を分析して重複要素を新規な仮想規則ノードに変更し、前記新規な仮想規則ノードを非重複要素と組み合わせてイベント規則を生成するステップと、（ｂ）前記新規な仮想規則ノードを既に格納された仮想規則ノードの集合と順次に比較し、その比較の結果に基づいて、前記新規な仮想規則ノードまたは仮想規則ノードの集合を分割及び再構成するステップと、を含むことを特徴とする複合イベント処理のためのイベント構成規則の動的更新方法が提供される。
【００１６】
好ましくは、前記ステップ（ａ）は、前記イベント構成規則に関するグラフデータの各ノード別の隣接ノードの数及びＩＤに基づいて共通部分グラフを探索し、前記探索された共通部分グラフを新規な仮想規則ノードに変更するステップと、前記新規な仮想規則ノードと前記グラフデータの非重複要素とを組み合わせてイベント規則を生成するステップと、を含む。
【００１７】
上述した目的を達成するために、本発明のさらに他の側面によれば、（ａ）イベント構成規則を分析して重複要素を新規な仮想規則ノードに変更し、前記新規な仮想規則ノードを非重複要素と組み合わせてイベント規則を生成するステップと、（ｂ）前記新規な仮想規則ノードを既に格納された仮想規則ノードの集合と順次に比較し、その比較の結果に基づいて、前記新規な仮想規則ノードまたは仮想規則ノードの集合を分割及び再構成するステップと、を含むことを特徴とする複合イベント処理のためのイベント構成規則の動的更新方法がプログラムとして書き込まれたコンピュータにて読み取り可能な記録媒体が提供される。
【発明の効果】
【００１８】
本発明によれば、複合イベント処理に使用されるイベント構成規則を再使用するために頻繁に使用される構成規則を仮想規則ノードにより構成してテンプレート化することにより、演算回数を減らして全体のプロセスの処理時間を短縮することができる。
【００１９】
また、さらなるイベント構成規則が与えられたときに動的にイベント構成規則を最適化して仮想規則ノードを再構成することにより、大容量のデータに基づく高速な複合イベントの処理のためのイベント構成規則の処理時間を短縮することができる。
【００２０】
さらに、複合イベント処理に頻繁に使用されるイベント構成規則を再使用することにより、複合イベントの処理速度を改善することができ、しかも、使用性を増大させることができる。
【図面の簡単な説明】
【００２１】
【図１】本発明の実施形態による複合イベント処理のためのイベント構成規則の動的更新システムを示す図である。
【図２】本発明の実施形態による複合イベント処理のためのイベント構成規則の動的更新方法を示す図である。
【図３】イベント構成規則の動的更新方法を説明するための例示図である。
【発明を実施するための最良の態様】
【００２２】
以下、添付図面に基づき、本発明に係る「複合イベント処理のためのイベント構成規則の動的更新システム及び方法」について詳細に説明する。ここで説明する実施形態は、本発明の技術的思想を当業者に容易に理解させるために提供されるものであり、これらにより本発明が限定されることはない。なお、添付図面に示す事項は、本発明の実施形態を容易に説明するために図式化したものであり、実際に実現される形態とは異なる場合がある。
【００２３】
一方、後述する各構成要素は、本発明を実現するための例に過ぎない。このため、本発明の他の実現に際しては、本発明の思想及び範囲を逸脱しない範囲内において他の構成要素が使用可能である。また、各構成要素は、単にハードウェアまたはソフトウェアの構成のみにより実現されてもよいが、同じ機能を行う様々なハードウェア及びソフトウェアの構成の組み合わせにより実現されてもよい。なお、一つのハードウェアまたはソフトウェアにより２以上の構成要素が一緒に実現されてもよい。
【００２４】
これらに加えて、ある構成要素を「備える」という表現は、「開放型」の表現であり、当該構成要素が存在することを単に指し示すだけであり、さらなる構成要素を排除するものと理解されてはならない。
【００２５】
図１は、本発明の実施形態による複合イベント処理のためのイベント構成規則の動的更新システムを示す図である。
【００２６】
図１を参照すると、複合イベント処理のためのイベント構成規則の動的更新システム１００は、分析部１１０と、更新部１２０及び格納部１３０を備える。
【００２７】
分析部１１０は、イベント構成規則を分析して重複要素を新規な仮想規則ノードに変更し、前記新規な仮想規則ノードを非重複要素と組み合わせてイベント規則を生成する。
【００２８】
すなわち、分析部１１０は、イベント構成規則に関するグラフデータから共通部分グラフ（Ｃｏｍｍｏｎ Ｓｕｂ−Ｇｒａｐｈ）を探索し、共通部分グラフが存在する場合に重複要素が存在すれば判断する。このとき、分析部１１０は、イベント構成規則に関するグラフデータの各ノード別の隣接ノードの数及びＩＤに基づいて共通部分グラフを探索する。ここで、共通部分グラフは頻繁に使用されて再活用可能なグラフである。
【００２９】
更新部１２０は、分析部１１０において生成された新規な仮想規則ノードを格納部１３０に格納された仮想規則ノードの集合と順次に比較し、その比較の結果に基づいて、新規な仮想規則ノードまたは仮想規則ノードの集合を分割及び再構成する。
【００３０】
すなわち、更新部１２０は、新規な仮想規則ノードが仮想規則ノードの集合に存在する場合に当該仮想規則ノードを分割及び再構成し、新規な仮想規則ノードが仮想規則ノードの集合に存在しない場合には新規な仮想規則ノードを仮想規則ノードの集合に追加する。
【００３１】
格納部１３０には、重複するイベント構成規則に対する仮想規則ノードが格納されている。ここで、仮想規則ノードは、繰り返し使用可能なビジネスロジックを一つのパターンとして定義したものである。すなわち、仮想規則ノードは、特定の機能を行うために構成された個別的なイベント構成規則を一つの仮想規則ノードとして定義して、当該機能が必要である場合に個別のイベント構成規則を構成することなく当該仮想規則ノードを直ちに適用できるようにしたものである。
【００３２】
このような構成を有する複合イベント処理のためのイベント構成規則の動的更新システムは、複合イベント処理部１４０をさらに備える。
【００３３】
複合イベント処理部１４０は、リアルタイムイベントストリーム（Ｒｅａｌ−ｔｉｍｅ Ｅｖｅｎｔ Ｓｔｒｅａｍ）を既に定義されたイベント構成規則及び仮想ノード格納部１３０に格納された仮想規則ノードを用いて処理して結果を導出する。このとき、複合イベント処理部１４０は、同期方式のリアルタイム質疑／応答プロトコールを使用する。したがって、データストリームの処理結果を同期的に取得してユーザーのリアルタイムイベントに対してマッチング結果を提供することができる。
【００３４】
このような複合イベント処理部１４０は、イベント処理のために、様々なキュー及びプロセッサーを使用する。それぞれのキュー及びプロセッサーは、メモリにおいて全ての作業を行い、このような過程を通じて複合イベント処理システムサーバーの負荷を最小化させ、データの一貫性を維持する。
【００３５】
複合イベント処理部１４０は、収集されたデータをビジネスイベント化して処理する機能を行い、様々なタイプのイベント属性に対する汎用的な処理を行う。イベントソースから取り出したデータは、各種のプロセッサー及びキューの作業を通じてイベントの判断及びアクションを行うのに使用される。
【００３６】
一方、分析部１１０と、更新部１２０と、格納部１３０及び複合イベント処理部１４０のそれぞれは、コンピューティング装置上においてプログラムを実行するために必要とされるプロセッサーなどによりそれぞれ実現される。このように、ログ記録部１１０と、高負荷経路探索部１２０と、パーティション生成部１３０及び複合イベント処理部１４０は、物理的に独立したそれぞれの構成要素により実現され、一つのプロセッサー内において機能的に区別されるように実現される。このように、分析部１１０と、更新部１２０と、格納部１３０及び複合イベント処理部１４０は、物理的に独立したそれぞれの構成要素により実現され、一つのプロセッサー内において機能的に区別されるように実現される。
【００３７】
複合イベント処理のためのイベント構成規則の動的更新システム１００が備えるこれらの構成要素は、ハードウェア、ソフトウェアまたはこれらの組み合わせにより実現され、一つのハードウェアまたはソフトウェアにより２以上の構成要素が同時に実現される。
【００３８】
このような複合イベント処理のためのイベント構成規則の動的更新システム１００は、様々な通信規格を用いて他の電子装置と通信を行い、且つ、様々なデータ処理演算を行う電子装置により実現される。例えば、複合イベント処理のためのイベント構成規則の動的更新システム１００はサーバー装置として実現され、このようなサーバー装置に加えて、様々な電子装置として実現される。なお、複合イベント処理のためのイベント構成規則の動的更新システム１００は、単一の電子装置として実現されてもよく、２以上の電子装置が組み合わせられた装置として実現されてもよい。
【００３９】
図２は、本発明の実施形態による複合イベント処理のためのイベント構成規則の動的更新方法を示す図であり、図３から図５は、イベント構成規則の動的更新方法を説明するための例示図である。
【００４０】
図２を参照すると、複合イベント処理のためのイベント構成規則の動的更新システム１００は、イベント構成規則を分析して（ステップＳ２０２）、重複要素が存在するか否かを判断する（ステップＳ２０４）。このとき、複合イベント処理のためのイベント構成規則の動的更新システム１００は、イベント構成規則に関するグラフデータから共通部分グラフを探索し、共通部分グラフが存在する場合に重複要素が存在すれば判断する。
【００４１】
ステップＳ２０４における判断の結果、重複要素が存在すれば、複合イベント処理のためのイベント構成規則の動的更新システム１００は、当該重複要素を新規な仮想規則ノードに変更し（ステップＳ２０６）、新規な仮想規則ノードとグラフデータの非重複要素とを組み合わせてイベント規則を生成する（ステップＳ２０８）。
【００４２】
次いで、複合イベント処理のためのイベント構成規則の動的更新システム１００は、新規な仮想規則ノードを既に格納された仮想規則ノードの集合と順次に比較し、新規な仮想規則ノードが仮想規則ノードの集合に存在するか否かを判断する（ステップＳ２１０）。
【００４３】
ステップＳ２１０における判断の結果、新規な仮想規則ノードが仮想規則ノードの集合に存在すれば、複合イベント処理のためのイベント構成規則の動的更新システム１００は、当該仮想規則ノードを分割及び再構成して格納する（ステップＳ２１２）。
【００４４】
もし、ステップＳ２１０における判断の結果、新規な仮想規則ノードが仮想規則ノードの集合に存在しなければ、複合イベント処理のためのイベント構成規則の動的更新システム１００は、新規な仮想規則ノードを仮想規則ノードの集合に追加する（ステップＳ２１４）。
【００４５】
これにより、優れたイベント構成規則の使用性及びイベント処理の効率性を保証することができる。
【００４６】
以下、図３に基づき、複合イベント処理のためのイベント構成規則の動的更新システム１００がイベント構成規則を動的に更新する方法について説明する。
【００４７】
図３の（ａ）に示すように、イベント構成規則であるＲｕｌｅ Ａ及びＲｕｌｅＢを分析したところ、「ａ」のような重複要素が探索された場合、複合イベント処理のためのイベント構成規則の動的更新システム１００は、図３の（ｂ）に示すように、「ａ」を新規な仮想規則ノードＶＮ１として格納部に格納し、Ｒｕｌｅ Ａ及びＲｕｌｅ Ｂに新規な仮想規則ノードＶＮ１を適用する。
【００４８】
格納部に仮想規則ノードの集合が格納された状態で、図４に示すように、新規なイベント構成規則であるＲｕｌｅ Ｃが入力されれば、複合イベント処理のためのイベント構成規則の動的更新システム１００は、Ｒｕｌｅ ＣをＲｕｌｅ Ａ及びＲｕｌｅ Ｂと比較して重複要素を探索する。
【００４９】
重複要素を探索した結果、図５の（ａ）における「ｂ」のような重複要素が探索された場合、複合イベント処理のためのイベント構成規則の動的更新システム１００は、「ｂ」と同じものが格納部に格納された仮想規則ノードに存在するか否かを判断する。
【００５０】
上記の判断の結果、「ｂ」と同じものが格納部に格納された仮想規則ノードに存在しなければ、複合イベント処理のためのイベント構成規則の動的更新システム１００は、図５の（ｂ）に示すように、「ｂ」を仮想規則ノードＶＮ１１として格納部に格納する。
【００５１】
もし、「ｂ」と同じものが格納部に格納された仮想規則ノードに存在すれば、 複合イベント処理のためのイベント構成規則の動的更新システム１００は、図５の（ｃ）に示すように、仮想規則ノードＶＮ１を分割及び再構成して仮想規則ノードＶＮ１、仮想規則ノードＶＮ２を格納する。
【００５２】
一方、上述した本発明に係る複合イベント処理のためのイベント構成規則の動的更新方法は、これを起動するためのプログラム、アプリケーション、システムファイルにより実現され、本発明は、このようなプログラムなどが書き込まれたコンピュータにて読み取り可能な記録媒体として実現される。
【００５３】
このような複合イベント処理のためのイベント構成規則の動的更新方法はプログラムとして作成可能であり、プログラムを構成するコード及びコードセグメントは当該分野におけるプログラマーにより容易に推論可能である。なお、複合イベント処理のためのイベント構成規則の動的更新方法に関するプログラムは電子装置にて読み取り可能な情報記録媒体に格納され、電子装置により読み取られて起動される。
【００５４】
このように、本発明が属する技術分野における当業者は、本発明がその技術的思想や必須的特徴を変更することなく他の具体的な形態として実施可能であるということが理解できる筈である。よって、上述した実施形態はあらゆる面において例示的なものであり、限定的なものではないと理解されるべきである。本発明の範囲は前記詳細な説明よりは後述する特許請求の範囲によって開示され、特許請求の範囲の意味及び範囲並びにその等価概念から導き出されるあらゆる変更または変形された形態が本発明の範囲に含まれるものと解釈されるべきである。
【符号の説明】
【００５５】
１１０：分析部
１２０：更新部
１３０：仮想ノード格納部
１４０：複合イベント処理部
【図１】
2016081496.tif 000003
【図２】
2016081496.tif 000004
【図３】
2016081496.tif 000005
【図４】
2016081496.tif 000006
【図５】
2016081496.tif 000007
【手続補正書】
【提出日】平成27年1月23日(2015.1.23)
【手続補正１】
【補正対象書類名】明細書
【補正対象項目名】００２１
【補正方法】変更
【補正の内容】
【００２１】
【図１】本発明の実施形態による複合イベント処理のためのイベント構成規則の動的更新システムを示す図である。
【図２】本発明の実施形態による複合イベント処理のためのイベント構成規則の動的更新方法を示す図である。
【図３】イベント構成規則の動的更新方法を説明するための例示図である。
【図４】イベント構成規則の動的更新方法を説明するための例示図である。
【図５】イベント構成規則の動的更新方法を説明するための例示図である。