(57)【要約】【課題】様々な装置からのデータ収集、様々なプログラムでの処理、収集対象装置や処理プログラムの動的追加を可能とし、スケーラブルで拡張性の高いデータ収集を実現する。【解決手段】データ収集システムを、収集対象装置と、データ収集処理プログラムと、データの受渡しを中継するブローカ手段に加え、データ収集制御装置で構成し、該データ収集制御装置が、収集対象のデータ群を定義するデータ群登録要求の受信手段と、データ群用宛先割当て手段と、データ群登録手段と、データ群登録情報提供手段と、データ収集開始を指示する収集登録要求の受信手段と、収集用宛先割当て手段と、収集登録手段と、収集登録情報提供手段を備える。【選択図】図２
2017091454.tif 000002
【特許請求の範囲】
【請求項１】
収集対象テータを提供する収集対象装置と、
データ収集処理装置上で動作し、収集対象装置の収集対象データや別のデータ収集処理プログラムの処理結果データを処理対象データとして取得し処理するデータ収集処理プログラムと、
該収集対象装置と該データ収集処理プログラム間、及び、データ収集処理プログラム間の収集対象データの受渡しを制御するデータ収集制御装置と、
該収集対象装置、データ収集処理プログラム、データ収集制御装置間のデータの受渡しを中継するブローカ手段を持つブローカ装置で構成したシステムにおいて、
データ提供者は、既定、あるいは、上記データ収集制御装置が指示した該ブローカ手段上の階層化された宛先にデータを送信し、データ受信者は、該宛先を受信対象としてブローカに指定し、該宛先に送信されてきたデータを、該宛先を受信対象と指定したすべてのデータ受信者に対して該ブローカが中継するデータ収集システムのデータ収集制御装置であって、
該データ収集制御装置は、第１の既定の宛先を上記ブローカ手段に受信対象として設定し、収集対象データ群を定義するデータ群登録要求を該第１の宛先から受信する第１のデータ群登録要求受信手段と、
受信したデータ群登録要求に対応し、該データ群用として、上記ブローカ手段の第１の宛先階層を割当て、後述の第５の収集登録要求受信手段と第８の収集登録情報提供手段に該データ群用宛先階層情報を伝えて、該データ群の収集対象データの収集要求のための収集登録要求の受信と、該収集登録要求の処理結果の収集登録情報の提供を行わせる、第２のデータ群用宛先割当て手段と、
上記データ群登録要求に含まれる該収集対象データ群を識別するデータ群名称と、該収集対象データ群を構成するデータのデータ名称とデータタイプ情報を含むデータ形式情報と、該第２の手段で割当てた第１の該データ群用宛先階層情報を含む情報をデータ群登録情報として登録する第３のデータ群登録手段と、
データ群登録要求に含まれるデータ群名称に対応した第２の宛先と、既定の第３の宛先を上記ブローカ手段に送信先として設定し、該第２の宛先に対して、上記第３の手段で登録されたデータ群登録情報を送付し、該第３の宛先に対して、登録済みの全データ群登録情報を送付して、該宛先に対する受信者に、特定のデータ群登録情報、及び、登録済みの全データ群登録情報を提供する第４のデータ群登録情報提供手段とを備え、
さらに、上記第１のデータ群用宛先階層情報を上記第２の手段から受け、該第１の宛先階層下に既定の第４の宛先を上記ブローカ手段に受信対象として設定し、該第４の宛先から該データ群の収集対象データの収集登録要求を受信する第５の収集登録要求受信手段と
受信した収集登録要求に対応して、該収集対象データの送付先となる第２の収集用宛先階層の割当てを行う第６の収集用宛先割当て手段と、
上記収集登録要求に含まれる、収集対象データの提供元を識別する提供者名称と、該収集対象データを構成するデータのデータ名称一覧と、該第６の手段で割当てた第２の収集用宛先階層情報を含む情報を収集登録情報として登録をする第７の収集登録手段と、
上記第１のデータ群宛先階層情報を上記第２の手段から受け、該第１の階層下に、該データ群の収集対象データの収集登録要求に含まれる収集対象データ提供者名称に対応した第５の宛先と、既定の第６の宛先を送信先として設定し、該第５の宛先に対して、上記第７の手段で登録された収集登録情報を送付し、該第６の宛先に対して、該収集対象データ群の登録済み全収集登録情報を送付して、該宛先に対する受信者に、特定の収集登録情報、及び、登録済みの全収集登録情報を提供する第８の収集登録情報提供手段を具備することを特徴とするデータ収集制御装置。
【請求項２】
請求項１記載のデータ収集システムにおいて、上記データ群登録要求により上記データ収集制御装置に対して予め登録済みのデータ群の収集対象データを提供する収集対象装置であって、
該収集対象装置から収集対象データの提供を開始する際、該収集対象装置は、該データ群名称に対応して上記データ収集制御装置が設定した第２の宛先を上記ブローカ手段に対して受信対象として設定し、該第２の宛先から該データ群のデータ群登録情報を取得する第９のデータ群登録情報取得手段と、
該第９の手段で取得したデータ群登録情報に含まれる該データ群用宛先階層情報と既定の名称から得られる上記第１の階層下の第４の宛先に、該収集対象装置を識別する提供者名称と該収集対象装置から提供する収集対象データのデータ名称一覧を含む収集登録要求を送信する第１０の収集登録要求送信手段と、
該第９の手段で取得したデータ群登録情報に含まれる該データ群用宛先階層情報と該収集対象装置を識別する上記提供者名称から得られる上記第１の階層下の第５の宛先を上記ブローカ手段に受信対象として設定し、該第５の宛先から該収集対象装置の収集登録情報を取得する第１１の収集登録情報取得手段と、
該収集対象装置から収集対象データを提供する際、該第１１の手段で取得した該収集対象装置の収集登録情報に含まれる収集用宛先階層情報で示された第２の宛先階層下の既定の宛先、あるいは、該収集対象装置から収集登録要求で示した収集対象データのデータ名称一覧内のデータ名称に対応した第２の宛先階層下の宛先に、該収集対象データの送信を行う第１２の収集データ送信手段を具備することを特徴とする収集対象装置。
【請求項３】
請求項１記載のデータ収集システムのデータ収集処理プログラムであって、
上記データ収集制御装置が設定した該データ収集処理プログラムが処理対象とする収集対象データ群を識別するデータ群名称に対応した上記第２の宛先を上記ブローカ手段に受信対象として設定し、該第２の宛先から該データ群のデータ群登録情報を取得する第１の処理対象データ群登録情報取得ステップと、
該第１のステップで取得したデータ群登録情報に含まれる該データ群用宛先階層情報と既定の名称から得られる上記第１の階層下の第６の宛先を上記ブローカ手段に受信対象として設定し、該第６の宛先から該データ群の全収集登録情報を取得する第２の全収集登録情報取得ステップと、
該第２のステップで取得した全収集登録情報の各収集登録情報に含まれる各収集用宛先階層情報から得られる第２の階層下の既定の宛先名称、あるいは、該収集登録情報に含まれるデータ一覧名称内のデータ名称に対応した第２の階層下の宛先を受信対象として上記ブローカ手段に設定し、該宛先から処理対象の収集対象データを取得する第３の処理対象データ取得ステップと、
第１のステップで取得したデータ群登録情報に含まれる収集対象装置から取得する収集対象データのデータ形式情報に従って該第３のステップで取得したデータを解釈し、処理する第４の収集データ処理ステップを含むことを特徴とするデータ収集処理プログラム。
【請求項４】
請求項３記載のデータ収集処理プログラムであり、
上記データ群登録要求により上記データ収集制御装置に対して予め登録済みのデータ群の収集対象データを該データ収集処理プログラムの処理結果として提供するデータ収集処理プログラムであって、
さらに、該データ収集処理プログラムは、該データ群を識別するデータ群名称に対応して上記データ収集制御装置が設定した第２の宛先を上記ブローカ手段に対して受信対象として設定し、該第２の宛先から該データ群のデータ群登録情報を取得する第５の該処理プログラム用データ群登録情報取得ステップと、
該第５のステップで取得したデータ群登録情報に含まれる該データ群用宛先階層情報と既定の名称から得られる上記第１の階層下の第４の宛先に、該データ収集処理プログラムを識別する提供者名称と該データ収集処理プログラムが処理結果として提供する収集対象データのデータ名称一覧を含む収集登録要求を送信する第６の該処理プログラム用収集登録要求送信ステップと、
該第５のステップで取得したデータ群登録情報に含まれる該データ群用宛先階層情報と該データ収集処理プログラムを識別する上記提供者名称から得られる上記第１の階層下の第５の宛先を上記ブローカ手段に受信対象として設定し、該第５の宛先から該データ収集処理プログラムの収集登録情報を取得する第７の該処理プログラム用収集登録情報取得ステップと、
該第７のステップで取得した該データ収集処理プログラムの収集登録情報に含まれる収集用宛先階層情報で示された第２の宛先階層下の既定の宛先、あるいは、該収集対象装置から収集登録要求で示した収集対象データのデータ名称一覧内のデータ名称に対応した第２の宛先階層下の宛先に、上記第４のステップで生成した該データ収集処理プログラムの処理結果データを送信する第８の処理結果データ送信ステップを含むことを特徴とするデータ収集処理プログラム。
【請求項５】
請求項１記載のデータ収集制御装置であって、
上記第２のデータ群用宛先割当て手段、及び、第６の収集用宛先割当て手段で、割当てる第１の宛先階層、及び、第２の宛先階層は、それぞれ、上記データ群登録要求、及び、収集登録要求に含まれる、データ群名称、及び、提供者名称を、宛先階層名称として割当てることを特徴とするデータ収集制御装置。
【請求項６】
請求項１記載のデータ収集制御装置であり、かつ、宛先により１つまたは複数の装置に分散された上記ブローカ手段を介して、収集対象装置、データ収集処理プログラム、データ収集制御装置間のデータ受渡しを行うデータ収集制御装置であって、
さらに、上記データ群登録要求に、該データ群の収集対象データを提供する提供者数を表す収集対象数情報を含み、
上記第２のデータ群用宛先割当て手段が、さらに、ブローカ手段毎の割当て済みデータ群の合計収集対象数情報をデータ群・ブローカ割当て管理情報として管理し、該データ収集制御装置に対して設定されたデータ群収集単位数情報を用いて、各ブローカ手段に割当てる合計収集対象数が該データ群収集単位数を超えないように各データ群用宛先階層割当てを行うことを特徴とするデータ収集制御装置。
【請求項７】
請求項１記載のデータ収集制御装置であり、かつ、宛先により１つまたは複数の装置に分散された上記ブローカ手段を介して収集対象装置、データ収集処理プログラム、データ収集制御装置間のデータ受渡しを行うデータ収集制御装置であって、
さらに、第６の収集用宛先割当て手段が、上記ブローカ手段毎の割当て済み合計収集対象数を収集・ブローカ割当て管理情報として管理し、該データ収集制御装置に対して設定された収集単位数情報を用いて、各ブローカ手段が中継する収集対象数が該収集単位数を超えないように各収集用宛先階層割り当てを行うことを特徴とするデータ収集制御装置。
【請求項８】
請求項７記載のデータ収集制御装置であって、
上記データ群登録要求に、収集対象データの提供間隔情報を含み、
上記第３のデータ群登録手段は、該提供間隔情報も含めてデータ群登録情報に設定し、
上記第６の収集用宛先割当て手段は、さらに、登録対象の収集対象データが属するデータ群のデータ群登録情報に含まれる収集対象データの提供間隔情報を参照し、該提供間隔情報から、該データ収集制御装置に対して設定された処理余裕時間を除いた時間を、上記収集単位数で割った値を用いて、登録要求のあった収集対象データの提供者からの収集対象データの提供タイミングを均等に割当て、
上記第７の収集登録手段が、該第６の手段で割当てた収集対象データの提供タイミング情報も含めて収集登録情報に設定することを特徴とするデータ収集制御装置。
【請求項９】
請求項８記載のデータ収集制御装置を用いたデータ収集システムにおける請求項２記載の収集対象装置であり、かつ、該収集対象装置が提供する収集対象データのデータ群登録要求を、該収集対象データの提供間隔情報を含んだ形で行い、該提供間隔情報を含んだ形で登録されたデータ群の収集対象装置であって、
上記第１２の収集データ送信手段は、第１１の収集登録情報取得手段が取得した収集登録情報に含まれる収集対象データの提供タイミング情報に従ったタイミングで収集対象データを送信することを特徴とする収集対象装置。
【請求項１０】
請求項８記載のデータ収集制御装置を用いたデータ収集システムにおける請求項３、または、請求項４記載のデータ収集処理プログラムであって、
上記第４の収集データ処理ステップは、上記第２のステップで取得した各収集登録情報に含まれる各収集対象データの提供タイミング情報を参照し、該提供タイミング情報に従い、各収集対象データの収集タイムアウト処理、及び、該データ収集処理プログラム内の他の処理が間に合うように収集した各収集対象データの処理のスケジューリングを行うことを特徴とするデータ収集処理プログラム。
【請求項１１】
請求項８記載のデータ収集制御装置を用いたデータ収集システムにおける請求項４記載のデータ収集処理プログラムであり、かつ、該データ収集処理プログラムが提供する処理結果の収集対象データのデータ群登録要求を、該収集対象データの提供間隔情報を含んだ形で行い、該提供間隔情報を含んだ形で登録されたデータ群のデータ収集処理プログラムであって、
上記第８の処理結果データ送信ステップは、第７の該処理プログラム用収集登録情報取得ステップが取得した収集登録情報に含まれる収集対象データの提供タイミング情報に従ったタイミングで処理結果データを送信することを特徴とするデータ収集処理プログラム。
【請求項１２】
請求項１記載のデータ収集システムにおいて、
請求項１、または、請求項５記載のデータ収集制御装置と、
請求項２記載の複数の収集対象装置と、
請求項３、または、請求項４記載のデータ収集処理プログラムと、
該データ収集制御装置と収集対象装置とデータ収集処理プログラム間のデータの受渡し行う上記ブローカ手段で構成したことを特徴とするデータ収集システム。
【請求項１３】
請求項１記載のデータ収集システムにおいて、
請求項６、または、請求項７記載のデータ収集制御装置と、
請求項２記載の複数の収集対象装置と、
請求項３、または、請求項４記載のデータ収集処理プログラムと、
該データ収集制御装置と収集対象装置とデータ収集処理プログラム間のデータの受渡しを、宛先により１つ、または、複数の装置に分散された上記ブローカ手段で構成したことを特徴とするデータ収集システム。
【請求項１４】
請求項１記載のデータ収集システムにおいて、
請求項８記載のデータ収集制御装置と、
請求項９記載の複数の収集対象装置と、
請求項１０、または、請求項１１記載のデータ収集処理プログラムと、
該データ収集制御装置と収集対象装置とデータ収集処理プログラム間のデータの受渡しを、宛先により１つ、または、複数の装置に分散された上記ブローカ手段で構成したことを特徴とするデータ収集システム。
【請求項１５】
請求項１、請求項５〜請求項８記載のいずれかのデータ収集制御装置の上記各手段を実現するプログラムであって、本発明のデータ収集制御装置で実行させるデータ収集制御プログラム。
【請求項１６】
請求項１５記載のデータ収集制御プログラムを記録したコンピュータ読取り可能な記録媒体。
【請求項１７】
請求項２、または、請求項９記載の収集対象装置の上記各手段を実現するプログラムであって、本発明の収集対象装置で実行させる収集対象装置プログラム。
【請求項１８】
請求項１７記載の収集対象装置プログラムを記録したコンピュータ読み取り可能な記録媒体。
【請求項１９】
請求項３、請求項４、請求項１０、または、請求項１１記載のデータ収集処理プログラムを記録したコンピュータ読み取り可能な記録媒体。
【発明の詳細な説明】
【技術分野】
【０００１】
本発明は、様々な装置から様々な形式を持つデータを収集し、収集したデータに対して、様々な処理を実行し、処理した結果をさらに別の処理の入力として処理するのに適したデータ収集制御装置、収集対象装置、データ収集処理プログラム、データ収集システム、データ収集制御プログラム、収集対象装置プログラム、及び、記録媒体に関する。
【背景技術】
【０００２】
近年、様々なセンサーや装置をInternet of Things（IoT)としてネットワークに接続し、該センサーや装置（以下、収集対象装置と呼ぶ）からデータを収集して、収集したデータに対して様々な解析処理を行い、該処理結果を様々な用途に活用することが可能なデータ収集システムの提供が要望されている。
【０００３】
また、該データ収集システムにおいては、様々な収集対象装置からデータを集め、処理をするため、収集対象装置の数が多くなっても、遅延なく、スケーラブルに処理できる必要ある。
【０００４】
データ収集システムにおいて、様々な収集対象装置から様々な形式を持つデータを収集し、収集したデータを処理する従来技術としては、下記特許文献１、２に示す方法がある。
【０００５】
下記特許文献１では、収集対象装置から収集したバイナリデータに対し、再帰構造を持つフォーマット定義を用いて、該バイナリデータを、名前を付けた標準データ形式に変換し、データ収集処理プログラムで処理する方法が開示されている。
【０００６】
また、下記特許文献２では、さらに、収集したデータを処理する複数のデータ収集処理プログラムに対応して、データ変換のための複数の変換テンプレートを用意し、データ収集処理プログラムに対応したデータ形式に変換して処理する方法が開示されている。
【０００７】
また、IoT向けの軽量な通信プロトコルとして、下記非特許文献１にてMQTTというプロトコルが開示されている。
【０００８】
該MQTTでは、階層化された宛先に送信されたメッセージを、該宛先を受信対象としているすべての受信者にブローカが中継する方法が開示されている。
【０００９】
さらに、データ収集システムにおいて、スケーラブルにデータを収集する従来技術としては、下記特許文献３に示す方法がある。
【００１０】
下記特許文献３では、データ収集処理プログラムが動作するデータ収集処理装置において、各収集対象装置から収集するファイルの件数、容量、収集必要日数情報をもとにして収集スケジューリング情報を自動作成し、該スケジューリング情報に従い、収集対象装置が、データ収集処理装置にファイルを転送する方法が開示されている。
【先行技術文献】
【特許文献】
【００１１】
【特許文献１】特開２００９−１６９７９８
【特許文献２】特開２０１１−１７５５７９
【特許文献３】特開２００５−２７５８４６
【非特許文献】
【００１２】
【非特許文献１】MQTT Version 3.1.1. Edited by Andrew Banks and Rahul Gupta. 29 September 2014. OASIS Standard. Latest version: http://docs.oasis-open.org/mqtt/mqtt/v3.1.1/mqtt-v3.1.1.html
【発明の概要】
【発明が解決しようとする課題】
【００１３】
背景技術で開示した特許文献１、及び、特許文献２の従来技術では、収集対象装置や、データ収集処理プログラムの数が少なく、該データ収集システムの管理者が把握し、該管理者が管理できる状況では、収集対象装置とデータ収集処理プログラムの組合せに対応して、該管理者がフォーマット定義や変換テンプレートを用意することが可能であるが、収集対象装置やデータ収集処理プログラムの種類が多くなると、組合せが爆発的に多くなり、収集対象装置と、データ収集処理プログラムの組合せに対応したフォーマット定義や変換テンプレートを該管理者が用意し、手動で管理することが困難であるという問題があった。
【００１４】
また、データ収集システム内にどういうフォーマット定義やテンプレートがあるかが外部からはわからないため、該システム管理者にフォーマット定義、テンプレートの設定を依頼しないと、新たなフォーマット定義やテンプレートの追加が外部からはできなかった。
【００１５】
従って、新たな装置からのデータ収集を追加したり、収集されたデータを該システム外のデータ収集処理プログラムで利用したり、新たなデータ収集処理プログラムを該システムに登録したり、該システムで収集したデータや、該システム内の既存のデータ収集処理プログラムの処理結果を、新たに追加したデータ収集処理プログラムの入力として利用することが簡単にはできなかった。
【００１６】
また、非特許文献１の従来技術であるMQTTでは、階層化した宛先を介し、ブローカ経由でデータの受渡しができるため、収集対象装置から、該ブローカ上のある宛先を介して、第１のデータ収集処理プログラムが収集対象データを収集して処理し、該第１のデータ収集処理プログラムの処理結果を該第１のデータ収集処理プログラムが第２の宛先に送信し、第２のデータ収集処理プログラムが該第２の宛先から該第１のデータ収集処理プログラムの処理結果を受信して処理することで、データ収集処理プログラムを追加し、収集したデータを次々と加工処理していくことが可能となるが、上記従来技術と同様、処理対象のデータがどの宛先にどのようなデータ形式で存在するかを事前に知っていないと新たなデータ収集処理プログラムを追加して処理することができないという問題があった。
【００１７】
また、特許文献３の従来技術によれば、収集タイミングの自動スケジューリング機能により、収集対象装置からのデータ収集負荷を分散させることが可能であるが、データ収集処理装置の管理者が、各収集対象装置のデータ件数、サイズ、収集日数情報をデータ収集制御装置に予め設定しておく必要があり、管理者の手間を煩わせることなく、負荷を分散させることができなかった。
【００１８】
さらに、特許文献３の従来技術で、収集タイミングを動的に分散させると、収集対象装置からの収集対象データがいつ揃うかがデータ収集処理プログラムからわからず、予め該データ収集処理プログラムに合わせたスケジューリングを組んでおかないと、該データ収集処理プログラムがいつ処理すればよいか自動で判断できないという問題があった。
【００１９】
また、特許文献３の従来技術では、１つのデータ収集処理装置内の収集タイミングは分散できるが、複数のデータ収集処理装置間で分散させることができなかった。
【００２０】
さらに、非特許文献１で示したMQTTを用いたデータ収集システムにおいて、一般的な負荷分散装置を用い、収集負荷などで、複数のブローカに中継先を分散させた場合、どのブローカにデータが分散送信されているかが該データを処理するデータ収集処理プログラムからわからず、振り分けられたブローカとデータ収集処理プログラムをペアーで動作させるなどの制約が課せられ、様々なデータ収集処理プログラムを組み合わせて処理するということが簡単にできなかった。
【００２１】
本発明の目的は、上記データ収集システムにおいて、様々な収集対象装置からのデータ収集を追加したり、該システムで収集したデータを様々なデータ収集処理プログラムで処理させたり、新たなデータ収集処理プログラムを本システムに登録し、該データ収集処理プログラムの処理結果を別のデータ収集処理プログラムの入力として処理させたりを、該システム管理者の介入なしで、外部から簡単に行えるようにすることにある。
【００２２】
また、収集対象装置が増えても、スケーラブルに収集処理が行え、かつ、様々なデータ収集処理プログラムからも、処理対象とするデータが、どこに、どのような形式で存在するかを把握して、処理対象のデータを自動で収集し、処理できるようにすることにある。
【課題を解決するための手段】
【００２３】
まず、本発明に関わるデータ収集システムは、収集対象でータを提供する収集対象装置と、データ収集処理装置上で動作し、収集対象装置の収集対象データや別のデータ収集処理プログラムの処理結果データを処理対象データとして処理するデータ収集処理プログラムと、該収集対象装置と該データ収集処理プログラム間、及び、データ収集処理プログラム間の収集対象データの受渡しを制御するデータ収集制御装置と、該収集対象装置、データ収集処理プログラム、データ収集制御装置間のデータの受渡しを中継するブローカ手段を持つブローカ装置で構成したシステムであって、データ提供者は、既定、あるいは、上記データ収集制御装置が指示した該ブローカ手段上の階層化された宛先にデータを送信し、データ受信者は、該宛先を受信対象としてブローカに指定し、該宛先に送信されてきたデータを、該宛先を受信対象と指定したすべてのデータ受信者に対して該ブローカが中継するデータ収集システムである。
【００２４】
上述の目的を達成する本発明の第１の態様であるデータ収集制御装置は、上記本発明に関わるデータ収集システムのデータ収集制御装置であって、該データ収集制御装置は、第１の既定の宛先を上記ブローカ手段に受信対象として設定し、収集対象データ群を定義するデータ群登録要求を該第１の宛先から受信する第１のデータ群登録要求受信手段と、受信したデータ群登録要求に対応し、該データ群用として、上記ブローカ手段の第１の宛先階層を割当て、後述の第５の収集登録要求受信手段と第８の収集登録情報提供手段に該データ群用宛先階層情報を伝えて、該データ群の収集対象データの収集要求のための収集登録要求の受信と、該収集登録要求の処理結果である収集登録情報の提供を行わせる、第２のデータ群用宛先割当て手段と、上記データ群登録要求に含まれる該収集対象データ群を識別するデータ群名称と、該収集対象データ群を構成するデータのデータ名称とデータタイプ情報を含むデータ形式情報と、該第２の手段で割当てた第１の該データ群用宛先階層情報を含む情報をデータ群登録情報として登録する第３のデータ群登録手段と、データ群登録要求に含まれるデータ群名称に対応した第２の宛先と、既定の第３の宛先を上記ブローカ手段に送信先として設定し、該第２の宛先に対して、上記第３の手段で登録されたデータ群登録情報を送付し、該第３の宛先に対して、登録済みの全データ群登録情報を送付して、該宛先に対する受信者に、特定のデータ群登録情報、及び、登録済みの全データ群登録情報を提供する第４のデータ群登録情報提供手段とを備え、さらに、上記第１のデータ群用宛先階層情報を上記第２の手段から受け、該第１の宛先階層下に既定の第４の宛先を上記ブローカ手段に受信対象として設定し、該第４の宛先から該データ群の収集対象データの収集登録要求を受信する第５の収集登録要求受信手段と、受信した収集登録要求に対応して、該収集対象データの送付先となる第２の収集用宛先階層の割当てを行う第６の収集用宛先割当て手段と、上記収集登録要求に含まれる、収集対象データの提供元を識別する提供者名称と、該収集対象データを構成するデータのデータ名称一覧と、該第６の手段で割当てた第２の収集用宛先階層情報を含む情報を収集登録情報として登録をする第７の収集登録手段と、上記第１のデータ群宛先階層情報を上記第２の手段から受け、該第１の階層下に、該データ群の収集対象データの収集登録要求に含まれる収集対象データ提供者名称に対応した第５の宛先と、既定の第６の宛先を送信先として設定し、該第５の宛先に対して、上記第７の手段で登録された収集登録情報を送付し、該第６の宛先に対して、該収集対象データ群の登録済み全収集登録情報を送付して、該宛先に対する受信者に、特定の収集登録情報、及び、登録済みの全収集登録情報を提供する第８の収集登録情報提供手段を具備するものである。
【００２５】
また、上述の目的を達成する本発明の第２の態様である収集対象装置は、上記本発明に関わるデータ収集システムの収集対象装置であり、上記第１の態様の上記データ群登録要求により上記データ収集制御装置に対して予め登録済みのデータ群の収集対象データを提供する収集対象装置であって、該収集対象装置から収集対象データの提供を開始する際、該収集対象装置は、該データ群名称に対応して上記データ収集制御装置が設定した第２の宛先を上記ブローカ手段に対して受信対象として設定し、該第２の宛先から該データ群のデータ群登録情報を取得する第９のデータ群登録情報取得手段と、該第９の手段で取得したデータ群登録情報に含まれる該データ群用宛先階層情報と既定の名称から得られる上記第１の階層下の第４の宛先に、該収集対象装置を識別する提供者名称と該収集対象装置から提供する収集対象データのデータ名称一覧を含む収集登録要求を送信する第１０の収集登録要求送信手段と、該第９の手段で取得したデータ群登録情報に含まれる該データ群用宛先階層情報と該収集対象装置を識別する上記提供者名称から得られる上記第１の階層下の第５の宛先を上記ブローカ手段に受信対象として設定し、該第５の宛先から該収集対象装置の収集登録情報を取得する第１１の収集登録情報取得手段と、該収集対象装置から収集対象データを提供する際、該第１１の手段で取得した該収集対象装置の収集登録情報に含まれる収集用宛先階層情報で示された第２の宛先階層下の既定の宛先、あるいは、該収集対象装置から収集登録要求で示した収集対象データのデータ名称一覧内のデータ名称に対応した第２の宛先階層下の宛先に、該収集対象データの送信を行う第１２の収集データ送信手段を具備するものである。
【００２６】
また、上述の目的を達成する本発明の第３の態様であるデータ収集処理プログラムは、上記本発明に関わるデータ収集システムのデータ収集処理プログラムであり、該データ収集処理プログラムは、上記第１の態様のデータ収集制御装置が設定した該データ収集処理プログラムが処理対象とする収集対象データ群を識別するデータ群名称に対応した上記第２の宛先を上記ブローカ手段に受信対象として設定し、該第２の宛先から該データ群のデータ群登録情報を取得する第１の処理対象データ群登録情報取得ステップと、該第１のステップで取得したデータ群登録情報に含まれる該データ群用宛先階層情報と既定の名称から得られる上記第１の階層下の第６の宛先を上記ブローカ手段に受信対象として設定し、該第６の宛先から該データ群の全収集登録情報を取得する第２の全収集登録情報取得ステップと、該第２のステップで取得した全収集登録情報の各収集登録情報に含まれる各収集用宛先階層情報から得られる第２の階層下の既定の宛先名称、あるいは、該収集登録情報に含まれるデータ一覧名称内のデータ名称に対応した第２の階層下の宛先を受信対象として上記ブローカ手段に設定し、該宛先から処理対象の収集対象データを取得する第３の処理対象データ取得ステップと、第１のステップで取得したデータ群登録情報に含まれる収集対象装置から取得する収集対象データのデータ形式情報に従って該第３のステップで取得したデータを解釈し、処理する第４の収集データ処理ステップを含むものである。
【００２７】
また、上述の目的を達成する本発明の第４の態様であるデータ収集処理プログラムは、上記第３の態様のデータ収集処理プログラムであり、上記第１の態様の上記データ群登録要求により上記データ収集制御装置に対して予め登録済みのデータ群の収集対象データを該データ収集処理プログラムの処理結果として提供するデータ収集処理プログラムであって、さらに、該データ収集処理プログラムは、該データ群を識別するデータ群名称に対応して上記データ収集制御装置が設定した第２の宛先を上記ブローカ手段に対して受信対象として設定し、該第２の宛先から該データ群のデータ群登録情報を取得する第５の該処理プログラム用データ群登録情報取得ステップと、該第５のステップで取得したデータ群登録情報に含まれる該データ群用宛先階層情報と既定の名称から得られる上記第１の階層下の第４の宛先に、該データ収集処理プログラムを識別する提供者名称と該データ収集処理プログラムが処理結果として提供する収集対象データのデータ名称一覧を含む収集登録要求を送信する第６の該処理プログラム用収集登録要求送信ステップと、該第５のステップで取得したデータ群登録情報に含まれる該データ群用宛先階層情報と該データ収集処理プログラムを識別する上記提供者名称から得られる上記第１の階層下の第５の宛先を上記ブローカ手段に受信対象として設定し、該第５の宛先から該データ収集処理プログラムの収集登録情報を取得する第７の該処理プログラム用収集登録情報取得ステップと、該第７のステップで取得した該データ収集処理プログラムの収集登録情報に含まれる収集用宛先階層情報で示された第２の宛先階層下の既定の宛先、あるいは、該収集対象装置から収集登録要求で示した収集対象データのデータ名称一覧内のデータ名称に対応した第２の宛先階層下の宛先に、上記第４のステップで生成した該データ収集処理プログラムの処理結果データを送信する第８の処理結果データ送信ステップを含むものである。
【００２８】
また、上述の目的を達成する本発明の第５の態様であるデータ収集制御装置は、第１の態様のデータ収集制御装置であって、上記第２のデータ群用宛先割当て手段、及び、第６の収集用宛先割当て手段で、割当てる第１の宛先階層、及び、第２の宛先階層は、それぞれ、上記データ群登録要求、及び、収集登録要求に含まれる、データ群名称、及び、提供者名称を、宛先階層名称として割当てるものである。
【００２９】
また、上述の目的を達成する本発明の第６の態様であるデータ収集制御装置は、第１の態様のデータ収集制御装置であり、かつ、宛先により１つまたは複数の装置に分散された上記ブローカ手段を介して、収集対象装置、データ収集処理プログラム、データ収集制御装置間のデータ受渡しを行うデータ収集制御装置であって、さらに、上記データ群登録要求に、該データ群の収集対象データを提供する提供者数を表す収集対象数情報を含み、上記第２のデータ群用宛先割当て手段が、さらに、ブローカ手段毎の割当て済みデータ群の合計収集対象数情報をデータ群・ブローカ割当て管理情報として管理し、該データ収集制御装置に対して設定されたデータ群収集単位数情報を用いて、各ブローカ手段に割当てる合計収集対象数が該データ群収集単位数を超えないように各データ群用宛先階層割当てを行うものである。
【００３０】
また、上述の目的を達成する本発明の第７の態様であるデータ収集制御装置は、第１の態様のデータ収集制御装置であり、かつ、宛先により１つまたは複数の装置に分散された上記ブローカ手段を介して収集対象装置、データ収集処理プログラム、データ収集制御装置間のデータ受渡しを行うデータ収集制御装置であって、さらに、第６の収集用宛先割当て手段が、上記ブローカ手段毎の割当て済み合計収集対象数を収集・ブローカ割当て管理情報として管理し、該データ収集制御装置に対して設定された収集単位数情報を用いて、各ブローカ手段が中継する収集対象数が該収集単位数を超えないように各収集用宛先階層割り当てを行うものである。
【００３１】
また、上述の目的を達成する本発明の第８の態様であるデータ収集制御装置は、第７の態様のデータ収集制御装置であって、上記データ群登録要求に、収集対象データの提供間隔情報を含み、上記第３のデータ群登録手段は、該提供間隔情報も含めてデータ群登録情報に設定し、上記第６の収集用宛先割当て手段は、さらに、登録対象の収集対象データが属するデータ群のデータ群登録情報に含まれる収集対象データの提供間隔情報を参照し、該提供間隔情報から、該データ収集制御装置に対して設定された処理余裕時間を除いた時間を、上記収集単位数で割った値を用いて、登録要求のあった収集対象データの提供者からの収集対象データの提供タイミングを均等に割当て、上記第７の収集登録手段が、該第６の手段で割当てた収集対象データの提供タイミング情報も含めて収集登録情報に設定するものである。
【００３２】
また、上述の目的を達成する本発明の第９の態様である収集対象装置は、第８の態様のデータ収集制御装置を用いたデータ収集システムの第２の態様の収集対象装置であり、かつ、該収集対象装置が提供する収集対象データのデータ群登録要求を、該収集対象データの提供間隔情報を含んだ形で行い、該提供間隔情報を含んだ形で登録されたデータ群の収集対象装置であって、上記第１２の収集データ送信手段は、第１１の収集登録情報取得手段が取得した収集登録情報に含まれる収集対象データの提供タイミング情報に従ったタイミングで収集対象データを送信するものである。
【００３３】
また、上述の目的を達成する本発明の第１０の態様であるデータ収集処理プログラムは、第８の態様のデータ収集制御装置を用いたデータ収集システムの第３、または、第４の態様のデータ収集処理プログラムであって、上記第４の収集データ処理ステップは、第２のステップで取得した各収集登録情報に含まれる各収集対象データの提供タイミング情報を参照し、該提供タイミング情報に従い、各収集対象データの収集タイムアウト処理、及び、該データ収集処理プログラム内の他の処理が間に合うように収集した各収集対象データの処理のスケジューリングを行うものである。
【００３４】
また、上述の目的を達成する本発明の第１１の態様であるデータ収集処理プログラムは、第８の態様のデータ収集制御装置を用いたデータ収集システムの第４の態様のデータ収集処理プログラムであり、かつ、該データ収集処理プログラムが提供する処理結果の収集対象データのデータ群登録要求を、該収集対象データの提供間隔情報を含んだ形で行い、該提供間隔情報を含んだ形で登録されたデータ群のデータ収集処理プログラムであって、上記第８の処理結果データ送信ステップは、第７の該処理プログラム用収集登録情報取得ステップが取得した収集登録情報に含まれる収集対象データの提供タイミング情報に従ったタイミングで処理結果データを送信するものである。
【００３５】
また、上述の目的を達成する本発明の第１２の態様であるデータ収集システムは、上記第１、または、第５の態様のデータ収集制御装置と、第２の態様の複数の収集対象装置と、第３、または、第４の態様のデータ収集処理プログラムと、該データ収集制御装置と収集対象装置とデータ収集処理プログラム間のデータの受渡し行う上記ブローカ手段で構成するものである。
【００３６】
また、上述の目的を達成する本発明の第１３の態様であるデータ収集システムは、上記第６、または、第７の態様のデータ収集制御装置と、第２の態様の複数の収集対象装置と、第３、または、第４の態様のデータ収集処理プログラムと、該データ収集制御装置と収集対象装置とデータ収集処理プログラム間のデータの受渡しを、宛先により１つ、または、複数の装置に分散された上記ブローカ手段で構成するものである。
【００３７】
また、上述の目的を達成する本発明の第１４の態様であるデータ収集システムは、上記第８の態様のデータ収集制御装置と、第９の態様の複数の収集対象装置と、第１０、第１１のデータ収集処理プログラムと、該データ収集制御装置と収集対象装置とデータ収集処理プログラム間のデータの受渡しを、宛先により１つ、または、複数の装置に分散された上記ブローカ手段で構成するものである。
【００３８】
また、上述の目的を達成する本発明の第１５の態様であるデータ収集制御プログラムは、上記第１、第５〜第８のいずれかの態様のデータ収集制御装置の上記各手段を実現する本発明のデータ収集制御装置で実行させるプログラムである。
【００３９】
また、上述の目的を達成する本発明の第１６の態様である記録媒体は、上記第１５のデータ収集制御プログラムを記録したコンピュータ読取り可能なものである。
【００４０】
また、上述の目的を達成する本発明の第１７の態様である収集対象装置プログラムは、第２、第９のいずれかの態様の収集対象装置の上記各手段を実現する本発明の収集対象装置で実行させるプログラムである。
【００４１】
また、上述の目的を達成する本発明の第１８の態様である記録媒体は、上記第１７のプログラムを記録したコンピュータ読取り可能なものである。
【００４２】
また、上述の目的を達成する本発明の第１９の態様である記録媒体は、第３、第４、第１０、第１１のデータ収集処理プログラムを記録したコンピュータ読取り可能なものである。
【００４３】
本発明の第１〜第５の態様のデータ収集制御装置、収集対象装置、データ収集処理プログラムを用いた第１２の態様のデータ収集システムによれば、上記データ群登録要求、収集登録要求を処理する手段を上記データ収集制御装置が提供しているので、該データ群登録要求、収集登録要求により、収集対象装置、データ収集処理プログラムを該データ収集システムの管理者の手を煩わせることなく、上記データ収集制御装置に対して、登録することが可能である。
【００４４】
また、該データ群登録要求に、収集対象装置、データ収集処理プログラムが提供する収集対象データ、処理結果データのデータ形式情報が含まれており、かつ、上記データ収集制御装置の第４のデータ群登録情報提供手段により、上記第３の宛先を介して、該データ形式情報を含んだデータ群登録情報として提供され、データ収集処理プログラムの第１のデータ群登録情報取得ステップで、該データ群登録情報を取得することが可能であり、各データ収集処理プログラムは、該データ群登録情報に含まれるデータ形式情報から、該処理対象データの一覧と、該処理対象データのデータ形式を自動的に認識して、上記第４の収集データ処理ステップにて処理することができる。
【００４５】
さらに、本発明の第６の態様のデータ収集制御装置を用いた第１３の態様のデータ収集システムによれば、該データ群登録要求に収集対象数情報を含み、かつ、データ群登録要求に対して、データ収集制御装置の第２のデータ群用宛先割当て手段が、ブローカ手段毎の割当て済み合計収集対象数を管理し、該データ収集制御装置に対して設定されたデータ群収集単位数情報を用いて、各ブローカ手段で中継する収集対象数が該データ群収集単位数を超えないように各データ群用宛先階層割当てを行い、該割当て結果を、データ収集制御装置の第４の手段により、上記データ群登録情報として収集対象装置、データ収集処理プログラムから参照可能としている。
【００４６】
収集対象装置、データ収集処理プログラムは、第９のデータ群登録情報取得手段、及び、第１、第５のデータ群登録情報処理ステップにて、該データ群登録情報を取得し、該データ群登録情報に含まれるデータ群用宛先階層情報に従い、続く第１０、第１１の手段、第２、第６、第７のステップにて、指定のデータ群用宛先階層下の宛先への収集登録要求の送信や、指定のデータ群用宛先階層下の宛先から収集登録情報を取得しているため、該収集登録要求、収集登録情報取得を、該宛先によりデータ群毎に複数のブローカ手段に分散させて処理できる。
【００４７】
また、本発明の第７の態様のデータ収集制御装置を用いた第１３の態様のデータ収集システムによれば、各収集登録要求に対して、データ収集制御装置の第６の収集用宛先割当て手段が、ブローカ手段毎の割当て済み合計収集対象数を管理し、該データ収集制御装置に対して設定された収集単位数情報を用いて、各ブローカ手段で中継する収集対象データ数が該収集単位数を超えないように各収集用宛先階層割当てを行い、該割当て結果を、データ収集制御装置の第８の手段により、上記収集登録情報として収集対象装置、データ収集処理プログラムから参照可能としている。
【００４８】
収集対象装置、データ収集処理プログラムは、第１１の収集登録情報取得手段、及び、第７の該処理プログラム用収集登録情報取得ステップにて、該収集登録情報を取得し、該収集登録情報に含まれる収集用宛先階層情報に従い、第１２の手段、第８のステップにて、指定の収集用宛先階層下の宛先に収集対象データ、処理結果データを送信しているため、複数の収集対象装置、データ収集処理プログラムから収集データの送信先を該宛先により複数のブローカ手段に分散させて処理できる。
【００４９】
また、データ収集処理プログラムは、第２のステップにて処理対象データ群の全収集登録情報を取得し、続く第３のステップにて、取得した各収集登録情報の収集用宛先階層情報に従い、該収集用宛先階層化の宛先から収集対象データを取得するため、複数のブローカ手段に分散された収集対象データを収集し処理できる。
【００５０】
さらに、本発明の第８の態様のデータ収集制御装置を用いた第１４の態様のデータ収集システムによれば、データ群登録要求に、収集対象データの提供間隔情報を含み、かつ、各収集登録要求に対して、データ収集制御装置の第６の収集用宛先割当て手段が該提供間隔情報を参照し、該提供間隔から、該データ収集制御装置に対して設定された処理余裕時間を除いた時間を、上記収集単位数で割った値を用いて、各ブローカ手段を経由する収集対象データの提供タイミングを均等に割当て、割当てた該提供タイミング情報を上記収集登録情報として、データ収集制御装置の第８の手段により、収集対象装置、データ収集処理プログラムから参照可能としている。
【００５１】
収集対象装置、データ収集処理プログラムは、第１１の収集登録情報取得手段、及び、第７の該処理プログラム用収集登録情報取得ステップにて、該収集登録情報を取得し、取得した該収集登録情報に含まれる該提供タイミング情報に従い、指定されたタイミングで、第１２の収集データ送信手段、及び、第８の処理結果データ送信ステップにて、指定の宛先に収集対象データ、処理結果データを送信することで、同一ブローカ手段で中継処理されるデータの時間的な集中を防ぎ、均等化することができる。
【００５２】
しかも、データ収集制御装置の第８の手段により提供される該提供タイミング情報を含む収集登録情報は、データ収集処理プログラムの第２の全収集登録情報取得ステップで取得され、第３の処理対象データ取得ステップにて、該提供タイミング情報から各収集対象データの提供タイミングを把握し、各収集対象データの収集タイムアウト処理や該データ収集処理プログラム内の他の処理が間に合うように、収集した各収集対象データに対する処理をスケジューリングすることができる。
【００５３】
なお、上述した各態様における、各手段は、一般的な情報処理装置上で動作するプログラムで実現してもよい。
【００５４】
また、ブローカ手段、データ収集処理プログラムは、データ収集制御装置とは別の装置上で動作する例を示したが、データ収集制御装置と同居してもよい。
【００５５】
また、上述した各態様における、上記ブローカ手段の階層化された宛先について、宛先をすべて文字列で記述し、宛先文字列の中で、送受信先のブローカ手段を区別できる形であっても、個々のブローカ手段のネットワークアドレス情報を、文字列による宛先記述の上位の宛先階層情報として扱い、ブローカ手段のネットワークアドレスと文字列による宛先記述をペアとした宛先情報であってもよい。
【発明の効果】
【００５６】
本発明のデータ収集制御装置、収集対象装置、データ収集処理プログラム、データ収集システム、データ収集制御プログラム、収集対象装置プログラム、及び、記録媒体によれば、上記データ群登録要求、収集登録要求を用いて、様々な収集対象装置やデータ収集処理プログラムをデータ収集システムの管理者の手間を煩わせることなく、登録することができる。
【００５７】
また、上記データ群登録要求に収集対象データや処理結果データのデータ形式情報が含まれているため、データ収集処理プログラムで、該データ形式情報を取得し、該データ形式情報を用い、処理対象データのデータ形式を自動的に判断して処理できるため、様々なデータ収集処理プログラムを追加し、かつ、該データ収集処理プログラムの処理結果を、さらに、別のデータ収集処理プログラムの入力とすることで、収集対象装置から取得した収集対象データに対して様々な処理を施し、様々な形のデータを得ることができる。
【００５８】
さらに、上記データ収集制御装置の第２のデータ群用宛先割当て手段により、データ群単位で、複数のブローカ手段にデータ中継処理を分散化することできる。
【００５９】
また、上記データ収集制御装置の第５の収集用宛先割当て手段により、データ群内の各収集対象データの中継を、複数のブローカ手段に分散化することができる。
【００６０】
さらに、上記第５の収集用宛先割当手段に割当てた提供タイミング情報により、同一のブローカ手段を介して中継される各収集対象装置、データ収集処理プログラムから提供される収集対象データ、処理結果データを、時間的に分散化させ、時間的な集中により、中継処理が遅延することを防止できる。
【００６１】
従って、収集対象データを提供する収集対象装置や、収集したデータを処理し、処理した結果を新たな収集対象データとして別のデータ収集処理プログラムに提供するデータ収集処理プログラムの数が増えてもスケーラブルに対応できる。
【００６２】
また、上記タイミング情報を用いて、データ収集処理プログラムが各処理対象データの取得タイムアウトや収集したデータの処理タイミングを自動的にスケジューリングでき、効率がよい収集処理を自動で実現できる。
【図面の簡単な説明】
【００６３】
【図１】本発明のデータ収集システムの一実施形態のシステム構成図である。
【図２】本発明のデータ収集制御装置の一実施形態の機能ブロック図、及び、本発明に関わるブローカ手段の宛先例を示す構成図である。
【図３】本発明のデータ群登録要求の具体例を示す構成図である。
【図４】本発明のデータ群登録情報の具体例を示す構成図である。
【図５】本発明の収集登録要求の具体例を示す構成図である。
【図６】本発明の収集登録情報の具体例を示す構成図である。
【図７】本発明のデータ収集制御装置のデータ群登録要求受信手段に対応した処理の一実施形態を示すフローチャート図である。
【図８】本発明のデータ収集制御装置のデータ群宛先割当て手段に対応した処理の一実施形態を示すフローチャート図である。
【図９】本発明のデータ収集制御装置のデータ群登録情報提供手段に対応した処理の一実施形態を示すフローチャート図である。
【図１０】本発明のデータ収集制御装置のデータ群登録手段に対応した処理の一実施形態を示すフローチャート図である。
【図１１】本発明のデータ収集制御装置の収集登録要求受信手段に対応した処理の一実施形態を示すフローチャート図である。
【図１２】本発明のデータ収集制御装置の収集用宛先割当て手段に対応した処理の一実施形態を示すフローチャート図である。
【図１３】本発明のデータ収集制御装置の収集登録手段に対応した処理の一実施形態を示すフローチャート図である。
【図１４】本発明のデータ収集制御装置の収集登録情報提供手段に対応した処理の一実施形態を示すフローチャート図である。
【図１５】本発明の収集対象装置の一実施形態の機能ブロック図、及び、本発明に関わるブローカ手段の宛先例を示す構成図である。
【図１６】本発明の収集対象装置のデータ群登録情報取得手段に対応した処理の一実施形態を示すフローチャート図である。
【図１７】本発明の収集対象装置の収集登録要求送信手段に対応した処理の一実施形態を示すフローチャート図である。
【図１８】本発明の収集対象装置の収集登録情報取得手段に対応した処理の一実施形態を示すフローチャート図である。
【図１９】本発明の収集対象装置の収集データ送信手段に対応した処理の一実施形態を示すフローチャート図である。
【図２０】本発明のデータ収集処理プログラムの一実施形態の機能ブロック図、及び、本発明に関わるブローカ手段の宛先例を示す構成図である。
【図２１】本発明のデータ収集処理プログラムの処理対象データ群登録情報取得ステップの一実施形態を示すフローチャート図である。
【図２２】本発明のデータ収集処理プログラムの処理対象データ群の全収集登録情報取得ステップの一実施形態を示すフローチャート図である。
【図２３】本発明のデータ収集処理プログラムの処理対象データ取得ステップの一実施形態を示すフローチャート図である。
【図２４】本発明のデータ収集処理プログラムの収集データ処理ステップの一実施形態を示すフローチャート図である。
【図２５】他のデータ収集処理プログラムに処理結果を提供する本発明のデータ収集処理プログラムの一実施形態の機能ブロック図、及び、本発明に関わるブローカ手段の宛先例を示す構成図である。
【図２６】本発明の図２５のデータ収集処理プログラムの該処理プログラム用データ群登録情報取得ステップの一実施形態を示すフローチャート図である。
【図２７】本発明の図２５のデータ収集処理プログラムの該処理プログラム用収集登録要求送信ステップの一実施形態を示すフローチャート図である。
【図２８】本発明の図２５のデータ収集処理プログラムの該処理プログラム用収集登録情報取得ステップの一実施形態を示すフローチャート図である。
【図２９】本発明の図２５のデータ収集処理プログラムの処理結果データ送信ステップの一実施形態を示すフローチャート図である。
【図３０】１つ、または、複数のブローカ手段で構成した本発明のデータ収集システムの一実施形態のシステム構成図である。
【図３１】データ群でブローカ手段を分散化する本発明のデータ収集制御装置の一実施形態の機能ブロック図である。
【図３２】本発明の図３１のデータ収集制御装置で使用されるデータ群登録要求の具体例を示す構成図である。
【図３３】本発明の図３１のデータ収集制御装置のデータ群・ブローカ割当て管理情報の具体例を示す構成図である。
【図３４】本発明の図３１のデータ収集制御装置のデータ群用宛先割当て手段の宛先階層割当て処理の一実施形態を示すフローチャート図である。
【図３５】本発明の図３１のデータ収集制御装置のデータ群用宛先割当て手段が生成するデータ群用宛先階層情報の具体例を示す構成図である。
【図３６】収集登録毎にブローカ手段を分散化する本発明のデータ収集制御装置の一実施形態の機能ブロック図である。
【図３７】本発明の図３６のデータ収集制御装置の収集・ブローカ割当て管理情報の具体例を示す構成図である。
【図３８】本発明の図３６のデータ収集制御装置の収集用宛先割当て手段の宛先階層割当て処理の一実施形態を示すフローチャート図である。
【図３９】本発明の図３６のデータ収集制御装置で収集用宛先割当て手段が生成する収集用宛先階層情報の具体例を示す構成図である。
【図４０】収集登録毎にブローカ手段のデータ収集タイミングを分散化させる本発明のデータ収集制御装置の機能ブロック図である。
【図４１】本発明の図４０のデータ収集制御装置で使用されるデータ群登録要求の具体例を示す構成図である。
【図４２】本発明の図４０のデータ収集制御装置で使用されるデータ群登録情報の具体例を示す構成図である
【図４３】本発明の図４０のデータ収集制御装置のデータ群登録手段に対応した処理の一実施形態を示すフローチャートである
【図４４】本発明の図４０のデータ収集制御装置の収集登録情報の具体例を示す構成図である。
【図４５】本発明の図４０のデータ収集制御装置の収集用宛先割当て手段に対応した処理の一実施形態を示すフローチャート図である。
【図４６】本発明の図４０のデータ収集制御装置の収集登録手段に対応した処理の一実施形態を示すフローチャート図である。
【図４７】本発明の図４０のデータ収集制御装置に対応したデータ収集処理プログラムの収集データ処理ステップ送信手段の一実施形態を示すフローチャート図である。
【図４８】本発明の図４０のデータ収集制御装置に対応したデータ収集処理プログラムの収集データ処理ステップの一実施形態を示すフローチャート図である。
【図４９】本発明の図４０のデータ収集制御装置に対応したデータ収集処理プログラムの処理結果データ送信ステップの一実施形態を示すフローチャート図である。
【図５０】本発明のデータ収集制御装置、収集対象装置、データ収集処理プログラムが動作する収集データ処理装置、ブローカ手段を具備するブローカ装置の物理的な一実施形態を示す情報処理装置の構成ブロック図である。
【発明を実施するための形態】
【００６４】
以下、本発明のデータ収集制御装置、収集対象装置、データ収集処理プログラム、データ収集システム、データ収集制御プログラム、収集対象装置プログラム、及び、記録媒体を実施するための形態例について、図面に基づき説明する。
【００６５】
（実施形態１）
図１に本発明のデータ収集制御装置、収集対象装置、データ収集処理プログラム、データ収集システム、データ収集制御プログラム、収集対象装置プログラム、及び、記録媒体を適用する本発明のデータ収集システムの一構成例を示す。
【００６６】
本発明のデータ収集システムは、収集対象データ１２０を提供する収集対象装置５２と、データ収集処理装置８３上で動作し、収集対象装置５２の収集対象データ１２０や別のデータ収集処理プログラム５３の処理結果データ１２０Ｐｋを処理対象データとして収集し、処理するデータ収集処理プログラム５３と、該収集対象装置５２と該データ収集処理プログラム５３間、及び、データ収集処理プログラム５３間の収集対象データの受渡しを制御するデータ収集制御装置５１と、該収集対象装置５２、データ収集処理プログラム５３、データ収集制御装置５１間のデータの受渡しを中継するブローカ手段５４を持つブローカ装置８４で構成する。
【００６７】
本発明のデータ収集システムでは、データ提供者は、既定、あるいは、上記データ制御装置が指示した該ブローカ手段上の階層化された宛先にデータを送信し、データ受信者は、該宛先を受信対象としてブローカに指定し、該宛先に送信されてきたデータを、該宛先を受信対象と指定したすべてのデータ受信者に対して該ブローカが中継する。
【００６８】
該データ収集システムのブローカ手段５４は、例えば、上記従来技術で示したMQTTプロトコルを中継するためのブローカで、データ提供者がブローカ装置８４上のある宛先４００にデータを送信すると、該宛先４００を受信対象として該ブローカ装置８４のブローカ手段５４に対して指定した全データ受信者に対して、該宛先に送信されてきたデータを該ブローカ手段５４が中継する。
【００６９】
本発明のデータ収集制御装置５１は、収集対象装置５２の収集対象データ１２０、及び、データ収集処理プログラム５３の処理結果データを収集対象データ１２０として、同種の収集対象データ１２０をデータ群として定義登録するデータ群登録機能と、
該データ群登録機能により定義されたデータ群の収集対象データ１２０を提供する収集対象装置５２、データ収集処理プログラム５３からのデータ収集を登録し、該収集対象装置５２、データ収集処理プログラム５３が提供する該収集対象データ１２０を第２のデータ収集処理プログラム５３で収集処理してもらうための収集登録機能を提供する。
【００７０】
該データ群登録は、データ群登録要求１００を用いて、該データ収集制御装置５１に対して行い、該データ群登録要求１００の登録結果を、データ群登録情報１０１、全データ群登録情報１０２として取得できる機能をデータ収集制御装置５１が提供する。
【００７１】
また、上記収集登録は、収集登録要求１１０を用いて、該データ収集制御装置５１に対して行い、該収集登録要求１１０の登録結果を、収集登録情報１１１、全収集登録情報１１２として取得できる機能をデータ収集制御装置５１が提供する。
【００７２】
データ群登録要求１００は、データ収集制御装置５１に対して手動で実施するが、登録されたデータ群登録情報１０１、１０２の取得、収集登録要求１１０の送信、収集登録情報１１１、１１２の取得は、各収集対象処理装置５２、各データ収集処理プログラム５３が自動で実行し、該登録要求、登録情報の取得よって得られる情報に基づいて、各収集対象処理装置５２、各データ収集処理プログラム５３がデータ送受信先のブローカ手段５４の宛先４００を切替え、該宛先を介して、収集対象データ１２０の受渡しを行う。
【００７３】
また、データ収集処理プログラム５４は、上記データ群登録情報１１１により、収集対象データのデータ形式などを知り、自動で収集対象データに対するアクセスや処理を調整して、収集対象データ１２０に対する収集、処理を実施する。
【００７４】
該データ収集システムによると、上記データ収集制御装置５１が提供するデータ群登録機能、収集登録機能により、様々な収集対象装置５２の収集対象データ１２０を、収集対象として追加登録し、かつ、追加登録された収集対象データ１２０を様々なデータ収集処理プログラム５３で処理し、さらに、データ収集処理プログラム５３で処理した収集対象データ１２０の処理結果を、さらに、別データ収集処理プログラム５３の入力として処理でき、様々な収集対象データ１２０を様々に加工処理して利用することが可能となる。
【００７５】
以下、本実施形態のデータ収集システムにおける、本発明のデータ収集制御装置５１、収集対象装置５２、データ収集処理プログラム５３の実施形態の一例を説明する。
【００７６】
（実施形態２）
まず、上記実施形態１のデータ収集システムにおける本発明のデータ収集制御装置５１の実施形態を説明する。
【００７７】
図２は、本発明のデータ収集制御装置５１の一実施形態のブロック図と、データの受渡しのためのブローカ手段５４の宛先の具体的な構成例を示す
本発明のデータ収集制御装置５１は、データ群登録要求受信手段１と、データ群用宛先階層割当て手段２と、データ群登録手段３と、データ群登録情報提供手段４と、データ群登録情報１０１を保持するデータ群登録情報データベース２１と、収集登録要求受信手段５と、収集用宛先割当て手段６と、収集登録手段７と、収集登録情報提供手段８と、収集登録情報１１１を保持する収集登録情報データベース２２を備える。
【００７８】
また、図３、図４、図５、図６に、該データ収集制御装置５１が、収集対象装置５２、データ収集処理プログラム５３との間で受渡しをするデータ群登録要求１００、データ群登録情報１０１／全データ群登録情報１０２、収集登録要求１１０、収集登録情報１１１／全収集登録情報１１２の具体的な構成例を示す。
【００７９】
データ群登録要求１００は、例えば、データ群Ｘ用の登録要求１００Ｘの場合、図３に示すとおり、該データ群を識別するデータ群名称１００１Ｘと、該データ群の概要情報１００２Ｘと、該データ群の収集対象データを構成する各データのデータ名称１００３１、データタイプ情報１００３２を含むデータ形式情報１００３Ｘを含む。
【００８０】
データ群登録情報１０１は、例えば、データ群Ｘ用のデータ群登録情報１０１Ｘの場合、図４に示すとおり、例えば、データ群登録要求１００Ｘに含まれる該データ群を識別するデータ群名称１０１１Ｘと、該データ群の概要情報１０１２Ｘと、該データ群の収集対象データを構成する各データのデータ形式情報１０１３Ｘに加え、本発明のデータ群用宛先割当て手段２が該データ群登録要求に対して割当てた該データ群用宛先階層情報１０１４Ｘを含む。
【００８１】
また、全データ群登録情報１０２は、図４に示すとおり、登録済みの全データ群登録情報１０１で構成する。
【００８２】
収集登録要求１１０は、例えば、データ群Ｘのデータ提供者Ｘｋの収集登録要求１１０Ｘｋの場合、図５に示すとおり、該データ群Ｘの収集対象データの提供者を識別するデータ提供者名称１１０１Ｘｋと、該データ提供者の概要情報１１０２Ｘｋと、該提供者から提供する収集対象データを構成するデータ名称一覧１１０３Ｘｋを含む。
【００８３】
データ提供者名称１１０１Ｘは、収集対象装置５２が収集対象データ１２０の提供者となる場合は、例えば、該収集対象装置５２をユニークに識別可能な装置名称などを設定する。
【００８４】
データ収集処理プログラム５３が、該データ収集処理プログラム５３の処理結果を、別のデータ収集処理プログラム５３の収集対象データとして提供する場合は、データ提供者名称１１０１Ｘとして、例えば、該データ収集処理プログラム５３をユニークに識別するプログラム名称などを設定する。
【００８５】
収集登録情報１１１は、例えば、データ群Ｘのデータ提供者Ｘｋの収集登録情報１１１Ｘｋの場合、図６に示すとおり、収集登録要求１１０Ｘｋに含まれる該提供者を識別するデータ提供者名称１１１Ｘｋと、該データ提供者の概要情報１１１２Ｘｋと、データ名称一覧１１１３Ｘｋに加え、本発明の収集用宛先割当て手段５が該収集登録要求に対して割当てた該収集用宛先階層情報１１１４Ｘｋを含む。
【００８６】
また、全収集登録情報１１２は、図６に示すとおり、登録済みの収集登録情報１１１で構成する。
【００８７】
以下、本発明のデータ収集制御装置５１が具備する各手段の詳細を説明する。
【００８８】
本発明のデータ収集制御装置５１が具備するデータ群登録要求受信手段１はデータ群登録要求１００を受信する手段である。
【００８９】
該データ群登録要求受信手段１に対応した処理の一実施形態のフローチャートを図７に示す。
【００９０】
該データ群登録要求受信手段１は、まず、ブローカ手段５４に対して、データ群登録要求用の宛先４０１を受信対象として設定する。（処理５０１１）
【００９１】
図２の例では、「GrpRegReq」という既定の宛先を該データ群登録要求宛先４０１として、設定する。
【００９２】
次に、新たなデータ群登録要求１００が該宛先４０１に到着すると、ブローカ手段５４から通知を受け、該宛先４０１に新たに到着したデータ群登録要求１００を、ブローカ手段５４を介して該宛先４０１から受信することで、本手段によるデータ群登録要求の受信処理を実現する。（処理５０１２）
【００９３】
本発明のデータ収集制御装置５１が具備するデータ群用宛先割当て手段２は、データ群登録要求１００に対して、該データ群用のデータの受渡しのためのブローカ手段５４上のデータ群用宛先階層を割当てる手段である。
【００９４】
該データ群用宛先割当て手段２による処理は、上記データ群登録要求受信手段１によるデータ群登録要求１００受信に引続いて実行される。
【００９５】
データ群Ｘのデータ群登録要求１００Ｘに対する該データ群用宛先割当て手段２に対応した処理の一実施形態のフローチャートを図８に示す。
【００９６】
該データ群用宛先割当て手段２は、まず、データ群登録要求１００Ｘに対応して、該データ群用の宛先階層４１０Ｘを割当てる。
【００９７】
具体的には、図２の例に示すとおり、例えば、データ群登録要求１００Ｘに含まれるデータ群名称１００１Ｘに対応した「データ群Ｘ」という宛先階層を該データ群用宛先階層４１０Ｘとして割当てる。（処理５０２１）
【００９８】
次に、前処理で割当てたデータ群用宛先階層４１０Ｘを、収集登録要求受信手段５と収集登録情報提供手段８に通知し、該データ群データの収集登録要求１１０Ｘｋの受信処理と登録結果の収集登録情報１１１Ｘｋ／１１２Ｘｋの提供を開始し、本データ群用宛先割当て手段２による処理を終了する。（処理５０２２）
【００９９】
本発明のデータ収集制御装置５１が具備するデータ群登録手段３は、データ群登録要求１００に対して、該登録要求の処理結果であるデータ群登録情報１０１を作成し、データ群登録情報データベース２１登録する手段である。
【０１００】
該データ群登録手段３による処理は、上記データ群宛先割当て手段２によるデータ群用宛先階層割当て処理に引続いて実行される。
【０１０１】
データ群Ｘのデータ群登録要求１００Ｘに対する該データ群登録手段３に対応した処理の一実施形態のフローチャートを図９に示す。
【０１０２】
該データ群登録手段３は、まず、データ群登録要求１００に対応して、該データ群登録要求１００に含まれるデータ群名称１００１Ｘ、データ群の概要１００２Ｘ、データ形式情報１００３Ｘを、そのまま、データ群名称１０１１Ｘ、データ群の概要１０１２Ｘ、データ形式情報１０１３Ｘとしてデータ群登録情報１０１Ｘに含めると共に、さらに、上記データ群宛先割当て手段２で割当てた該データ群用のデータ群宛先階層情報１０１４Ｘを含むデータ群登録情報１０１Ｘを作成する。（処理５０３１）
【０１０３】
次に、前処理で作成したデータ群登録情報１０１Ｘをデータ群登録情報データベース２１に登録し、本データ群登録手段３による処理を終了する。（処理５０３２）
【０１０４】
本発明のデータ収集制御装置５１が具備するデータ群登録情報提供手段４は、データ群登録要求１００の処理結果のデータ群登録情報１０１／１０２を、収集対象装置５２、データ収集処理プログラム５３に提供する手段である。
【０１０５】
該データ群登録情報提供手段４による処理は、上記データ群登録手段３によるデータ群登録情報１０１の作成、登録処理に引続いて実行される。
【０１０６】
データ群Ｘのデータ群登録要求１００Ｘに対するデータ群登録情報提供手段４に対応した処理の一実施形態のフローチャートを図１０に示す。
【０１０７】
該データ群登録情報提供手段４は、上記データ群登録手段３で生成したデータ群登録情報１０１Ｘを、ブローカ手段５４のデータ群Ｘ用のデータ群登録情報提供宛先４０２Ｘに送信する。（処理５０４１）
【０１０８】
データ群Ｘ用のデータ群登録情報提供宛先４０２Ｘは、例えば、データ群登録要求１００Ｘに含まれるデータ群名称１００１Ｘに対応した宛先名称を使用する。
【０１０９】
図２の例では、例えば、「GrpRegInfo/」という既定の階層名に、該データ群Ｘのデータ群名称である「データ群Ｘ」という名称を加えた宛先をデータ群Ｘ用のデータ登録情報提供宛先４０２Ｘとして使用している。
【０１１０】
次に、データ群登録情報提供手段４は、データ群登録情報データベース２１に登録された全データ群登録情報１０２を、ブローカ手段５４の全データ群登録情報提供宛先４０３に送信し、本データ群登録情報提供手段４の処理を終了する。（処理５０４２）
【０１１１】
全データ群登録情報提供宛先４０３は、既定の宛先を使用し、図２の例では、例えば、「GrpRegInfo/All_Reg」という宛先を全データ群登録情報提供宛先４０３として使用している。
【０１１２】
本発明のデータ収集制御装置５１が具備する収集登録要求受信手段５は、収集登録群要求１１０を受信する手段である。
【０１１３】
データ群Ｘの収集対象データの収集登録要求１１０Ｘｋに対する該収集登録要求受信手段５に対応した処理の一実施形態のフローチャートを図１１に示す。
【０１１４】
該収集登録要求受信手段５は、まず、上記データ群登録要求１００Ｘに対応して上記手段２で割当てたデータ群Ｘ用の宛先階層情報４１０Ｘを上記データ群用宛先割当て手段２から取得する。(処理５０５１)
次に、前処理で取得したデータ群Ｘ用の宛先階層４１０Ｘの下に該データ群Ｘ向けの収集登録要求用の宛先４１１Ｘを作成し、ブローカ手段５４に対して、該収集登録用宛先４１１を受信対象として設定し、該データ群Ｘに対する収集登録要求の受付を開始する。（処理５０５２）
【０１１５】
図２の例では、例えば、「データ群Ｘ/」をデータ群Ｘ用宛先階層４１０Ｘとし、該宛先階層４１０Ｘの下に「CollectReq」という既定の名称で、該データ群Ｘ向けの収集登録要求用の宛先４１１Ｘと設定している。
【０１１６】
次に、データ群Ｘの新たな収集登録要求１１０Ｘｋが該宛先４１１Ｘに到着すると、ブローカ手段５４から通知を受け、該宛先４１１Ｘから、新たに到着した収集登録要求１１０Ｘｋを、ブローカ手段５４を介して受信することで、本手段による収集登録要求１１０Ｘｋの受信処理を実現する。（処理５０５３）
【０１１７】
本発明のデータ収集制御装置５１が具備する収集用宛先割当て手段６は、収集登録要求１１０に対して、該収集登録要求１１０の要求者からの収集対象データ１２０の収集を行うためのブローカ手段５４上の収集用宛先階層４２０を割当てる手段である。
【０１１８】
該収集用宛先割当て手段６による処理は、上収集登録要求受信手段５による収集登録要求１１０受信に引続いて実行される。
【０１１９】
データ群Ｘの収集対象データの収集登録要求１１０Ｘｋに対する該収集用宛先割当て手段６に対応した処理の一実施形態のフローチャートを図１２示す。
【０１２０】
該収集用宛先割当て手段６は、収集用登録要求１１０Ｘｋに対応して、収集用宛先階層４２０Ｘｋを割当てる。（処理５０６１）
【０１２１】
具体的には、図２の例に示すとおり、例えば、データ群Ｘの装置ｋからの収集登録要求Ｘｋの場合、データ群Ｘ用の宛先階層「データ群Ｘ/」４１０Ｘの下に、収集登録要求１１０Ｘｋに含まれる提供者名称１１０１Ｘｋに対応した「装置ｋ/」という宛先階層を該収集用宛先階層４２０Ｘｋとして割当てる。
【０１２２】
本発明のデータ収集制御装置５１が具備する収集登録手段７は、収集登録要求１１０に対して、該登録要求の処理結果である収集登録情報１１１を作成し、収集登録情報データベース２２登録する手段である。
【０１２３】
該収集登録手段７による処理は、上記収集用宛先割当て手段６による収集用宛先階層割当て処理に引続いて実行される。
【０１２４】
データ群Ｘの収集対象データの収集登録要求１１０Ｘｋに対する該収集登録手段７に対応した処理の一実施形態のフローチャートを図１３に示す。
【０１２５】
該収集登録手段７は、まず、収集登録要求１１０Ｘｋに対応して、該収集登録要求１１０Ｘｋに含まれる提供者名称１１０１Ｘｋ、データ提供者の概要１１０２Ｘｋ、データ形式情報１１０３Ｘｋを、そのまま、提供者名称１１１１Ｘｋ、データ提供者の概要１１１２Ｘｋ、データ形式情報１１１３Ｘｋとして、収集登録情報１１１Ｘｋに含めると共に、さらに、上記収集用宛先割当て手段６で割当てた収集用群宛先階層情報１１１４Ｘｋを含む収集登録情報１１１Ｘｋを作成する。（処理５０７１）
【０１２６】
次に、前処理で作成した収集登録情報１１１Ｘｋを収集登録情報データベース２２に登録し、本収集登録手段７による処理を終了する。（処理５０７２）
【０１２７】
本発明のデータ収集制御装置５１が具備する収集登録情報提供手段８は、収集登録要求１１０の処理結果の収集登録情報１１１／１１２を、収集対象装置５２、データ収集処理プログラム５３に提供する手段である。
【０１２８】
該収集登録情報提供手段８による処理は、上記収集登録手段７による収集登録情報１１１の作成、登録処理に引続いて実行される。
【０１２９】
データ群Ｘの収集対象データの収集登録要求１１０Ｘｋに対する収集登録情報提供手段８に対応した処理の一実施形態のフローチャートを図１４に示す。
【０１３０】
該収集登録情報提供手段８は、上記収集登録手段７で生成した収集登録情報１１１Ｘｋを、ブローカ手段５４の収集登録情報提供宛先４１２Ｘｋに送信する。（処理５０８１）
【０１３１】
収集登録情報提供宛先４１２Ｘｋは、例えば、収集登録要求１１０Ｘｋに含まれる提供者名称１１０１Ｘに対応した宛先名称を使用する。
【０１３２】
図２の例では、例えば、データ群Ｘの装置ｋからの収集登録要求Ｘｋの場合、データ群Ｘ用の宛先階層「データ群Ｘ/」４１０Ｘの下の既定名称階層「CollectInfo/」の下に、収集登録要求１１０Ｘｋに含まれる提供者名称１１０１Ｘｋに対応した「装置ｋ」という宛先を収集登録情報提供宛先４１２Ｘｋとして使用している。
【０１３３】
次に、収集登録情報提供手段８は、収集登録情報データベース２２に登録されたデー亜群Ｘの全収集登録情報１１２Ｘを、ブローカ手段５４のデータ群Ｘ用の全収集登録情報提供宛先４１３Ｘに送信し、本収集登録情報提供手段８の処理を終了する。（処理５０８２）
【０１３４】
データ群Ｘの全収集登録情報提供宛先４１３Ｘは、データ群Ｘ用の宛先階層４１１Ｘの下の既定の宛先を使用し、図２の例では、例えば、「データ群Ｘ/All_Reg」という宛先を全収集登録情報提供宛先４１３Ｘとして使用している。
【０１３５】
なお、上記実施形態の収集登録情報提供手段８では、収集登録情報データベース２２に登録されたデータ群Ｘの全収集登録情報１１２Ｘをそのまま全収集登録情報提供宛先４１３Ｘに送信する例を示しているが、最終的に受信者が全収集登録情報１１２Ｘに変換できる情報であれば、どのような形でデータを送信してもよい。
【０１３６】
例えば、毎回全収集登録情報１１２Ｘを送信するのではなく、データ群Ｘの全データ収集登録情報１１２Ｘの送付は、一定周期毎にし、該周期間の収集登録要求１１０Ｘｋに対しては、追加した収集登録情報１１１Ｘｋだけを差分情報として送付する形としてもよい。
【０１３７】
また、宛先を分けて、１つの宛先に一定周期時刻毎に該周期毎のスナップショットのデータ群Ｘの全データ収集登録情報１１２Ｘを送信し、もう1つの宛先に、該周期間の収集登録要求１１０Ｘｋに対する収集登録情報１１１Ｘｋを差分情報として送信してもよい。
【０１３８】
本実施形態のデータ収集制御装置５１によると、上記データ群登録要求受信手段１、データ群用宛先階層割当て手段２、データ群登録手段３、データ群登録情報提供手段４により、上記データ収集システムのデータ群登録機能を実現でき、上記収集登録要求受信手段５、収集用宛先階層割当て手段６、収集登録手段７、収集登録情報提供手段８により、上記データ収集システムの収集登録機能を実現できる。
【０１３９】
従って、様々な収集対象装置５２の収集対象データ１２０を追加登録し、登録された収集対象データを様々なデータ収集処理プログラム５３で処理し、さらに、該データ収集処理プログラム５３の処理結果を別のデータ収集処理プログラム５３の入力として、様々な収集対象データ１２０を入力とし、該収集対象データ１２０対して、様々な処理を施し、様々な用途に利用することが可能となる。
【０１４０】
また、データ収集制御装置５１で、データ群毎や収集登録毎に、ブローカ手段５４の宛先を切替えることができるため、障害時のリダイレクトや、負荷分散が可能となる。
【０１４１】
（実施形態３）
次に上記実施形態２の本発明のデータ収集制御装置５１に対応した、本発明の収集対象装置５２の一実施形態を説明する。
【０１４２】
図１５は、上記データ収集制御装置５１に対応した本発明の収集対象装置５２の一実施形態のブロック図と、データの受渡しのためのブローカ手段５４の宛先の具体的な構成例を示す。
【０１４３】
本発明の収集対象装置５２は、データ群登録情報取得手段９と、収集登録要求送信手段１０と、収集登録情報取得手段１１と、収集データ送信手段１２を備える。
【０１４４】
以下、本発明の収集対象装置５２が具備する各手段の詳細を説明する。
【０１４５】
本発明の収集対象装置５２が具備するデータ群登録情報取得手段９は、該収集対象装置５２が属するデータ群のデータ群登録情報１０１を取得する手段である。
【０１４６】
データ群Ｘに属する収集対象装置５２の該データ群登録情報取得手段９に対応した処理の一実施形態のフローチャートを図１６に示す。
【０１４７】
該データ群登録情報取得手段９は、まず、自装置が所属するデータ群Ｘ用のデータ群登録情報提供宛先４０２Ｘをブローカ手段５４に対して、受信対象として設定する。（処理５０９１）
【０１４８】
データ群登録情報提供宛先４０２Ｘは、図１５の例では、上記データ収集制御装置５１のデータ群登録情報提供手段４が設定した宛先と同様に、既定の宛先階層「GrpRegInfo/」に、該データ群の名称「データ群Ｘ」を加えた宛先名称を使用している。
【０１４９】
既にデータ群Ｘのデータ群登録要求１００Ｘが上記データ収集制御装置５１に対して実行されている場合、上記データ収集制御装置５１のデータ群登録情報提供手段４より、データ群登録情報１０１Ｘが該データ群登録情報提供宛先４０２Ｘに対して送付されている。
【０１５０】
既にデータ群Ｘのデータ群登録情報１０１Ｘが該データ群登録情報提供宛先４０２Ｘに送付されている状態で、上記処理にてデータ群登録情報提供宛先４０２Ｘに対して受信対象とブローカ手段５４に設定すると、該ブローカ手段５４は、受信済みのデータ群Ｘのデータ群登録情報１０１Ｘを、該宛先４０２Ｘを受信設定した該収集対象装置５２に中継する。
【０１５１】
該データ群登録情報受信手段９は、該ブローカ手段５４から中継された該データ群Ｘのデータ群登録情報１０１Ｘを、該ブローカ手段５４の該データ群登録情報提供宛先４０２Ｘから受信し、本データ群登録情報取得手段９による取得処理を終了する。（処理５０９２）
【０１５２】
本発明の収集対象装置５２が具備する収集登録要求送信手段１０は、該収集対象装置５２からの収集対象データの収集を登録するための収集登録要求１１０を送信する手段である。
【０１５３】
該収集登録要求送信手段１０による処理は、上記データ群登録情報取得手段９によるデータ群登録情報の取得処理に引続いて実行される。
【０１５４】
データ群Ｘに属する収集対象装置５２「装置ｋ」の該収集登録要求送信手段１０に対応した処理の一実施形態のフローチャートを図１７に示す。
【０１５５】
該収集登録要求送信手段１０は、まず、上記データ群登録情報取得手段９で取得した該データ群Ｘ用のデータ群登録情報１０１Ｘからデータ群Ｘ用宛先階層情報１０１４Ｘを取得する。（処理５１０１）
【０１５６】
次に、該収集登録要求送信手段１０は、該データ群Ｘ用宛先階層情報１０１４Ｘで指定された宛先階層４１０Ｘ下の上記ブローカ手段５４の既定の収集登録要求宛先４１１Ｘに対し、収集登録要求１１０Ｘｋを送信し、本収集登録要求送信手段１０による送信処理を終了する。（処理５１０２）
【０１５７】
収集登録要求宛先４１１Ｘは、図１５の例では、データ群Ｘ用宛先階層「データ群Ｘ/」に、既定の宛先名称「CollectReq」を加えた「データ群Ｘ/CollectReq」という宛先名称を使用している。
【０１５８】
本発明の収集対象装置５２が具備する収集登録情報取得手段１１は、上記収集登録要求送信手段１０で送信した収集登録要求１１０に対する処理結果である収集登録情報１１１を取得する手段である。
【０１５９】
該収集登録情報取得手段１１による処理は、上記収集登録要求送信手段１０による収集登録要求１１０の送信処理に引続いて実行される。
【０１６０】
データ群Ｘに属する収集対象装置５２「装置ｋ」の該収集登録情報取得手段１１に対応した処理の一実施形態のフローチャートを図１８に示す。
【０１６１】
該収集登録情報取得手段１１は、まず、上記データ群登録情報取得手段９で取得したデータ群Ｘのデータ群登録情報１０１Ｘからデータ群Ｘ用の宛先階層情報１０１４Ｘを取得する。（処理５１１１）
【０１６２】
次に、該収集登録情報取得手段１１は、上記処理で取得したデータ群Ｘ用の宛先階層情報１０１４Ｘと、上記収集登録要求送信手段１０で送信した収集登録要求１１０Ｘｋで指定した提供者名称１１０１Ｘｋから、該収集対象装置５２用の収集登録情報提供宛先４１２Ｘｋを計算する。(処理５１１２)
具体的には、図１５の例では、データ群Ｘ用の宛先階層「データ群Ｘ/」に、既定の階層名「CollectInfo/」を加え、さらに、提供者名称１１０１Ｘに指定した「装置ｋ」という名称を加えた、「データ群Ｘ/CollectInfo/装置ｋ」を収集登録情報提供宛先４１２Ｘｋとして使用する。
【０１６３】
次に、該収集登録情報取得手段１１は、上記処理で計算した収集登録情報提供宛先４１２Ｘｋを、ブローカ手段５４に対して受信対象として設定する。（処理５１１３）
【０１６４】
最後に、該収集登録情報取得手段１１は、上記収集登録要求送信手段１０が送信した収集登録要求１１０Ｘｋを上記本発明のデータ収集制御装置５１にて処理し、該データ収集制御装置５１の収集登録情報提供手段８が送信した該収集登録要求の処理結果である収集登録情報１１１Ｘｋを、該収集登録情報提供宛先４１２Ｘｋから受信し、本該収集登録情報取得手段１１の処理を終了する。（処理５１１４）
【０１６５】
本発明の収集対象装置５２が具備する収集データ送信手段１２は、該収集対象装置５２から収集対象データ１２０を送信し、データ収集処理プログラム５３に該収集対象データ１２０を提供する手段である。
【０１６６】
該収集データ送信手段１２による処理は、上記収集登録情報取得手段１１で収集登録情報１１１を取得した後で実行される処理で、一旦、上記収集登録情報取得手段１１で収集登録情報１１１を取得すると、該収集対象装置５２を停止、あるいは、該収集登録情報１１１を取得後、一定期間以上経過しない限り、該収集登録情報１１１を再取得せず、最後に取得した収集登録情報１１１を用い、該収集対象装置５２から、定期的、あるいは、特定の事象が発生した時点で、該収集対象装置５２の収集対象データ１２０を送信する。
【０１６７】
データ群Ｘに属する収集対象装置５２「装置ｋ」の該収集データ送信手段１２に対応した毎回の収集対象データの送信処理の一実施形態のフローチャートを図１９に示す。
【０１６８】
該収集データ送信手段１２は、まず、上記収集登録情報取得手段１１で取得した該収集対象装置５２の収集登録情報１１１Ｘｋから収集用宛先階層情報１１１４Ｘｋを取得する。（処理５１２１）
【０１６９】
次に、該収集データ送信手段１２は、上記処理で取得した収集用宛先階層情報１１１４Ｘｋを用い、該収集対象装置５２から提供する収集対象データ１２０Ｘｋを送信する収集用宛先階層下４２０Ｘｋ下の収集対象データ提供宛先４２１Ｘｋを計算する。（処理５１２２）
【０１７０】
具体的には、図１５の例では、収集用宛先階層下４２０Ｘｋである「データ群Ｘ/装置ｋ/」に「Data」という既定の宛先名称を加えた宛先を収集対象データ提供宛先４２１Ｘｋとしている。
【０１７１】
図１５の例では、収集対象データ１２０Ｘｋを一括で送信する宛先として「Data」という既定の宛先名称を用いる例を示しているが、収集対象データ１２０Ｘｋを構成する個々のデータを、宛先を分離して送信する場合は、該収集対象装置５２から収集登録要求１１０Ｘｋで示した収集対象データのデータ名称一覧１１０３Ｘｋ内のデータ名称に対応した宛先名を「Data」の代わりに用いてもよい。
【０１７２】
最後に、該収集データ送信手段１２は、上記処理で計算した収集対象データ提供宛先４２１Ｘｋを宛先として、上記ブローカ手段５４に対して、該収集対象装置５２の収集対象データ１２０Ｘｋを送信し、本収集データ送信手段１２の処理を終了する。（処理５１２３）
【０１７３】
本実施形態の収集対象装置５２によると、データ群登録要求１００を用いて新たなタイプの一群の収集対象装置５２を追加することで、該データ群に属する収集対象装置５２から収集対象データ１２０を収集して、データ収集処理プログラム５３で処理することが可能となる。
【０１７４】
また、該収集対象装置５２の収集登録要求送信１０により、自動的に該収集対象装置５２からの収集を登録できるので、登録済みのデータ群に属する新たな収集対象装置５２を簡単に収集対象として追加することが可能となる。
【０１７５】
さらに、データ群登録情報取得手段９、収集登録情報取得手段１１で取得したデータ群登録情報１０１、収集登録情報１１１に従い、収集登録要求１１０や、収集対象データ１２０のブローカ手段５４への宛先を動的に切替えるため、ブローカ手段５４やデータ収集処理プログラム５３の障害時のリダイレクトや、負荷分散を行うことが可能となる。
【０１７６】
（実施形態４）
次に上記実施形態２の本発明のデータ収集制御装置５１に対応した、本発明のデータ収集処理プログラム５３の一実施形態を説明する。
【０１７７】
図２０は、上記データ収集制御装置５１に対応した本発明のデータ収集処理プログラム５３の一実施形態のブロック図と、データの受渡しのためのブローカ手段５４の宛先の具体的な構成例を示す。
【０１７８】
本発明のデータ収集処理プログラム５３は、処理対象データ群登録情報取得ステップ３０１と、該処理対象データ群の全収集登録情報取得ステップ３０２と、処理対象データ取得ステップ３０３と、収集データ処理ステップ３０４を含む。
【０１７９】
以下、本発明のデータ収集処理プログラム５３に含まれる各処理ステップの詳細を説明する。
【０１８０】
本発明のデータ収集処理プログラム５４に含まれる収集対象データ群登録情報取得ステップ３０１は、該データ収集処理プログラム５３が処理する収集対象データ群のデータ群登録情報１０１を取得する処理ステップである。
【０１８１】
収集対象データ群Ｘの収集対象データを処理するデータ収集処理プログラム５３の該収集対象データ群登録情報取得ステップ３０１での処理の一実施形態のフローチャートを図２１に示す。
【０１８２】
該収集対象データ群登録情報取得ステップ３０１では、まず、該データ収集処理プログラム５３が処理対象とする収集対象データ群Ｘ用のデータ群登録情報提供宛先４０２Ｘをブローカ手段５４に対して、受信対象として設定する。（ステップ３０１１）
【０１８３】
データ群登録情報提供宛先４０２Ｘは、図２０の例では、上記データ収集制御装置５１のデータ群登録情報提供手段４が設定した宛先と同様に、既定の宛先階層「GrpRegInfo/」に、該データ群の名称「データ群Ｘ」を加えた宛先名称を使用している。
【０１８４】
既にデータ群登録要求１００が上記データ収集制御装置５１に対して実行されている場合、上記データ収集制御装置５１のデータ群登録情報提供手段４より、データ群登録情報１０１Ｘが該データ群登録情報提供宛先４０２Ｘに対して送付されている。
【０１８５】
既にデータ群登録情報１０１Ｘが該データ群登録情報提供宛先４０２Ｘに送付されている状態で、上記処理にてデータ群登録情報提供宛先４０２Ｘに対して受信対象とブローカ手段５４に設定すると、該ブローカ手段５４は、受信済みのデータ群Ｘのデータ群登録情報１０１Ｘを、該宛先４０２Ｘを受信設定した該データ収集処理プログラム５３に中継する。
【０１８６】
該データ収集処理プログラム５３は、該ブローカ手段５４から中継された該データ群Ｘのデータ群登録情報１０１Ｘを、該ブローカ手段５４の該データ群登録情報提供宛先４０２Ｘから受信し、本収集対象データ群登録情報取得ステップ３０１による取得処理を終了する。（ステップ３０１２）
【０１８７】
本発明のデータ収集処理プログラム５３に含まれる処理対象データ群の全収集登録情報取得ステップ３０２は、処理対象とする収集対象データ群の全収集登録情報を取得する処理ステップである。
【０１８８】
該処理対象データ群の全収集登録情報取得ステップ３０２による処理は、上記収集対象データ群登録情報取得ステップ３０１による収集対象データ群のデータ群登録情報の取得処理に引続いて実行される。
【０１８９】
収集対象データ群Ｘの収集対象データを処理するデータ収集処理プログラム５３の処理対象データ群の全収集登録情報取得ステップ３０２での処理の一実施形態のフローチャートを図２２に示す。
【０１９０】
該処理対象データ群の全収集登録情報取得ステップ３０２では、まず、上記収集対象データ群登録情報取得ステップ３０１で取得した処理対象である収集対象データ群Ｘのデータ群登録情報１０１Ｘから、該データ群用宛先階層情報１０１４Ｘを取得する。（ステップ３０２１）
【０１９１】
次に、該処理対象データ群の全収集登録情報取得ステップ３０２では、上記処理ステップで取得したデータ群用宛先階層情報１０１４Ｘを用い、データ群Ｘ用宛先階層４１０Ｘの宛先階層名に、既定の宛先名称を追加し、該データ群Ｘの登録済み全収集登録情報提供宛先４１３Ｘを計算する。（ステップ３０２２）
【０１９２】
具体的には、図２０の例では、データ群Ｘ用宛先階層４１０Ｘの宛先階層名「データ群Ｘ/」に、登録済み全収集登録情報提供用の既定の宛先名称である「CollectInfo/All_Reg」を追加した宛先名称を該データ群Ｘの登録済み全収集登録情報提供宛先４１３Ｘとして使用している。
【０１９３】
次に、該処理対象データ群の全収集登録情報取得ステップ３０２では、
上記ブローカ手段５４に対し、上記処理ステップで計算したデータ群Ｘの登録済み全収集登録情報提供宛先４１３Ｘを受信対象として設定する。（ステップ３０２３）
【０１９４】
最後に、該処理対象データ群の全収集登録情報取得ステップ３０２では、上記処理ステップで設定したデータ群Ｘの登録済み全収集登録情報提供宛先４１３Ｘから、該データ群Ｘの全収集登録情報１１２Ｘを受信し、本処理対象データ群の全収集登録情報取得ステップ３０２による処理対象データ群Ｘの全収集登録情報１１２Ｘの取得処理を終了する。（ステップ３０２４）
【０１９５】
なお、上記実施形態の処理対象データ群の全収集登録情報取得ステップ３０２では、データ群Ｘの全収集登録情報１１２Ｘをそのまま全収集登録情報提供宛先４１３Ｘから受信する例を示しているが、最終的に全収集登録情報１１２Ｘに変換できる情報であれば、データ群Ｘ用の全収集登録情報提供宛先４１３Ｘ経由で、どのような形式のデータを受信してもよい。
【０１９６】
例えば、上記実施形態２のデータ収集制御装置５１の収集登録情報提供手段８の実施形態で示したとおり、例えば、該収集登録情報提供手段８が、収集登録要求１１０毎に全収集登録情報１１２Ｘを該宛先４１３Ｘに送信するのではなく、データ群Ｘの全データ収集登録情報１１２Ｘの送付は、一定周期毎にし、該周期間の収集登録要求１１０Ｘｋに対しては、追加した収集登録情報１１１Ｘｋだけを差分情報として送付する方式であれば、本処理対象データ群の全収集登録情報取得ステップ３０２では、該収集登録情報手段８が送信してきた該データを受信し、受信した一定周期毎の全データ収集登録情報１１２Ｘと上記差分情報から最新のデータ群Ｘの全データ収集登録情報１１２Ｘを構築するという形でもよい。
【０１９７】
また、該収集登録情報提供手段８が、宛先を分けて、１つの宛先に一定周期時刻毎に該周期毎のスナップショットのデータ群Ｘの全データ収集登録情報１１２Ｘを送信し、もう1つの宛先に、該周期間の収集登録要求１１０Ｘｋに対する収集登録情報１１１Ｘｋを差分情報として送信する方式であれば、同様に、本処理対象データ群の全収集登録情報取得ステップ３０２では、宛先を分け、一方の宛先からは、一定周期毎、あるいは、1回だけ一定周期毎の全データ収集登録情報１１２Ｘを受信し、もう一方の宛先からは、毎回の収集登録要求に対応した上記差分情報を受信し、２つの宛先か受信した情報から、最新のデータ群Ｘの全データ収集登録情報１１２Ｘを構築するという形でもよい。
【０１９８】
本発明のデータ収集処理プログラム５３に含まれる処理対象データ取得ステップ３０３は、処理対象とする全収集対象データを取得する処理ステップである。
【０１９９】
該処理対象データ取得ステップ３０３による処理は、上記処理対象データ群の全収集登録情報取得ステップ３０２による処理対象データ群の全収集登録情報１１２の取得処理に引続いて実行される。
【０２００】
収集対象データ群Ｘの収集対象データを処理するデータ収集処理プログラム５３の処理対象データ取得ステップ３０３での処理の一実施形態のフローチャートを図２３に示す。
【０２０１】
該処理対象データ取得ステップ３０３では、処理対象データ群の全収集登録情報取得ステップ３０２で取得したデータ群Ｘの全収集登録情報１１２Ｘを参照し、１つずつ順に処理するため、まず、取得したデータ群Ｘの全収集登録情報１１２Ｘに未処理の収集登録情報１１１Ｘｋがないかチェックする。（ステップ３０３１）
【０２０２】
チェックの結果、すべての収集登録情報１１１Ｘｋを処理済みであれば、本処理対象データ取得ステップ３０３による収集対象データの取得処理を終了する。
【０２０３】
チェックの結果、未処理の収集登録情報１１１Ｘｋがある場合は、該収集登録情報１１１Ｘｋから、収集対象データを取得するための収集用宛先階層情報１１１４Ｘｋを取得する。（ステップ３０３２）
【０２０４】
さらに、上記処理ステップで取得した収集用宛先階層情報１１１４Ｘｋから収集用宛先階層４２０Ｘｋ下の収集対象データ１２０Ｘｋを取得するための収集対象データ提供宛先４２１Ｘｋを計算する。（ステップ３０３３）
【０２０５】
具体的には、図２０の例では、収集用宛先階層４２０Ｘｋである「データ群Ｘ/装置ｋ/」に「Data」という既定の宛先名称を加えた宛先を収集対象データ提供宛先４２１Ｘｋとしている。
【０２０６】
図２０の例では、収集対象データ１２０Ｘｋを一括で送信する宛先として「Data」という既定の宛先名称を用いる例を示しているが、収集対象データ１２０Ｘｋを構成する個々のデータを、宛先を分離して送信する場合は、上記収集登録情報１１１Ｘｋに含まれる収集対象データのデータ名称一覧１１１３Ｘｋ内のデータ名称に対応した宛先名を「Data」の代わりに用いてもよい。
【０２０７】
次に、上記処理ステップで計算した収集対象データ提供宛先４２１Ｘｋを、上記ブローカ手段５４に対して、受信対象として設定する。（ステップ３０３４）
【０２０８】
次に、上記処理ステップで設定した収集対象データ提供宛先４２１Ｘｋから、該収集対象データ提供宛先４２１Ｘｋに対して送信された収集対象データ１２０Ｘｋを受信し、処理ステップ３０３１に戻る。（ステップ３０３５）
【０２０９】
本発明のデータ収集処理プログラム５３に含まれる収集データ処理ステップ３０４は、収集した全収集対象データを処理するステップである。
【０２１０】
該収集データ処理ステップ３０４による処理は、上記処理対象データ取得ステップ３０３による処理対象データ群の全収集対象データ１２０Ｘｋの取得処理に引続いて実行される。
【０２１１】
収集対象データ群Ｘの収集対象データを処理するデータ収集処理プログラム５３の収集データ処理ステップ３０４での処理の一実施形態のフローチャートを図２４に示す。
【０２１２】
該収集データ処理ステップ３０４では、まず、記収集対象データ群登録情報取得ステップ３０１で取得した収集対象データ群のデータ群登録情報１０１Ｘから、該データ群Ｘのデータ形式情報１０１３Ｘを取得する。（ステップ３０４１）
【０２１３】
次に、上記処理ステップで取得したデータ群Ｘのデータ形式情報１０１３Ｘを参照し、上記処理対象データ取得ステップ３０３で取得した処理対象のすべての収集対象データ１２０Ｘｋをデータ形式情報１０１３Ｘに従ってアクセスし、該アクセス結果で得られた情報に対して所定の処理を実行し、本収集データ処理ステップ３０４の処理を終了する。（ステップ３０４２）
【０２１４】
本実施形態のデータ収集処理プログラムによれば、データ群登録情報１０１により、処理するデータのデータ形式を知って、収集対象データ１２０への適切なアクセス方法を自動的に選択することができ、様々な収集対象装置５２の収集対象データ１２０や、別の収集対象処理プログラムの処理結果を柔軟に処理することが可能となる。
また、収集登録情報１１１により、処理対象である収集対象装置５２、データ収集処理プログラム５３を動的に知ることができるため、処理対象の収集対象装置５２やデータ収集処理プログラムが増えても、自動的に対応できる。  
【０２１５】
（実施形態５）
次に上記実施形態２の本発明のデータ収集制御装置５１に対応し、他のデータ収集処理プログラム５３に処理結果を提供する、本発明のデータ収集処理プログラム５３の一実施形態を説明する。
【０２１６】
本実施形態のデータ収集処理プログラム５３は、収集した処理対象データを処理するだけでなく、該データ収集処理プログラム５３の処理結果データを、収集対象データとして、該データ収集処理プログラム５３群から生成される処理結果データ群をデータ群登録要求１００によりデータ収集制御装置５１に対しデータ群登録し、該該データ収集処理プログラム５３群の処理結果データを、別のデータ収集処理プログラム５３が処理対象とできるようにしたデータ収集処理プログラム５３である。
【０２１７】
図２５は、上記実施形態２のデータ収集制御装置５１に対応した本実施形態のデータ収集処理プログラム５３の一実施形態のブロック図と、データの受渡しのためのブローカ手段５４の宛先の具体的な構成例を示す。
【０２１８】
本実施形態のデータ収集処理プログラム５３は、上記実施形態４のデータ収集処理プログラム５３が持つ処理ステップに加え、さらに、該処理プログラム用データ群登録情報取得ステップ３０５と、該処理プログラム用収集登録要求送信ステップ３０６と、該処理プログラム用収集登録情報取得ステップ３０７と、処理結果データ送信ステップ３０８を含む。
【０２１９】
以下、本実施形態のデータ収集処理プログラム５３に追加で含まれる各処理ステップの詳細を説明する。
【０２２０】
本実施形態のデータ収集処理プログラム５３に含まれる該処理プログラム用データ群登録情報取得ステップ３０５は、該データ収集処理プログラム５３群が生成する処理結果データのデータ群登録情報１０１を取得する処理ステップである。
【０２２１】
データ群Ｐに属するデータ収集処理プログラム５３の該処理プログラム用データ群登録情報取得ステップ３０５の処理の一実施形態のフローチャートを図２６に示す。
【０２２２】
該処理プログラム用データ群登録情報取得ステップ３０５では、まず、該データ収集処理プログラム５３が属するデータ群Ｐ用のデータ群登録情報提供宛先４０２Ｐをブローカ手段５４に対して、受信対象として設定する。（ステップ３０５１）
【０２２３】
データ群登録情報提供宛先４０２Ｐは、図２５の例では、上記データ収集制御装置５１のデータ群登録情報提供手段４が設定した宛先と同様に、既定の宛先階層「GrpRegInfo/」に、該データ群の名称「データ群Ｐ」を加えた宛先名称を使用している。
【０２２４】
既にデータ群Ｐのデータ群登録要求１００Ｐが上記データ収集制御装置５１に対して実行されている場合、上記データ収集制御装置５１のデータ群登録情報提供手段４より、データ群登録情報１０１Ｐが該データ群登録情報提供宛先４０２Ｐに対して送付されている。
【０２２５】
既にデータ群Ｐのデータ群登録情報１０１Ｐが該データ群登録情報提供宛先４０２Ｐに送付されている状態で、上記処理ステップにてデータ群登録情報提供宛先４０２Ｐに対して受信対象とブローカ手段５４に設定すると、該ブローカ手段５４は、受信済みのデータ群Ｐのデータ群登録情報１０１Ｐを、該宛先４０２Ｐを受信設定した該データ収集処理プログラム５３に中継する。
【０２２６】
該データ収集処理プログラム５３の該処理プログラム用データ群登録情報取得ステップ３０５では、該ブローカ手段５４から中継された該データ群Ｘのデータ群登録情報１０１Ｐを、該ブローカ手段５４の該データ群登録情報提供宛先４０２Ｐから受信し、本該処理プログラム用データ群登録情報取得ステップ３０５による取得処理を終了する。（ステップ３０５２）
【０２２７】
本実施形態のデータ収集処理プログラム５３に含まれる該処理プログラム用収集登録要求送信ステップ３０６は、該データ収集処理プログラム５３が生成する処理結果データを、別のデータ収集処理プログラムが処理対象とする収集対象データ１２０として、収集登録するための収集登録要求１１０を送信する処理ステップである。
【０２２８】
該処理プログラム用収集登録要求送信ステップ３０６による処理は、上記該処理プログラム用データ群登録情報取得ステップ３０５によるデータ群登録情報の取得処理に引続いて実行される。
【０２２９】
データ群Ｐに属するデータ収集処理プログラム５３「プログラムｋ」の該処理プログラム用収集登録要求送信ステップ３０６の処理の一実施形態のフローチャートを図２７に示す。
【０２３０】
該処理プログラム用収集登録要求送信ステップ３０６では、まず、上記該処理プログラム用データ群登録情報取得ステップ３０５で取得した該データ群Ｐ用のデータ群登録情報１０１Ｐからデータ群Ｐ用宛先階層情報１０１４Ｐを取得する。（ステップ３０６１）
【０２３１】
次に、該処理プログラム用収集登録要求送信ステップ３０６では、該データ群Ｐ用宛先階層情報１０１４Ｐで指定された宛先階層４１０Ｐ下の上記ブローカ手段５４の既定の収集登録要求宛先４１１Ｐに対し、収集登録要求１１０Ｐｋを送信し、本該処理プログラム用収集登録要求送信ステップ３０６による送信処理を終了する。（ステップ３０６２）
【０２３２】
収集登録要求宛先４１１Ｐは、図２５の例では、データ群Ｐ用宛先階層「データ群Ｐ/」に、既定の宛先名称「CollectReq」を加えた「データ群Ｐ/CollectReq」という宛先名称を使用している。
【０２３３】
本実施形態のデータ収集処理プログラム５３に含まれる該処理プログラム用収集登録情報取得ステップ３０７は、該処理プログラム用収集登録要求送信ステップ３０６で送信した収集登録要求１１０に対する処理結果である収集登録情報１１１を取得する処理ステップである。
【０２３４】
該処理プログラム用収集登録情報取得ステップ３０７による処理は、上記該処理プログラム用収集登録要求送信ステップ３０６による収集登録要求１１０の送信処理に引続いて実行される。
【０２３５】
データ群Ｐに属するデータ収集処理プログラム５３「プログラムｋ」の該処理プログラム用収集登録情報取得ステップ３０７の処理の一実施形態のフローチャートを図２８に示す。
【０２３６】
該処理プログラム用収集登録情報取得ステップ３０７では、まず、上記該処理プログラム用データ群登録情報取得ステップ３０５で取得したデータ群Ｐのデータ群登録情報１０１Ｐからデータ群Ｐ用の宛先階層情報１０１４Ｐを取得する。（ステップ３０７１）
【０２３７】
次に、該処理プログラム用収集登録情報取得ステップ３０７では、上記処理で取得したデータ群Ｐ用の宛先階層情報１０１４Ｐと、上記該処理プログラム用収集登録要求送信ステップ３０６で送信した収集登録要求１１０Ｐｋで指定した提供者名称１１０１Ｐｋから、該データ収集処理プログラム５３用の収集登録情報提供宛先４１２Ｐｋを計算する。(ステップ３０７２)
具体的には、図２５の例では、データ群Ｐ用の宛先階層「データ群Ｐ/」に、既定の階層名「CollectInfo/」を加え、さらに、提供者名称１１０１Ｐに指定した「プログラムｋ」という名称を加えた、「データ群Ｐ/CollectInfo/プログラムｋ」を収集登録情報提供宛先４１２Ｐｋとして使用する。
【０２３８】
次に、該処理プログラム用収集登録情報取得ステップ３０７では、上記処理で計算した収集登録情報提供宛先４１２Ｐｋを、ブローカ手段５４に対して受信対象として設定する。（ステップ３０７３）
【０２３９】
最後に、該処理プログラム用収集登録情報取得ステップ３０７では、上記該処理プログラム用収集登録要求送信ステップ３０６にて送信した収集登録要求１１０Ｐｋを上記本発明のデータ収集制御装置５１にて処理し、該データ収集制御装置５１の収集登録情報提供手段８が送信した該収集登録要求の処理結果である収集登録情報１１１Ｐｋを、該収集登録情報提供宛先４１２Ｐｋから受信し、本該処理プログラム用収集登録情報取得ステップ３０７の処理を終了する。（ステップ３０７４）
【０２４０】
本実施形態のデータ収集処理プログラム５３に含まれる処理結果データ送信ステップ３０８は、該データ収集処理プログラム５３の処理結果データを収集対象データ１２０として送信し、別のデータ収集処理プログラム５３に該収集対象データを提供する処理ステップである。
【０２４１】
該処理結果データ送信ステップ３０８による処理は、上記該データ収集処理プログラム５３の収集データ処理３０４により収集対象データに対して所定の処理を実施した後、引続き実行される。
【０２４２】
データ群Ｐに属するデータ収集処理プログラム５３「プログラムｋ」の該処理結果データ送信ステップ３０８の送信処理の一実施形態のフローチャートを図２９に示す。
【０２４３】
該処理結果データ送信ステップ３０８では、まず、上記該処理プログラム用収集登録情報取得ステップ３０７で取得したデータ収集処理プログラム５３の収集登録情報１１１Ｐｋから収集用宛先階層情報１１１４Ｐｋを取得する。（ステップ３０８１）
【０２４４】
次に、該処理結果データ送信ステップ３０８では、上記処理ステップで取得した収集用宛先階層情報１１１４Ｐｋを用い、該データ収集処理プログラム５３から提供する処理結果の収集対象データ１２０Ｐｋを送信する収集用宛先階層下４２０Ｐｋ下の収集対象データ提供宛先４２１Ｐｋを計算する。（ステップ３０８２）
【０２４５】
具体的には、図２５の例では、収集用宛先階層下４２０Ｐｋである「データ群Ｘ/プログラムｋ」に「Data」という既定の宛先名称を加えた宛先を収集対象データ提供宛先４２１Ｐｋとしている。
【０２４６】
図２５の例では、処理結果の収集対象データ１２０Ｐｋを一括で送信する宛先として「Data」という既定の宛先名称を用いる例を示しているが、処理結果の収集対象データ１２０Ｐｋを構成する個々のデータを、宛先を分離して送信する場合は、該データ収集処理プログラム５３から収集登録要求１１０Ｐｋで示した収集対象データのデータ名称一覧１１０３Ｘｋ内のデータ名称に対応した宛先名を「Data」の代わりに用いてもよい。
【０２４７】
最後に、該処理結果データ送信ステップ３０８では、上記処理ステップで計算した収集対象データ提供宛先４２１Ｐｋを宛先として、ブローカ手段５４に対して、該データ収集処理プログラム５３の処理結果を収集対象データ１２０Ｐｋとして送信し、本処理結果データ送信ステップ３０８の処理を終了する。（ステップ３０８３）
【０２４８】
本実施形態のデータ収集処理プログラム５３によれば、該データ収集処理プログラム５３の処理結果を別のデータ収集処理プログラム５３の入力とすることが可能となるため、収集対象データ１２０に対して、様々な処理や加工を次々と施すことが可能となる。
【０２４９】
例えば、データ変換を行うデータ収集処理プログラム５３を登録すれば、入力とした収集対象データ１２０を、既存のデータ収集処理プログラム５３で使用可能なデータ形式に変換することができる。
【０２５０】
また、アラーム監視を行うデータ収集処理プログラム５３を登録すれば、別のデータ収集処理プログラム５３の間に入り、収集対象データ１２０に対して、閾値監視を行い、ある条件でアラームを挙げるといった処理も可能となる。
【０２５１】
（実施形態６）
上記本発明の実施形態１では、ブローカ手段５４が１つの例を示したが、ブローカ手段を１つ、または、複数で構成する本発明のデータ収集システムの実施形態について説明する。
【０２５２】
図３０は、１つ、または、複数のブローカ手段５４で構成する本発明のデータ収集システムの一構成例を示す。
【０２５３】
本発明の本実施形態では、上記実施形態１のデータ収集システムにおいて、ブローカ手段５４を含むブローカ装置８４を１つ、または、複数で構成し、データ収集処理プログラム５３が動作するデータ収集処理装置８３も１つ、または、複数で構成する。
【０２５４】
本実施形態のデータ収集システムでは、データ収集制御装置５１が、収集対象データ１２０の送受信先のブローカ手段５４の宛先を制御し、収集対象装置５２とデータ収集処理プログラム５３間、及び、データ収集処理プログラム５３間の収集対象データ１２０の受渡しを、複数のブローカ手段５４に分散化するように制御する。
【０２５５】
本データ収集システムによれば、データ収集制御装置５１によって、ブローカ手段５４の宛先を切替え、各ブローカ手段５４で中継するデータを負荷分散することが可能となる。
【０２５６】
図３０の実施形態では、該データ収集制御装置５１と収集対象装置５２、データ収集処理プログラム５３間のデータ群登録要求／データ登録情報取得、収集登録要求／収集登録情報取得のための通信を中継するブローカ手段５４と、収集対象装置５２とデータ収集処理プログラム５３間、及び、データ収集処理プログラム５３間の収集対象データ１２０のための通信を中継するブローカ手段５４も分離した例を示すが、分離せず、同居した形でもよい。
【０２５７】
また、図３０では、ブローカ手段５４、データ収集処理プログラム５３は、データ収集制御装置５１とは別の装置上に具備、あるいは、実行される形態を示しているが、同一の装置上で具備、あるいは、実行される形態であってもよい。
【０２５８】
以下、本実施形態６のデータ収集システムにおける、本発明のデータ収集制御装置５１、収集対象装置５２、データ収集処理プログラム５３の実施形態を説明する。
【０２５９】
（実施形態７）
まず、上記実施形態６のデータ収集システムにおいて、データ群でブローカ手段を分散化させる本発明のデータ収集制御装置５１の実施形態を説明する。
【０２６０】
図３１は、上記実施形態６のデータ収集システムにおいて、データ群でブローカ手段を分散化させる本発明のデータ収集制御装置５１の一実施形態の構成例を示す。
【０２６１】
本実施形態のデータ収集制御装置５１は、実施形態２のデータ収集制御装置５１の構成に加え、データ群収集単位数情報３１と、データ群・ブローカ割当て管理情報３２を備える。
【０２６２】
該データ群収集単位数情報３１は、ブローカ手段５４毎で中継するデータ群として登録された収集対象装置５２、あるいは、データ収集処理プログラム５３の数の上限値を示す情報である。
【０２６３】
該データ群・ブローカ割当て管理情報３２は、ブローカ手段５４毎に、データ群として登録された収集対象装置５２、あるいは、データ収集処理プログラム５３の中継をいくつ割当て済みであるかを管理する情報である。
【０２６４】
本実施形態のデータ収集制御装置５１で扱う上記データ群登録要求１００には、該データ群に属する収集対象装置５２、あるいは、データ収集処理プログラム５３の数情報が追加されている。
【０２６５】
図３２に、本実施形態のデータ収集制御装置５１で使用されるデータ群登録要求１００の具体的な一構成例を示す。
【０２６６】
図３２は、データ群Ｘのデータ群登録要求の例を示すが、本実施形態では、上記図３で示したデータ群登録要求１００Ｘの構成要素に加え、該データ群に属する収集対象装置５２、あるいは、データ収集処理プログラム５３の数を示した収集対象数情報１００４Ｘを追加で含む。
【０２６７】
図３３は、本実施形態で追加された本発明のデータ群・ブローカ割当て管理情報３２の具体的な一構成例を示す。
【０２６８】
図３３の実施形態では、ブローカ手段識別情報３２１と、対応する各ブローカ手段５４に対して、データ群として登録された収集対象装置５２、あるいは、データ収集処理プログラム５３の中継をいくつ割当てたかの数を示す割当て済み合計収集対象数情報３２２をペアとした表で構成する。
【０２６９】
本実施形態のデータ収集制御装置５１では、上記実施形態２のデータ群用宛先階層割当て手段２内の処理が一部変更されており、本実施形態で追加されたデータ群登録要求１００Ｘの収集対象数情報１００４Ｘ、及び、データ群収集単位数情報３１、データ群・ブローカ割当て管理情報３２を用いて、データ群用の宛先階層割当てを行う。
【０２７０】
本実施形態で変更となった上記実施形態２のデータ群用宛先階層割当て手段２の処理の中の図８の宛先階層４１０Ｘ割当て処理５０２１部分の処理の一実施形態のフローチャートを図３４に示す。
【０２７１】
本実施形態のデータ群用宛先階層４１０Ｘ割当て処理５０２１では、まず、データ群登録要求受信手段１で取得したデータ群登録要求１００Ｘから上記収集対象数情報１００４Ｘを取得する。（処理５０２１１）
【０２７２】
次に、上記データ群・ブローカ割当て管理情報３２を参照し、割当て済み合計収集対象数３２２＋該収集対象数１００４Ｘが、データ群収集単位数３１以下であるブローカ手段５４を検索する。（処理５０２１２）
【０２７３】
次に、上記処理で発見したブローカ手段５４のデータ群・ブローカ割当て管理情報エントリの割当て済み合計収集対象数３２２を、該収集対象数１００４Ｘを加算した値に更新する。(処理５０２１３)
最後に、上記処理５０２１２で発見したブローカ手段５４が中継担当となる該ブローカ手段５４のアドレス情報を含むデータ群用宛先階層４１０Ｘの宛先情報を生成し、本実施形態のデータ群用宛先階層４１０Ｘ割当て処理５０２１の処理を終了する。（処理５０２１４）
【０２７４】
上記処理５０２１４で生成するデータ群用宛先階層４１０Ｘの宛先名称の一具体例を図３４に示す。
【０２７５】
図３５の実施形態では、例えば、最初がブローカ手段５４のアドレスに対応した情報であることがわかるように、宛先名称を「//」で始め、「//」の直後に、割当てたブローカ手段５４のアドレスに対応した情報として、処理５０２１２で発見したブローカ手段の識別情報３２１を記述し、その直後にデータ群Ｘの名称「データ群Ｘ」を「/」で区切って追加した宛先名称を使用する。
【０２７６】
図３５の実施形態では、データ群用宛先階層４１０Ｘをブローカ手段５４のアドレス情報も含めて文字列で記述した例を示したが、ブローカ手段５４のバイナリのアドレス情報と、該ブローカ手段５４下の文字列宛先情報をペアとした形の宛先情報をデータ群用宛先階層４１０Ｘとして使用してもよい。
【０２７７】
本実施形態のデータ収集制御装置５１によれば、データ群毎に、ブローカ手段５４の宛先を切替えることができ、各ブローカ手段５４が中継するデータ群を分散化することができる。
【０２７８】
（実施形態８）
次に、上記実施形態６のデータ収集システムにおいて、収集登録毎でブローカ手段を分散化させる本発明のデータ収集制御装置５１の実施形態を説明する。
【０２７９】
図３６は、上記実施形態６のデータ収集システムにおいて、収集登録毎でブローカ手段を分散化させる本発明のデータ収集制御装置５１の一実施形態の構成例を示す。
【０２８０】
本実施形態のデータ収集制御装置５１は、実施形態２のデータ収集制御装置５１の構成に加え、収集単位数情報３３と、収集・ブローカ割当て管理情報３４を備える。
【０２８１】
該収集単位数情報３３は、ブローカ手段５４毎で中継する収集登録された収集対象装置５２、あるいは、データ収集処理プログラム５３の数の上限値を示す情報である。
【０２８２】
該収集・ブローカ割当て管理情報３４は、ブローカ手段５４毎に、収集登録された収集対象装置５２、あるいは、データ収集処理プログラム５３の中継をいくつ割当て済みであるかを管理する情報である。
【０２８３】
図３７は、本実施形態で追加された本発明の収集・ブローカ割当て管理情報３４の具体的な一構成例を示す。
【０２８４】
図３７の実施形態では、ブローカ手段識別情報３４１と、対応する各ブローカ手段５４に対して、収集登録された収集対象装置５２、あるいは、データ収集処理プログラム５３の中継をいくつ割当てたかの数を示す割当て済み合計収集対象数情報３４２をペアとした表で構成する。
【０２８５】
本実施形態のデータ収集制御装置５１では、上記実施形態２の収集用宛先階層割当て手段６内の処理が一部変更されており、本実施形態で追加された収集単位数情報３３、収集・ブローカ割当て管理情報３４を用いて、収集用宛先階層割当てを行う。
【０２８６】
本実施形態で変更となった上記実施形態２の収集用宛先階層割当て手段６の処理の中の図１２の収集用宛先階層４２０Ｘｋ割当て処理５０６１部分の処理の一実施形態のフローチャートを図３８に示す。
【０２８７】
本実施形態の収集用宛先階層４２０Ｘ割当て処理５０６１では、上記収集・ブローカ割当て管理情報３４を参照し、割当て済み合計収集対象数３４２が、上記収集単位数情報３１未満であるブローカ手段５４を検索する。（処理５０６１１）
【０２８８】
次に、上記処理で発見したブローカ手段５４の収集・ブローカ割当て管理情報エントリの割当て済み合計収集対象数３４２を、１加算した値に更新する。(処理５０６１２)
最後に、上記処理５０６１１で発見したブローカ手段５４が中継担当となる該ブローカ手段５４のアドレス情報を含む収集用宛先階層４２０Ｘｋの宛先情報を生成し、本実施形態の収集用宛先階層４２０Ｘ割当て処理５０６１の処理を終了する。（処理５０６１３）
【０２８９】
上記処理５０６１３で生成する収集用宛先階層４２０Ｘｋの宛先名称の一具体例を図３９に示す。
【０２９０】
図３９の実施形態では、例えば、最初がブローカ手段５４のアドレスに対応した情報であることがわかるように、宛先名称を「//」で始め、「//」の直後に、割当てたブローカ手段５４のアドレスに対応した情報として、処理５０６１１で発見したブローカ手段の識別情報３４１を記述し、その直後にデータ群Ｘの名称「データ群Ｘ」と、収集登録要求１１０Ｘｋのデータ提供者名称１１０１Ｘｋで指定された「装置ｋ」を「/」で区切って追加した宛先名称を使用する。
【０２９１】
図３９の実施形態では、収集用宛先階層４２０Ｘｋをブローカ手段５４のアドレス情報も含めて文字列で記述した例を示したが、ブローカ手段５４のバイナリのアドレス情報と、該ブローカ手段５４下の文字列宛先情報をペアとした形の宛先情報を収集用宛先階層４２０Ｘｋとして使用してもよい。
【０２９２】
本実施形態のデータ収集制御装置５１によれば、収集登録毎にブローカ手段５４の宛先を切替えることができるので、各ブローカ手段５４で中継する収集対象データ１２０を分散化することができる。
【０２９３】
（実施形態９）
次に、上記実施形態６のデータ収集システムにおいて、ブローカ手段５４のデータ収集タイミングを分散化させる本発明のデータ収集制御装置５１の実施形態を説明する。
【０２９４】
図４０は、上記実施形態６のデータ収集システムにおいて、ブローカ手段５４のデータ収集タイミングを分散化させる本発明のデータ収集制御装置５１の一実施形態の構成例を示す。
【０２９５】
本実施形態のデータ収集制御装置５１は、実施形態８のデータ収集制御装置５１の構成に加え、処理余裕時間情報３５を備える。
【０２９６】
該処理余裕時間情報３５は、収集対象データ１２０を収集した後、データ収集処理プログラム５３にて、所定の処理を実行するために割当てられた最小時間である。
【０２９７】
また、本実施形態のデータ収集制御装置５１では、上記データ群登録要求１００、データ群登録情報１０１に、該データ群の収集対象データが提供される提供間隔情報が追加されている。
【０２９８】
図４１に、本実施形態におけるデータ群Ｘ用のデータ群登録要求１００Ｘの具体的な構成例を示す。
【０２９９】
図４１に示すとおり、本実施形態のデータ群登録要求１００Ｘは、図３で示したデータ群登録要求の構成要素に加え、収集データの提供間隔情報１００５Ｘを追加で含む。
【０３００】
図４２に、本実施形態におけるデータ群Ｘ用のデータ群登録情報１０１Ｘの具体的な構成例を示す。
【０３０１】
図４２に示すとおり、本実施形態のデータ群登録情報１０１Ｘは、図４で示したデータ群登録情報の構成要素に加え、同様に、収集データの提供間隔情報１０１５Ｘを追加で含む。
【０３０２】
図４１で示したデータ群登録要求１００Ｘから、データ群登録情報１０１Ｘを作成するため、本実施形態のデータ群登録手段３に対応した処理は、図４３に示すとおり、処理５０３１において、図９の実施形態の同処理に加えて、データ群登録要求１００Ｘに含まれる提供間隔情報１００５Ｘを、提供間隔情報１０１５Ｘとして、データ群登録情報１０１Ｘにコピーして設定する。
【０３０３】
本実施形態のデータ収集制御装置５１は、該データ群登録情報１０１Ｘに含まれる収集データの提供間隔情報１０１５Ｘと、上記収集単位数情報３３と、収集・ブローカ割当て管理情報３４と、該処理余裕時間情報３５を用いて、同一ブローカ手段５４のデータ収集タイミングを分散化させる。
【０３０４】
具体的には、収集対象装置５２、あるいは、データ収集処理プログラム５３からの収集登録要求１１０Ｘｋに対して、該データ収集制御装置５１の収集用宛先階層割当て手段６にて、上記情報を用いて、該収集対象装置５２、データ収集処理プログラム５３からの収集データの提供タイミングを割当て、収集登録手段７にて生成する、該収集登録要求１１０Ｘｋに対応した収集登録情報１１１Ｘｋに、該提供タイミング情報を含めることで、同一ブローカ手段５４のデータ収集タイミングの分散化を実現する。
【０３０５】
図４４に、本実施形態における収集登録情報１１１Ｘｋの具体的な構成例を示す。
【０３０６】
図４４に示すとおり、本実施形態の収集登録情報１１１Ｘｋは、図６で示した収集登録情報１１１Ｘｋの構成要素に加え、上記提供タイミング情報１１１５Ｘｋが追加されている。
【０３０７】
図４５は、本実施形態のデータ収集制御装置５１の収集用宛先階層割当て手段６に対応した処理の一実施形態のフローチャートを示す。
【０３０８】
図４５に示すとおり、図１２の実施形態で示した処理５０５１に加え、処理５０６２、処理５０６３が追加となっている。
【０３０９】
該収集用宛先階層割当て手段６は、図１２の実施形態で示した処理と同様、まず、該収集登録要求１１０Ｘｋに対応して、収集用宛先階層４２０Ｘｋを割当てる。（処理５０６１）
【０３１０】
次に、本実施形態の収集用宛先階層割当て手段６では、該データ群Ｘのデータ群登録情報１０１Ｘから提供間隔情報１０１５Ｘを取得する。（処理５６０２）
【０３１１】
次に、本実施形態の収集用宛先階層割当て手段６は、収集登録要求を行ったデータ提供者からの収集対象データの提供タイミング値を（収集データ提供間隔情報１０１５Ｘ−処理余裕時間情報３５）／収集単位数情報３３×処理５０６１２で更新した収集・ブローカ割当て管理情報エントリの割当て済み合計収集対象数３４２）で計算し、収集用宛先階層割当て手段６による処理を終了する。（処理５６０３）
【０３１２】
図４６は、本実施形態のデータ収集制御装置５１の収集登録手段７に対応した処理の一実施形態のフローチャートを示す。
【０３１３】
図４６に示すとおり、本実施形態のデータ収集制御装置５１の収集登録手段７では、図１３の実施形態の処理５０７１において、図１３の処理５０７１の処理に加えて、上記本実施形態の収集用宛先階層割当て手段６にて計算した提供タイミング値を提供タイミング情報１１１５Ｘとして収集登録情報１１１Ｘに含め、収集登録情報１１１Ｘを作成する。（処理５７０１）。
【０３１４】
次に、処理５０７１で生成した収集登録情報１１１Ｘを収集登録情報データベース２２に登録し、本収集登録手段７の処理を終了する。（処理５０７２）
【０３１５】
本実施形態のデータ収集制御装置５１によれば、同一ブローカ手段５４で中継される収集対象データ１２０を時間的に分散化させ、同一ブローカ手段５４に、多数の収集対象装置５２やデータ収集処理プログラム５３からの収集対象データ１２０が時間的に集中することを防ぎ、中継処理の遅延を防止できる。
【０３１６】
また、データ収集処理プログラム５３は、収集登録情報１１１より、各収集対象データ１２０の収集タイミングを知ることができるため、各収集対象データ１２０の収集タイムアウト処理や、各収集処理データ１２０に対する処理を自動スケジューリングして、最適に処理することができる。
【０３１７】
（実施形態１０）
次に、上記実施形態６のデータ収集システムにおいて、上記実施形態９のデータ収集制御装置５１に対応した収集対象装置５２の実施形態を説明する。
【０３１８】
上記実施形態９のデータ収集制御装置５１に対応した本実施形態の収集対象装置５２の構成は、上記図１５の実施形態の構成と同じであるが、収集データ送信手段１２に対応した処理が、図１９で示した実施形態の処理と異なる。
【０３１９】
図４７に、本実施形態の収集対象装置５２の収集データ送信手段１２に対応した処理の一実施形態のフォローチャートを示す。
【０３２０】
図１９の実施形態と異なる点は、処理５１２２と処理５１２３の間に、処理５１２２１、処理５１２２２が追加になっている点だけである。
【０３２１】
本実施形態の収集対象装置５２の収集データ送信手段１２では、処理５１２２の後、収集登録情報取得手段１１で取得した該収集対象装置５２の収集登録情報１１１Ｘｋから提供タイミング情報１１１５Ｘｋを取得する。（処理５１２２１）
【０３２２】
次に、上記処理で取得した提供タイミング情報１１１５Ｘｋに従い、定時の送信時刻から、続く処理５１２３の送信処理の実行を、該提供タイミング情報１１１５Ｘｋで指定された時間分遅延させる。（処理５１２２２）
【０３２３】
上記追加された処理により、本実施形態の収集対象装置５２は、収集対象データ１２０のブローカ手段５４への送信タイミングを分散化させる。
【０３２４】
本実施形態の収集対象装置５２によれば、データ収集制御装置５１の指示に従い、同一ブローカ手段５４への収集対象データ１２０の送付を分散化させ、同一ブローカ手段５４への時間的集中による遅延を防ぐことができる。
【０３２５】
（実施形態１１）
次に、上記実施形態６のデータ収集システムにおいて、上記実施形態９のデータ収集制御装置５１に対応したデータ収集処理プログラム５３の実施形態を説明する。
【０３２６】
上記実施形態９のデータ収集制御装置５１に対応した本実施形態のデータ収集処理プログラム５３の構成は、上記図２０の実施形態の構成と同じであるが、収集データ処理ステップ３０４に対応した処理が、図２４で示した実施形態の処理と異なる。
【０３２７】
図４８に、本実施形態のデータ収集処理プログラム５３の収集データ処理ステップ３０４に対応した処理の一実施形態のフォローチャートを示す。
【０３２８】
図２４の実施形態と異なる点は、ステップ３０４０が追加となっている点だけである。
【０３２９】
本実施形態のデータ収集処理プログラム５３の収集データ処理ステップ３０４では、収集した収集対象データに対する処理を開始する前に、全収集登録情報取得ステップ３０２で取得した処理対象のデータ群Ｘの全収集登録情報１１２Ｘの各収集登録情報１１１Ｘに含まれる提供タイミング情報１１１５Ｘから、各収集対象データ１２０Ｘｋが提供されるべきタイミングを知り、各収集対象データ１２０Ｘｋの取得タイムアウト処理の実行や、ステップ３０４２での該収集対象データ１２０に対する処理の実行タイミングを調整する。(ステップ３０４０)
本実施形態のデータ収集処理プログラム５３によれば、収集登録情報１１１より、各収集対象データ１２０の収集タイミングを知り、各収集対象データ１２０の収集タイムアウト処理や、各収集処理データ１２０に対する処理を自動でスケジューリングし、最適な処理を実行することができる。
【０３３０】
（実施形態１２）
次に、上記実施形態６のデータ収集システムにおいて、上記実施形態９のデータ収集制御装置５１に対応したデータ収集処理プログラム５３であって、該データ収集処理プログラムの処理結果を別のデータ収集処理プログラム５３に提供するデータ収集処理プログラム５３の実施形態を説明する。
【０３３１】
上記実施形態９のデータ収集制御装置５１に対応した本実施形態のデータ収集処理プログラム５３の構成は、上記図２５の実施形態の構成と同じであるが、処理結果データ送信ステップ３０８に対応した処理が、図２９で示した実施形態の処理と異なる。
【０３３２】
図４９に、本実施形態のデータ収集処理プログラム５３の処理結果データ送信ステップ３０８に対応した処理の一実施形態のフォローチャートを示す。
【０３３３】
図２９の実施形態と異なる点は、ステップ３０８２とステップ３０８３の間に、ステップ３０８２１、ステップ３０８２２が追加されている点だけである。
【０３３４】
本実施形態の処理結果データ送信ステップ３０８では、ステップ３０８２の処理の後、該処理プログラム用収集登録情報取得ステップ３０７で取得した収集登録情報１１１Ｐｋから提供タイミング情報１１１５Ｐｋを取得する。（ステップ３０８２１）
【０３３５】
次に、上記処理ステップで取得した提供タイミング情報１１１５Ｐｋに従い、定時の送信時刻から、続くステップ３０８３の送信処理の実行を、該提供タイミング情報１１１５Ｐｋで指定された時間分遅延させる。（ステップ３０８２２）
【０３３６】
本実施形態のデータ収集処理プログラム５３によれば、データ収集制御装置５１の指示に従い、同一ブローカ手段５４への収集対象データ１２０の送付を分散化させ、同一ブローカ手段５４への時間的集中による遅延を防ぐことができる。
【０３３７】
（実施形態１３）
最後に、本発明、あるいは、本発明に関わる装置、手段の実施形態として、物理的な実現形態を説明する。
【０３３８】
本発明の上記データ収集制御装置５１、収集対象装置５２、データ収集処理装置８３、及び、本発明に関わるブローカ装置８４は、例えば、一般的な情報処理装置９０として実現する。
【０３３９】
また、上記データ収集制御装置５１、収集対象装置５２、ブローカ装置８４上の各手段や、データ収集処理装置８３上で動作するデータ収集処理プログラム５３は、該情報処理装置９０上で動作するプログラムとして実現する。
【０３４０】
図５０に、本発明、あるいは、本発明に関わる、各装置、手段、収集データ処理プログラム５３を実現する情報処理装置９０の一実施形態の構成を示す。
【０３４１】
情報処理装置９０は、プログラムやデータを格納した記憶装置９３と、プログラムやデータを格納するＲＡＭ（Ｒａｎｄｏｍ Ａｃｃｅｓｓ Ｍｅｍｏｒｙ）９２と、ＲＡＭ７３上のプログラムを実行するプロセッサ９１と、情報処理装置９０間でデータの受渡しを行うための通信インタフェース９５と、記憶装置７２、ＲＡＭ７３、プロセッサ７４、通信インタフェース９５間でデータやプログラムの受け渡しを行うためのバス９４で構成される。
【０３４２】
本発明の上記データ収集制御装置５１、収集対象装置５２、データ収集処理装置８３、及び、本発明に関わるブローカ装置８４の各手段、及び、データ収集処理プログラム５３を実現するプログラムは、最初、記憶装置９３に格納されており、該情報処理装置９０の起動により、バス９４を介してＲＡＭ９４にロードされて、プロセッサ９１で実行することで、それぞれの機能を実現する。
【０３４３】
従って、データ収集処理プログラム５３、ブローカ手段５４、データ収集制御装置５１の各手段に対応した各プログラムを、同じ情報処理装置９０上で実行しても、分離した情報処理装置９０上で実行してもかまわない。
【０３４４】
以上、本発明を実施するための各実施形態について説明してきたが、各実施形態において記述したデータ群登録要求や、収集登録要求についての処理手段及び処理ステップなどと同様の構成を用いて、データの削除も当然実現可能である。すなわち、本明細書で記述した「登録」を「削除」で読み変えた、データ群削除要求や、収集削除要求に対する処理手段及び処理ステップを本発明の実施形態に係るデータ収集制御装置、収集対象装置及びデータ収集処理プログラムに含んでもよい。
【産業上の利用可能性】
【０３４５】
本発明のデータ収集制御装置、収集対象装置、データ収集処理プログラム、データ収集システム、データ収集制御プログラム、収集対象装置プログラム、及び、記録媒体によれば、様々な収集対象装置からデータを収集し、収集したデータに対して、様々な処理や加工を施し、様々な用途に利用でき、かつ、多数の収集対象装置からのデータ収集や多数のデータ収集処理プログラムによる処理に対しても、スケーラブルに対応できるため、ＩｏＴ向けのデータ収集システムとして利用できる。
【符号の説明】
【０３４６】
１……データ群登録要求受信手段
２……データ群用宛先割当て手段
３……データ群登録手段
４……データ群登録情報提供手段
５……収集登録要求受信手段
６……収集用宛先割当て手段
７……収集登録手段
８……収集登録情報提供手段
９……データ群登録情報取得手段
１０……収集登録要求送信手段
１１……収集登録情報取得手段
１２……収集データ送信手段
２１……データ群登録情報データベース
２２……収集登録情報データベース
３１……データ群収集単位数情報
３２……データ群・ブローカ割当て管理情報
３３……収集単位数情報
３４……収集・ブローカ割当て管理情報
５１……データ収集制御装置
５２……収集対象装置
５３……データ収集処理プログラム
５４……ブローカ手段
８３……データ収集処理装置
８４……ブローカ装置
９０……情報処理装置
９１……プロセッサ
９２……ＲＡＭ
９３……記憶装置
９４……バス
９５……通信インタフェース
１００……データ群登録要求
１０１……データ群登録情報
１０２……全データ群登録情報
１１０……収集登録要求
１１１……収集登録情報
１１２……全収集登録情報
１２０……収集対象データ、処理結果データ
３０１……処理対象データ群登録情報取得ステップ
３０２……全収集登録情報取得ステップ
３０３……処理対象データ取得ステップ
３０４……収集データ処理ステップ
３０５……該処理プログラム用データ群登録情報取得ステップ
３０６……該処理プログラム用収集登録要求送信ステップ
３０７……該処理プログラム用収集登録情報取得ステップ
３０８……処理結果データ送信ステップ
４００……ブローカ手段上の宛先
４０１……データ群登録要求宛先
４０２……各データ群登録情報提供宛先
４０３……全データ群登録情報提供宛先
４１０……データ群用宛先階層
４１１……収集登録要求宛先
４１２……各収集登録情報提供宛先
４１３……全収集登録情報提供宛先
４２０……収集用宛先階層
４２１……収集対象データ／処理結果データ送信用宛先
【図１】
2017091454.tif 000003
【図２】
2017091454.tif 000004
【図３】
2017091454.tif 000005
【図４】
2017091454.tif 000006
【図５】
2017091454.tif 000007
【図６】
2017091454.tif 000008
【図７】
2017091454.tif 000009
【図８】
2017091454.tif 000010
【図９】
2017091454.tif 000011
【図１０】
2017091454.tif 000012
【図１１】
2017091454.tif 000013
【図１２】
2017091454.tif 000014
【図１３】
2017091454.tif 000015
【図１４】
2017091454.tif 000016
【図１５】
2017091454.tif 000017
【図１６】
2017091454.tif 000018
【図１７】
2017091454.tif 000019
【図１８】
2017091454.tif 000020
【図１９】
2017091454.tif 000021
【図２０】
2017091454.tif 000022
【図２１】
2017091454.tif 000023
【図２２】
2017091454.tif 000024
【図２３】
2017091454.tif 000025
【図２４】
2017091454.tif 000026
【図２５】
2017091454.tif 000027
【図２６】
2017091454.tif 000028
【図２７】
2017091454.tif 000029
【図２８】
2017091454.tif 000030
【図２９】
2017091454.tif 000031
【図３０】
2017091454.tif 000032
【図３１】
2017091454.tif 000033
【図３２】
2017091454.tif 000034
【図３３】
2017091454.tif 000035
【図３４】
2017091454.tif 000036
【図３５】
2017091454.tif 000037
【図３６】
2017091454.tif 000038
【図３７】
2017091454.tif 000039
【図３８】
2017091454.tif 000040
【図３９】
2017091454.tif 000041
【図４０】
2017091454.tif 000042
【図４１】
2017091454.tif 000043
【図４２】
2017091454.tif 000044
【図４３】
2017091454.tif 000045
【図４４】
2017091454.tif 000046
【図４５】
2017091454.tif 000047
【図４６】
2017091454.tif 000048
【図４７】
2017091454.tif 000049
【図４８】
2017091454.tif 000050
【図４９】
2017091454.tif 000051
【図５０】
2017091454.tif 000052