(57)【要約】  本発明の解析処理システムは、所定の解析処理を行う解析エンジン５２０と、当該解析エンジンの動作を制御して解析処理を実行する解析処理実行部５１０と、解析エンジンの処理性能を制御する処理性能制御部５３０と、を備え、上記処理性能制御部５３０は、解析エンジン及び解析処理実行部とは異なり独立して解析処理システムに装備可能な処理モジュールにて構成されており、解析処理実行部にて呼び出され、特定の解析エンジンの状態を表す状態情報を検出して、当該検出した状態情報に基づいて予め設定された処理を実行する、という構成をとる。
2013069191.tif 000002
【特許請求の範囲】
【請求項１】
所定の解析処理を行う解析エンジンと、当該解析エンジンの動作を制御して解析処理を実行する解析処理実行部と、前記解析エンジンの処理性能を制御する処理性能制御部と、を備え、
前記処理性能制御部は、前記解析エンジン及び前記解析処理実行部とは異なり独立して解析処理システムに装備可能な処理モジュールにて構成されており、前記解析処理実行部にて呼び出され、特定の前記解析エンジンの状態を表す状態情報を検出して、当該検出した状態情報に基づいて予め設定された処理を実行する、
解析処理システム。
【請求項２】
請求項１に記載の解析処理システムであって、
前記処理性能制御部は、前記特定の解析エンジンに入力される入力データの入力状況を前記状態情報として検出し、当該検出した状態情報に基づいて予め設定された処理を実行する、
解析処理システム。
【請求項３】
請求項２に記載の解析処理システムであって、
前記処理性能制御部は、前記特定の解析エンジンに入力される入力データを一時的に蓄積する入力バッファの蓄積状況を前記状態情報として検出し、当該検出した状態情報に基づいて予め設定された処理を実行する、
解析処理システム。
【請求項４】
請求項３に記載の解析処理システムであって、
前記処理性能制御部は、前記特定の解析エンジンの前記入力バッファの蓄積状況を前記状態情報として検出し、当該検出した状態情報に基づいて、前記特定の解析エンジンの前記入力バッファに蓄積されている入力データの少なくとも一部を当該入力バッファ内から破棄する処理を実行する、
解析処理システム。
【請求項５】
請求項３又は４に記載の解析処理システムであって、
前記処理性能制御部は、前記特定の解析エンジンの前記入力バッファの蓄積状況を前記状態情報として検出し、当該検出した状態情報に基づいて、前記特定の解析エンジンの前段側に位置する他の解析エンジンへの入力データを一時的に蓄積する他の入力バッファに蓄積されている入力データの少なくとも一部を、当該他の入力バッファ内から破棄する処理を実行する、
解析処理システム。
【請求項６】
請求項１乃至５のいずれかに記載の解析処理システムであって、
前記処理性能制御部は、前記特定の解析エンジンから出力される出力データの出力状況を前記状態情報として検出し、当該検出した状態情報に基づいて予め設定された処理を実行する、
解析処理システム。
【請求項７】
請求項６に記載の解析処理システムであって、
前記処理性能制御部は、前記特定の解析エンジンから出力される出力データの出力状況を前記状態情報として検出し、当該検出した状態情報に基づいて、前記特定の解析エンジンの後段側に位置する他の解析エンジンに対して前記特定の解析エンジンから出力する前記出力データの少なくとも一部を破棄する処理を実行する、
解析処理システム。
【請求項８】
請求項６又は７に記載の解析処理システムであって、
前記処理性能制御部は、前記特定の解析エンジンから出力される出力データの出力状況を前記状態情報として検出し、当該検出した状態情報に基づいて、前記特定の解析エンジンの後段側に位置する複数の他の解析エンジンに対して前記特定の解析エンジンから出力する前記出力データを分散して出力する処理を実行する、
解析処理システム。
【請求項９】
請求項６乃至８のいずれかに記載の解析処理システムであって、
前記処理性能制御部は、前記特定の解析エンジンから出力される出力データの出力状況を前記状態情報として検出し、当該検出した状態情報に基づいて、前記特定の解析エンジンの後段側に位置する他の解析エンジンに対して前記特定の解析エンジンから出力する前記出力データを、当該特定の解析エンジンの後段側に位置する別の解析エンジンに出力するよう前記出力データの出力先を変更する処理を実行する、
解析処理システム。
【請求項１０】
請求項６乃至９のいずれかに記載の解析処理システムであって、
前記処理性能制御部は、前記特定の解析エンジンから出力される出力データの出力状況を前記状態情報として検出し、当該検出した状態情報に基づいて、前記特定の解析エンジンの後段側に位置する他の解析エンジンによる解析処理が他の解析処理よりも優先的に処理される度合を表す優先度を設定する処理を実行する、
解析処理システム。
【請求項１１】
請求項１乃至１０のいずれかに記載の解析処理システムであって、
前記処理性能制御部は、前記特定の解析エンジンに入力される入力データの入力状況を前記状態情報として検出し、当該検出した状態情報に基づいて、前記特定の解析エンジンを呼び出す処理を実行する、
解析処理システム。
【請求項１２】
請求項１１に記載の解析処理システムであって、
前記処理性能制御部は、前記特定の解析エンジンの単位時間当たりの呼び出し回数を検出し、当該呼び出し回数が予め設定された上限値を超えた場合に、前記特定の解析エンジンの呼び出しを所定時間待つ処理を実行する、
解析処理システム。
【請求項１３】
所定の解析処理を行う解析エンジンを備えた情報処理装置に、
前記解析エンジンの動作を制御して解析処理を実行する解析処理実行部と、前記解析エンジンの処理性能を制御する処理性能制御部と、を実現させると共に、
前記処理性能制御部は、前記解析エンジン及び前記解析処理実行部とは異なり独立して解析処理システムに装備可能な処理モジュールにて構成されており、前記解析処理実行部にて呼び出され、特定の前記解析エンジンの状態を表す状態情報を検出して、当該検出した状態情報に基づいて予め設定された処理を実行する、
ことを実現させるためのプログラム。
【請求項１４】
請求項１３に記載のプログラムであって、
前記処理性能制御部は、前記特定の解析エンジンに入力される入力データの入力状況を前記状態情報として検出し、当該検出した状態情報に基づいて予め設定された処理を実行する、
プログラム。
【請求項１５】
所定の解析処理を行う解析エンジンを備えた情報処理装置にて、
解析処理実行部が前記解析エンジンの動作を制御して解析処理を実行すると共に、処理性能制御部が前記解析エンジンの処理性能を制御し、
前記処理性能制御部は、前記解析エンジン及び前記解析処理実行部とは異なり独立して解析処理システムに装備可能な処理モジュールにて構成されており、前記解析処理実行部にて呼び出され、特定の前記解析エンジンの状態を表す状態情報を検出して、当該検出した状態情報に基づいて予め設定された処理を実行する、
解析処理方法。
【請求項１６】
請求項１５に記載の解析処理方法であって、
前記処理性能制御部は、前記特定の解析エンジンに入力される入力データの入力状況を前記状態情報として検出し、当該検出した状態情報に基づいて予め設定された処理を実行する、
解析処理方法。
【発明の詳細な説明】
【技術分野】
【０００１】
本発明は、解析処理システムにかかり、特に、搭載された解析エンジンの動作を制御する機能を有する解析処理システムに関する。
【背景技術】
【０００２】
近年、情報処理技術の発達に伴い、様々なデータの解析を行う解析エンジンの開発が行われている。例えば、動画像データから人間の動線をトレースする位置情報を生成する解析エンジン、静止画像データから人物を特定する解析エンジン、音声データからテキストデータを生成する解析エンジンなど、様々な解析エンジンが開発されている。【０００３】
そして、同種あるいは異種の解析エンジンを複数組み合わせて、入力データから様々な解析処理結果を得ることができる解析処理システムの開発も行われている。例えば、カメラから入力した映像データを、動線抽出エンジン、顔抽出エンジン、年齢判別エンジンなどを用いて並列又は直列に処理し、所定の挙動の人物を判定する、といった解析処理を行うシステムに適用することができる。また、特許文献１に示されるように、画像処理を他段階で実行するような解析処理システムもある。
【先行技術文献】
【特許文献】
【０００４】
【特許文献１】特開２００３−３０３１０２号公報
【発明の概要】
【発明が解決しようとする課題】
【０００５】
ところが、上述したように複数の解析エンジンを組み合わせた解析処理システムでは、各解析エンジンにて連続的にデータを処理する必要があり、リアルタイムでの解析が必要となるが、特定の解析エンジンで処理が遅滞することも生じうる。すると、解析処理システム全体における処理に遅延が生じ、必要な解析結果を迅速に得ることができない、という問題が生じる。一方、解析処理の遅延を防止すべく各解析エンジンが実装される情報処理装置に十分な処理性能を持たせた場合には、システムにかかるコストが増大する、という問題が生じる。【０００６】
このため、本発明の目的は、上述した課題である、解析処理の遅延やコスト増大化を抑制することができる解析処理システムを提供することにある。
【課題を解決するための手段】
【０００７】
本発明の一形態である解析処理システムは、
所定の解析処理を行う解析エンジンと、当該解析エンジンの動作を制御して解析処理を実行する解析処理実行部と、前記解析エンジンの処理性能を制御する処理性能制御部と、を備え、
前記処理性能制御部は、前記解析エンジン及び前記解析処理実行部とは異なり独立して解析処理システムに装備可能な処理モジュールにて構成されており、前記解析処理実行部にて呼び出され、特定の前記解析エンジンの状態を表す状態情報を検出して、当該検出した状態情報に基づいて予め設定された処理を実行する、
という構成をとる。【０００８】
また、本発明の他の形態であるプログラムは、
所定の解析処理を行う解析エンジンを備えた情報処理装置に、
前記解析エンジンの動作を制御して解析処理を実行する解析処理実行部と、前記解析エンジンの処理性能を制御する処理性能制御部と、を実現させると共に、
前記処理性能制御部は、前記解析エンジン及び前記解析処理実行部とは異なり独立して解析処理システムに装備可能な処理モジュールにて構成されており、前記解析処理実行部にて呼び出され、特定の前記解析エンジンの状態を表す状態情報を検出して、当該検出した状態情報に基づいて予め設定された処理を実行する、
ことを実現させるためのプログラムである。【０００９】
また、本発明の他の形態である解析処理方法は、
所定の解析処理を行う解析エンジンを備えた情報処理装置にて、
解析処理実行部が前記解析エンジンの動作を制御して解析処理を実行すると共に、処理性能制御部が前記解析エンジンの処理性能を制御し、
前記処理性能制御部は、前記解析エンジン及び前記解析処理実行部とは異なり独立して解析処理システムに装備可能な処理モジュールにて構成されており、前記解析処理実行部にて呼び出され、特定の前記解析エンジンの状態を表す状態情報を検出して、当該検出した状態情報に基づいて予め設定された処理を実行する、
という構成をとる。
【発明の効果】
【００１０】
本発明は、以上のように構成されることにより、コストを抑制しつつ、解析処理性能の向上を図ることができる解析処理システムを提供することができる。
【図面の簡単な説明】
【００１１】
【図１】本発明における解析処理システムの一例を示す図である。
【図２】本発明における解析処理システムの構成を示すブロック図である。
【図３】図２に開示したデータ解析装置の一部の構成を示すブロック図である。
【図４】図２に開示したデータ解析装置の一部の構成を示すブロック図である。
【図５】図２に開示した解析処理システムによる解析処理の様子を示す図である。
【図６】図２に開示した解析処理システムによる解析処理の様子を示す図である。
【図７】図４に開示した各モジュールの動作を示すフローチャートである。
【図８】本発明の付記１における構成を示すブロック図である。
【発明を実施するための形態】
【００１２】
＜実施形態１＞
本発明の第１の実施形態を、図１乃至図７を参照して説明する。図１乃至図４は、本実施形態における解析処理システムの構成を説明するための図であり、図５乃至図７は、解析処理システムの動作を説明するための図である。
【００１３】
図１に示す解析処理システムは、１台又は複数台の情報処理装置で構成されたデータ解析システム１００と、解析対象となる解析対象データを取得するデータ取得システム２００と、解析対象データに対する解析処理を要求して解析結果を取得するアプリケーション３００と、を備えて構成されている。
【００１４】
上記アプリケーション３００は、例えば、ユーザが操作する情報処理端末に組み込まれており、データ取得システム２００やデータ解析システム１００にネットワークを介して接続している。そして、アプリケーション３００は、データ取得システム２００やデータ解析システム１００に対して解析処理を要求して、解析結果を取得する。
【００１５】
上記データ取得システム２００は、解析対象データとなる映像データ（ストリームデータ）を取得するカメラ２１０と、取得した映像データを収集してデータ解析システム１００に配信するストリームデータ収集・蓄積・配信部２２０と、を備えている。なお、本実施形態では、データ解析システム１００で解析処理する解析対象データが映像データである場合を例示するが、解析対象データは音声データや画像データなど、いかなるデータであってもよい。従って、データ取得システム２００にて取得される解析対象データは、いかなるデータであってもよい。
【００１６】
上記データ解析システム１００は、複数の解析エンジン３０を備えると共に、これら解析エンジン３０を用いて解析対象データである映像データを解析処理するデータ解析装置１を備える。
【００１７】
以下、本発明の特徴部分となる上記データ解析装置１について詳細に説明する。図２に示すように、データ解析装置１は、複数の解析エンジン３０に接続されており、各解析エンジン３０に対応してそれぞれエンジン制御部１０を備える。また、エンジン制御部１０は、解析処理実行部１１を備えており、この解析処理実行部１１は、さらに、実行部１２と実行情報管理部１３とを備える。
【００１８】
上記実行情報管理部１３は、解析エンジン３０にて解析処理を行う解析対象データである入力データや、解析エンジン３０による解析処理結果である出力データを管理する機能を有している。また、実行情報管理部１３は、入力データ及び出力データをそれぞれ一時的に保存する入力バッファ及び出力バッファを備えている。
【００１９】
上記実行部１２は、対応する解析エンジン３０による解析処理の実行を制御して、実行情報管理部１３が有する入力バッファに保存されている入力データの解析処理を解析エンジン３０に実行させるよう制御したり、その解析処理結果を実行情報管理部１３が有する出力バッファに保存する。
【００２０】
上記解析データ交換部１４は、解析エンジン３０による解析処理結果である出力データを、この解析エンジン３０の後段側に位置する他の解析エンジンなどの予め設定された出力先に出力する。
【００２１】
なお、データ解析装置１が備える上記各部１０〜１４，２０は、データ解析装置１を構成する情報処理装置にプログラムが組み込まれることで実現される。
【００２２】
ここで、上記解析エンジン３０は、例えば、取得した映像データから物体の動線を抽出する動線抽出エンジン、映像データ内の人物の顔を抽出する顔抽出エンジン、映像データ内の人物の年齢を判別する年齢判別エンジン、などである。そして、これら解析エンジン３０を組み合わせて実行される解析処理手順を表す解析実行ルールが予め設定されており、解析実行ルール管理部２０に記憶されている。解析実行ルールは、例えば、図５に示すように、入力された映像データを解析エンジンＡで処理し、その解析結果を解析エンジンＢと解析エンジンＤに出力してそれぞれ解析処理し、解析エンジンＤの解析結果を解析エンジンＥ−１，Ｅ−２にそれぞれ出力してそれぞれ解析処理し、解析エンジンＢ、解析エンジンＥ−１，Ｅ−２の解析結果を解析エンジンＣに出力して解析処理を行う、というものである。このとき、特定の解析エンジンに対して入力データが入力されてくる側に位置する他の解析エンジン側を、前段側と呼び、特定の解析エンジンから出力データが出力される側に位置する他の解析エンジン側を、後段側と呼ぶ。つまり、図５において、特定の解析エンジンを基準として、左側を前段側、右側を後段側、と呼ぶ。
【００２３】
また、上述したデータ解析システム１００は、各解析エンジン３０に対応して、当該各解析エンジン３０の処理性能を制御する処理性能制御部４０を備えている。換言すると、図２に示すように、データ解析装置１は、各解析エンジン３０ごとに、１つあるいは複数の処理性能制御部４０が接続されており、これら処理性能制御部４０は、各解析エンジン３０及び解析処理実行１１とは異なって独立した処理モジュールにて構成されている。なお、上記処理性能制御部４０は、データ解析装置１を構成する情報処理装置やデータ解析装置１に接続された他の情報処理装置に、プログラムが組み込まれることで実現される。
【００２４】
上記処理性能制御部４０は、解析処理実行部１１にて対応する解析エンジン３０による解析処理を実行する際に呼び出され（図７のステップＳ１）、当該解析エンジン３０の状態を表す状態情報を検出して（図７のステップＳ２）、当該検出した状態情報に基づいて（図７のステップＳ３でＹｅｓ）、予め設定された処理を実行する（図７のステップＳ４）、という機能を有する。例えば、処理性能制御部４０としては、図３に示すように、入力バッファ管理モジュール４１、エンジン呼出判定モジュール４２、送信先決定モジュール４３、出力バッファ管理モジュール４４、があり、これらはそれぞれ以下の機能を有する。
【００２５】
上記入力バッファ管理モジュール４１は、呼び出されると、まず、対応する解析エンジン３０の状態情報として、当該解析エンジン３０に入力される入力データの入力状況、特に、入力バッファ３０ａにおける入力データの蓄積状況を検出する。そして、検出した入力バッファ３０ａの容量が入力データで一杯となると、新規に入力される入力データは破棄する、という処理を実行する（図６の解析エンジンＢにおける矢印Ｙ１参照）。あるいは、入力バッファ管理モジュール４１は、検出した入力バッファの容量が入力データで一杯となると、入力バッファ内に蓄積されている入力データのうち古いものから破棄する、という処理を実行する。あるいは、入力バッファ管理モジュール４１は、検出した入力バッファの容量が入力データで一杯となると、入力バッファ内に蓄積されている入力データのうちランダムに入力データを破棄する、という処理を実行する。これにより、入力バッファ管理モジュール４１にて状態を検出している解析エンジン３０に入力されるデータ量が減少する。
【００２６】
また、入力バッファ管理モジュール４１は、対応する解析エンジン３０の状態情報に応じて、他の解析エンジン３０の性能を制御する処理も実行する。例えば、入力バッファ管理モジュール４１は、対応する解析エンジン３０の入力バッファ３０ａの容量が一杯となったことを検出すると、対応する解析エンジン３０（例えば、図６の解析エンジンＤ）の前段側に位置する他の解析エンジン３０（例えば、図６の解析エンジンＡ）の入力バッファ内に蓄積されている入力データの一部を破棄する、という処理を実行する（図６の解析エンジンＤから解析エンジンＡに向かう矢印Ｙ３参照）。このとき、前段の解析エンジン３０の入力バッファ内から、古い入力データから削除してもよく、ランダムに削除してもよい。これにより、その後、入力バッファの入力データを破棄した解析エンジンよりも後段側に位置し、入力バッファ管理モジュール４１にて状態を検出している解析エンジン３０に入力されるデータ量が減少する。
【００２７】
なお、入力バッファ管理モジュール４１は、対応する解析エンジン３０の入力バッファの容量が一定数以下になるように、当該入力バッファに入力される入力データや入力バッファ内に蓄積されている入力データの少なくとも一部を、所定の基準に従ってあるいはランダムに破棄してもよい。
【００２８】
以上のような機能を有する入力バッファ管理モジュール４１を設けることにより、特定の解析エンジン３０にて入力データの処理が滞った場合に、かかる入力データが解析処理前に間引きされるなど減少するため、その後の解析処理結果の精度が劣化するなどの影響は出るものの、解析エンジン３０によるスループットの向上を図ることができる。
【００２９】
また、上記エンジン呼出判定モジュール４２は、呼び出されると、まず、対応する解析エンジン３０の状態情報として、当該解析エンジンに入力される入力データの入力状況、特に、入力バッファ３０ａに入力データが存在するか否かを検出する。そして、入力バッファ３０ａに入力データが存在することを検出すると、かかる入力データに対して解析エンジン３０が解析処理を実行するよう当該解析エンジン３０を呼び出す、という処理を実行する。また、エンジン呼出判定モジュール４２は、上述したように対応する解析エンジン３０を呼び出した単位時間当たりの回数を記録した参照データリスト３０ｂから検出し、かかる回数が予め設定された上限値を超えた場合に、解析エンジンの呼び出しを所定時間待つ、という処理を実行する。
【００３０】
また、上記送信先決定モジュール４３は、呼び出されると、まず、対応する解析エンジン３０の状態情報として、当該解析エンジン３０から出力される出力データの出力状況を記録した実行結果リスト３０ｃから検出する。そして、一回の解析処理にて解析エンジン３０から出力された出力データのデータ数が予め設定された閾値を超えると、出力データのデータ数が閾値以下になるよう当該出力データの一部を破棄する、という処理を実行する（図６の解析エンジンＢにおける矢印Ｙ２参照）。これにより、後段側に位置する他の解析エンジン３０に対して出力される出力データの数が減るため、負荷が軽減される。
【００３１】
あるいは、送信先決定モジュール４３は、一回の解析処理にて解析エンジン３０から出力された出力データのデータ数が予め設定された閾値を超えると、後段に同一の他の解析エンジン３０が複数ある場合に、これら後段の複数の他の解析エンジン３０に出力データを分散して出力する、という処理を実行する（図６の解析エンジンＤにおける矢印Ｙ４参照）。図６の例で説明すると、例えば、解析エンジンＤから解析エンジンＥ−１に対してのみ出力データを出力しているときに（矢印Ｄ１参照）、出力データのデータ数が閾値を超えると、かかる出力データを半分ずつ解析エンジンＥ−１，Ｅ−２のそれぞれに分散して出力する（矢印Ｄ１及び矢印Ｄ２参照）。これにより、解析エンジンＥ−１による解析処理が２台の解析エンジンＥ−１，Ｅ−２にて実行されることとなるため、負荷分散を図ることができる。
【００３２】
あるいは、送信先決定モジュール４３は、一回の解析処理にて解析エンジン３０から出力された出力データのデータ数が予め設定された閾値を超えると、後段の解析エンジン３０による解析処理が、他の解析処理よりも優先的に処理されるようその度合いを表す優先度を上げて設定する、という処理を実行する。これにより、設定後は、後段の解析エンジン３０による解析処理が優先的に実行されることとなる。
【００３３】
上記出力バッファ管理モジュール４４は、呼び出されると、まず、対応する解析エンジン３０の状態情報として、当該解析エンジンから出力される出力データの出力状況、特に、出力バッファ３０ｄにおける出力データの蓄積状況を検出する。そして、検出した出力バッファ３０ｄの容量が出力データで一杯となると、新規に解析エンジン３０から出力される出力データは出力バッファ３０ｄに蓄積せず破棄する、という処理を実行する（図６の解析エンジンＢにおける矢印Ｙ２参照）。あるいは、出力バッファ管理モジュール４４は、検出した出力バッファの容量が出力データで一杯となると、出力バッファ内に蓄積されている出力データの一部を、古いものから又はランダムに破棄する、という処理を実行する。
【００３４】
あるいは、出力バッファ管理モジュール４４は、検出した出力バッファの容量が出力データで一杯となると、出力データの出力先に後段側の他の解析エンジンが設定されている場合に、この出力先を後段側の別の解析エンジンに変更する、という処理を実行する。図６の例で説明すると、例えば、解析エンジンＤから解析エンジンＥ−１に対してのみ出力データを出力しているときに（矢印Ｄ１参照）、出力データのデータ数が閾値を超えると、かかる出力データを解析エンジンＥ−２に出力先を変更して出力する（矢印Ｄ２参照）。これにより、解析エンジンＥ−１による解析処理が２台の解析エンジンＥ−１，Ｅ−２にて実行されることとなるため、負荷分散を図ることができる。
【００３５】
なお、上述したように出力バッファの容量が一杯となる場合は、例えば、通信遅延や後段側の解析エンジンの障害などでデータ通信が滞る場合が考えられるが、上述したように出力データの一部を破棄したり、出力先を変更することで、かかる状況を解消することができる。
【００３６】
ここで、上述した性能制御処理部４０は、つまり、入力バッファ管理モジュール４１などのようにモジュール化していることで、必要に応じてデータ解析システム１００に対して容易に着脱することができる。従って、図４に示すように、図３の状態から送信先決定モジュール４３、出力バッファ管理モジュール４４を容易に取り外すことができ、逆に、図４の状態から送信先決定モジュール４３、出力バッファ管理モジュール４４を容易に装着することができる。そして、各モジュールを装着後に、当該モジュールがエンジン制御部１０にて呼び出されることにより、上述したように解析エンジン３０の状態を検出して、検出した状態に応じて作動するよう設定することで、容易に解析エンジンの性能を制御することができる。
【００３７】
以上より、解析処理システムの構成にあわせて、解析エンジンの状態に応じて適切に作動する適切な性能制御処理部４０を、容易に組み込むことができる。その結果、低コストにて解析処理の遅延を抑制することができる解析処理システムを実現することができる。
【００３８】
なお、上記では、性能制御処理部４０の一例として、入力バッファ管理モジュール４１、エンジン呼出判定モジュール４２、送信先決定モジュール４３、出力バッファ管理モジュール４４、を挙げて説明したが、性能制御処理部４０はこれらに限定されず、他の機能を有するモジュールであってもよい。
【００３９】
＜付記＞
上記実施形態の一部又は全部は、以下の付記のようにも記載されうる。以下、本発明における解析処理システム（図８参照）、プログラム、解析処理方法の構成の概略を説明する。但し、本発明は、以下の構成に限定されない。
【００４０】
（付記１）
所定の解析処理を行う解析エンジン５２０と、当該解析エンジン５２０の動作を制御して解析処理を実行する解析処理実行部５１０と、前記解析エンジン５２０の処理性能を制御する処理性能制御部５３０と、を備え、
前記処理性能制御部５３０は、前記解析エンジン５２０及び前記解析処理実行部５１０とは異なり独立して解析処理システム５００に装備可能な処理モジュールにて構成されており、前記解析処理実行部５１０にて呼び出され、特定の前記解析エンジン５２０の状態を表す状態情報を検出して、当該検出した状態情報に基づいて予め設定された処理を実行する、
解析処理システム５００。
【００４１】
（付記２）
付記１に記載の解析処理システムであって、
前記処理性能制御部は、前記特定の解析エンジンに入力される入力データの入力状況を前記状態情報として検出し、当該検出した状態情報に基づいて予め設定された処理を実行する、
解析処理システム。
【００４２】
（付記３）
付記２に記載の解析処理システムであって、
前記処理性能制御部は、前記特定の解析エンジンに入力される入力データを一時的に蓄積する入力バッファの蓄積状況を前記状態情報として検出し、当該検出した状態情報に基づいて予め設定された処理を実行する、
解析処理システム。
【００４３】
（付記４）
付記３に記載の解析処理システムであって、
前記処理性能制御部は、前記特定の解析エンジンの前記入力バッファの蓄積状況を前記状態情報として検出し、当該検出した状態情報に基づいて、前記特定の解析エンジンの前記入力バッファに蓄積されている入力データの少なくとも一部を当該入力バッファ内から破棄する処理を実行する、
解析処理システム。
【００４４】
（付記５）
付記３又は４に記載の解析処理システムであって、
前記処理性能制御部は、前記特定の解析エンジンの前記入力バッファの蓄積状況を前記状態情報として検出し、当該検出した状態情報に基づいて、前記特定の解析エンジンの前段側に位置する他の解析エンジンへの入力データを一時的に蓄積する他の入力バッファに蓄積されている入力データの少なくとも一部を、当該他の入力バッファ内から破棄する処理を実行する、
解析処理システム。
【００４５】
（付記６）
付記１乃至５のいずれかに記載の解析処理システムであって、
前記処理性能制御部は、前記特定の解析エンジンから出力される出力データの出力状況を前記状態情報として検出し、当該検出した状態情報に基づいて予め設定された処理を実行する、
解析処理システム。
【００４６】
（付記７）
付記６に記載の解析処理システムであって、
前記処理性能制御部は、前記特定の解析エンジンから出力される出力データの出力状況を前記状態情報として検出し、当該検出した状態情報に基づいて、前記特定の解析エンジンの後段側に位置する他の解析エンジンに対して前記特定の解析エンジンから出力する前記出力データの少なくとも一部を破棄する処理を実行する、
解析処理システム。
【００４７】
（付記８）
付記６又は７に記載の解析処理システムであって、
前記処理性能制御部は、前記特定の解析エンジンから出力される出力データの出力状況を前記状態情報として検出し、当該検出した状態情報に基づいて、前記特定の解析エンジンの後段側に位置する複数の他の解析エンジンに対して前記特定の解析エンジンから出力する前記出力データを分散して出力する処理を実行する、
解析処理システム。
【００４８】
（付記９）
付記６乃至８のいずれかに記載の解析処理システムであって、
前記処理性能制御部は、前記特定の解析エンジンから出力される出力データの出力状況を前記状態情報として検出し、当該検出した状態情報に基づいて、前記特定の解析エンジンの後段側に位置する他の解析エンジンに対して前記特定の解析エンジンから出力する前記出力データを、当該特定の解析エンジンの後段側に位置する別の解析エンジンに出力するよう前記出力データの出力先を変更する処理を実行する、
解析処理システム。
【００４９】
（付記１０）
付記６乃至９のいずれかに記載の解析処理システムであって、
前記処理性能制御部は、前記特定の解析エンジンから出力される出力データの出力状況を前記状態情報として検出し、当該検出した状態情報に基づいて、前記特定の解析エンジンの後段側に位置する他の解析エンジンによる解析処理が他の解析処理よりも優先的に処理される度合を表す優先度を設定する処理を実行する、
解析処理システム。
【００５０】
（付記１１）
付記１乃至１０のいずれかに記載の解析処理システムであって、
前記処理性能制御部は、前記特定の解析エンジンに入力される入力データの入力状況を前記状態情報として検出し、当該検出した状態情報に基づいて、前記特定の解析エンジンを呼び出す処理を実行する、
解析処理システム。
【００５１】
（付記１２）
付記１１に記載の解析処理システムであって、
前記処理性能制御部は、前記特定の解析エンジンの単位時間当たりの呼び出し回数を検出し、当該呼び出し回数が予め設定された上限値を超えた場合に、前記特定の解析エンジンの呼び出しを所定時間待つ処理を実行する、
解析処理システム。
【００５２】
（付記１３）
所定の解析処理を行う解析エンジンを備えた情報処理装置に、
前記解析エンジンの動作を制御して解析処理を実行する解析処理実行部と、前記解析エンジンの処理性能を制御する処理性能制御部と、を実現させると共に、
前記処理性能制御部は、前記解析エンジン及び前記解析処理実行部とは異なり独立して解析処理システムに装備可能な処理モジュールにて構成されており、前記解析処理実行部にて呼び出され、特定の前記解析エンジンの状態を表す状態情報を検出して、当該検出した状態情報に基づいて予め設定された処理を実行する、
ことを実現させるためのプログラム。
【００５３】
（付記１４）
付記１３に記載のプログラムであって、
前記処理性能制御部は、前記特定の解析エンジンに入力される入力データの入力状況を前記状態情報として検出し、当該検出した状態情報に基づいて予め設定された処理を実行する、
プログラム。
【００５４】
（付記１５）
所定の解析処理を行う解析エンジンを備えた情報処理装置にて、
解析処理実行部が前記解析エンジンの動作を制御して解析処理を実行すると共に、処理性能制御部が前記解析エンジンの処理性能を制御し、
前記処理性能制御部は、前記解析エンジン及び前記解析処理実行部とは異なり独立して解析処理システムに装備可能な処理モジュールにて構成されており、前記解析処理実行部にて呼び出され、特定の前記解析エンジンの状態を表す状態情報を検出して、当該検出した状態情報に基づいて予め設定された処理を実行する、
解析処理方法。
【００５５】
（付記１６）
付記１５に記載の解析処理方法であって、
前記処理性能制御部は、前記特定の解析エンジンに入力される入力データの入力状況を前記状態情報として検出し、当該検出した状態情報に基づいて予め設定された処理を実行する、
解析処理方法。
【００５６】
なお、上述したプログラムは、記憶装置に記憶されていたり、コンピュータが読み取り可能な記録媒体に記録されている。例えば、記録媒体は、フレキシブルディスク、光ディスク、光磁気ディスク、及び、半導体メモリ等の可搬性を有する媒体である。
【００５７】
以上、上記実施形態等を参照して本願発明を説明したが、本願発明は、上述した実施形態に限定されるものではない。本願発明の構成や詳細には、本願発明の範囲内で当業者が理解しうる様々な変更をすることができる。
【００５８】
なお、本発明は、日本国にて２０１１年１１月９日に特許出願された特願２０１１−２４５１４９の特許出願に基づく優先権主張の利益を享受するものであり、当該特許出願に記載された内容は、全て本明細書に含まれるものとする。
【符号の説明】
【００５９】
１  データ解析装置
１０  エンジン制御部
１１  解析処理実行部
１２  実行部
１３  実行情報管理部
１４  解析データ交換部
２０  解析実行ルール管理部
３０  解析エンジン
４０  性能制御処理部
４１  入力バッファ管理モジュール
４２  エンジン呼出判定モジュール
４３  送信先決定モジュール
４４  出力バッファ管理モジュール
１００  データ解析システム
２００  データ取得システム
２１０  カメラ
２２０  ストリームデータ収集・蓄積・配信部
３００  アプリケーション
【図１】
2013069191.tif 000003
【図２】
2013069191.tif 000004
【図３】
2013069191.tif 000005
【図４】
2013069191.tif 000006
【図５】
2013069191.tif 000007
【図６】
2013069191.tif 000008
【図７】
2013069191.tif 000009
【図８】
2013069191.tif 000010
【国際調査報告】
2013069191.tif 000011
2013069191.tif 000012
2013069191.tif 000013
2013069191.tif 000014