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