(57)【要約】【課題】共通のシステムで収集対象として様々な形式のデータを扱えるようにする。【解決手段】データ収集システム５００において、複数の収集装置３００は、情報１０１を収集し、情報１０１を収集装置３００ごとに決められたデータ構造を持つ収集データ３０２に変換し、収集装置３００を識別する収集装置識別子を収集データ３０２に付加し、収集装置識別子付きの収集データ３０２を送信する。サーバ装置４００は、複数の収集装置３００のそれぞれから収集装置識別子付きの収集データ３０２を受信し、収集装置識別子から収集データ３０２のデータ構造を特定し、特定したデータ構造に応じて収集データ３０２を解析することで情報１０１を抽出する。【選択図】図１
2018055457.tif 000002
【特許請求の範囲】
【請求項１】
情報を収集し、前記情報を収集装置ごとに決められたデータ構造を持つ収集データに変換し、収集装置を識別する収集装置識別子を前記収集データに付加し、前記収集装置識別子付きの前記収集データを送信する複数の収集装置と、
前記複数の収集装置のそれぞれから前記収集装置識別子付きの前記収集データを受信し、前記収集装置識別子から前記収集データのデータ構造を特定し、特定したデータ構造に応じて前記収集データを解析することで前記情報を抽出するサーバ装置と
を備えるデータ収集システム。
【請求項２】
前記サーバ装置は、前記収集装置識別子から収集装置ごとに決められた処理種別を特定し、特定した処理種別の情報処理を前記情報に対して実行する請求項１に記載のデータ収集システム。
【請求項３】
前記収集データのデータ構造として、前記情報を文字列で表す形式が収集装置ごとに決められている請求項１または２に記載のデータ収集システム。
【請求項４】
前記複数の収集装置は、前記収集装置識別子を表す文字列を含む第１文字列と、前記情報を表す文字列を含む第２文字列とを前記収集装置識別子付きの前記収集データに含める請求項３に記載のデータ収集システム。
【請求項５】
前記複数の収集装置は、前記情報を表す文字列を前記第２文字列に２つ以上含める場合、区切り文字を前記第２文字列の、当該２つ以上の文字列の間に挿入する請求項４に記載のデータ収集システム。
【請求項６】
前記複数の収集装置は、前記収集装置識別子を表す文字列として、前記複数の収集装置の間で共通の長さの文字列を前記第１文字列の先頭に配置する請求項４または５に記載のデータ収集システム。
【請求項７】
前記複数の収集装置のうち少なくとも１つの収集装置は、複数の機器から前記情報を収集し、
前記第１文字列の、前記収集装置識別子を表す文字列の後には、前記情報の取得源となった機器を識別する機器識別子を表す文字列が含まれている請求項４から６のいずれか１項に記載のデータ収集システム。
【請求項８】
前記少なくとも１つの収集装置は、前記機器識別子を表す文字列を前記第１文字列に２つ以上含める場合、区切り文字を前記第１文字列の、当該２つ以上の文字列の間に挿入する請求項７に記載のデータ収集システム。
【請求項９】
前記少なくとも１つの収集装置は、前記複数の機器のうち２つ以上の機器から前記情報として個別の値を取得した場合、前記機器識別子を表す文字列を前記第１文字列に含める順序と同じ順序で、前記機器識別子に対応する機器から取得した値を表す文字列を前記第２文字列に含める請求項７または８に記載のデータ収集システム。
【請求項１０】
情報を収集する収集装置において、
前記情報を収集装置ごとに決められたデータ構造を持つ収集データに変換し、収集装置を識別する収集装置識別子を前記収集データに付加する変換部と、
前記収集装置識別子付きの前記収集データを送信する通信部と
を備える収集装置。
【請求項１１】
情報を収集する収集装置として機能するコンピュータに、
前記情報を収集装置ごとに決められたデータ構造を持つ収集データに変換し、収集装置を識別する収集装置識別子を前記収集データに付加する変換処理と、
前記収集装置識別子付きの前記収集データを送信する通信処理と
を実行させる情報収集プログラム。
【請求項１２】
情報を収集し前記情報を収集装置ごとに決められたデータ構造を持つ収集データに変換し収集装置を識別する収集装置識別子を前記収集データに付加する複数の収集装置のそれぞれから前記収集装置識別子付きの前記収集データを受信する通信部と、
前記収集装置識別子から前記収集データのデータ構造を特定し、特定したデータ構造に応じて前記収集データを解析することで前記情報を抽出する解析部と
を備えるサーバ装置。
【請求項１３】
コンピュータに、
情報を収集し前記情報を収集装置ごとに決められたデータ構造を持つ収集データに変換し収集装置を識別する収集装置識別子を前記収集データに付加する複数の収集装置のそれぞれから前記収集装置識別子付きの前記収集データを受信する通信処理と、
前記収集装置識別子から前記収集データのデータ構造を特定し、特定したデータ構造に応じて前記収集データを解析することで前記情報を抽出する解析処理と
を実行させるサーバプログラム。
【発明の詳細な説明】
【技術分野】
【０００１】
本発明は、データ収集システム、収集装置、情報収集プログラム、サーバ装置およびサーバプログラムに関するものである。
【背景技術】
【０００２】
特許文献１には、コンピュータの監視情報のデータ構造をＣＩＭ形式で標準化する技術が記載されている。「ＣＩＭ」は、Ｃｏｍｍｏｎ  Ｉｎｆｏｒｍａｔｉｏｎ  Ｍｏｄｅｌの略語である。
【先行技術文献】
【特許文献】
【０００３】
【特許文献１】特開２０１２−１６４１１７号公報
【発明の概要】
【発明が解決しようとする課題】
【０００４】
インターネット経由でデータ収集を行うシステムでは、監視対象の機器より出力されるデータが、中継装置を経由して収集装置へ送信されるか、もしくは、収集装置へ直接送信される。収集装置は、中継装置もしくは監視機器より送信されたデータを、インターネットを経由して専用のサーバへ送信する。サーバは、収集装置より送信されたデータをデータベースに登録する。サーバは、必要に応じて、データをユーザに提供したり、データを分析して分析結果をユーザに通知したりする。
【０００５】
監視対象の機器より出力されるデータは、ユーザの業務内容に応じて内容および形式が異なるため、特許文献１に記載されている監視情報のように、単にデータ構造を標準化すればよいというものではない。しかし、それぞれでシステムを個別に用意しなければならないとすれば、システムごとに設備の用意が必要になり、また、システムごとに開発費用がかかることになってしまう。
【０００６】
本発明は、共通のシステムで収集対象として様々な形式のデータを扱えるようにすることを目的とする。
【課題を解決するための手段】
【０００７】
本発明の一態様に係るデータ収集システムは、
情報を収集し、前記情報を収集装置ごとに決められたデータ構造を持つ収集データに変換し、収集装置を識別する収集装置識別子を前記収集データに付加し、前記収集装置識別子付きの前記収集データを送信する複数の収集装置と、
前記複数の収集装置のそれぞれから前記収集装置識別子付きの前記収集データを受信し、前記収集装置識別子から前記収集データのデータ構造を特定し、特定したデータ構造に応じて前記収集データを解析することで前記情報を抽出するサーバ装置とを備える。
【発明の効果】
【０００８】
本発明では、収集装置より送信されるデータに付加された収集装置の識別子からデータ構造を特定できるため、共通のシステムで収集対象として様々な形式のデータを扱えるようになる。
【図面の簡単な説明】
【０００９】
【図１】実施の形態１に係るデータ収集システムの構成を示すブロック図。
【図２】実施の形態１に係る収集装置の構成を示すブロック図。
【図３】実施の形態１に係るデータ収集サーバの構成を示すブロック図。
【図４】実施の形態１に係るデータ処理サーバの構成を示すブロック図。
【図５】実施の形態１に係る収集装置の動作を示すフローチャート。
【図６】実施の形態１に係るデータ収集サーバの動作を示すフローチャート。
【図７】実施の形態１に係るデータ処理サーバの動作を示すフローチャート。
【発明を実施するための形態】
【００１０】
以下、本発明の実施の形態について、図を用いて説明する。各図中、同一または相当する部分には、同一符号を付している。実施の形態の説明において、同一または相当する部分については、説明を適宜省略または簡略化する。なお、本発明は、以下に説明する実施の形態に限定されるものではなく、必要に応じて種々の変更が可能である。例えば、以下に説明する実施の形態は、部分的に実施されても構わない。
【００１１】
実施の形態１．
本実施の形態について、図１から図７を用いて説明する。
【００１２】
＊＊＊構成の説明＊＊＊
図１を参照して、本実施の形態に係るデータ収集システム５００の構成を説明する。
【００１３】
データ収集システム５００は、複数の機器１００と、複数の中継装置２００と、複数の収集装置３００と、サーバ装置４００とを備える。
【００１４】
機器１００は、収集対象となる値を出力または計測し、その値を含むデータを、中継装置２００を経由して収集装置３００へ送信するか、または、収集装置３００へ直接送信する装置である。本実施の形態では、機器１００として、電力値検出機器１１０、温湿度検出機器１２０および位置情報検出機器１３０が備えられている。
【００１５】
電力値検出機器１１０は、電力値および電圧値を計測する装置である。電力値検出機器１１０は、例えば、スマートメータである。電力値検出機器１１０の数は、任意の数でよいが、本実施の形態では、電力値検出機器Ａ１、電力値検出機器Ａ２および電力値検出機器Ａ３の３つである。
【００１６】
温湿度検出機器１２０は、気温および湿度を計測する装置である。温湿度検出機器１２０は、例えば、温湿度センサである。温湿度検出機器１２０の数は、任意の数でよいが、本実施の形態では、温湿度検出機器Ａ４の１つである。
【００１７】
位置情報検出機器１３０は、緯度経度といった位置情報を出力する装置である。位置情報検出機器１３０は、例えば、ＧＰＳ受信機である。「ＧＰＳ」は、Ｇｌｏｂａｌ  Ｐｏｓｉｔｉｏｎｉｎｇ  Ｓｙｓｔｅｍの略語である。位置情報検出機器１３０の数は、任意の数でよいが、本実施の形態では、位置情報検出機器Ａ５および位置情報検出機器Ａ６の２つである。
【００１８】
中継装置２００は、機器１００からのデータを集約または加工して収集装置３００へ送信する装置である。中継装置２００の数は、任意の数でよいが、本実施の形態では、１つの温湿度検出機器１２０に対して中継装置Ｂ１の１つ、および、２つの位置情報検出機器１３０に対して中継装置Ｂ２の１つである。なお、中継装置２００は、データを収集装置３００へ直接送信する機器１００に対しては備えられる必要がない。本実施の形態では、３つの電力値検出機器１１０に対しては、中継装置２００が１つも備えられていない。
【００１９】
収集装置３００は、機器１００からのデータを集約してインターネット等のネットワーク５１０経由でサーバ装置４００へ送信する装置である。収集装置３００の数は、任意の数でよいが、本実施の形態では、機器１００の１つの種別に対して１つである。具体的には、３つの電力値検出機器１１０に対して収集装置Ｃ１が備えられ、１つの温湿度検出機器１２０に対して収集装置Ｃ２が備えられ、２つの位置情報検出機器１３０に対して収集装置Ｃ３が備えられている。３つの電力値検出機器１１０のうち２つが収集装置Ｃ１に接続され、１つが別の収集装置３００に接続されていてもよい。
【００２０】
いずれの収集装置３００にも、共通ライブラリ３０１が組み込まれている。共通ライブラリ３０１は、収集装置３００がサーバ装置４００に対して送信するデータの枠組みを統一するための機能を持つプログラム部品である。
【００２１】
サーバ装置４００は、収集装置３００より送信されたデータを解析し、監視処理および通知処理等を行うサーバまたはサーバグループである。サーバ装置４００は、例えば、クラウドシステムとして実装される。
【００２２】
サーバ装置４００は、１つの統合されたサーバでもよいが、本実施の形態では、データ収集サーバ４１０と、データ処理サーバ４２０と、データベース４３０とを備える。
【００２３】
データベース４３０は、データ収集サーバ４１０およびデータ処理サーバ４２０のいずれかに組み込まれていてもよいし、データ収集サーバ４１０およびデータ処理サーバ４２０のそれぞれに分散して組み込まれてもよいが、本実施の形態では、独立したデータベースサーバである。データベース４３０は、少なくとも１つのテーブルからなる共有エリア４３１と、収集装置３００ごと、あるいは、機器１００ごとに分けられた複数のテーブルからなる固有エリア４３２とを有する。
【００２４】
データ収集サーバ４１０は、収集装置３００より送信されたデータを受信してデータベース４３０の共有エリア４３１へ登録するサーバである。
【００２５】
データ処理サーバ４２０は、データベース４３０の共有エリア４３１に登録されているデータを定期的に確認し、データを解析して、機器１００が出力または計測した値を取り出し、取り出した値をデータベース４３０の固有エリア４３２へ登録するサーバである。後述するように、データ処理サーバ４２０は、共通処理と、収集装置３００ごとに専用の解析処理と、収集装置３００ごとに専用の判定処理とを実行する。
【００２６】
図２を参照して、本実施の形態に係る収集装置３００の構成を説明する。
【００２７】
収集装置３００は、コンピュータである。収集装置３００は、プロセッサ３１１を備えるとともに、メモリ３１２および通信装置３１３といった他のハードウェアを備える。プロセッサ３１１は、信号線を介して他のハードウェアと接続され、これら他のハードウェアを制御する。
【００２８】
収集装置３００は、機能要素として、収集部３２１と、変換部３２２と、通信部３２３とを備える。収集部３２１、変換部３２２および通信部３２３の機能は、ソフトウェアにより実現される。
【００２９】
プロセッサ３１１は、各種処理を行うＩＣである。「ＩＣ」は、Ｉｎｔｅｇｒａｔｅｄ
Ｃｉｒｃｕｉｔの略語である。プロセッサ３１１は、例えば、ＣＰＵである。「ＣＰＵ」は、Ｃｅｎｔｒａｌ  Ｐｒｏｃｅｓｓｉｎｇ  Ｕｎｉｔの略語である。
【００３０】
メモリ３１２には、共通ライブラリ３０１が予め記憶されている。メモリ３１２には、複数の機器１００から収集された情報１０１と、情報１０１を変換して得られる収集データ３０２とが記憶される。情報１０１には、機器１００が出力または計測した値が含まれる。メモリ３１２は、例えば、フラッシュメモリまたはＲＡＭである。「ＲＡＭ」は、Ｒａｎｄｏｍ  Ａｃｃｅｓｓ  Ｍｅｍｏｒｙの略語である。
【００３１】
通信装置３１３は、データを受信するレシーバおよびデータを送信するトランスミッタを含む。レシーバは、特に、機器１００または中継装置２００からデータを受信するために用いられる。トランスミッタは、特に、ネットワーク５１０経由でサーバ装置４００へデータを送信するために用いられる。通信装置３１３は、例えば、通信チップまたはＮＩＣである。「ＮＩＣ」は、Ｎｅｔｗｏｒｋ  Ｉｎｔｅｒｆａｃｅ  Ｃａｒｄの略語である。
【００３２】
メモリ３１２には、収集部３２１、変換部３２２および通信部３２３の機能を実現するプログラムである情報収集プログラムが記憶されている。情報収集プログラムは、プロセッサ３１１に読み込まれ、プロセッサ３１１によって実行される。メモリ３１２には、ＯＳも記憶されている。「ＯＳ」は、Ｏｐｅｒａｔｉｎｇ  Ｓｙｓｔｅｍの略語である。プロセッサ３１１は、ＯＳを実行しながら、情報収集プログラムを実行する。なお、情報収集プログラムの一部または全部がＯＳに組み込まれていてもよい。
【００３３】
情報収集プログラムおよびＯＳは、補助記憶装置に記憶されていてもよい。補助記憶装置は、例えば、フラッシュメモリまたはＨＤＤである。「ＨＤＤ」は、Ｈａｒｄ  Ｄｉｓｋ  Ｄｒｉｖｅの略語である。補助記憶装置に記憶されている情報収集プログラムおよびＯＳは、メモリ３１２にロードされ、プロセッサ３１１によって実行される。
【００３４】
収集装置３００は、プロセッサ３１１を代替する複数のプロセッサを備えていてもよい。これら複数のプロセッサは、情報収集プログラムの実行を分担する。それぞれのプロセッサは、プロセッサ３１１と同じように、各種処理を行うＩＣである。
【００３５】
収集部３２１、変換部３２２および通信部３２３の処理の結果を示す情報、データ、信号値および変数値は、メモリ３１２、補助記憶装置、または、プロセッサ３１１内のレジスタまたはキャッシュメモリに記憶される。
【００３６】
情報収集プログラムは、磁気ディスクおよび光ディスクといった可搬記録媒体に記憶されてもよい。
【００３７】
図３を参照して、本実施の形態に係るデータ収集サーバ４１０の構成を説明する。
【００３８】
データ収集サーバ４１０は、コンピュータである。データ収集サーバ４１０は、プロセッサ４１１を備えるとともに、メモリ４１２および通信装置４１３といった他のハードウェアを備える。プロセッサ４１１は、信号線を介して他のハードウェアと接続され、これら他のハードウェアを制御する。
【００３９】
データ収集サーバ４１０は、機能要素として、通信部４４１と、登録部４４２とを備える。通信部４４１および登録部４４２の機能は、ソフトウェアにより実現される。
【００４０】
プロセッサ４１１は、各種処理を行うＩＣである。プロセッサ４１１は、例えば、ＣＰＵである。
【００４１】
メモリ４１２には、収集装置３００から受信された収集データ３０２が記憶される。メモリ４１２は、例えば、フラッシュメモリまたはＲＡＭである。
【００４２】
通信装置４１３は、データを受信するレシーバおよびデータを送信するトランスミッタを含む。レシーバは、特に、ネットワーク５１０経由でサーバ装置４００からデータを受信するために用いられる。トランスミッタは、特に、データベース４３０へデータを送信するために用いられる。通信装置４１３は、例えば、通信チップまたはＮＩＣである。
【００４３】
メモリ４１２には、通信部４４１および登録部４４２の機能を実現するプログラムである第１サーバプログラムが記憶されている。第１サーバプログラムは、プロセッサ４１１に読み込まれ、プロセッサ４１１によって実行される。メモリ４１２には、ＯＳも記憶されている。プロセッサ４１１は、ＯＳを実行しながら、第１サーバプログラムを実行する。なお、第１サーバプログラムの一部または全部がＯＳに組み込まれていてもよい。
【００４４】
第１サーバプログラムおよびＯＳは、補助記憶装置に記憶されていてもよい。補助記憶装置は、例えば、フラッシュメモリまたはＨＤＤである。補助記憶装置に記憶されている第１サーバプログラムおよびＯＳは、メモリ４１２にロードされ、プロセッサ４１１によって実行される。
【００４５】
データ収集サーバ４１０は、プロセッサ４１１を代替する複数のプロセッサを備えていてもよい。これら複数のプロセッサは、第１サーバプログラムの実行を分担する。それぞれのプロセッサは、プロセッサ４１１と同じように、各種処理を行うＩＣである。
【００４６】
通信部４４１および登録部４４２の処理の結果を示す情報、データ、信号値および変数値は、メモリ４１２、補助記憶装置、または、プロセッサ４１１内のレジスタまたはキャッシュメモリに記憶される。
【００４７】
第１サーバプログラムは、磁気ディスクおよび光ディスクといった可搬記録媒体に記憶されてもよい。
【００４８】
図４を参照して、本実施の形態に係るデータ処理サーバ４２０の構成を説明する。
【００４９】
データ処理サーバ４２０は、コンピュータである。データ処理サーバ４２０は、プロセッサ４２１を備えるとともに、メモリ４２２および通信装置４２３といった他のハードウェアを備える。プロセッサ４２１は、信号線を介して他のハードウェアと接続され、これら他のハードウェアを制御する。
【００５０】
データ処理サーバ４２０は、機能要素として、解析部４４３と、判定部４４４とを備える。解析部４４３および判定部４４４の機能は、ソフトウェアにより実現される。
【００５１】
プロセッサ４２１は、各種処理を行うＩＣである。プロセッサ４２１は、例えば、ＣＰＵである。
【００５２】
メモリ４２２には、解析処理により得られた情報１０１が記憶される。メモリ４２２は、例えば、フラッシュメモリまたはＲＡＭである。
【００５３】
通信装置４２３は、データを受信するレシーバおよびデータを送信するトランスミッタを含む。レシーバは、特に、データベース４３０からデータを受信するために用いられる。トランスミッタは、特に、データベース４３０または図示していないユーザ端末へデータを送信するために用いられる。通信装置４２３は、例えば、通信チップまたはＮＩＣである。
【００５４】
メモリ４２２には、解析部４４３および判定部４４４の機能を実現するプログラムである第２サーバプログラムが記憶されている。第２サーバプログラムは、プロセッサ４２１に読み込まれ、プロセッサ４２１によって実行される。メモリ４２２には、ＯＳも記憶されている。プロセッサ４２１は、ＯＳを実行しながら、第２サーバプログラムを実行する。なお、第２サーバプログラムの一部または全部がＯＳに組み込まれていてもよい。
【００５５】
第２サーバプログラムおよびＯＳは、補助記憶装置に記憶されていてもよい。補助記憶装置は、例えば、フラッシュメモリまたはＨＤＤである。補助記憶装置に記憶されている第２サーバプログラムおよびＯＳは、メモリ４２２にロードされ、プロセッサ４２１によって実行される。
【００５６】
データ処理サーバ４２０は、プロセッサ４２１を代替する複数のプロセッサを備えていてもよい。これら複数のプロセッサは、第２サーバプログラムの実行を分担する。それぞれのプロセッサは、プロセッサ４２１と同じように、各種処理を行うＩＣである。
【００５７】
解析部４４３および判定部４４４の処理の結果を示す情報、データ、信号値および変数値は、メモリ４２２、補助記憶装置、または、プロセッサ４２１内のレジスタまたはキャッシュメモリに記憶される。
【００５８】
第２サーバプログラムは、磁気ディスクおよび光ディスクといった可搬記録媒体に記憶されてもよい。
【００５９】
上記のように、サーバ装置４００は、機能要素として、通信部４４１と、登録部４４２と、解析部４４３と、判定部４４４とを備える。通信部４４１、登録部４４２、解析部４４３および判定部４４４の機能は、ソフトウェアにより実現される。
【００６０】
＊＊＊動作の説明＊＊＊
主に図１を参照して、本実施の形態に係るデータ収集システム５００の動作の概要を説明する。データ収集システム５００の動作は、本実施の形態に係るデータ収集方法に相当する。
【００６１】
収集装置３００は、機器１００からの情報１０１を集約する。収集装置３００には、共通ライブラリ３０１が導入されており、収集装置３００は、この共通ライブラリ３０１を用いて情報１０１を収集データ３０２に変換する。このとき、収集装置３００は、収集装置３００を識別するＩＤを収集データ３０２に含めておく。「ＩＤ」は、ＩＤｅｎｔｉｆｉｅｒの略語である。収集装置３００は、収集データ３０２をインターネット等のネットワーク５１０経由でデータ収集サーバ４１０に送信する。
【００６２】
データ収集サーバ４１０は、収集データ３０２をデータベース４３０に送信して共有エリア４３１へ登録する。
【００６３】
データ処理サーバ４２０は、共有エリア４３１に登録されている収集データ３０２に相当するレコードをデータベース４３０から受信する。データ処理サーバ４２０は、共通処理として、そのレコードに含まれているＩＤから収集装置３００を特定する処理を実行する。データ処理サーバ４２０は、共通処理の結果として特定された収集装置３００に応じた解析処理および判定処理を実行する。
【００６４】
上記のような動作により、１つの収集装置３００に対して１つの専用システムを構築する必要がなくなり、様々な収集装置３００からのデータを１つのシステムにて扱うことが可能となる。
【００６５】
主に図５を参照して、本実施の形態に係る収集装置３００の動作を説明する。
【００６６】
ステップＳ１１において、収集部３２１は、情報１０１を収集する。
【００６７】
ステップＳ１２において、変換部３２２は、共通ライブラリ３０１を用いて、情報１０１を収集装置３００ごとに決められたデータ構造を持つ収集データ３０２に変換する。このとき、変換部３２２は、情報１０１を表す文字列を生成し、生成した文字列を収集データ３０２に含める。
【００６８】
ステップＳ１３において、変換部３２２は、収集装置３００を識別する収集装置識別子を収集データ３０２に付加する。
【００６９】
ステップＳ１４において、通信部３２３は、収集装置識別子付きの収集データ３０２をデータ収集サーバ４１０に送信する。
【００７０】
収集データ３０２は、すべての収集装置３００の間で共通の枠組みを持つデータである。図１に示したように、本実施の形態では、収集データ３０２の枠組みとして、第１文字列と、第２文字列と、第３文字列と、タイムスタンプとで構成される枠組みが規定されている。収集データ３０２は、ＸＭＬのようなマークアップ言語で作成されることが望ましく、その場合、第１文字列、第２文字列、第３文字列およびタイムスタンプを、それぞれ独自のタグによって区別することが可能となる。「ＸＭＬ」は、Ｅｘｔｅｎｓｉｂｌｅ  Ｍａｒｋｕｐ  Ｌａｎｇｕａｇｅの略語である。なお、文字列の数は、３つに限るものではないが、解析処理の負荷が過大になることを避けるため、あまり多くないことが望ましい。
【００７１】
ここで、収集装置識別子付きの収集データ３０２の具体例を２つ示す。
【００７２】
例１：
＜第１文字列＞Ｃ１％Ａ１％Ａ２％Ａ３
＜第２文字列＞１００％１０％５０
＜第３文字列＞Ｐ％Ｐ％Ｐ
＜タイムスタンプ＞２０１６−０８−２２  １０：５１：００
【００７３】
例２：
＜第１文字列＞Ｃ２％Ａ４
＜第２文字列＞３０％６０
＜第３文字列＞Ａ％２０１６０８２２１０５０２３
＜タイムスタンプ＞２０１６−０８−２２  １０：５１：００
【００７４】
第１文字列には、収集装置識別子を表す文字列が含まれている。本実施の形態では、変換部３２２は、収集装置識別子を表す文字列として、３つの収集装置３００の間で共通の長さの文字列を第１文字列の先頭に配置する。具体例では、第１文字列の先頭の２桁が収集装置識別子を表す文字列になっている。例１では、収集装置Ｃ１のＩＤを表す「Ｃ１」が第１文字列の先頭に配置されている。例２では、収集装置Ｃ２のＩＤを表す「Ｃ２」が第１文字列の先頭に配置されている。なお、収集装置識別子を表す文字列の長さは、３つの収集装置３００の間で共通になっていれば、任意の長さでよい。
【００７５】
本実施の形態では、３つの収集装置３００のうち少なくとも１つの収集装置３００は、複数の機器１００から情報１０１を収集する。例えば、収集装置Ｃ１は、３つの電力値検出機器１１０から情報１０１を収集する。そのため、第１文字列の、収集装置識別子を表す文字列の後には、情報１０１の取得源となった機器１００を識別する機器識別子を表す文字列が含まれている。例１では、電力値検出機器Ａ１、電力値検出機器Ａ２および電力値検出機器Ａ３のＩＤを表す「Ａ１」、「Ａ２」および「Ａ３」が、収集装置Ｃ１のＩＤを表す「Ｃ１」の後に配置されている。例２でも、温湿度検出機器Ａ４のＩＤを表す「Ａ４」が、収集装置Ｃ２のＩＤを表す「Ｃ２」の後に配置されているが、この「Ａ４」は省略してもよい。
【００７６】
例１および例２では、収集装置識別子を表す文字列と機器識別子を表す文字列との間に区切り文字が挿入されているが、この区切り文字は省略してもよい。
【００７７】
変換部３２２は、機器識別子を表す文字列を第１文字列に２つ以上含める場合、区切り文字を第１文字列の、当該２つ以上の文字列の間に挿入する。例１および例２では、第１文字列の、機器識別子を表す文字列同士が「％」で区切られている。
【００７８】
第２文字列には、情報１０１を表す文字列が含まれている。例１では、電力値検出機器Ａ１、電力値検出機器Ａ２および電力値検出機器Ａ３から取得された電力値を表す「１００」、「１０」および「５０」が第２文字列に含まれている。例２では、温湿度検出機器Ａ４から取得された気温および湿度の値を表す「３０」および「６０」が第２文字列に含まれている。
【００７９】
第２文字列に含まれる文字列自体については、形式が統一されておらず、収集装置３００ごとに個別の形式が規定されている。すなわち、本実施の形態では、収集データ３０２のデータ構造として、情報１０１を文字列で表す形式が収集装置３００ごとに決められている。
【００８０】
変換部３２２は、情報１０１を表す文字列を第２文字列に２つ以上含める場合、区切り文字を第２文字列の、当該２つ以上の文字列の間に挿入する。例１および例２では、第２文字列の、情報１０１を表す文字列同士が「％」で区切られている。
【００８１】
変換部３２２は、２つ以上の機器１００から情報１０１として個別の値を取得した場合、機器識別子を表す文字列を第１文字列に含める順序と同じ順序で、機器識別子に対応する機器１００から取得した値を表す文字列を第２文字列に含める。例１では、電力値検出機器Ａ１のＩＤを表す「Ａ１」が第１文字列の先頭に最も近い位置に配置されているため、電力値検出機器Ａ１から取得された電力値を表す「１００」が第２文字列の先頭に配置されている。電力値検出機器Ａ２のＩＤを表す「Ａ２」が第１文字列の先頭に次に近い位置に配置されているため、電力値検出機器Ａ２から取得された電力値を表す「１０」が第２文字列の２番目に配置されている。そして、電力値検出機器Ａ３のＩＤを表す「Ａ３」が第１文字列の最後尾に配置されているため、電力値検出機器Ａ３から取得された電力値を表す「５０」が第２文字列の最後尾に配置されている。
【００８２】
第３文字列には、情報１０１の種別を表す文字列と、情報１０１の取得日時を表す文字列とのうち少なくともいずれかが含まれている。例１では、第２文字列に含まれる「１００」、「１０」および「５０」がパルス値を表す文字列であるため、情報１０１の種別がパルス値であることを表す「Ｐ」が第３文字列に含まれている。パルス値とは、単位時間における数量を示す値のことである。例２では、第２文字列に含まれる「３０」および「６０」がアナログ値を表す文字列であるため、情報１０１の種別がアナログ値であることを表す「Ａ」が第３文字列に含まれている。例２では、さらに、温湿度検出機器Ａ４から気温および湿度のアナログ値が取得された日時を表す「２０１６０８２２１０５０２３」が第３文字列に含まれている。
【００８３】
第２文字列と同じように、第３文字列に含まれる文字列自体については、形式が統一されておらず、収集装置３００ごとに個別の形式が規定されている。すなわち、本実施の形態では、収集データ３０２のデータ構造として、情報１０１の種別または取得日時を文字列で表す形式も収集装置３００ごとに決められている。
【００８４】
なお、ここでは、収集装置３００が情報１０１としてアナログ値またはパルス値を収集する例を挙げているが、収集装置３００は、デジタル値等、その他の種別の情報１０１を収集してもよい。
【００８５】
変換部３２２は、情報１０１の種別を表す文字列を第３文字列に２つ以上含める場合、区切り文字を第３文字列の、当該２つ以上の文字列の間に挿入する。例１では、第３文字列の、情報１０１の種別を表す文字列同士が「％」で区切られている。
【００８６】
変換部３２２は、情報１０１の種別を表す文字列と、情報１０１の取得日時を表す文字列との両方を第３文字列に含める場合、区切り文字を第３文字列の、情報１０１の種別を表す文字列と、情報１０１の取得日時を表す文字列との間に挿入する。例２では、第３文字列の、情報１０１の種別を表す文字列と、情報１０１の取得日時を表す文字列とが「％」で区切られている。
【００８７】
変換部３２２は、２つ以上の機器１００から情報１０１として個別の値を取得した場合、機器１００から取得した情報１０１を表す文字列を第２文字列に含める順序と同じ順序で、情報１０１の種別を表す文字列を第３文字列に含める。例１では、電力値検出機器Ａ１、電力値検出機器Ａ２および電力値検出機器Ａ３から取得された電力値がいずれもパルス値であるため、そのことを表す「Ｐ」が第３文字列に３つ配置されている。なお、変換部３２２は、第２文字列に情報１０１、第３文字列に情報１０１の種別を並べるときに、第１文字列とは異なる順序で並べてもよい。例えば、例１で示すと、第１文字列に電力値検出機器１１０のＩＤが「Ａ１」、「Ａ２」、「Ａ３」の順に並んでいるが、第２文字列には情報１０１が「Ａ３」、「Ａ２」、「Ａ１」の順に、第３文字列には情報１０１の種別が「Ａ２」、「Ａ３」、「Ａ１」の順に並んでいるように構成してもよい。この場合、解析部４４３が第２文字列以降の順番を記憶し、第１文字列のＩＤ順に並べ替えた上で、解析を行う機能を有する。
【００８８】
タイムスタンプは、収集データ３０２の送信日時を表すデータである。収集装置３００は、収集データ３０２を送信する前に、タイムスタンプを収集データ３０２に付加する。
【００８９】
本実施の形態では、収集装置３００は、異常の発生を検知した場合、異常の発生を示すデータを収集データ３０２に埋め込むことで、サーバ装置４００に対して異常の発生を通知する。
【００９０】
ここで、収集装置識別子付きの収集データ３０２の別の具体例を２つ示す。
【００９１】
例３：
＜第１文字列＞Ｃ１％Ａ１％Ａ２％Ａ３
＜第２文字列＞Ｎ％１０％５０
＜第３文字列＞Ｎ％Ｐ％Ｐ
＜タイムスタンプ＞２０１６−０８−２２  １０：５１：００
【００９２】
例４：
＜第１文字列＞Ｃ２％Ａ４
＜第２文字列＞Ｘ
＜タイムスタンプ＞２０１６−０８−２２  １０：５１：００
【００９３】
変換部３２２は、収集装置３００が、対応する機器１００のいずれかと通信不能になった場合、該当する機器１００から取得した値を表す文字列の代わりに、該当する機器１００と通信不能であることを表す文字列を第２文字列に含める。例３では、収集装置Ｃ１が電力値検出機器Ａ１と通信不能になっているため、例１の第２文字列の、電力値検出機器Ａ１から取得された電力値を表す「１００」が「Ｎ」に置き換わっている。例１の第３文字列の、電力値検出機器Ａ１から取得された情報１０１の種別を表す「Ｐ」も「Ｎ」に置き換わっているが、この「Ｎ」は、省略されてもよい。
【００９４】
変換部３２２は、収集部３２１が、対応する機器１００のいずれかから情報１０１として異常な値を取得した場合、該当する機器１００から取得した値を表す文字列の代わりに、該当する機器１００から異常な値を取得したことを表す文字列を第２文字列に含める。例４では、温湿度検出機器Ａ４から気温または湿度として現実にはあり得ない値、あるいは、アナログ値とは異なる種別の値が送信されてきたため、第２文字列が「Ｘ」になっている。第３文字列は省略されているが、変形例として、第３文字列が第２文字列と同様に、異常な値を取得したことを表す「Ｘ」になっていてもよい。
【００９５】
主に図６を参照して、本実施の形態に係るデータ収集サーバ４１０の動作を説明する。
【００９６】
ステップＳ２１において、通信部４４１は、複数の収集装置３００のそれぞれから収集装置識別子付きの収集データ３０２を受信する。
【００９７】
ステップＳ２２において、登録部４４２は、収集装置識別子付きの収集データ３０２を分解してデータベース４３０に登録する。具体的には、登録部４４２は、ステップＳ２１で受信された収集データ３０２をデータベース４３０の共有エリア４３１のテーブルにレコードとして追加する。共有エリア４３１のテーブルは、収集装置識別子付きの収集データ３０２に含まれる第１文字列、第２文字列、第３文字列およびタイムスタンプのそれぞれに対応するカラムを有する。このため、１つのレコードには、第１文字列、第２文字列、第３文字列およびタイムスタンプが１つずつ含まれることになる。
【００９８】
主に図７を参照して、本実施の形態に係るデータ処理サーバ４２０の動作を説明する。
【００９９】
ステップＳ３１において、解析部４４３は、データベース４３０から、収集装置識別子付きの収集データ３０２に相当するレコードを取得する。具体的には、解析部４４３は、共通処理の一部として、データベース４３０の共有エリア４３１のテーブルから、まだ専用解析処理の対象となっていないレコードを取得する。
【０１００】
ステップＳ３２において、解析部４４３は、レコードから収集装置識別子を取得する。具体的には、解析部４４３は、ステップＳ３１で取得したレコードに含まれる第１文字列の先頭の２桁を読み込む。
【０１０１】
ステップＳ３３において、解析部４４３は、収集装置識別子から収集データ３０２のデータ構造を特定する。具体的には、解析部４４３は、ステップＳ３２で読み込んだ第１文字列の先頭の２桁が「Ｃ１」と「Ｃ２」と「Ｃ３」とのいずれであるかを判定する。「Ｃ１」であれば、ステップＳ３４の処理が行われることになる。「Ｃ２」であれば、ステップＳ３５の処理が行われることになる。「Ｃ３」であれば、ステップＳ３６の処理が行われることになる。
【０１０２】
本実施の形態では、解析部４４３は、さらに、収集装置識別子から収集装置３００ごとに決められた処理種別を特定する。
【０１０３】
ステップＳ３４、ステップＳ３５またはステップＳ３６において、解析部４４３は、ステップ３３で特定したデータ構造に応じて収集データ３０２に相当するレコードを解析することで情報１０１を抽出する。
【０１０４】
本実施の形態では、解析部４４３は、さらに、ステップＳ３３で特定した処理種別の情報処理を情報１０１に対して実行する。
【０１０５】
ステップＳ３４では、解析部４４３は、専用解析処理Ｄ１を実行する。専用解析処理Ｄ１は、収集装置Ｃ１から送信された収集データ３０２の解析処理である。
【０１０６】
例１の収集データ３０２の解析処理が実行されるとすると、まず、解析部４４３は、ステップＳ３１で取得したレコードに含まれる第１文字列を分解して「Ａ１」、「Ａ２」および「Ａ３」の３つの文字列を得る。これにより、電力値検出機器Ａ１、電力値検出機器Ａ２および電力値検出機器Ａ３から情報１０１が取得されたことが認識される。次に、解析部４４３は、ステップＳ３１で取得したレコードに含まれる第２文字列を分解して「１００」、「１０」および「５０」の３つの文字列を得る。これにより、電力値検出機器Ａ１、電力値検出機器Ａ２および電力値検出機器Ａ３から情報１０１として取得された電力値が認識される。次に、解析部４４３は、ステップＳ３１で取得したレコードに含まれる第３文字列を分解して「Ｐ」、「Ｐ」および「Ｐ」の３つの文字列を得る。これにより、電力値検出機器Ａ１、電力値検出機器Ａ２および電力値検出機器Ａ３から情報１０１として取得された電力値がパルス値であることが認識される。続けて、解析部４４３は、データベース４３０の固有エリア４３２に含まれるテーブルのうち収集装置Ｃ１に対応するテーブルを選択する。解析部４４３は、選択したテーブルから、前回得た電力値検出機器Ａ１の積算値を取得し、その積算値と今回認識された電力値とを加算することで、電力値検出機器Ａ１の最新の積算値を得る。解析部４４３は、ステップＳ３１で取得したレコードに含まれるタイムスタンプによって示される日時とともに、電力値検出機器Ａ１の最新の積算値をテーブルに登録する。電力値検出機器Ａ２および電力値検出機器Ａ３についても、電力値検出機器Ａ１と同様の処理が行われる。これらの処理の内容は、ステップＳ３３で特定された処理種別によって決まるものである。
【０１０７】
ステップＳ３５では、解析部４４３は、専用解析処理Ｄ２を実行する。専用解析処理Ｄ２は、収集装置Ｃ２から送信された収集データ３０２の解析処理である。
【０１０８】
例２の収集データ３０２の解析処理が実行されるとすると、まず、解析部４４３は、ステップＳ３１で取得したレコードに含まれる第２文字列を分解して「３０」および「６０」の２つの文字列を得る。これにより、温湿度検出機器Ａ４から情報１０１として取得された気温および湿度の値が認識される。次に、解析部４４３は、ステップＳ３１で取得したレコードに含まれる第３文字列を分解して「Ａ」および「２０１６０８２２１０５０２３」の２つの文字列を得る。これにより、温湿度検出機器Ａ４から情報１０１として取得された気温および湿度の値がアナログ値であること、および、温湿度検出機器Ａ４から値が取得された日時が２０１６年８月２２日１０時５０分２３秒であることが認識される。続けて、解析部４４３は、データベース４３０の固有エリア４３２に含まれるテーブルのうち収集装置Ｃ２に対応するテーブルを選択する。解析部４４３は、今回認識された日時とともに、今回認識された気温および湿度の最新の値をテーブルに登録する。この処理の内容は、ステップＳ３３で特定された処理種別によって決まるものである。
【０１０９】
ステップＳ３６では、解析部４４３は、専用解析処理Ｄ３を実行する。専用解析処理Ｄ３は、収集装置Ｃ３から送信された収集データ３０２の解析処理である。
【０１１０】
ステップＳ３７、ステップＳ３８またはステップＳ３９において、判定部４４４は、ステップＳ３１で取得されたレコードに含まれる文字列から情報１０１の取得源および取得経路のいずれかにおける異常の発生有無を判定する。具体的には、判定部４４４は、第１文字列から情報１０１の取得源となった機器１００を特定し、特定した機器１００ごとに、第２文字列から異常の発生有無を判定する。本実施の形態では、以下のような７つの判定基準が定められている。
【０１１１】
・判定基準１：判定部４４４は、第２文字列によって表されたアナログ値が上限値を超過している場合に、異常が発生したと判定する。
・判定基準２：判定部４４４は、第２文字列によって表されたアナログ値が下限値を下回っている場合に、異常が発生したと判定する。
・判定基準３：判定部４４４は、第２文字列によって表されたデジタル値が基準値と異なっており、かつ、同じ収集装置３００によって同じ取得源から前回取得されたデジタル値とも異なっている場合に、異常が発生したと判定する。なお、基準値は、０または１等予め定められた値である。
・判定基準４：判定部４４４は、第２文字列によって表されたパルス値を積算して得られた積算値が上限値を超過している場合に、異常が発生したと判定する。
・判定基準５：判定部４４４は、第２文字列に、収集装置３００がいずれかの機器１００と通信不能であることを表す文字列が含まれている場合に、当該機器１００用のカウンタを１つインクリメントする。判定部４４４は、カウンタの数が規定数に達していれば、異常が発生したと判定する。判定部４４４は、第２文字列に、収集装置３００が当該機器１００から取得した情報１０１を表す文字列が含まれている場合には、カウンタをリセットする。すなわち、判定部４４４は、収集装置３００が同じ機器１００と規定回数連続で通信に失敗した場合に、異常が発生したと判定する。
・判定基準６：判定部４４４は、第２文字列に、収集装置３００がいずれかの機器１００から情報１０１として異常な値を取得したことを表す文字列が含まれている場合に、当該機器１００用のカウンタを１つインクリメントする。判定部４４４は、カウンタの数が規定数に達していれば、異常が発生したと判定する。判定部４４４は、第２文字列に、収集装置３００が当該機器１００から取得した情報１０１を表す文字列が含まれている場合には、カウンタをリセットする。すなわち、判定部４４４は、収集装置３００が同じ機器１００から情報１０１として異常な値を規定回数連続で取得した場合に、異常が発生したと判定する。なお、判定基準５の判定に使用されるカウンタと、判定基準６の判定に使用されるカウンタは、別々のものである。
・判定基準７：判定部４４４は、収集データ３０２が受信される度に記録される、収集データ３０２に付加されたタイムスタンプを一定間隔で参照し、３つの収集装置３００のいずれかから収集データ３０２が一定期間受信されていない場合に、異常が発生したと判定する。
【０１１２】
判定部４４４は、異常が発生したと判定した場合、異常が発生したことを示すメッセージをユーザ端末の画面に表示させたり、異常が発生したことを電子メールでユーザに通知したりする。
【０１１３】
ステップＳ３７では、判定部４４４は、専用判定処理Ｅ１を実行する。専用判定処理Ｅ１は、収集装置Ｃ１から送信された収集データ３０２に基づく判定処理である。
【０１１４】
例１の収集データ３０２に基づく判定処理が実行されるとすると、ステップＳ３４で得られた電力値検出機器Ａ１の最新の積算値が上限値を超過している場合、判定部４４４は、判定基準４に基づく異常が発生したと判定する。電力値検出機器Ａ２および電力値検出機器Ａ３についても、電力値検出機器Ａ１と同様に異常の発生有無が判定される。
【０１１５】
例３の収集データ３０２に基づく判定処理が実行されるとすると、ステップＳ３４で第２文字列から「Ｎ」が得られるため、判定部４４４は、判定基準５に基づく異常が発生したと判定する。
【０１１６】
ステップＳ３８では、判定部４４４は、専用判定処理Ｅ２を実行する。専用判定処理Ｅ２は、収集装置Ｃ２から送信された収集データ３０２に基づく判定処理である。
【０１１７】
例２の収集データ３０２に基づく判定処理が実行されるとすると、ステップＳ３５で得られた、温湿度検出機器Ａ４からの気温または湿度の値が上限値を超過している場合、判定部４４４は、判定基準１に基づく異常が発生したと判定する。また、ステップＳ３５で得られた、温湿度検出機器Ａ４からの気温または湿度の値が下限値を下回っている場合、判定部４４４は、判定基準２に基づく異常が発生したと判定する。
【０１１８】
例４の収集データ３０２に基づく判定処理が実行されるとすると、ステップＳ３５で第２文字列から「Ｘ」が得られるため、判定部４４４は、判定基準６に基づく異常が発生したと判定する。
【０１１９】
ステップＳ３９では、判定部４４４は、専用判定処理Ｅ３を実行する。専用判定処理Ｅ３は、収集装置Ｃ３から送信された収集データ３０２に基づく判定処理である。
【０１２０】
＊＊＊実施の形態の効果の説明＊＊＊
本実施の形態では、収集装置３００より送信されるデータに付加された収集装置３００の識別子からデータ構造を特定できるため、共通のシステムで収集対象として様々な形式のデータを扱えるようになる。
【０１２１】
本実施の形態では、機器１００が出力または計測している値を含む情報１０１が、中継装置２００を経由して収集装置３００へ送信されるか、もしくは、機器１００より収集装置３００へ直接送信される。収集装置３００は、機器１００もしくは中継装置２００より送信された情報１０１を、共通ライブラリ３０１を用いて収集データ３０２に変換し、収集装置識別子付きの収集データ３０２を送信する。共通ライブラリ３０１では、第１文字列、第２文字列および第３文字列の３つの文字列型と、１つのタイムスタンプ型とを扱ったデータ送信を行うことが可能である。共通ライブラリ３０１を用いた送信のパターンとしては、定期的な送信と即時的な送信との２パターンを扱うことができ、いずれも送信タイミングを収集装置３００ごとに設定することが可能である。収集データ３０２は、インターネット等のネットワーク５１０を経由してデータ収集サーバ４１０へ送信される。データ収集サーバ４１０は、共通ライブラリ３０１を通じて送信されてきた収集データ３０２を１つのレコードとしてデータベース４３０の共有エリア４３１へ登録する。データ処理サーバ４２０は、定期的にデータベース４３０の共有エリア４３１を確認し、共有エリア４３１の各レコードを解析する。データ処理サーバ４２０は、解析の結果をデータベース４３０へ再登録する。このとき、データ処理サーバ４２０は、第１文字列に含まれている収集装置識別子を基に、対応する専用解析処理を選択し、その処理を実行した結果を、対応する固有エリア４３２へ登録する。
【０１２２】
このように、各収集装置３００に共通ライブラリ３０１を導入し、送信するデータの枠組みを統一することにより、種類の異なる収集装置３００からのデータ送信を１つのサーバ装置４００にて処理することが可能になる。また、データの内容および形式を個別化し、データ処理サーバ４２０にて収集装置３００のＩＤに応じて専用解析処理を選択することにより、専用解析処理を自由に設計することができ、様々な業務へ適用することが可能となる。収集情報量が多い収集装置３００であっても、１つの文字列に複数の値を格納し、％等の記号を切り分け文字として挟むことにより対応が可能である。このため、ユーザが、それぞれ専用のシステムを用意する必要がなくなり、全体的なコストを低減することが可能となる。また、サーバ装置４００をクラウドシステムとして構築することで、複数の事業所または企業に設置された収集装置３００からの情報１０１を一括して処理することができ、データ処理の量を増加させることができる。遠方にある事業所または企業からのデータ収集にも対応できるので、汎用性が広がる。
【０１２３】
＊＊＊他の構成＊＊＊
本実施の形態では、収集装置３００の収集部３２１、変換部３２２および通信部３２３の機能がソフトウェアにより実現されるが、変形例として、収集装置３００の収集部３２１、変換部３２２および通信部３２３の機能がソフトウェアとハードウェアとの組み合わせにより実現されてもよい。すなわち、収集装置３００の収集部３２１、変換部３２２および通信部３２３の機能の一部が専用の電子回路により実現され、残りがソフトウェアにより実現されてもよい。
【０１２４】
本実施の形態では、サーバ装置４００の通信部４４１、登録部４４２、解析部４４３および判定部４４４の機能がソフトウェアにより実現されるが、変形例として、サーバ装置４００の通信部４４１、登録部４４２、解析部４４３および判定部４４４の機能がソフトウェアとハードウェアとの組み合わせにより実現されてもよい。すなわち、サーバ装置４００の通信部４４１、登録部４４２、解析部４４３および判定部４４４の機能の一部が専用の電子回路により実現され、残りがソフトウェアにより実現されてもよい。
【０１２５】
専用の電子回路は、例えば、単一回路、複合回路、プログラム化したプロセッサ、並列プログラム化したプロセッサ、ロジックＩＣ、ＧＡ、ＦＰＧＡまたはＡＳＩＣである。「ＧＡ」は、Ｇａｔｅ  Ａｒｒａｙの略語である。「ＦＰＧＡ」は、Ｆｉｅｌｄ−Ｐｒｏｇｒａｍｍａｂｌｅ  Ｇａｔｅ  Ａｒｒａｙの略語である。「ＡＳＩＣ」は、Ａｐｐｌｉｃａｔｉｏｎ  Ｓｐｅｃｉｆｉｃ  Ｉｎｔｅｇｒａｔｅｄ  Ｃｉｒｃｕｉｔの略語である。
【０１２６】
プロセッサ３１１，４１１，４２１、メモリ３１２，４１２，４２２および専用の電子回路を、総称して「プロセッシングサーキットリ」という。つまり、収集装置３００の収集部３２１、変換部３２２および通信部３２３の機能がソフトウェアにより実現されるか、ソフトウェアとハードウェアとの組み合わせにより実現されるかに関わらず、収集装置３００の収集部３２１、変換部３２２および通信部３２３の機能は、プロセッシングサーキットリにより実現される。サーバ装置４００の通信部４４１、登録部４４２、解析部４４３および判定部４４４の機能がソフトウェアにより実現されるか、ソフトウェアとハードウェアとの組み合わせにより実現されるかに関わらず、サーバ装置４００の通信部４４１、登録部４４２、解析部４４３および判定部４４４の機能は、プロセッシングサーキットリにより実現される。
【０１２７】
収集装置３００の「装置」を「方法」に読み替え、収集部３２１、変換部３２２および通信部３２３の「部」を「工程」に読み替えてもよい。あるいは、収集装置３００の「装置」を「プログラム」、「プログラムプロダクト」または「プログラムを記録したコンピュータ読取可能な媒体」に読み替え、収集部３２１、変換部３２２および通信部３２３の「部」を「手順」または「処理」に読み替えてもよい。
【０１２８】
サーバ装置４００の「サーバ装置」を「サービス提供方法」に読み替え、通信部４４１、登録部４４２、解析部４４３および判定部４４４の「部」を「工程」に読み替えてもよい。あるいは、サーバ装置４００の「装置」を「プログラム」、「プログラムプロダクト」または「プログラムを記録したコンピュータ読取可能な媒体」に読み替え、通信部４４１、登録部４４２、解析部４４３および判定部４４４の「部」を「手順」または「処理」に読み替えてもよい。
【符号の説明】
【０１２９】
１００  機器、１０１  情報、１１０  電力値検出機器、１２０  温湿度検出機器、１３０  位置情報検出機器、２００  中継装置、３００  収集装置、３０１  共通ライブラリ、３０２  収集データ、３１１  プロセッサ、３１２  メモリ、３１３  通信装置、３２１  収集部、３２２  変換部、３２３  通信部、４００  サーバ装置、４１０  データ収集サーバ、４１１  プロセッサ、４１２  メモリ、４１３  通信装置、４２０  データ処理サーバ、４２１  プロセッサ、４２２  メモリ、４２３  通信装置、４３０  データベース、４３１  共有エリア、４３２  固有エリア、４４１  通信部、４４２  登録部、４４３  解析部、４４４  判定部、５００  データ収集システム、５１０  ネットワーク。
【図１】
2018055457.tif 000003
【図２】
2018055457.tif 000004
【図３】
2018055457.tif 000005
【図４】
2018055457.tif 000006
【図５】
2018055457.tif 000007
【図６】
2018055457.tif 000008
【図７】
2018055457.tif 000009
【手続補正書】
【提出日】平成29年9月19日(2017.9.19)
【手続補正１】
【補正対象書類名】特許請求の範囲
【補正対象項目名】全文
【補正方法】変更
【補正の内容】
【特許請求の範囲】
【請求項１】
情報を収集し、前記情報を収集装置ごとに決められたデータ構造を持つ収集データに変換し、収集装置を識別する収集装置識別子を前記収集データに付加し、前記収集装置識別子付きの前記収集データを送信する複数の収集装置と、
前記複数の収集装置のそれぞれから前記収集装置識別子付きの前記収集データを受信し、前記収集装置識別子から前記収集データのデータ構造を特定し、特定したデータ構造に応じて前記収集データを解析することで前記情報を抽出するサーバ装置と
を備え、
前記収集データのデータ構造として、前記情報を文字列で表す形式が収集装置ごとに決められているデータ収集システム。
【請求項２】
前記サーバ装置は、前記収集装置識別子から収集装置ごとに決められた処理種別を特定し、特定した処理種別の情報処理を前記情報に対して実行する請求項１に記載のデータ収集システム。
【請求項３】
前記複数の収集装置は、前記収集装置識別子を表す文字列を含む第１文字列と、前記情報を表す文字列を含む第２文字列とを前記収集装置識別子付きの前記収集データに含める請求項１または２に記載のデータ収集システム。
【請求項４】
前記複数の収集装置は、前記情報を表す文字列を前記第２文字列に２つ以上含める場合、区切り文字を前記第２文字列の、当該２つ以上の文字列の間に挿入する請求項３に記載のデータ収集システム。
【請求項５】
前記複数の収集装置は、前記収集装置識別子を表す文字列として、前記複数の収集装置の間で共通の長さの文字列を前記第１文字列の先頭に配置する請求項３または４に記載のデータ収集システム。
【請求項６】
前記複数の収集装置のうち少なくとも１つの収集装置は、複数の機器から前記情報を収集し、
前記第１文字列の、前記収集装置識別子を表す文字列の後には、前記情報の取得源となった機器を識別する機器識別子を表す文字列が含まれている請求項３から５のいずれか１項に記載のデータ収集システム。
【請求項７】
前記少なくとも１つの収集装置は、前記機器識別子を表す文字列を前記第１文字列に２つ以上含める場合、区切り文字を前記第１文字列の、当該２つ以上の文字列の間に挿入する請求項６に記載のデータ収集システム。
【請求項８】
前記少なくとも１つの収集装置は、前記複数の機器のうち２つ以上の機器から前記情報として個別の値を取得した場合、前記機器識別子を表す文字列を前記第１文字列に含める順序と同じ順序で、前記機器識別子に対応する機器から取得した値を表す文字列を前記第２文字列に含める請求項６または７に記載のデータ収集システム。
【請求項９】
情報を収集する収集装置において、
前記情報を収集装置ごとに決められたデータ構造を持つ収集データに変換し、収集装置を識別する収集装置識別子を前記収集データに付加する変換部と、
前記収集装置識別子付きの前記収集データを送信する通信部と
を備え、
前記収集データのデータ構造として、前記情報を文字列で表す形式が収集装置ごとに決められている収集装置。
【請求項１０】
情報を収集する収集装置として機能するコンピュータに、
前記情報を収集装置ごとに決められたデータ構造を持つ収集データに変換し、収集装置を識別する収集装置識別子を前記収集データに付加する変換処理と、
前記収集装置識別子付きの前記収集データを送信する通信処理と
を実行させ、
前記収集データのデータ構造として、前記情報を文字列で表す形式が収集装置ごとに決められている情報収集プログラム。
【請求項１１】
情報を収集し前記情報を収集装置ごとに決められたデータ構造を持つ収集データに変換し収集装置を識別する収集装置識別子を前記収集データに付加する複数の収集装置のそれぞれから前記収集装置識別子付きの前記収集データを受信する通信部と、
前記収集装置識別子から前記収集データのデータ構造を特定し、特定したデータ構造に応じて前記収集データを解析することで前記情報を抽出する解析部と
を備え、
前記収集データのデータ構造として、前記情報を文字列で表す形式が収集装置ごとに決められているサーバ装置。
【請求項１２】
コンピュータに、
情報を収集し前記情報を収集装置ごとに決められたデータ構造を持つ収集データに変換し収集装置を識別する収集装置識別子を前記収集データに付加する複数の収集装置のそれぞれから前記収集装置識別子付きの前記収集データを受信する通信処理と、
前記収集装置識別子から前記収集データのデータ構造を特定し、特定したデータ構造に応じて前記収集データを解析することで前記情報を抽出する解析処理と
を実行させ、
前記収集データのデータ構造として、前記情報を文字列で表す形式が収集装置ごとに決められているサーバプログラム。