(57)【要約】【課題】  分散した機器を多階層で構成するシステムにおいて、監視トラフィックを削減し、中間ノードの保持する情報を削減し、信頼性を向上し、情報を効率的に収集することを目的とする。【解決手段】  各ノードは、直下の階層に属するノードの最終更新時間（以下ＬＵＴ：ＬａｓｔＵｐｄａｔｅＴｉｍｅ）を記憶しており、所定のタイミングで直下のノードにＬＵＴをポーリングし、ＬＵＴに変化があった場合に、当該ノードから前回のＬＵＴから変化があった情報（差分情報）のみを収集し、また、上位のノードからＬＵＴの問い合せがあった場合に、自ノードのＬＵＴを通知するとともに、上位ノードから差分情報の問い合せがあった場合に上位ノードに差分情報を送信する。【選択図】        図１
2005250521.tif 000002
【特許請求の範囲】
【請求項１】
複数のデータ処理装置を有し、前記複数のデータ処理装置が論理的な階層構造を形成するデータ処理システムであって、
前記複数のデータ処理装置のそれぞれは、
それぞれのデータ処理装置よりも下位の特定のデータ処理装置について前記特定のデータ処理装置が情報の更新を行った更新時刻を記憶しており、
所定のタイミングで、前記特定のデータ処理装置に対して最新の更新時刻を問い合せ、前記特定のデータ処理装置から通知された最新の更新時刻が記憶している更新時刻よりも後の時刻である場合に、前記特定のデータ処理装置から最新の更新時刻に更新された情報を受信することを特徴とするデータ処理システム。
【請求項２】
前記複数のデータ処理装置のそれぞれは、
それぞれのデータ処理装置の直下の階層に位置する直下データ処理装置の更新時刻を記憶しており、
所定のタイミングで、前記直下データ処理装置に対して最新の更新時刻を問い合せ、前記直下データ処理装置から通知された最新の更新時刻が記憶している更新時刻よりも後の時刻である場合に、前記直下データ処理装置から最新の更新時刻に更新された情報を受信することを特徴とする請求項１に記載のデータ処理システム。
【請求項３】
前記複数のデータ処理装置のそれぞれは、
前記直下データ処理装置から通知された最新の更新時刻が記憶している更新時刻よりも後の時刻である場合に、最新の更新時刻に更新された前記直下データ処理装置及び前記直下データ処理装置よりも下位のデータ処理装置に関する情報を前記直下データ処理装置から受信することを特徴とする請求項２に記載のデータ処理システム。
【請求項４】
前記複数のデータ処理装置のそれぞれは、
前記直下データ処理装置及び前記直下データ処理装置よりも下位のデータ処理装置に関する情報であって、最新の更新時刻に前回の更新時刻から変化した情報のみを前記直下データ処理装置から受信することを特徴とする請求項３に記載のデータ処理システム。
【請求項５】
前記複数のデータ処理装置のそれぞれは、
所定のタイミングで、それぞれのデータ処理装置及びそれぞれのデータ処理装置よりも下位のデータ処理装置に関する情報を更新し、
それぞれのデータ処理装置よりも上位の特定のデータ処理装置からそれぞれのデータ処理装置及びそれぞれのデータ処理装置よりも下位のデータ処理装置に関する更新後の情報の送信を要求された場合に、前記特定のデータ処理装置にそれぞれのデータ処理装置及びそれぞれのデータ処理装置よりも下位のデータ処理装置に関する更新後の情報を送信することを特徴とする請求項１に記載のデータ処理システム。
【請求項６】
前記複数のデータ処理装置のそれぞれは、
それぞれのデータ処理装置及びそれぞれのデータ処理装置よりも下位のデータ処理装置に関する情報を更新する度に更新時刻を記憶し、
前記特定のデータ処理装置から最新の更新時刻の通知を要求された場合に、記憶している最新の更新時刻を前記特定のデータ処理装置に通知し、
最新の更新時刻を通知した後に前記特定のデータ処理装置からそれぞれのデータ処理装置及びそれぞれのデータ処理装置よりも下位のデータ処理装置に関する更新後の情報の送信を要求された場合に、前記特定のデータ処理装置にそれぞれのデータ処理装置及びそれぞれのデータ処理装置よりも下位のデータ処理装置に関する更新後の情報を送信することを特徴とする請求項５に記載のデータ処理システム。
【請求項７】
前記複数のデータ処理装置のそれぞれは、
それぞれのデータ処理装置及びそれぞれのデータ処理装置よりも下位のデータ処理装置に関する情報であって、最新の更新時刻に前回の更新時刻から変化した情報のみを前記特定のデータ処理装置に送信することを特徴とする請求項５に記載のデータ処理システム。
【請求項８】
前記複数のデータ処理装置のそれぞれは、
複数の直下データ処理装置を有し、
複数の直下データ処理装置のそれぞれから、最新の更新時刻に更新された直下データ処理装置及び直下データ処理装置よりも下位のデータ処理装置に関する情報を受信し、
複数の直下データ処理装置から受信した情報を分析し、同一のデータ処理装置に関する情報を重複して受信していた場合に、重複情報のいずれかを選択するとともに、選択しなかった重複情報を削除することを特徴とする請求項３に記載のデータ処理システム。
【請求項９】
前記複数のデータ処理装置のそれぞれは、
それぞれのデータ処理装置よりも上位の複数のデータ処理装置から、それぞれのデータ処理装置及びそれぞれのデータ処理装置よりも下位のデータ処理装置に関する更新後の情報の送信を要求され、
上位の複数のデータ処理装置のそれぞれにそれぞれのデータ処理装置及びそれぞれのデータ処理装置よりも下位のデータ処理装置に関する更新後の情報を送信することを特徴とする請求項５に記載のデータ処理システム。
【請求項１０】
前記データ処理システムは、
下位のデータ処理装置における更新内容を下位のデータ処理装置から上位のデータ処理装置に通知し、上位のデータ処理装置において下位のデータ処理装置から通知された更新内容に当該上位のデータ処理装置における更新内容を追加して当該上位のデータ処理装置及び下位のデータ処理装置における更新内容をより上位のデータ処理装置に通知することを特徴とする請求項１に記載のデータ処理システム。
【請求項１１】
前記複数のデータ処理装置のそれぞれは、
それぞれのデータ処理装置よりも下位の複数のデータ処理装置に対して最新の更新時刻を問い合せ、最新の更新時刻が記憶している更新時刻よりも後の時刻であるデータ処理装置に対して最新の更新時刻に更新された情報の優先度及び情報サイズを問い合せ、
問い合せに応答して各データ処理装置から送信された優先度及び情報サイズに基づいて各データ処理装置から最新の更新時刻に更新された情報を受信する際の順序を決定し、決定した順序に従って各データ処理装置から最新の更新時刻に更新された情報を受信することを特徴とする請求項１に記載のデータ処理システム。
【請求項１２】
前記複数のデータ処理装置のそれぞれは、
受信可能な情報サイズの範囲内で優先度の高い情報から順に受信することを特徴とする請求項１１に記載のデータ処理システム。
【請求項１３】
前記複数のデータ処理装置のそれぞれは、
それぞれのデータ処理装置及びそれぞれのデータ処理装置よりも下位のデータ処理装置に関する情報を更新するとともに、更新後の情報に優先度を設定し、
それぞれのデータ処理装置よりも上位の特定のデータ処理装置から要求された場合に、更新後の情報の情報サイズを算出するとともに、更新後の情報の優先度及び情報サイズを上位の特定のデータ処理装置に送信することを特徴とする請求項５に記載のデータ処理システム。
【請求項１４】
前記複数のデータ処理装置のそれぞれは、
更新後の情報の情報種別、更新後の情報の値、及び更新時刻の少なくともいずれかに基づいて、更新後の情報の優先度を決定することを特徴とする請求項１３に記載のデータ処理システム。
【請求項１５】
前記複数のデータ処理装置のそれぞれは、
所定の場合に、優先度が一定レベル以下の情報に対して圧縮処理を行い、圧縮処理後の情報を保持することを特徴とする請求項１３に記載のデータ処理システム。
【請求項１６】
複数のデータ処理装置が論理的な階層構造を形成するデータ処理システムに含まれるデータ処理装置であって、
自データ処理装置よりも下位の特定のデータ処理装置について前記特定のデータ処理装置が情報の更新を行った更新時刻を記憶する更新時刻記憶部と、
所定のタイミングで、前記特定のデータ処理装置に対して最新の更新時刻を問い合せるとともに、前記特定のデータ処理装置から最新の更新時刻を示す応答を受信する更新時刻問い合せ部と、
前記特定のデータ処理装置からの応答に示された最新の更新時刻が前記更新時刻記憶部に記憶されている更新時刻よりも後の時刻である場合に、前記特定のデータ処理装置から最新の更新時刻に更新された情報を受信する更新情報受信部とを有することを特徴とするデータ処理装置。
【請求項１７】
前記更新時刻記憶部は、
自データ処理装置の直下の階層に位置する直下データ処理装置の更新時刻を記憶しており、
前記更新時刻問い合せ部は、
所定のタイミングで、前記直下データ処理装置に対して最新の更新時刻を問い合せるとともに、前記直下データ処理装置から最新の更新時刻を示す応答を受信し、
前記更新情報受信部は、
前記直下データ処理装置からの応答に示された最新の更新時刻が前記更新時刻記憶部に記憶されている更新時刻よりも後の時刻である場合に、前記直下データ処理装置から最新の更新時刻に更新された情報を受信することを特徴とする請求項１６に記載のデータ処理装置。
【請求項１８】
前記更新情報受信部は、
前記直下データ処理装置からの応答に示された最新の更新時刻が前記更新時刻記憶部に記憶されている更新時刻よりも後の時刻である場合に、最新の更新時刻に更新された前記直下データ処理装置及び前記直下データ処理装置よりも下位のデータ処理装置に関する情報を前記直下データ処理装置から受信することを特徴とする請求項１７に記載のデータ処理装置。
【請求項１９】
前記更新情報受信部は、
前記直下データ処理装置及び前記直下データ処理装置よりも下位のデータ処理装置に関する情報であって、最新の更新時刻に前回の更新時刻から変化した情報のみを前記直下データ処理装置から受信することを特徴とする請求項１８に記載のデータ処理装置。
【請求項２０】
前記データ処理装置は、更に、
自データ処理装置及び下位のデータ処理装置に関する情報を記憶する情報記憶部と、
所定のタイミングで、前記情報記憶部に記憶された自データ処理装置及び下位のデータ処理装置に関する情報を更新する更新管理部と、
前記更新管理部により更新された後の自データ処理装置及び下位のデータ処理装置に関する情報の送信要求を上位の特定のデータ処理装置から受信するとともに、更新後の自データ処理装置及び下位のデータ処理装置に関する情報を前記情報記憶部から取得して更新後の自データ処理装置及び下位のデータ処理装置に関する情報を前記特定のデータ処理装置に対して送信する更新情報送信部とを有することを特徴とする請求項１６に記載のデータ処理装置。
【請求項２１】
前記更新時刻記憶部は、
前記更新管理部により自データ処理装置及び下位のデータ処理装置に関する情報が更新される度に更新時刻を記憶し、
前記更新情報送信部は、
前記特定のデータ処理装置から最新の更新時刻の通知を要求された場合に、前記更新時刻記憶部に記憶されている最新の更新時刻を前記特定のデータ処理装置に通知し、
最新の更新時刻を通知した後に前記特定のデータ処理装置から更新後の自データ処理装置及び下位のデータ処理装置に関する情報の送信要求を受信した場合に、更新後の自データ処理装置及び下位のデータ処理装置に関する情報を前記特定のデータ処理装置に対して送信することを特徴とする請求項２０に記載のデータ処理装置。
【請求項２２】
前記更新情報送信部は、
更新後の自データ処理装置及び下位のデータ処理装置に関する情報であって、最新の更新時刻に前回の更新時刻から変化した情報のみを前記特定のデータ処理装置に送信することを特徴とする請求項２０に記載のデータ処理装置。
【請求項２３】
前記データ処理装置は、
複数の直下データ処理装置を有し、
前記更新情報受信部は、
複数の直下データ処理装置のそれぞれから、最新の更新時刻に更新された直下データ処理装置及び直下データ処理装置よりも下位のデータ処理装置に関する情報を受信し、
複数の直下データ処理装置から受信した情報を分析し、同一のデータ処理装置に関する情報を重複して受信していた場合に、重複情報のいずれかを選択するとともに、選択しなかった重複情報を削除することを特徴とする請求項１８に記載のデータ処理装置。
【請求項２４】
前記更新情報送信部は、
上位の複数のデータ処理装置から更新後の自データ処理装置及び下位のデータ処理装置に関する情報の送信要求を受信し、上位の複数のデータ処理装置のそれぞれに対して更新後の自データ処理装置及び下位のデータ処理装置に関する情報を送信することを特徴とする請求項２０に記載のデータ処理装置。
【請求項２５】
前記更新時刻問い合せ部は、
下位の複数のデータ処理装置に対して最新の更新時刻を問い合せ、
前記更新情報受信部は、
応答に示された最新の更新時刻が前記更新時刻記憶部に記憶されている更新時刻よりも後の時刻であるデータ処理装置に対して最新の更新時刻に更新された情報の優先度及び情報サイズを問い合せ、
問い合せに応答して各データ処理装置から送信された優先度及び情報サイズに基づいて各データ処理装置から最新の更新時刻に更新された情報を受信する際の順序を決定し、決定した順序に従って各データ処理装置から最新の更新時刻に更新された情報を受信することを特徴とする請求項１６に記載のデータ処理装置。
【請求項２６】
前記更新情報受信部は、
受信可能な情報サイズの範囲内で優先度の高い情報から順に受信することを特徴とする請求項２５に記載のデータ処理装置。
【請求項２７】
前記更新管理部は、
前記情報記憶部に記憶された自データ処理装置及び下位のデータ処理装置に関する情報を更新するとともに、更新後の情報に優先度を設定し、
前記情報記憶部は、
前記更新管理部により自データ処理装置及び下位のデータ処理装置に関する情報が更新された場合に、更新後の自データ処理装置及び下位のデータ処理装置に関する情報とともに優先度を記憶し、
前記更新情報送信部は、
上位の特定のデータ処理装置から要求された場合に、更新後の自データ処理装置及び下位のデータ処理装置に関する情報の情報サイズを算出するとともに、更新後の自データ処理装置及び下位のデータ処理装置に関する情報の優先度及び情報サイズを上位の特定のデータ処理装置に送信することを特徴とする請求項２０に記載のデータ処理装置。
【請求項２８】
前記更新管理部は、
更新後の自データ処理装置及び下位のデータ処理装置に関する情報の情報種別、更新後の自データ処理装置及び下位のデータ処理装置に関する情報の値、及び更新時刻の少なくともいずれかに基づいて、更新後の自データ処理装置及び下位のデータ処理装置に関する情報の優先度を決定することを特徴とする請求項２７に記載のデータ処理装置。
【請求項２９】
前記更新管理部は、
所定の場合に、優先度が一定レベル以下の情報に対して圧縮処理を行い、
前記情報記憶部は、
圧縮処理後の情報を記憶することを特徴とする請求項２８に記載のデータ処理装置。
【請求項３０】
論理的な階層構造を形成するデータ処理システムにおいてデータ処理を行うデータ処理方法であって、
特定の下位の階層において情報の更新が行われた更新時刻を記憶する更新時刻記憶ステップと、
所定のタイミングで、前記特定の下位の階層に対して最新の更新時刻を問い合せるとともに、前記特定の下位の階層から最新の更新時刻を示す応答を受信する更新時刻問い合せステップと、
前記特定の下位の階層からの応答に示された最新の更新時刻が前記更新時刻記憶ステップにおいて記憶した更新時刻よりも後の時刻である場合に、前記特定の下位の階層から最新の更新時刻に更新された情報を受信する更新情報受信ステップとを有することを特徴とするデータ処理方法。
【発明の詳細な説明】
【技術分野】
【０００１】
本発明は、分散した機器を多階層で構成するシステムにおいて、各機器の情報を収集する情報収集技術に関する。
【背景技術】
【０００２】
従来の分散機器情報収集方式は、ポーリング方式、またはトラップ方式によって、機器の情報を収集していた。しかし、ポーリング方式では機器の台数が増加するとそれに伴いトラフィックやサーバ負荷が増加する、ポーリング間隔を長くすると情報遅延が増加したり情報漏れが発生する、という問題点があった。また、トラップ方式では定常的な負荷を低減することが可能であるが、トラップが消失する可能性や機器自体の停止を検出できないなど信頼性が低く、また非同期にトラップが発生するため、一斉に複数のトラップが発生した場合にサーバ負荷が高くなるという問題点があった。
【０００３】
また、管理対象数の増加に対応するために階層構造によって、管理する方法も提案されている（例えば、特許文献１、２）。しかし特許文献１では、各ノードが全ノードの状態のテーブルを保持する必要があり、台数の増加に伴い、各ノードが保持する情報量が膨大になってしまうという問題点があり、また管理する状態は動作しているかどうかといった状態情報のみであり、各機器が複数の情報を持つ場合に対応できない。特許文献２ではトラップ方式の信頼性の低さを解決するためにポーリング方式と組み合わせる方式が提案されているが、一斉に複数のトラップが発生した場合にサーバ負荷が高くなる問題には対応できず、また特許文献１と同様に管理する状態は動作しているかどうかといった状態情報のみであり、各機器が複数の情報を持つ場合に対応できない。
【特許文献１】特許第３１４９９２４号公報
【特許文献２】特開平４−１７８０３９号公報
【発明の開示】
【発明が解決しようとする課題】
【０００４】
この発明は上記のような問題点を解決するためになされたもので、多数の機器の構成を多階層化し、信頼性の高いポーリング方式をベースとし、機器の増加や各機器が複数の情報を持つ場合においても、監視トラフィックを削減し、中間ノードの保持する情報を削減し、信頼性を向上し、情報を効率的に収集することを目的とする。
【課題を解決するための手段】
【０００５】
本発明に係るデータ処理システムは、複数のデータ処理装置を有し、前記複数のデータ処理装置が論理的な階層構造を形成するデータ処理システムであって、
前記複数のデータ処理装置のそれぞれは、
それぞれのデータ処理装置よりも下位の特定のデータ処理装置について前記特定のデータ処理装置が情報の更新を行った更新時刻を記憶しており、
所定のタイミングで、前記特定のデータ処理装置に対して最新の更新時刻を問い合せ、前記特定のデータ処理装置から通知された最新の更新時刻が記憶している更新時刻よりも後の時刻である場合に、前記特定のデータ処理装置から最新の更新時刻に更新された情報を受信することを特徴とする。
【発明の効果】
【０００６】
本発明では、下位の特定のデータ処理装置に対して最新の更新時刻を問い合せ、特定のデータ処理装置から通知された最新の更新時刻が記憶している更新時刻よりも後の時刻である場合に、特定のデータ処理装置から最新の更新時刻に更新された情報を受信するため、データ処理装置間の通信量を削減することができる。また、各データ処理装置は下位の特定のデータ処理装置における更新時刻と最新の更新時刻に更新された情報のみを管理するため、各データ処理装置が管理する情報量を削減することができる。
【発明を実施するための最良の形態】
【０００７】
実施の形態１．
図１はこの発明の全体のシステムを示す構成図である。
【０００８】
図１において、監視サーバ（０１０１）は各機器（０１０２）及び中間ノード（０１０３）の状態等を監視するサーバである。管理は多階層で行い、各中間ノード（０１０３ａａ〜０１０３ｍｎ）は監視対象となる複数の下位ノード（下位の中間ノード及び機器）と、自ノードおよびその下位ノードの状態等を監視する１つの上位ノードを持つ。各機器（０１０２ａ〜０１０２ｎ）は状態、運転モード、性能値、負荷値などの各種情報（０１０５ａ〜ｎ）を保持する。各中間ノード（０１０３ａａ〜ｍｎ）は下位ノード及び自ノードの状態、運転モード、性能値、負荷等の変化を示す情報（差分情報）を受信し、受信した差分情報を差分情報ＤＢ（０１０６ａａ〜ｍｎ）に保持する。監視サーバ（０１０１）は収集された各種情報を機器情報ＤＢ（０１０４）に保持する。また、監視サーバ（０１０１）、中間ノード（０１０３）、機器（０１０２）は、それぞれデータ処理装置の例である。
【０００９】
次に図２〜図４を用いて監視サーバ（０１０１）の構成について説明する。
【００１０】
図２において通信処理部（０２０１）は各下位ノードとの通信を制御する機構であり、状態取得処理部（０２０２）の指示に従い、各下位ノードの状態等を差分情報として収集する。状態取得処理部（０２０２）は各下位ノードの差分情報を効率的に収集するための機構である。ＬＵＴ管理部（０２０３）は自ノードおよびその下位ノードの最終更新時間（以下ＬＵＴ：Ｌａｓｔ  Ｕｐｄａｔｅ  Ｔｉｍｅ）を管理するための機構であり、図３のように自ノードのＬＵＴと各下位ノードの機器識別子とＬＵＴを管理する。ここで機器識別子は各機器、各ノードを一意に決めるための識別子である。差分情報処理部（０２０４）は状態取得処理部（０２０２）により取得された差分情報を受け取り、機器情報ＤＢ管理部（０２０５）を通じて機器情報ＤＢ（０１０４）に登録する機構である。機器情報ＤＢ（０１０４）には、図４のように機器最新情報として機器識別子、情報識別子、情報値を、履歴情報として、タイムスタンプ、機器識別子、情報識別子、新情報値、旧情報値を管理する。なお、状態取得処理部（０２０２）は更新時刻問い合せ部及び更新情報受信部に相当し、ＬＵＴ管理部（０２０３）は更新時刻記憶部に相当する。
【００１１】
なお、監視サーバ（０１０１）は、図示していないが、例えばマイクロプロセッサ等のＣＰＵ、半導体メモリ等や磁気ディスク等の記録手段、及び通信手段を有する計算機により実現することができる。記録手段には、監視サーバ（０１０１）に含まれる各構成要素の機能を実現するプログラムが記録されており、ＣＰＵがこれらのプログラムを読み込むことにより監視サーバ（０１０１）の動作を制御し、各構成要素の機能を実現することができる。
【００１２】
次に図５、６を用いて中間ノード（０１０３）の構成について説明する。
【００１３】
図５において通信処理部（０５０１）は上位ノードおよび各下位ノードとの通信を制御する機構であり、上位ノードからの問い合わせを状態返信処理部（０５０２）に転送し、状態取得処理部（０５０３）からの問い合わせを下位ノードに送信する機構である。状態返信処理部（０５０２）は通信処理部（０５０１）からの問い合わせに対し、ＬＵＴ管理部（０５０４）、および差分情報管理部（０５０５）を通じて差分情報ＤＢ（０１０６）の情報を参照し、問い合わせの結果を通信処理部（０５０１）を通じて上位ノードに返信する機構である。状態取得処理部（０５０３）は各下位ノードの差分情報を効率的に収集するための機構である。ＬＵＴ管理部（０５０４）は自ノードおよびその下位ノードのＬＵＴを管理するための機構であり、図３のように自ノードのＬＵＴと各下位ノードの機器識別子とＬＵＴを管理する。差分情報管理部（０５０５）は差分情報ＤＢを管理する機構であり、状態返信処理部（０５０２）からの問い合わせに対し差分情報ＤＢ（０１０６）の情報を返信し、状態取得処理部（０５０３）からのリクエストに対し、差分情報ＤＢ（０１０６）の更新を行う。差分情報ＤＢ（０１０６）では図６のように差分情報としてタイムスタンプ、機器識別子、情報識別子、新情報値、旧情報値を管理する。ここで、状態返信処理部（０５０２）は更新情報送信部に相当し、状態取得処理部（０５０３）は更新時刻問い合せ部及び更新情報受信部に相当し、ＬＵＴ管理部（０５０４）は更新時刻記憶部に相当し、差分情報管理部（０５０５）は更新管理部に相当し、差分情報ＤＢは情報記憶部に相当する。
【００１４】
なお、中間ノード（０１０３）は、図示していないが、例えばマイクロプロセッサ等のＣＰＵ、半導体メモリ等や磁気ディスク等の記録手段、及び通信手段を有する計算機により実現することができる。記録手段には、中間ノード（０１０３）に含まれる各構成要素の機能を実現するプログラムが記録されており、ＣＰＵがこれらのプログラムを読み込むことにより中間ノード（０１０３）の動作を制御し、各構成要素の機能を実現することができる。
【００１５】
次に図７、８を用いて各機器（０１０２）の構成について説明する。
【００１６】
図７において通信処理部（０７０１）は上位ノードとの通信を制御する機構であり、上位ノードからの問い合わせを状態返信処理部（０７０２）に送る。状態返信処理部（０７０２）は通信処理部（０７０１）からの問い合わせに対し、情報管理部（０７０３）を通じて各種情報（０１０５）の情報を参照し、問い合わせの結果を通信処理部（０５０１）を通じて上位ノードに返信する機構である。情報管理部（０７０３）は各種情報（０１０５）を管理する機構であり、状態返信処理部（０７０２）からの問い合わせに対し各種情報（０１０５）の値を返信し、各種センサ、メータなど（０７０４）から収集された値や機器の状態、運転モードなどにより、各種情報（０１０５）の更新を行う。各種情報（０１０５）では図８のように情報識別子、情報値を管理する。ここで、情報識別子は各情報を一意に決めるためのものであり、ＳＮＭＰにおけるＭＩＢのＯＩＤなどのようなものである。
【００１７】
なお、機器（０１０２）は、図示していないが、例えばマイクロプロセッサ等のＣＰＵ、半導体メモリ等や磁気ディスク等の記録手段、及び通信手段を有する計算機により実現することができる。記録手段には、機器（０１０２）に含まれる各構成要素の機能を実現するプログラムが記録されており、ＣＰＵがこれらのプログラムを読み込むことにより機器（０１０２）の動作を制御し、各構成要素の機能を実現することができる。
【００１８】
次に動作について図９、１０を用いて説明する。
【００１９】
図９は上位ノードの下位ノードに対して問い合わせを行うフローチャートである。
【００２０】
ステップ０９０１において、全ての下位ノードに関しステップ０９０２〜０９１３の処理を行い、全ての下位ノードの処理が完了したらステップ０９１４に飛ぶ。
【００２１】
まず、ステップ０９０２において問い合わせを行う下位ノードがＬＵＴに対応しているか調べ、対応していたらステップ０９０３に進み、対応していなかったらステップ０９０５に飛ぶ。ここで、下位ノードが中間ノード（０１０３）であれば、中間ノード（０１０３）はＬＵＴを管理しているので、ＬＵＴに対応しているとしてステップ０９０３に移り、下位ノードが機器（０１０２）であれば、機器（０１０２）はＬＵＴを管理していないので、ＬＵＴに対応していないとしてステップ０９０５に移る。
【００２２】
下位ノードがＬＵＴに対応している場合は、ステップ０９０３において、下位ノードにＬＵＴを問い合わせる。ステップ０９０４において、取得したＬＵＴが保持しているＬＵＴと異なるか（取得したＬＵＴが保持しているＬＵＴよりも後であるか）調べ、異なる場合はステップ０９０５に進み、同一の場合はステップ０９０１に戻り次の下位ノードの処理に移る。これらステップ０９０２〜０９０４は、状態取得処理部（０２０２）又は状態取得処理部（０５０３）により行われる。
【００２３】
ステップ０９０５では、問い合わせを行う下位ノードが差分情報に対応しているかを調べ、対応していたらステップ０９０６に進み、対応していなかったらステップ０９０９に飛ぶ。ここで、下位ノードが中間ノード（０１０３）であれば、中間ノード（０１０３）は差分情報を管理しているので、差分情報に対応しているとしてステップ０９０６に移り、下位ノードが機器（０１０２）であれば、機器（０１０２）は差分情報を管理していないので、差分情報に対応していないとしてステップ０９０９に移る。ステップ０９０６では、下位ノードに差分情報を問い合わせる。これらステップ０９０５、０９０６は状態取得処理部（０２０２）又は状態取得処理部（０５０３）により行われる。
【００２４】
ステップ０９０７では、取得した差分情報により、差分情報ＤＢを更新する。この時、最上位ノード（監視サーバ）の場合は機器履歴情報に登録し、機器最新情報を更新する。次に、ステップ０９０８では、問い合わせを行った下位ノードのＬＵＴおよび自ノードのＬＵＴを更新し、ステップ０９０１に戻り次の下位ノードの処理に移る。これらステップ０９０７、０９０８は、機器情報ＤＢ管理部（０２０５）又は差分情報管理部（０５０５）により行われる。
【００２５】
ステップ０９０９以降は、最下位の中間ノードが下位ノードである機器（０１０２）に対して問い合わせを行う場合の処理を示している。
【００２６】
ステップ０９０９では、問い合わせる下位ノード（機器（０１０２））が保持する全ての情報識別子についてステップ０９１０〜０９１３の処理を行い、すべて完了したらステップ０９０１に戻り次の下位ノードの処理に移る。ステップ０９１０において下位ノードに情報を問い合わせる。このステップ０９１０は状態取得処理部（０５０３）により行われる。
【００２７】
ステップ０９１１では、取得した情報と保持している情報が異なるか調べ、異なればステップ０９１２に進み、同一であればステップ０９０９に戻り次の情報識別子の処理に移る。ステップ０９１２では、取得した情報、および保持している情報により差分情報ＤＢを更新する。つまり、最下位の中間ノードは、下位ノードである機器（０１０２）の全ての情報項目（状態、運転モード、性能値、負荷値等）に関する現在値のテーブルを保持しており、このテーブルの現在値と機器から伝達される情報とを比較して、テーブルの値を更新するとともに、機器の状態等に変化があったときに差分情報を作成する。ステップ０９１３では、問い合わせを行った下位ノードのＬＵＴおよび自ノードのＬＵＴを更新し、ステップ０９０９に戻り次の情報識別子の処理に移る。これらステップ０９１１〜０９１３は機器情報ＤＢ管理部（０２０５）又は差分情報管理部（０５０５）により行われる。
【００２８】
その後、ステップ０９１４において次のポーリング時間まで待機し、ステップ０９０１に戻る。
【００２９】
図１０は下位ノードの上位ノードからの問い合わせに対して返信を行うフローチャートである。
【００３０】
ステップ１００１において上位ノードからの問い合わせ待ちを行い、問い合わせを受信したらステップ１００２に進む。
【００３１】
ステップ１００２では、問い合わせの種類を判別し、ＬＵＴの問い合わせであればステップ１００３に進み、差分情報問い合わせであればステップ１００４に進み、情報問い合わせであればステップ１００７に進む。通常、中間ノード（０１０３）の場合は、上位ノードからの問い合せはＬＵＴの問い合わせ及び差分情報問い合わせであり、機器（０１０２）の場合は、上位ノードからの問い合わせは情報問い合わせである。
【００３２】
ステップ１００３では、自ノードのＬＵＴを参照し、ＬＵＴを上位ノードに返信し、ステップ１００１に戻る。このステップ１００３は状態返信処理部（０５０２）により行われる。
【００３３】
ステップ１００４では、差分情報ＤＢから問い合わせＬＵＴ以降の差分情報を取得し、返信用データを作成する。その後、ステップ１００５において、作成したデータを上位ノードに返信する。これらステップ１００４〜１００５は、状態返信処理部（０５０２）により行われる。また、ステップ１００６では、送信した差分情報を削除し、ステップ１００１に戻る。このステップ１００６は、差分情報管理部（０５０５）により行われる。
【００３４】
ステップ１００７では、問い合わせられた情報の値を取得し返信用データを作成する。また、ステップ１００８では、作成したデータを上位ノードに返信し、ステップ１００１に戻る。これらステップ１００７及び１００８は、状態返信処理部（０７０２）及び情報管理部（７０３）により行われる。
【００３５】
また、本フローチャートでは各処理をシーケンシャルに実行するように記述しているが、各下位ノードに対する問い合わせなど並列に処理可能な部分については、並列に実行しても良い。
【００３６】
また、以上の図９及び図１０の処理は、各ノードで独立に行われ、必ずしもノード間で同期をとる必要はない。
【００３７】
次に、各ノードにおける情報の流れを図２０を参照して説明する。図２０では、説明の便宜のため、各ノード間の関係が１対１であるシステムとしている。
【００３８】
それぞれのノードにおいて図９に示した動作が行われた結果、監視サーバ（０１００）〜機器（０１０２ａ）において、それぞれ独立に、下位ノードに対するＬＵＴの問い合せ、下位ノードに対する差分情報の問い合せ又は情報の問い合せが行われる。また、それぞれのノードにおいて図１０に示した動作が行われた結果、機器（０１０２ａ）〜監視サーバ（０１０１）において、それぞれ独立に、上位ノードへのＬＵＴの送信、上位ノードへの情報の送信又は差分情報の送信が行われる。情報の送信又は差分情報の送信は、具体的には、機器（０１０２ａ）から中間ノード（０１０３ｍａ）に対して機器（０１０２ａ）の最新の状態（状態、運転モード、性能値、負荷値等、以下、状態とは状態、運転モード、性能値、負荷値等を意味する）を示した情報が送信される。中間ノード（０１０３ｍａ）からは、一つ上位の階層の中間ノード（０１０３ｌａ）（図示せず）に対して機器（０１０２ａ）の状態の変化と中間ノード（０１０３ｍａ）の状態の変化を示す差分情報が送信され、以降、同様にして各中間ノードでそれぞれの中間ノードの状態の変化を追加した差分情報を上位ノードに送信する。この結果、中間ノード（０１０３ｂａ）は、下位ノードである機器（０１０２ａ）の状態及び中間ノード（０１０３ｃａ）〜中間ノード（０１０３ｍａ）のそれぞれの状態の変化を示す差分情報を中間ノード（０１０３ｃａ）から受信する。中間ノード（０１０３ｂａ）は、中間ノード（０１０３ｂａ）自身の状態の変化を追加して機器（０１０２ａ）の状態及び中間ノード（０１０３ｂａ）〜中間ノード（０１０３ｍａ）のそれぞれの状態の変化を示す差分情報を中間ノード（０１０３ａａ）に送信する。中間ノード（０１０３ａａ）でも同様に中間ノード（０１０３ａａ）自身の状態の変化を追加して機器（０１０２ａ）の状態及び中間ノード（０１０３ａａ）〜中間ノード（０１０３ｍａ）のそれぞれの状態の変化を示す差分情報を監視サーバ（０１０１）に送信し、監視サーバ（０１０１）は収集された各種情報を機器情報ＤＢに保持する。
【００３９】
このように、本実施の形態に示したデータ処理システムは、複数のノード（データ処理装置）を有し、複数のノード（データ処理装置）が論理的な階層構造を形成するデータ処理システムであって、複数のノード（データ処理装置）のそれぞれは、それぞれのノード（データ処理装置）よりも下位の特定のノード（データ処理装置）について特定のノード（データ処理装置）が情報の更新を行った更新時刻を記憶しており、所定のタイミングで、特定のノード（データ処理装置）に対して最新の更新時刻を問い合せ、特定のノード（データ処理装置）から通知された最新の更新時刻が記憶している更新時刻よりも後の時刻である場合に、特定のノード（データ処理装置）から最新の更新時刻に更新された情報を受信することを特徴とする。
【００４０】
また、複数のノード（データ処理装置）のそれぞれは、それぞれのノード（データ処理装置）の直下の階層に位置するノード（データ処理装置）の更新時刻を記憶しており、所定のタイミングで、直下ノード（データ処理装置）に対して最新の更新時刻を問い合せ、直下ノード（データ処理装置）から通知された最新の更新時刻が記憶している更新時刻よりも後の時刻である場合に、直下ノード（データ処理装置）から最新の更新時刻に更新された情報を受信することを特徴とする。
【００４１】
また、複数のノード（データ処理装置）のそれぞれは、直下ノード（データ処理装置）から通知された最新の更新時刻が記憶している更新時刻よりも後の時刻である場合に、最新の更新時刻に更新された直下ノード（データ処理装置）及び直下ノード（データ処理装置）よりも下位のノード（データ処理装置）に関する情報を直下ノード（データ処理装置）から受信することを特徴とする。
【００４２】
また、複数のノード（データ処理装置）のそれぞれは、直下ノード（データ処理装置）及び直下ノード（データ処理装置）よりも下位のノード（データ処理装置）に関する情報であって、最新の更新時刻に前回の更新時刻から変化した情報のみを直下ノード（データ処理装置）から受信することを特徴とする。
【００４３】
また、複数のノード（データ処理装置）のそれぞれは、所定のタイミングで、それぞれのノード（データ処理装置）及びそれぞれのノード（データ処理装置）よりも下位のノード（データ処理装置）に関する情報を更新し、それぞれのノード（データ処理装置）よりも上位の特定のノード（データ処理装置）からそれぞれのノード（データ処理装置）及びそれぞれのノード（データ処理装置）よりも下位のノード（データ処理装置）に関する更新後の情報の送信を要求された場合に、上位の特定のノード（データ処理装置）にそれぞれのノード（データ処理装置）及びそれぞれのノード（データ処理装置）よりも下位のノード（データ処理装置）に関する更新後の情報を送信することを特徴とする。
【００４４】
また、複数のノード（データ処理装置）のそれぞれは、それぞれのノード（データ処理装置）及びそれぞれのノード（データ処理装置）よりも下位のノード（データ処理装置）に関する情報を更新する度に更新時刻を記憶し、上位の特定のノード（データ処理装置）から最新の更新時刻の通知を要求された場合に、記憶している最新の更新時刻を上位の特定のノード（データ処理装置）に通知し、最新の更新時刻を通知した後に上位の特定のノード（データ処理装置）からそれぞれのノード（データ処理装置）及びそれぞれのノード（データ処理装置）よりも下位のノード（データ処理装置）に関する更新後の情報の送信を要求された場合に、上位の特定のノード（データ処理装置）にそれぞれのノード（データ処理装置）及びそれぞれのノード（データ処理装置）よりも下位のノード（データ処理装置）に関する更新後の情報を送信することを特徴とする。
【００４５】
また、複数のノード（データ処理装置）のそれぞれは、それぞれのノード（データ処理装置）及びそれぞれのノード（データ処理装置）よりも下位のノード（データ処理装置）に関する情報であって、最新の更新時刻に前回の更新時刻から変化した情報のみを上位の特定のノード（データ処理装置）に送信することを特徴とする。
【００４６】
また、本実施の形態に示したデータ処理システムは、下位のノード（データ処理装置）における更新内容を下位のノード（データ処理装置）から上位のノード（データ処理装置）に通知し、上位のノード（データ処理装置）において下位のノード（データ処理装置）から通知された更新内容に当該上位のノード（データ処理装置）における更新内容を追加して当該上位のノード（データ処理装置）及び下位のノード（データ処理装置）における更新内容をより上位のノード（データ処理装置）に通知することを特徴とする。
【００４７】
以上のように上位ノードは各下位ノードのＬＵＴについてポーリングを行い、変更があったもののみ情報を取得するため、ネットワークトラフィックを削減することができる。また、各中間ノードはＬＵＴと差分情報のみを管理するため、各中間ノードの管理する情報量を削減することができる。
【００４８】
実施の形態２．
以上の実施の形態１では、各中間ノードを１つの上位ノードにより監視するようにしたものであるが、次に信頼性を向上するために複数の上位ノードによる監視を可能とする実施形態を示す。
【００４９】
図１１を用いて実施の形態２のシステムの構成を説明する。図１１の各構成要素は図１の各構成要素と同様なものであるが、各中間ノードは複数の上位ノードによる監視に対応できるように拡張されている。以下に実施の形態１との構成要素、および動作の差異を記述する。
【００５０】
図５の各中間ノードのＬＵＴ管理部（０５０４）は図３に記載の情報のほかに新たに図１２のような機器識別子と上位ノードＬＵＴを管理する。また、動作について、図９の上位ノードから下位ノードへの問い合わせのフローチャートにおいて、ステップ０９０７およびステップ０９１２の差分情報ＤＢを更新する時に同一の差分情報がある場合はその情報を削除するように変更する。また、図１０の下位ノードの上位ノードからの問い合わせに対するフローチャートにおいて、ステップ１００６の差分情報削除において、送信した差分情報を削除するのではなく、上位ノードＬＵＴ内の最も古い時間以前の差分情報を削除するように変更する。
【００５１】
以下、図２１を用いて実施の形態２に係る動作例を説明する。なお、図２１では、説明の便宜のため、図１１と異なる構成にしている。
【００５２】
まず、中間ノード（０１０３ｃａ）は、自ノード以下のノードの差分情報（０１０３ｃａ〜）を上位ノードである中間ノード（０１０３ｂａ）及び中間ノード（０１０３ｂｂ）に送信する。同様に、中間ノード（０１０３ｃｂ）も、自ノード以下のノードの差分情報（０１０３ｃｂ〜）を上位ノードである中間ノード（０１０３ｂａ）及び中間ノード（０１０３ｂｂ）に送信する。
【００５３】
中間ノード（０１０３ｂａ）は、受信した差分情報（０１０３ｃａ〜）と差分情報（０１０３ｃｂ〜）を比較し、両者に重複がないため、差分情報（０１０３ｃａ〜）と差分情報（０１０３ｃｂ〜）に自ノードの変化を追加して差分情報（０１０３ｂａ、０１０３ｃａ〜、０１０３ｃｂ〜）として上位ノードである中間ノード（０１０３ａａ）及び中間ノード（０１０３ａｂ）に送信する。同様に、中間ノード（０１０３ｂｂ）も、受信した差分情報（０１０３ｃａ〜）と差分情報（０１０３ｃｂ〜）を比較し、両者に重複がないため、差分情報（０１０３ｃａ〜）と差分情報（０１０３ｃｂ〜）に自ノードの変化を追加して差分情報（０１０３ｂｂ、０１０３ｃａ〜、０１０３ｃｂ〜）として上位ノードである中間ノード（０１０３ａａ）及び中間ノード（０１０３ａｂ）に送信する。
【００５４】
中間ノード（０１０３ａａ）は、受信した差分情報（０１０３ｂａ、０１０３ｃａ〜、０１０３ｃｂ〜）と差分情報（０１０３ｂｂ、０１０３ｃａ〜、０１０３ｃｂ〜）を比較し、差分情報のうち０１０３ｃａ〜、０１０３ｃｂ〜の部分に重複があるため、重複部分のいずれか一方を削除するとともに自ノードの変化を追加して差分情報（０１０３ａａ、０１０３ｂａ、０１０３ｂｂ、０１０３ｃａ〜、０１０３ｃｂ〜）として上位ノードである監視サーバ（０１０１）に送信する。同様に、中間ノード（０１０３ａｂ）も、受信した差分情報（０１０３ｂａ、０１０３ｃａ〜、０１０３ｃｂ〜）と差分情報（０１０３ｂｂ、０１０３ｃａ〜、０１０３ｃｂ〜）を比較し、差分情報のうち０１０３ｃａ〜、０１０３ｃｂ〜の部分に重複があるため、重複部分のいずれか一方を削除するとともに自ノードの変化を追加して差分情報（０１０３ａｂ、０１０３ｂａ、０１０３ｂｂ、０１０３ｃａ〜、０１０３ｃｂ〜）として上位ノードである監視サーバ（０１０１）に送信する。
【００５５】
監視サーバ（０１０１）では、受信した差分情報（０１０３ａａ、０１０３ｂａ、０１０３ｂｂ、０１０３ｃａ〜、０１０３ｃｂ〜）と差分情報（０１０３ａｂ、０１０３ｂａ、０１０３ｂｂ、０１０３ｃａ〜、０１０３ｃｂ〜）を比較し、差分情報のうち０１０３ｂａ、０１０３ｂｂ、０１０３ｃａ〜、０１０３ｃｂ〜の部分に重複があるため、重複部分のいずれか一方を削除し、差分情報（０１０３ａａ、０１０３ａｂ、０１０３ｂａ、０１０３ｂｂ、０１０３ｃａ〜、０１０３ｃｂ〜）を機器情報として機器情報ＤＢに格納する。
【００５６】
このように、本実施の形態では、複数のノード（データ処理装置）のそれぞれは、複数の直下ノード（データ処理装置）を有し、複数の直下ノード（データ処理装置）のそれぞれから、最新の更新時刻に更新された直下ノード（データ処理装置）及び直下ノード（データ処理装置）よりも下位のノード（データ処理装置）に関する情報を受信し、
複数の直下ノード（データ処理装置）から受信した情報を分析し、同一のノード（データ処理装置）に関する情報を重複して受信していた場合に、重複情報のいずれかを選択するとともに、選択しなかった重複情報を削除することを特徴とする。
【００５７】
また、複数のノード（データ処理装置）のそれぞれは、それぞれのノード（データ処理装置）よりも上位の複数のノード（データ処理装置）から、それぞれのノード（データ処理装置）及びそれぞれのノード（データ処理装置）よりも下位のノード（データ処理装置）に関する更新後の情報の送信を要求され、上位の複数のノード（データ処理装置）のそれぞれにそれぞれのノード（データ処理装置）及びそれぞれのノード（データ処理装置）よりも下位のノード（データ処理装置）に関する更新後の情報を送信することを特徴とする。
【００５８】
以上のように構成することにより、各中間ノードに障害が発生した場合においても情報が途切れることがなく監視を継続することが可能となり、信頼性が向上する。
【００５９】
実施の形態３．
実施の形態３は実施の形態１および実施の形態２の差分情報に役割を付加し、管理方法を変更することにより、より効率的に情報を収集することを可能とした実施形態である。
【００６０】
つまり、本実施の形態の内容を概説すると、上位ノードは、実際に差分情報の問い合わせを行う前に、優先度、情報数、情報サイズが示された差分リストを複数の下位ノードから受信し、複数の下位ノードから収集した差分リストを優先度順に並べた問い合わせリストを生成し、問い合わせリストに示された順に下位ノードに差分情報の問い合わせを行う。そして、下位ノードから差分情報を取得したら、情報の役割（状態情報、性能情報、ログ情報）に応じて差分情報に優先度を設定する。また、各ノードは、自己の上位ノードから差分リストの問い合わせがあった場合には、設定した優先度に従って差分リストを作成して送信する。
【００６１】
本実施の形態では、監視サーバ、中間ノード、機器の各構成要素は実施の形態１および実施の形態２と同様のものであるが、中間ノードの管理する差分情報ＤＢの内容を図１３〜１５のように変更する。図１３のように差分情報には新しく役割を示すデータを付加する。役割は「状態情報」、「性能情報」、「ログ情報」といった差分情報が管理している情報の役割を示すためのものである。また、図１４のように差分情報テーブルを優先度毎に複数保持し、優先度テーブルにより管理する。また、優先度テーブルの最下位に圧縮用の領域を設ける。図１５は上位ノードからの問い合わせにより作成する差分リストであり、優先度テーブルと差分情報から問い合わせＬＵＴ以降の情報を検索し、優先度、情報数、情報サイズをまとめたものである。優先度は「差分テーブルの優先度」、情報数は「その優先度の差分テーブルに含まれる問い合わせＬＵＴ以降の情報（テーブルの行）の数」、情報サイズは「その優先度の差分テーブルに含まれる問い合わせＬＵＴ以降の情報の合計サイズ」となる。
【００６２】
次に図１６〜１９を用いて本実施の形態における動作を説明する。
【００６３】
図１６は上位ノードの下位ノードへの問い合わせを行うフローチャートである。
【００６４】
ステップ１６０１において、全ての下位ノードに関しステップ１６０２〜１６０７の処理を行い、全ての下位ノードの処理が完了したらステップ１６０８へ飛ぶ。なお、ステップ１６０１〜１６０５は図９のステップ０９０１〜０９０５と同じである。
【００６５】
ステップ１６０２では、問い合わせを行う下位ノードがＬＵＴに対応しているか調べ、対応していたらステップ１６０３に進み、対応していなかったらステップ１６０５に飛ぶ。
【００６６】
ステップ１６０３では、下位ノードにＬＵＴを問い合わせる。ステップ１６０４では、取得したＬＵＴが保持しているＬＵＴと異なるか調べ、異なる場合はステップ１６０５に進み、同一の場合はステップ１６０１に戻り次の下位ノードの処理に移る。
【００６７】
ステップ１６０５では、問い合わせを行う下位ノードが差分情報に対応しているかを調べ、対応していたらステップ１６０６に進み、対応していなかったらステップ１６０８に飛ぶ。
【００６８】
ステップ１６０６では、下位ノードに差分リストを問い合わせる。
ステップ１６０７では、取得した差分リストを、問い合わせリストに追加しステップ１６０１に戻る。問い合わせリストの構成は図１７の通りであり、種類に「差分情報」を、機器識別子に問い合わせを行う機器の識別子を、優先度、情報数、情報サイズは取得した差分リストを用いて追加を行う。具体的には、機器識別子は「問い合わせ先のノード、機器（差分リストを回答したノード、機器）の機器識別子」、情報識別子は「空」となり、優先度、情報数、情報サイズは差分リストの内容となる。また、各ノードの動作としては、下位ノードから取得した差分情報テーブルの内容（機器識別子、情報識別子が含まれる）をそのまま自ノードの指定した優先度の差分情報テーブルに追加する。
【００６９】
また、ステップ１６０８では、情報問い合わせを問い合わせリストに追加し、ステップ１６０１に戻る。追加する問い合わせは、種類に「情報」を、機器識別子に問い合わせを行う機器の識別子を、情報識別子に問い合わせを行う情報の識別子を情報サイズにその情報識別子の型のサイズを用いて追加を行う。具体的には、各中間ノードは、「中間ノード内の情報」として、問い合わせを行うノード、機器（機器識別子）、問い合わせを行う情報（情報識別子）、その情報識別子で管理される情報のサイズ、情報数、優先度を管理しており、情報識別子と情報サイズは機器が対応している仕様（ＳＮＭＰ（Ｓｉｍｐｌｅ  Ｎｅｔｗｏｒｋ  Ｍａｎａｇｅｍｅｎｔ  Ｐｒｏｔｏｃｏｌ）のＭＩＢ（Ｍａｎａｇｅｍｅｎｔ  Ｉｎｆｏｒｍａｔｉｏｎ  Ｂａｓｅ）  やＤＭＩ（Ｄｅｓｋｔｏｐ  Ｍａｎａｇｅｍｅｎｔ  Ｉｎｔｅｒｆａｃｅ）のＭＩＦ（Ｍａｎａｇｅｍｅｎｔ  Ｉｎｆｏｒｍａｔｉｏｎ  Ｆｏｒｍａｔ）、ＣＩＭ（Ｃｏｍｍｏｎ  Ｉｎｆｏｒｍａｔｉｏｎ  Ｍｏｄｅｌ）のＭＯＦ（Ｍａｎａｇｅｄ  Ｏｂｊｅｃｔ  Ｆｏｒｍａｔ）など）の情報を用い、情報数は機器がその情報を保持している数、優先順位はシステム管理者が設定する。そして、問い合せリストは、上記「中間ノード内の情報」を用いて作成する。各ノードの動作としては、下位ノードから取得した「情報の値」と「中間ノード内の情報」から差分情報を作成し、自ノードの指定した優先度の差分情報テーブルに追加する。
【００７０】
次に、全ての下位ノードについてステップ１６０２〜１６０７（又は１６０８）が完了した後に、ステップ１６０９において、問い合わせリストを優先度順に並べ替える。この時、情報サイズの総量がポーリング時間内で取得可能なサイズを超えていた場合はその分の問い合わせリストは削除する。
【００７１】
ステップ１６１０において、全ての問い合わせリストの問い合わせについてステップ１６１１〜１６１２までの処理を行い、全ての処理が完了したら、ステップ１６１３へ飛ぶ。
【００７２】
ステップ１６１１において、差分情報もしくは情報の問い合わせを行う。ステップ１６１２において、差分情報ＤＢを更新し、ステップ１６１０に戻り次の問い合わせについての処理を行う。この時、最上位ノード（監視サーバ）の場合は機器履歴情報に登録し、機器最新情報を更新する。なお、ステップ１６１１の差分情報ＤＢの更新についての詳細は図１８を用いて後述する。ステップ１６１３において、全下位ノードのＬＵＴを更新する。ステップ１６１４において、次のポーリングまで待機し、ステップ１６０１に戻る。
【００７３】
次に、図１８を用いて、差分情報ＤＢの更新のフローチャートを説明する。
【００７４】
ステップ１８０１において、下位ノードから取得した情報の役割を確認し、役割が「状態情報」であればステップ１８０２に、「ログ情報」であればステップ１８０８に、「性能情報」であればステップ１８１１に飛ぶ。
【００７５】
ステップ１８０２では、差分情報ＤＢ内の同一機器識別子、同一情報識別子の差分情報（下位ノードから取得した差分情報と同一の機器識別子及び同一の情報識別子を有する差分情報）を検索する。ステップ１８０３において、検索の結果、当該差分情報が検出されていればステップ１８０４に進み、検出されなければステップ１８０６に飛ぶ。ステップ１８０４では、差分情報ＤＢ内の情報と取得した差分情報のどちらが新しいかを確認し、取得した差分情報が新しければステップ１８０５に進み、古ければステップ１８０８に飛ぶ。ステップ１８０５では、検出された古い差分情報をプライオリティ最低のテーブルに移動する。ステップ１８０６では、取得した状態情報の値、もしくは性能情報の閾値によりプライオリティに変換する。プライオリティへの変換は、例えば、「１」は正常で優先度低、「２」は警告で優先度中、「３」は異常で優先度高といった形が考えられる。ステップ１８０７では、取得した情報を変換したプライオリティの差分情報テーブルに登録する。
【００７６】
一方、ステップ１８０８では、取得した差分情報をプライオリティ最低のテーブルに登録する。ステップ１８０９において、プライオリティ最低の差分情報テーブルが一定量を超えた、もしくは一定時間が経過した場合はステップ１８１０に進み、それ以外の場合は次のステップ（ステップ１６１０）に進む。ステップ１８１０においてプライオリティ最低の差分情報テーブルに圧縮をかけ、圧縮領域に追加し、次のステップ（ステップ１６１０）に進む。
【００７７】
ステップ１８１１において、性能情報があらかじめ設定されていた閾値を超えているかを確認し、超えていたらステップ１８０２に飛び、超えていなければステップ１８０８に飛ぶ。
【００７８】
図１９は下位ノードの上位ノードからの問い合わせに対して返信を行うフローチャートである。
【００７９】
図１９におけるステップ１００１〜１００８は図１０におけるステップと同様である。ステップ１９０１において、問い合わせの種類を判別し、問い合わせの種類が「ＬＵＴ問い合わせ」であればステップ１００３に、「差分リスト問い合わせ」であればステップ１９０２に、「差分情報問い合わせ」であればステップ１００４に、「情報問い合わせ」であればステップ１００７に飛ぶ。
【００８０】
ステップ１９０２において、優先度テーブルと差分情報から問い合わせＬＵＴ以降の情報を検索し、優先度、情報数、情報サイズをまとめた差分リストを作成し、返信用のデータを作成する。ステップ１９０３において作成した返信用データを上位ノードに返信し、ステップ１００１に戻る。
【００８１】
以上の各ノードの処理を図２２を用いて説明する。
【００８２】
まず、上位の中間ノード（０１０３ａａ）は、下位の中間ノード（０１０３ｂａ、０１０３ｂｂ、０１０３ｃａ）にＬＵＴ問い合わせを行う。なお、図２２では、作図上の便宜のため、中間ノード（０１０３ａａ）と中間ノード（０１０３ｂａ）間の通信のみを示しているが、他の中間ノードにおいても同様の通信が行われる。
【００８３】
下位の中間ノード（０１０３ｂａ）は、上位の中間ノード（０１０３ａａ）からのＬＵＴの問い合せに対してＬＵＴを応答する。
【００８４】
更に、上位の中間ノード（０１０３ａａ）は応答のあったＬＵＴが記憶しているＬＵＴよりも新しい場合に、下位の中間ノード（０１０３ｂａ）に差分リストの問い合わせを行い、下位の中間ノード（０１０３ｂａ）は差分リストを送信する。
【００８５】
上位の中間ノード（０１０３ａａ）では、下位の中間ノード（０１０３ｂａ、０１０３ｂｂ、０１０３ｃａ）のそれぞれから受信した差分リストに基づき問い合わせリストを作成するとともに、問い合せリストの順に従って、下位の中間ノード（０１０３ｂａ）に対して差分情報の問い合わせを行う。下位の中間ノード（０１０３ｂａ）では、上位の中間ノード（０１０３ａａ）からの問い合わせに応答して差分情報を送信する。
【００８６】
この後、上位の中間ノード（０１０３ａａ）では、下位の中間ノード（０１０３ｂａ、０１０３ｂｂ、０１０３ｃａ）のそれぞれから受信した差分情報に対して優先度を設定するとともに、更に上位の中間ノード（図示せず）から差分リストの問い合わせがあった場合には、差分情報の情報サイズを算出するとともに優先度に従って差分リストを生成し、更に上位の中間ノードに差分リストを送信する。
【００８７】
なお、本実施の形態では、ステップ１６０９において問い合わせリストを優先度順に並べ替えたが、その他に機器識別子や情報識別子毎の優先度やサイズなどを考慮した並べ替えを行っても良い。
【００８８】
このように、本実施の形態に示したデータ処理システムでは、複数のノード（データ処理装置）のそれぞれは、それぞれのノード（データ処理装置）よりも下位の複数のノード（データ処理装置）に対して最新の更新時刻を問い合せ、最新の更新時刻が記憶している更新時刻よりも後の時刻であるノード（データ処理装置）に対して最新の更新時刻に更新された情報の優先度及び情報サイズを問い合せ、問い合せに応答して各ノード（データ処理装置）から送信された優先度及び情報サイズに基づいて各ノード（データ処理装置）から最新の更新時刻に更新された情報を受信する際の順序を決定し、決定した順序に従って各ノード（データ処理装置）から最新の更新時刻に更新された情報を受信することを特徴とする。
【００８９】
また、複数のノード（データ処理装置）のそれぞれは、受信可能な情報サイズの範囲内で優先度の高い情報から順に受信することを特徴とする。
【００９０】
また、複数のノード（データ処理装置）のそれぞれは、それぞれのノード（データ処理装置）及びそれぞれのノード（データ処理装置）よりも下位のノード（データ処理装置）に関する情報を更新するとともに、更新後の情報に優先度を設定し、それぞれのノード（データ処理装置）よりも上位の特定のノード（データ処理装置）から要求された場合に、更新後の情報の情報サイズを算出するとともに、更新後の情報の優先度及び情報サイズを上位の特定のノード（データ処理装置）に送信することを特徴とする。
【００９１】
また、複数のノード（データ処理装置）のそれぞれは、更新後の情報の情報種別、更新後の情報の値、及び更新時刻の少なくともいずれかに基づいて、更新後の情報の優先度を決定することを特徴とする。
【００９２】
また、複数のノード（データ処理装置）のそれぞれは、所定の場合に、優先度が一定レベル以下の情報に対して圧縮処理を行い、圧縮処理後の情報を保持することを特徴とする。
【００９３】
以上のように構成することにより、ポーリング時間内に全ての差分情報を取得できないような場合においても優先度の高いものから順に収集されるため、重要な障害がその他の情報により遅延が大きくなるといったことが起きなくなる。また優先度の低いものは圧縮されて転送を行うことができるため、効率的に情報を収集することが可能となる。また、ポーリング間隔をより短くすることができるため、情報の遅延も削減することが可能となる。
【００９４】
ここで、以上の実施の形態で説明した分散機器情報収集方式の特徴を以下に示す。
【００９５】
以上の実施の形態で説明した分散機器情報収集方式は、分散した機器を多階層で構成するシステムにおいて、中間ノードが下位ノードの最終更新時間（ＬＵＴ：ＬａｓｔＵｐｄａｔｅＴｉｍｅ）をポーリングし、ＬＵＴに変化があった機器の情報のみを収集することを特徴とする。
【００９６】
また、各中間ノードは各下位ノードの情報の変化を変化時間と共に差分情報として管理し、上位ノードからの問い合わせに対し、前回の問い合わせ時間からの差分情報のみを返信することを特徴とする。
【００９７】
また、最上位ノードを監視サーバとすることにより、システムの監視を行うことを特徴とする。
【００９８】
また、各中間ノードは複数の上位ノードからの問い合わせに対して対応可能なことを特徴とする。
【００９９】
また、各中間ノードの管理する差分情報に役割を付加し、各中間ノードは差分情報を優先度毎に管理する優先度テーブルを保持し、役割毎に差分情報の管理方法を変えることを特徴とする。
【０１００】
また、役割が「状態情報」であり、同一機器識別子、同一情報識別子であった場合に、時間の新しいものの優先度を高く、古いものを優先度を低くすることにより、最新の情報を優先的に最上位ノードに収集することを特徴とする。
【０１０１】
また、役割が「ログ情報」であった場合に優先度を低く設定し、優先度の低い情報が一定時間、もしくは一定量溜まった場合に圧縮し、通信量を削減することを特徴とする。
【０１０２】
また、役割が「性能情報」であった場合にあらかじめ設定した閾値を超えた場合には優先度を高く設定し、それ以外の場合は優先度を低く設定することを特徴とする。
【図面の簡単な説明】
【０１０３】
【図１】実施の形態１に係るシステム構成例を示す図。
【図２】実施の形態１に係る監視サーバの構成例を示す図。
【図３】実施の形態１に係るＬＵＴ管理部の管理する情報の例を示す図。
【図４】実施の形態１に係る機器最新情報の例を示す図。
【図５】実施の形態１に係る中間ノードの構成例を示す図。
【図６】実施の形態１に係る差分情報テーブルの例を示す図。
【図７】実施の形態１に係る機器の構成例を示す図。
【図８】実施の形態１に係る情報テーブルの例を示す図。
【図９】実施の形態１に係る各ノードの動作例を示すフローチャート図。
【図１０】実施の形態１に係る各ノードの動作例を示すフローチャート図。
【図１１】実施の形態２に係るシステム構成例を示す図。
【図１２】実施の形態３に係るＬＵＴ管理部の管理する情報の例を示す図。
【図１３】実施の形態３に係る差分情報テーブルの例を示す図。
【図１４】実施の形態３に係る優先度テーブルの例を示す図。
【図１５】実施の形態３に係る差分リストの例を示す図。
【図１６】実施の形態３に係る各ノードの動作例を示すフローチャート図。
【図１７】実施の形態３に係る問い合せリストの例を示す図。
【図１８】実施の形態３に係る各ノードの動作例を示すフローチャート図。
【図１９】実施の形態３に係る各ノードの動作例を示すフローチャート図。
【図２０】実施の形態１に係る各ノードの動作例を示す図。
【図２１】実施の形態２に係る各ノードの動作例を示す図。
【図２２】実施の形態３に係る各ノードの動作例を示す図。
【符号の説明】
【０１０４】
０１０１  監視サーバ、０１０２  機器、０１０３  中間ノード、０１０４  機器情報ＤＢ、０１０５  各種情報、０１０６  差分情報ＤＢ、０２０１  通信処理部、０２０２  状態取得処理部、０２０３  ＬＵＴ管理部、０２０４  差分情報処理部、０２０５  機器情報ＤＢ管理部、０５０１  通信処理部、０５０２  状態返信処理部、０５０３  状態取得処理部、０５０４  ＬＵＴ管理部、０５０５  差分情報管理部、０７０１  通信処理部、０７０２  状態返信処理部、０７０３  情報管理部、０７０４  各種センサ、メータなど。
【図１】
2005250521.tif 000003
【図２】
2005250521.tif 000004
【図３】
2005250521.tif 000005
【図４】
2005250521.tif 000006
【図５】
2005250521.tif 000007
【図６】
2005250521.tif 000008
【図７】
2005250521.tif 000009
【図８】
2005250521.tif 000010
【図９】
2005250521.tif 000011
【図１０】
2005250521.tif 000012
【図１１】
2005250521.tif 000013
【図１２】
2005250521.tif 000014
【図１３】
2005250521.tif 000015
【図１４】
2005250521.tif 000016
【図１５】
2005250521.tif 000017
【図１６】
2005250521.tif 000018
【図１７】
2005250521.tif 000019
【図１８】
2005250521.tif 000020
【図１９】
2005250521.tif 000021
【図２０】
2005250521.tif 000022
【図２１】
2005250521.tif 000023
【図２２】
2005250521.tif 000024