(57)【特許請求の範囲】
【請求項１】
機器から情報を収集する収集部、
該収集部が収集した情報を一時的に蓄積するバッファ、
該バッファに蓄積された情報を記憶装置に送信する伝送部、
前記収集部が前記機器から情報を収集する収集速度と、前記伝送部が前記記憶装置に前記情報を伝送する伝送速度と、設定された処理内容で前記情報を収集するために必要となる必要収集速度であって前記情報毎に設定された情報サイズと収集周期と前記情報毎に段階的に設定された情報量を削減する処理内容とを用いて算出した前記必要収集速度とに基づいて、前記処理内容が段階的に設定された情報量削減レベルを判定し、当該情報量削減レベルの処理内容で前記収集部を制御する収集制御部
を備えたことを特徴とする情報処理装置。
【請求項２】
前記情報を収集する機器の機器アドレスと、前記情報の情報アドレスと、前記情報の情報サイズと、前記情報の収集周期と、前記情報に対応する前記情報量削減レベル毎の処理内容と、が記憶された記憶部を備え、
前記収集制御部は、前記記憶部に記憶された前記機器アドレスと前記情報アドレスに対応する、前記情報サイズと前記収集周期と前記処理内容とを用いて、前記必要収集速度を算出することを特徴とする請求項１に記載の情報処理装置。
【請求項３】
前記情報を収集する機器の機器アドレスと、前記情報の情報アドレスと、前記情報の情報サイズと、前記情報の収集周期と、前記情報を削減する処理内容の種類を示す処理種別と、前記情報量削減レベル毎に設定された処理種別毎の処理内容と、が記憶された記憶部を備え、
前記収集制御部は、前記記憶部に記憶された前記機器アドレスと前記情報アドレスに対応する、前記情報サイズと前記収集周期と前記情報の処理種別に対応した前記情報量削減レベルの処理内容とを用いて前記必要収集速度を算出し、収集する前記情報の処理種別に対応する前記情報量削減レベルに設定された処理内容で前記収集部を制御することを特徴とする請求項１に記載の情報処理装置。
【請求項４】
情報処理装置により機器から情報を収集する方法において、
機器から情報を収集する収集ステップ、
前記収集ステップで収集した情報が一時的に蓄積されるバッファから、蓄積された情報を記憶装置に送信する伝送ステップ、
前記収集ステップが前記機器から情報を収集する収集速度と、前記伝送ステップが前記記憶装置に前記情報を伝送する伝送速度と、設定された処理内容で前記情報を収集するために必要となる必要収集速度であって前記情報毎に設定された情報サイズと収集周期と前記情報毎に段階的に設定された情報量を削減する処理内容とを用いて算出した前記必要収集速度とに基づいて、前記処理内容が段階的に設定された情報量削減レベルを判定し、当該情報量削減レベルの処理内容で前記収集ステップを制御する収集制御ステップ
を備えたことを特徴とする情報処理方法。
【発明の詳細な説明】
【技術分野】
【０００１】
本発明は、複数の機器から情報を収集する情報処理装置と情報処理方法に関するものである。
【背景技術】
【０００２】
インターネットを利用して、複数の機器からの情報の収集を行う場合、専用線を利用する場合に比べて利用できる通信帯域の変動が大きく、通信環境が悪化した際に、収集した情報の伝送が間に合わない状況が発生し得る。【０００３】
このような状況の中で、特許文献１においては、複数の計算機の障害を監視する管理マネージャーが、当該計算機からログを収集する方式について開示されている。本先行技術では、予め管理マネージャーが同じネットワークの計算機へ収集すべきログのレベルを送信し、計算機はそのレベル以上のログを収集して管理マネージャーに送信する。この際、ログのレベルはネットワークの混雑度合いによって決定し、収集するログの量を調整している。
また、特許文献２においては、データ収集記録装置が管理対象システムの状態を示すデータを収集し蓄積する方式について開示されている。本先行技術では、データ収集記録装置の残記録容量が所定の基準以下になった場合、管理対象システムから受信したデータの重要度を判定し、その重要度に応じて間引き間隔を変化させることで、収集する情報量を調整している。【０００４】
【特許文献１】特開２００３−１３２０１９号公報
【特許文献２】特開２０１１−２５８０６４号公報
【発明の概要】
【発明が解決しようとする課題】
【０００５】
特許文献１と２で示されるシステム及び方式では、ネットワークの混雑度合いや収集情報の重要度に応じて収集する情報を間引くことで情報量の削減を行う。そのため、情報を収集する状態の変動が激しくなり、収集しきれない状況が発生すると、ネットワークの混雑度合いや収集情報の重要度に応じて情報を間引いて収集する情報量を調整することになり、特定の状況で重要な情報を収集し損ねる可能性があるという問題があった。
【課題を解決するための手段】
【０００６】
この発明に係る情報処理装置は、機器から情報を収集する収集部、該収集部が収集した情報を一時的に蓄積するバッファ、該バッファに蓄積された情報を記憶装置に送信する伝送部、前記収集部が前記機器から情報を収集する収集速度と、前記伝送部が前記記憶装置に前記情報を伝送する伝送速度と、設定された処理内容で前記情報を収集するために必要となる必要収集速度であって前記情報毎に設定された情報サイズと収集周期と前記情報毎に段階的に設定された情報量を削減する処理内容とを用いて算出した必要収集速度とに基づいて、前記処理内容が段階的に設定された情報量削減レベルを判定し、当該情報量削減レベルの処理内容で前記収集部を制御する収集制御部を備えたことを特徴とする。
【発明の効果】
【０００７】
この発明は、収集速度と、伝送速度と、設定された処理内容で情報を収集するために必要となる必要収集速度であって情報毎に設定された情報サイズと収集周期と前記情報毎に段階的に設定された情報量を削減する処理内容とを用いて算出した必要収集速度とに基づいて、処理内容が段階的に設定された情報量削減レベルを判定し、当該情報量削減レベルの処理内容で前記収集部を制御して収集する情報の情報量の削減を段階的に行う。そのため、情報を収集する状態の変動が激しくなり、収集しきれない状況が発生しても、ネットワークの混雑度合いや収集情報の重要度に応じて間引く処理で情報量の調整を行う場合よりも、収集する情報の、特に高優先度の情報の欠損を最小限におさえることができる。
【図面の簡単な説明】
【０００８】
【図１】この発明の実施の形態１における情報処理装置１の構成図である。
【図２】この発明の実施の形態１における情報処理装置１のハードウェア構成図である。
【図３】この発明の実施の形態１における収集情報の例である。
【図４】この発明の実施の形態１における機器情報の追加の画面の例である。
【図５】この発明の実施の形態１における収集制御部８の動作を示すフローチャートである。
【図６】この発明の実施の形態１における収集制御部８の詳細な動作を示すフローチャートである。
【図７】この発明の実施の形態１における収集部５の動作を示すフローチャートである。
【図８】この発明の実施の形態１における伝送部７の動作を示すフローチャートである。
【図９】この発明の実施の形態２における収集情報９０の例である。
【図１０】この発明の実施の形態２における、情報量削減レベルの設定の画面の例である。
【図１１】この発明の実施の形態２における、機器情報の追加の画面の例である。
【発明を実施するための形態】
【０００９】
以下に、本発明にかかる情報処理装置の実施の形態を図面に基づいて詳細に説明する。なお、この実施の形態によりこの発明が限定されるものではない。
【００１０】
実施の形態１．
図１は、この発明の実施の形態１における情報処理装置１の構成図である。
図１において、情報処理装置１は、１つまたは複数の機器２と接続され、接続された機器２から情報を収集し、通信網３を経由して接続された外部の記憶装置４に、機器２から収集した情報を伝送して記憶する。
そして、情報処理装置１は、収集部５とバッファ６と伝送部７と収集制御部８と記憶部９から構成されている。
【００１１】
収集部５は、機器２と接続されている。そして、収集部２は、収集制御部８から収集リクエスト情報が入力されると、収集リクエスト情報の内容に従って、接続されている機器２から機器２の持つ情報を収集し、収集した情報をバッファ６に出力して一時的に記憶させる。そして、収集部５が、バッファ６に収集した情報を出力する際に、収集制御部８から収集する情報の情報量を削減するための処理内容を含む収集リクエスト情報が入力された場合には、収集した情報を処理内容で処理して、情報量を調整してバッファ６に出力する。また、収集部５は、情報を収集してバッファに一時的に記憶させる処理が完了すると収集制御部８に完了メッセージを出力する。上記収集部５の処理は全て、伝送部７及び収集制御部８とは独立してバックグラウンドで実行されるため、伝送部７及び収集制御部８の処理に影響を与えない。
【００１２】
バッファ６は、機器２から収集した情報が収集部５から入力され、入力された情報を一時的に記憶している。そして、バッファ６に一時的に記憶している情報は、伝送部７によって外部の記憶装置４に伝送される。バッファ６は、収集部５が機器２から情報を収集する収集速度と、伝送部７が記憶装置４に情報を送信する伝送速度との一時的な不均衡を調整する役割を持つ。また、バッファ６は、情報の記憶状況を要求する記憶状況リクエストが収集制御部８から入力されると、現在追加で蓄積することが可能な情報の容量（空き容量）を収集制御部８に出力する。
【００１３】
伝送部７は、バッファ６に一時的に記憶されている情報を外部の記憶装置４に通信網３を介して送信し、記憶させる。その際、伝送部７は、収集制御部８から送信リクエスト情報が入力されると、送信リクエスト情報に従って、バッファ６に一時的に記憶されている情報をバッファ６から取得する。そして、伝送部７は、取得した情報をＳＱＬ（Structured Query Language）文等を用いて、通信網３を介して記憶装置４に送信し、記憶させる。また、伝送部７は、記憶装置４に情報を送信して記憶させる処理が完了すると完了メッセージを収集制御部８に出力する。上記伝送部７の処理は全て、収集部５及び収集制御部８とは独立してバックグラウンドで実行されるため、収集部５及び収集制御部８の処理に影響を与えない。
【００１４】
収集制御部８は、バッファ６に記憶状況リクエストを出力し、バッファ６から取得した空き容量の情報から、次に取得する情報分の空き容量があれば、次に収集する情報に関する収集リクエスト情報を収集部５に出力する。その際に、収集制御部８は、記憶部９に記憶されている収集情報９０を参照して、収集する情報の順番を決定し、収集する情報の情報量を削減する処理内容を段階的に示す情報量削減レベルを判定し、収集する情報毎に判定した情報量削減レベルに対応した処理内容を決定する。そして、収集制御部８は、収集する機器２と、収集する情報と、収集する情報のサイズと、収集する情報の処理内容を含めた収集リクエスト情報を収集部５に出力する。収集制御部８は、収集リクエスト情報及び完了メッセージを通じて収集部５を管理し、収集制御部８の処理は収集部５とは非同期で実行される。
【００１５】
また、収集制御部８は、バッファ６に記憶状況リクエストを出力して、情報が記憶されている状況を取得し、バッファ６に情報が記憶されている状況であって、伝送部７から完了メッセージが入力されている場合には、次の情報を記憶装置４に送信する送信リクエスト情報を伝送部７に出力する。収集制御部８は、送信リクエスト情報及び完了メッセージを通じて伝送部７を管理し、収集制御部８の処理は伝送部７とは非同期で実行される。
【００１６】
また、収集制御部８は、情報量削減レベル毎に必要収集速度を算出する。必要収集速度は、情報毎に設定された収集周期と情報量削減レベルに設定された処理内容で全ての情報を収集するために必要となる収集速度である。収集制御部８は、収集部５が機器２から情報を収集する収集速度と、伝送部７が記憶装置４に情報を送信する伝送速度と、必要収集速度を用いて情報量削減レベルを判定し、判定結果により情報量削減レベルを変更する。そして、収集制御部８は、変更した情報量削減レベルに対応した処理内容を含めて収集リクエスト情報を収集部５に出力する。
【００１７】
記憶部９は、情報処理装置１の内部または外部に設けられ、収集部５が機器２から情報を収集するための収集情報が記憶されている。収集情報は、機器アドレスと、情報アドレスと、収集周期と、情報量削減レベル毎の処理内容と、情報量削減レベル毎の必要収集速度である。そして、情報を収集する機器の収集周期と、情報量削減レベル毎の処理内容のいずれかが更新されると、収集制御部８が必要収集速度を再び算出し、必要収集速度は算出した必要収集速度に更新される。収集情報の詳細な情報の説明は後述する。
【００１８】
図２は、この発明の実施の形態１における情報処理装置１のハードウェア構成図である。
情報処理装置１は、演算装置１０と、主記憶装置１１と、補助記憶装置１２と、通信装置１３から構成されている。そして、演算装置１０と、主記憶装置１１と、補助記憶装置１２と、通信装置１３はバス１４によって相互に接続されている。また、通信装置１３によって通信網３を介して外部の記憶装置４と入出力装置１５に接続されている。入出力装置１５は、バス１４によって接続されてもよい。
【００１９】
演算装置１０は、例えば、ＣＰＵ（Ｃｅｎｔｒａｌ Ｐｒｏｃｅｓｓｉｎｇ Ｕｎｉｔ）、ＤＳＰ（Ｄｉｇｉｔａｌ Ｓｉｇｎａｌ Ｐｒｏｃｅｓｓｏｒ）である。
補助記憶装置１２は、例えば、ＲＯＭ（Ｒｅａｄ Ｏｎｌｙ Ｍｅｍｏｒｙ）、フラッシュメモリ、ＨＤＤ（Ｈａｒｄ Ｄｉｓｋ Ｄｒｉｖｅ）である。
主記憶装置１１は、例えば、ＲＡＭ（Ｒａｎｄｏｍ Ａｃｃｅｓｓ Ｍｅｍｏｒｙ）である。
通信装置１３は、例えば、データを受信するレシーバー及びデータを送信するトランスミッターを含む。通信装置１３は、例えば、通信チップ又はＮＩＣ（Ｎｅｔｗｏｒｋ Ｉｎｔｅｒｆａｃｅ Ｃａｒｄ）である。
入出力装置１５は、例えば、マウス、キーボード、ディスプレイ、又はタッチパネル、もしくはそれらを備える計算機である。
【００２０】
収集部５および伝送部７は、演算装置１０によって処理が実行される。また、伝送部７は、通信装置１３によってネットワーク３を介して外部の記憶装置と通信を行い、情報を送信する。収集部５が収集した情報を一時的に記憶するバッファ６は、主記憶装置１１または補助記憶装置１２またはそれらの両方によって実現される。収集制御部８は、演算装置１０によって処理が実行され、計算途中の情報等は主記憶装置１１に記憶される。記憶部９に記憶される収集情報９０は、ネットワーク３を介して外部の入出力装置１５からユーザが設定し、補助記憶装置１２に記憶されている。
【００２１】
次に、収集情報について、例を用いて説明する。
図３は、この発明の実施の形態１における収集情報の例である。
収集情報９０には、機器アドレス９１と、機器内部の情報アドレス９２および情報サイズ９３と、情報を収集する収集周期９４と、収集する情報の情報量を段階的に削減する処理内容が設定された情報量削減レベル９５と、情報量削減レベル９５ごとの必要収集速度９６の情報を含む。機器アドレス９１と、情報アドレス９２と、情報サイズ９３と、収集周期９４と、情報量削減レベル９５は後述の方法によりユーザが設定する。
【００２２】
機器アドレス９１は、情報を収集する収集対象の機器２のアドレス値である。
情報アドレス９２は、収集する情報が機器２上に記憶されているアドレス値である。
情報サイズ９３は、収集する情報が機器２上に記憶されている範囲である。
収集周期９４は、収集対象の機器２から情報を収集する間隔であり、情報ごとに収集する周期が対応づけられて、記憶されている。
【００２３】
情報量削減レベル９５は、収集する情報毎に、段階的に設定された情報量を削減する処理内容である。情報量削減レベル９５は、情報の収集を行うユーザが設定する。情報量削減レベル９５は、情報量削減レベル９５が上がるほど、収集した情報の量を減らす処理内容が設定される。しかし、優先度の高い情報に対しては、優先度の低い情報よりも相対的に削減量が少なくなるように処理内容が設定される。そして、最優先に収集する情報に対しては、情報量削減レベル９５に処理内容は設定されない。情報量削減レベル９５に処理内容を設定しない場合は、情報量を削減する処理が行われずに情報を収集するため、重要な情報を取得し損ねることを防ぐことができる。
【００２４】
情報量削減レベル９５のレベルの数と処理内容は、情報処理装置１が処理可能な範囲でユーザが自由に設定することができるものとする。例えば、処理内容には、”間引く”、”移動平均”、”累積”などが設定される。”間引く”という処理内容が設定された場合には、間隔も任意に設定される。”移動平均”という処理内容が設定された場合には、どこまで過去の値から移動平均を算出するかの区間も設定される。”累積”という処理内容が設定された場合には、累積する区間も設定される。
【００２５】
必要収集速度９６は、各情報量削減レベル（削減を行わない状態であるレベル０も含む）における、情報を設定された収集周期と情報量削減レベルに設定された処理内容で全ての情報を収集するために必要となる収集速度である。必要収集速度９６は、収集する全ての情報の情報サイズと収集周期、情報量削減レベルから収集制御部８によって算出され、収集情報９０として記憶部９に記憶されている。
【００２６】
次に、ユーザが収集情報９０を設定する方法について説明する。
図４は、この発明の実施の形態１における機器情報の追加の画面の例である。
ユーザは、例えば、図４に示す様な機器情報の追加の画面によって、収集情報９０の入力を行う。ユーザが入力する項目は、機器アドレス９１、情報アドレス９２、情報サイズ９３、収集周期９４、及び情報量削減レベル９５である。情報量削減レベル９５には、レベル別に処理内容が入力される。ユーザは、情報処理装置１の通信網３を介して外部の入出力装置１５によって、図４に示すような画面から５項目を入力し、収集する機器毎に収集情報９０を設定する。あるいは、情報処理装置１に備わっている表示機能と入力機能からユーザが５項目を入力して設定してもよい。あるいはユーザは、外部の入出力装置１５によって、図４に示すような画面から５項目を入力し、その入力情報をデータファイルの形式で通信網３を介して情報処理装置１に入力してもよい。
【００２７】
次に、情報処理装置１の収集制御部８の動作について説明する。
図５は、この発明の実施の形態１における収集制御部８の動作を示すフローチャートである。
まず、情報を収集する前に、情報処理装置１の記憶部９に記憶される収集情報９０がユーザによって設定される。
【００２８】
そして、情報の収集を開始する際には、情報量削減レベル９５が０（ゼロ）に設定されているとする。即ち、情報の収集を開始する際には、処理内容として収集する情報量の削減を行わないため、収集制御部８は、収集部５に処理内容を出力しない。具体的には、バッファ６に次に収集する情報の空きがあり（Ｓ１）、前回の情報収集の完了メッセージが収集部５から入力されており（Ｓ２）、次の情報を収集するタイミングである（Ｓ３）場合に収集制御部８は、収集情報９０として記憶されている機器アドレスと、情報アドレスと、情報サイズ９３を１データずつ含めた収集リクエスト情報を収集部に出力する（Ｓ４）。バッファ６に空きが無い場合（Ｓ１でＮｏ）、または前回の情報収集が完了していない場合（Ｓ２でＮｏ）、または次の情報を収集するタイミングに達してない場合（Ｓ３でＮｏ）は収集部５へ収集リクエスト情報を送信せずに次の処理（Ｓ５）に移る。
【００２９】
次に、収集制御部８は、バッファ６に収集済みの情報があり（Ｓ５）、前回の外部記憶装置への伝送の完了メッセージが伝送部７から入力されている（Ｓ６）場合、送信リクエスト情報を伝送部７に出力する（Ｓ７）。バッファ６に収集済みの情報がない場合（Ｓ５でＮｏ）、または伝送部７の伝送が完了していない場合（Ｓ６でＮｏ）は、伝送部７へ伝送リクエスト情報を送信せずに次の処理（Ｓ８）に移る。
【００３０】
そして、収集制御部８は、情報の収集処理を終了することがユーザから入力されているか否かを判定し（Ｓ８）、終了がユーザから入力されると処理を終了する。
処理の終了がユーザから入力されていなければ、収集部５が機器２から収集する収集速度と、送信部７が記憶装置４に情報を送信する伝送速度と、必要収集速度９６に基づいて、情報量削減レベルを判定し、判定した情報量削減レベル９５に変更する（Ｓ９）。そして、変更した情報量削減レベルに対応した処理内容を収集リクエスト情報に含めてＳ２の処理戻り、収集リクエスト情報を収集部に出力する。
以上が収集制御部８の動作の説明である。
【００３１】
ここで、Ｓ４の処理について、例えば、情報量削減レベル９５が０（ゼロ）であった場合を説明する。
収集制御部８が、記憶部９の収集情報９０を参照して、例えば、図３の収集情報９０のうち機器アドレス９１「192.168.0.1」と、情報アドレス９２「10A8」のデータ（図３の３番目のデータ）を収集する情報として取得したとする。そして、収集制御部８が、機器アドレス９１「192.168.0.1」と、情報アドレス９２「10A8」の情報を収集するように、収集リクエスト情報を収集部５に出力して制御するとする。
この時、収集制御部８は、記憶部９の収集情報９０を参照して、機器アドレス９１「192.168.0.1」と、情報アドレス９２「10A8」に対応する情報量削減レベル９５が０（ゼロ）の処理内容を取得する。情報量削減レベル９５が０の時、処理内容は何も設定されていないため、収集制御部８は、処理内容なしの収集リクエスト情報を収集部５に出力する。即ち、収集制御部８は、機器アドレス９１「192.168.0.1」と、情報アドレス９２「10A8」と、情報サイズ９３「４」を含めた収集リクエスト情報を収集部５に出力する。
【００３２】
また、Ｓ４の処理について、例えば、情報量削減レベル９５が１であった場合を説明する。
図３の収集情報９０のうち、機器アドレス９１「192.168.0.1」と、情報アドレス９２「10A8」のデータ（図３の３番目のデータ）を収集するように、収集制御部８が収集リクエスト情報を収集部５に出力して制御するとする。
この時、収集制御部８は、記憶部９の収集情報９０を参照して、機器アドレス９１「192.168.0.1」と、情報アドレス９２「10A8」に対応する情報量削減レベル９５が１の処理内容を取得する。そこで、収集制御部８は、情報量削減レベル９５が１の処理内容である「移動平均（60ms）」を得る。そのため、収集制御部８は、処理内容「移動平均（60ms）」を含めた収集リクエスト情報を収集部５に出力する。即ち、収集制御部８は、機器アドレス９１「192.168.0.1」と、情報アドレス９２「10A8」と、情報サイズ９３「４」と、処理内容「移動平均（60ms）」を含めた収集リクエスト情報を収集部５に出力する。
【００３３】
また、Ｓ４の処理について、例えば、情報量削減レベル９５が２であった場合の処理を説明する。
図３の収集情報９０のうち、機器アドレス９１「192.168.0.1」と、情報アドレス９２「1F24」のデータ（図３の５番目のデータ）を収集するように、収集制御部８が収集リクエスト情報を収集部５に出力して制御するとする。
この時、収集制御部８は、記憶部９の収集情報９０を参照して、機器アドレス９１「192.168.0.1」と、情報アドレス９２「1F24」に対応する情報量削減レベル９５が２の処理内容を取得する。そこで、収集制御部８は、情報量削減レベル９４が２の処理内容である「累積」を得る。そのため、収集制御部８は、処理内容「累積」を含めた収集リクエスト情報を収集部５に出力する。即ち、収集制御部８は、機器アドレス９１「192.168.0.1」、情報アドレス９２「1F24」、情報サイズ９３「2」、処理内容「累積」を含めた収集リクエスト情報を収集部５に出力する。
以上がＳ４の具体例を用いた処理の説明である。
【００３４】
次に、収集制御部８のＳ９の動作について詳細に説明する。
図６は、この発明の実施の形態１における収集制御部８の動作を示すフローチャートである。
収集制御部８は、定期的に収集情報９０の内容が更新されたか否かを判定する（Ｓ２０１）。収集情報９０は、ユーザが収集する情報の追加を外部の入出力装置から入力することによって更新される。
収集情報９０の内容が更新されている場合は、更新された収集情報９０の情報サイズ９３、収集周期９４、情報量削減レベル９５から必要収集速度９６を算出し、収集情報９０の必要収集速度９６の情報を更新する（Ｓ２０２）。そして、Ｓ２０３以降の処理を実行する。
【００３５】
ここで必要収集速度の算出方法について説明する。
必要収集速度は、収集する全ての情報を収集情報９０で設定された周期で収集するために必要な収集速度であるため、例えば、情報量削減レベル９５がレベル０の場合、必要収集速度９６＝｛（機器アドレス１、情報アドレス１に対応する情報サイズ１／収集周期１）＋（機器アドレス１、情報アドレス２の情報サイズ２／収集周期２）＋・・・＋（機器アドレスＮ、情報アドレスＭの情報サイズＰ／収集周期Ｐ）｝となる。即ち、必要収集速度９６は、１秒間にどれほどの情報を収集しなければならないかの情報サイズを意味する。
【００３６】
また、情報量削減レベル９５がレベル１以上の場合、削減レベル０の計算に対して、収集する情報毎に処理内容を適用して算出する。例えば、間引く場合は、間引く処理をした情報サイズを間引く間隔分だけ加算した収集周期で除算する。累積の場合は、累積した情報サイズを累積した情報サイズの伝送間隔分だけ加算した収集周期で除算する。
以上が必要収集速度の算出方法の説明である。
【００３７】
次に、Ｓ２０１の判定の結果、収集情報９０の内容が更新されていない場合、収集制御部８は、収集速度と伝送速度を算出する（Ｓ２０３）。
収集速度は、収集部５に収集リクエスト情報を出力して、完了メッセージが入力されるまでの時間と、収集リクエスト情報に含む情報サイズから算出する。このように算出した収集速度を現在の収集速度として以下説明する。
伝送速度は、伝送部７に送信リクエスト情報を出力した伝送開始時刻から、完了メッセージが入力される伝送終了時刻までの時間と、送信リクエスト情報に含む情報サイズから算出する。送信リクエスト情報には、バッファアドレスと、情報サイズを含む。このように算出した伝送速度を現在の伝送速度として以下説明する。
基本的に、収集制御部８は、伝送速度が収集速度を上回り、かつ収集速度が必要収集速度９６を上回っているときは、情報量削減レベル９５が０（ゼロ）の処理内容を含む収集リクエスト情報を収集部５に出力する。
【００３８】
次に、現在の収集速度が、現在の情報量削減レベル９５の必要収集速度９６よりも小さいか否かを判定する（Ｓ２０４）。
現在の収集速度が現在の必要収集速度９６よりも小さければ、必要収集速度９６が収集速度より小さくなるまで情報量削減レベル９５の段階を上げて（レベルを加算して）、情報量削減レベル９５を変更する（Ｓ２０５）。
現在の収集速度が現在の必要収集速度９６以上であれば、Ｓ２０６以降を処理する。
【００３９】
次に、伝送速度が必要収集速度９６よりも小さいか否かを判定する（Ｓ２０６）。
伝送速度が必要収集速度９６よりも小さければ、一定時間後、バッファ６に次に収集する情報を記憶する容量が不足するか否か（バッファ６が溢れるか否か）を判定する（Ｓ２０７）
この時、収集制御部８は、バッファ６に記憶状況リクエストを出力して、バッファ６からバッファ６の記憶状況を取得して、バッファの容量が不足するか否かを判定する。
Ｓ２０６で、伝送速度が必要収集速度９６以上であれば、Ｓ２０９以降の処理を行う。
Ｓ２０７でバッファ６の容量が不足する場合は、情報量削減レベル９５を１段階上げて（Ｓ２０８）、情報量削減レベル９５を変更し、処理を終了（図５のＳ９の処理を終了）して図５のＳ１の処理を行う。
Ｓ２０７でバッファ６の容量が不足しない場合は、処理を終了（図５のＳ９の処理を終了）して図５のＳ１の処理を行う。
【００４０】
Ｓ２０６で、伝送速度が必要収集速度９６以上であれば、情報量削減レベル９５がレベル１以上であるか否かを判定する（Ｓ２０９）。
Ｓ２０９で、情報量削減レベルが１以上であれば、一定時間以上現在の情報量削減レベル９５か否かを判定する（Ｓ２１０）。
Ｓ２０９で、情報量削減レベルが１よりも小さければ、即ち情報量削減レベル９５がレベル０であれば、処理を終了（図５のＳ９の処理を終了）して、図５のＳ１の処理を行う。
Ｓ２１０で、設定された一定時間以上、現在の情報量削減レベル９５であれば、情報量削減レベル９５を１段階下げ（レベルを減算して）、１段階下げた情報量削減レベル９５の必要収集速度が収集速度と伝送速度のどちらよりも大きいか否かを判定する（Ｓ２１１）。
【００４１】
Ｓ２１０で、一定時間以上現在の情報量削減レベル９５でなければ、処理を終了（図５のＳ９の処理を終了）して図５のＳ１の処理を行う。
Ｓ２１１で、１段階下げた情報量削減レベルの必要収集速度が収集速度と伝送速度のどちらよりも大きい場合、情報量削減レベル９５を１段階下げて（Ｓ２１２）、情報量削減レベル９５を変更する。そして、処理を終了（図５のＳ９の処理を終了）して図５のＳ１の処理を行う。
Ｓ２１１で、１段階下げた情報量削減レベル９５の必要収集速度が収集速度以下、または伝送速度以下であれば、処理を終了（図５のＳ９の処理を終了）して図５のＳ１の処理を行う。
以上が収集制御部８のＳ９の動作の詳細な説明である。
【００４２】
次に、収集部５の動作について説明する。
図７は、この発明の実施の形態１における収集部５の動作を示すフローチャートである。
収集部５は、収集制御部８から収集リクエスト情報が入力されると（Ｓ３１）、収集リクエスト情報に含まれた機器アドレス９５の機器から、情報アドレス９２の情報を情報サイズ９３で収集する（Ｓ３２）。そして、収集した情報を収集リクエスト情報に含まれた処理内容で処理し（Ｓ３３）、処理内容に応じて情報量を削減した情報を、バッファ６に出力して、一時的に記憶させる（Ｓ３４）。そして、情報の収集が完了すると、完了メッセージを収集制御部８に出力する（Ｓ３５）。
【００４３】
尚、収集リクエスト情報に処理内容が含まれない場合は、処理を行わないため情報量は削減されずにバッファ６に出力することになる。
ここでは、収集制御部８から、処理内容を含めた収集リクエスト情報が収集部５に入力されるとして説明しているが、収集制御部８から、情報量削減レベル９５を含めた収集リクエスト情報が収集部５に入力されてもよい。その場合、収集部５が記憶部９に記憶された収集情報９０を参照して、情報量削減レベル９５に対応する処理内容を取得し、収集した情報に対して処理内容で処理を行いバッファ６に出力する。
【００４４】
次に、伝送部７の動作について説明する。
図８は、この発明の実施の形態１における伝送部７の動作を示すフローチャートである。
伝送部７は、収集制御部８から送信リクエスト情報が入力されると（Ｓ４１）、送信リクエスト情報に従って、通信網３を介してバッファ６の情報を記憶装置４に送信して（Ｓ４２）、記憶させる。そして、送信が完了すると、伝送部７は、完了メッセージを収集制御部８に出力する（Ｓ４３）。
【００４５】
このように、収集制御部８は、現在の収集速度と、現在の伝送速度と、収集する情報毎に情報量を削減する処理内容が段階的に設定された情報量削減レベルを用いて、収集する情報の情報量の削減を段階的に行う。そのため、情報を収集する状態の変動が激しくなり、収集しきれない状況が発生しても、ネットワークの混雑度合いによって収集する情報量の調整を行う場合よりも、収集する情報の、特に高優先度の情報の欠損を最小限におさえることができる。
また、情報毎に設定された情報量削減レベルには、レベル毎に処理方法として、移動平均や累積などを設定することができる。そのため、収集情報の重要度に応じて間引く処理で情報量の調整を行う場合よりも、収集する情報の欠損を防止することができる。
【００４６】
また、本効果は、複数の機器が設置され、各機器の稼働と停止の変化が激しい場合や、設定の変更等で機器の持つ情報が変化する工場や住宅、ビルなどの情報を収集する管理用途に特に有効である。例えば、集合住宅のエネルギー管理を行うために、各家庭で使われている家電機器からエネルギー情報や稼働情報を収集する際に、曜日や時間帯によって稼働している機器の数が変動しても、エネルギー管理に必要な情報毎に処理内容を設定して、段階的に情報量の削減を行い、エネルギー管理を継続することができる。それ以外でもサーバやオフィスのＰＣ（personal computer）のログ収集など一般的な情報システムにおけるデータ収集でも有効となる。
【００４７】
実施の形態２．
以上の実施の形態１では、機器からの情報ごとに複数のレベルに対して収集する情報量を削減する処理内容をユーザが細かく設定し、収集速度と伝送速度と段階的に設定された処理内容が設定された情報量削減レベルを用いて、段階的に収集する情報量を削減するように制御する構成を示した。しかし実際には図３の収集情報９０は膨大な数となり、全てを細かく設定することは現実的ではない。ここでは、より簡単に情報毎の情報量削減レベル毎に収集する情報量を削減する処理方法を設定する構成について示す。
【００４８】
まず、本形態で使用する収集情報９０の内容について説明する。
図９は、この発明の実施の形態２における収集情報９０の例である。
機器アドレス９１、情報アドレス９２、情報サイズ９３、収集周期９４、必要収集速度９６は、実施の形態１と同様である。実施の形態２では、収集する情報毎に処理種別９７を新たに設定する。また、一部の情報を例外処置として、ある情報量削減レベルまで削減を行いたくない場合には、処理種別９７に対応して削減開始レベル９８を設定することも可能である。そして、設定された処理種別９７に従った処理を情報量削減レベル毎に規定する。
【００４９】
また、情報量削減レベル９５によって処理種別９７を変更したい場合に、１つの情報に対して削減開始レベル９８付きで複数の処理種別を指定することも可能である。処理種別の種類については、情報の収集者が任意に決められるものとする。
また、処理種別９７を含む収集情報９０をユーザが設定する際には、例えば、図１０の情報量削減レベルの設定の画面、図１１の「機器情報の追加」の画面を用いる。
【００５０】
図１０は、この発明の実施の形態２における、情報量削減レベルの設定の画面の例である。
図１０の情報量削減レベルの設定では、入力項目として「レベル」「処理種別」「処理内容」がある。そして、レベル別に対応した処理種別９７と、レベル毎の処理種別に対応した処理内容９９をユーザが入力して設定する。
例えば、「レベル１」に対して処理種別９７に「平均」「間引き」「累積」などを入力する。更に、「レベル１」の「平均」に対して処理内容９９に「移動平均」、「間引き」に対して処理内容９９に「４個おきに間引く」、「累積」に対して処理内容９９に「処理なし」を入力する。また、「レベル２」に対して処理種別９７に「平均」「間引き」「累積」などを入力する。更に、「レベル２」の「平均」に対して処理内容９９に「移動平均」、「間引き」に対して処理内容９９に「２個おきに間引く」、「累積」に対して処理内容９９に「累積を計算」を入力することで、収集情報９０の情報量削減レベル９５をユーザが設定する。
【００５１】
図１１は、この発明の実施の形態２における、機器情報の追加の画面の例である。
図１１の機器情報の追加の設定では、入力項目として「機器アドレス」、「情報アドレス」、「情報サイズ」、「収集周期」、「情報タイプ」がある。そして、例えば「機器アドレス」に対して「192.168.0.3」、「情報アドレス」に対して「0x5B9C」、「情報サイズ」に対して「16bit」、「収集周期」に対して「25ms」、「処理種別」に対して「平均」、「削減開始レベル」に対して「１」をユーザが入力することで、収集情報９０の機器の情報を設定する。
【００５２】
このように設定された収集情報９０と現在の収集速度と現在の伝送速度を用いて、収集制御部８は収集部５が収集する情報量の削減を制御する。収集制御部８の動作は図６に示す処理と同様である。
例えば、収集制御部８が情報量削減レベル１と変更した場合に、図９に示す３番目のデータ（機器アドレス９１「192.168.0.1」、情報アドレス９２「10A8」）を収集する収集リクエスト情報を収集制御部８が収集部５に出力するとする。この時、収集制御部８は、
機器アドレス９１「192.168.0.1」、情報アドレス「10A8」に対応して、処理種別９７が「平均」であるため、情報量削減レベル１に設定された処理種別「平均」の処理内容「移動平均」を含めた収集リクエスト情報を収集部５に出力する。
【００５３】
即ち、収集制御部８は、機器アドレス９１「192.168.0.1」、情報アドレス「10A8」、情報サイズ９３「4」、収集周期９４「20ms」、処理内容「移動平均」を含む収集リクエスト情報を収集部５に出力して制御する。すると、収集部５は、機器アドレス９１「192.168.0.1」、情報アドレス「10A8」の情報を「移動平均」で処理することにより、情報量を削減して収集する。
【００５４】
この様に、収集する情報毎に処理種別を設定し、情報量削減レベル毎に処理種別に対応した処理内容を設定することで、ユーザは収集する情報に対して少ない設定で、段階的に収集する情報量の削減を行うことができる。そのため、情報を収集する状態の変動が激しくなり、収集しきれない状況が発生しても、優先度に応じて収集する情報量の調整を行う場合よりも、収集する情報の、特に高優先度の情報の欠損を最小限におさえることができる。
【産業上の利用可能性】
【００５５】
以上のように、本発明にかかる情報処理装置及び情報処理方法は、収集速度と伝送速度と収集する情報毎に情報量を削減する処理内容が段階的に設定された情報量削減レベルを用いて、収集する情報量の削減レベルを段階的に変更して、収集する情報量を調整する。そのため、例えば、工場や住宅、ビルなどに設置された各機器からエレルギー情報や稼働情報を収集する際に、各機器の稼働と停止の変動が激しくなり状況が悪化して情報を収集しきれない状況が発生しても、優先度に応じて収集する情報量の調整を行う場合や間引く処理によって収集する情報量の調整を行う場合よりも、収集する情報の、特に高優先度の情報の欠損を最小限におさえることができる。
【符号の説明】
【００５６】
１  情報処理装置、２  機器、３  情報網、４  記憶装置、５  収集部、６  バッファ、７  伝送部、８  収集制御部、９  記憶部、１０  演算装置、１１  主記憶装置、１２  補助記憶装置、１３  通信装置、１４  バス、１５  入出力装置、９０  収集情報、９１機器アドレス、９２  情報アドレス、９３  情報サイズ、９４  収集周期、９５  情報量削減レベル、９６  必要収集速度、９７  処理タイプ、９８  削減開始レベル。
【要約】
この発明は、収集速度と、伝送速度と、収集する情報毎に情報量を削減する処理内容が段階的に設定された情報量削減レベルに基づいて、収集する情報の情報量の削減を段階的に行う。そのため、例えば、工場や住宅、ビルなどに設置された各機器からエレルギー情報や稼働情報を収集する際に、各機器の稼働と停止の変動が激しくなり収集しきれない状況が発生しても、優先度に応じて収集する情報量の調整を行う場合や間引く処理によって収集する情報量の調整を行う場合よりも、収集する情報の、特に高優先度の情報の欠損を最小限におさえることができる。【図１】
0005967322.tif 000002
【図２】
0005967322.tif 000003
【図３】
0005967322.tif 000004
【図４】
0005967322.tif 000005
【図５】
0005967322.tif 000006
【図６】
0005967322.tif 000007
【図７】
0005967322.tif 000008
【図８】
0005967322.tif 000009
【図９】
0005967322.tif 000010
【図１０】
0005967322.tif 000011
【図１１】
0005967322.tif 000012