(57)【要約】【課題】必要なデータを随時収集しつつ、処理負荷を低減することができるデータ処理技術を提供すること。【解決手段】データ処理装置は、複数種のデータを収集するデータ収集装置に接続されるデータ処理装置であって、複数種のデータや要求をデータ収集装置と送受信する第１通信部と、第１通信部と接続され、データ分別設定処理やデータ収集処理の取りまとめを行う通信先制御処理部と、通信先制御処理部と接続され、複数種のデータのそれぞれを収集する要求をデータ収集装置に送信するデータ収集処理部と、データ収集処理部と接続され、複数種のデータを種類ごとに分別して格納する収集データ格納部と、を備える。【選択図】図１
2020107043.tif 000002
【特許請求の範囲】
【請求項１】
複数種のデータを収集するデータ収集装置に接続されるデータ処理装置であって、
前記複数種のデータや要求を前記データ収集装置と送受信する第１通信部と、
前記第１通信部と接続され、データ分別設定処理やデータ収集処理の取りまとめを行う通信先制御処理部と、
前記通信先制御処理部と接続され、前記複数種のデータのそれぞれを収集する要求を前記データ収集装置に送信するデータ収集処理部と、
前記データ収集処理部と接続され、前記複数種のデータを種類ごとに分別して格納する収集データ格納部と、
を備えるデータ処理装置。
【請求項２】
前記複数種のデータは、即時取得する即時データおよび蓄積しておく蓄積データである請求項１に記載のデータ処理装置。
【請求項３】
複数のデータ収集装置と、前記複数のデータ収集装置に接続され、前記データ収集装置から即時取得する即時データおよび／または蓄積しておく蓄積データを収集して処理を行うデータ処理装置と、を備えるデータ処理システムであって、
前記データ処理装置は、
前記即時データおよび前記蓄積データ並びに要求を前記データ収集装置と送受信する第１通信部と、
前記第１通信部と接続され、データ分別設定処理やデータ収集処理の取りまとめを行う通信先制御処理部と、
前記通信先制御処理部と接続され、前記即時データおよび前記蓄積データのそれぞれを収集する要求を前記データ収集装置に送信するデータ収集処理部と、
前記データ収集処理部と接続され、前記即時データおよび前記蓄積データを種類ごとに分別して格納する収集データ格納部と、を備え、
前記データ収集装置は、
前記即時データおよび前記蓄積データ並びに前記要求を前記データ処理装置と送受信する第２通信部と、
前記第２通信部と接続され、前記データ処理装置から受信した収集要求が、即時タイプおよび蓄積タイプのいずれの収集要求かの要求判別を行う要求判別処理部と、
前記要求判別処理部と接続され、前記即時データを収集して前記データ処理装置へ送信する即時データ収集処理部と、
前記要求判別処理部と接続され、前記蓄積データを収集する蓄積データ収集処理部と、
前記蓄積データ収集処理部と接続され、前記蓄積データ収集処理部から受信した前記蓄積データを格納する内部メモリと、
を備えるデータ処理システム。
【請求項４】
複数のデータ収集装置と、前記複数のデータ収集装置に接続され、前記データ収集装置から即時取得する即時データおよび／または蓄積しておく蓄積データを収集して処理するデータ処理装置が行うデータ処理方法であって、
データを収集する対象のデータ収集装置を設定するステップと、
前記設定したデータ収集装置を接続先として登録するステップと、
収集データを蓄積データおよび即時データに分別し設定要求を生成するステップと、
前記生成された設定要求を前記登録したデータ収集装置へ送信するステップと、
データ収集開始要求を生成するステップと、
前記生成されたデータ収集開始要求を前記登録したデータ収集装置へ送信するステップと、
前記蓄積データおよび前記即時データの収集要求を生成するステップと、
前記生成された収集要求を前記登録したデータ収集装置へ送信するステップと、
前記登録したデータ収集装置から送信された収集データを受信するステップと、
前記受信した収集データが蓄積データまたは即時データかを判定するステップと、
前記判定した収集データが蓄積データである場合、前記蓄積データを格納するステップと、
前記判定した収集データが即時データである場合、前記即時データを格納するステップと、
を含むデータ処理方法。
【請求項５】
データを収集する対象のデータ収集装置を設定するステップと、
前記設定したデータ収集装置を接続先として登録するステップと、
収集データを蓄積データおよび即時データに分別し設定要求を生成するステップと、
前記生成された設定要求を前記登録したデータ収集装置へ送信するステップと、
データ収集開始要求を生成するステップと、
前記生成されたデータ収集開始要求を前記登録したデータ収集装置へ送信するステップと、
前記蓄積データおよび前記即時データの収集要求を生成するステップと、
前記生成された収集要求を前記登録したデータ収集装置へ送信するステップと、
前記登録したデータ収集装置から送信された収集データを受信するステップと、
前記受信した収集データが蓄積データまたは即時データかを判定するステップと、
前記判定した収集データが蓄積データである場合、前記蓄積データを格納するステップと、
前記判定した収集データが即時データである場合、前記即時データを格納するステップと、
をコンピュータに実行させるプログラム。
【発明の詳細な説明】
【技術分野】
【０００１】
本発明は、データ処理技術に関し、より詳細には、複数の機器からデータを取得し、取得したデータを利活用するデータ処理装置、データ処理システム、データ処理方法およびプログラムに関する。
【背景技術】
【０００２】
従来、データ収集を行う場合、設定されたスケジュールに従ってデータを収集する事で動作環境に応じ効率的に機器からデータを収集する仕組みが知られている。また、別の手段として、スレーブ機器が取得したデータをマスタ機器に送信し、マスタ機器は受信したデータ内の即時データをコンピュータに即時送信し、残りは蓄積する技術が知られている。
【０００３】
このような技術の例として、例えば特許文献１には、複数のエリアに配置されている複数の機器に接続され、各機器からデータを収集するデータ収集装置であって、エリアごとに、機器の動作環境に影響を与える環境影響因子の測定値を取得するエリア測定値取得部と、前記エリア測定値取得部により取得されたエリアごとの測定値に対応させて、エリアごとにデータ収集条件を決定する収集条件決定部と、前記収集条件決定部により決定されたデータ収集条件に従って、エリアごとに、各機器からデータを収集するデータ収集部とを有することを特徴とする。仕組みが記載されている。これにより、エリアごとの環境影響因子の測定値に対応させてエリアごとにデータ収集条件を決定するため、エリアごとの動作環境に応じて効率的に機器からデータを収集することができるとされている。
【０００４】
また、特許文献２には、データ収集項目ごとに送信タイミングを判断し、即時送信が必要なデータは即時に送信し、バッチ送信が可能なデータは蓄積後に統合して送信することができるので、バッチ送信時のデータ量を抑えることができ、ネットワーク負荷の増加およびリソース不足の問題を発生させることなく、多数の機器からの収集データを送信することができる。
【先行技術文献】
【特許文献】
【０００５】
【特許文献１】特表２０１０−１０６６１４号公報
【特許文献２】特開２００９−２０５４８６号公報
【発明の概要】
【発明が解決しようとする課題】
【０００６】
しかしながら、特許文献１に記載のスケジューリングによる収集方法では、決まった時間でしか収集したデータの確認が出来ないため、リアルタイムでの確認が難しいという問題がある。
【０００７】
また、特許文献２に記載の技術では、コンピュータからデータ収集コマンド（要求）が発行される度に、マスタ機器と各スレーブ機器との間においてデータ取得が実行されることから、その都度通信が発生してしまい、その処理自体によって生じるＣＰＵ負荷やネットワーク負荷の増大が発生してしまうという問題がある。
【０００８】
本発明は、上記問題点に鑑みてなされたものであり、その目的は、必要なデータを随時収集しつつ、処理負荷を低減することができるデータ処理技術を提供することにある。
【課題を解決するための手段】
【０００９】
上記課題を解決するために本発明に係るデータ処理装置は、複数種のデータを収集するデータ収集装置に接続されるデータ処理装置であって、複数種のデータや要求をデータ収集装置と送受信する第１通信部と、第１通信部と接続され、データ分別設定処理やデータ収集処理の取りまとめを行う通信先制御処理部と、通信先制御処理部と接続され、複数種のデータのそれぞれを収集する要求をデータ収集装置に送信するデータ収集処理部と、データ収集処理部と接続され、複数種のデータを種類ごとに分別して格納する収集データ格納部と、を備える。
【発明の効果】
【００１０】
本発明に係るデータ処理システムによれば、必要なデータを随時収集しつつ、処理負荷を低減することができるデータ処理技術を提供することができる。なお、ここに記載された効果は、必ずしも限定されるものではなく、本技術中に記載されたいずれかの効果であってもよい。
【図面の簡単な説明】
【００１１】
【図１】本発明の一実施形態に係るデータ処理システムの構成例を示す模式図である。
【図２】本発明の一実施形態に係るデータ処理システムのシーケンス図であるる。
【図３】本発明の一実施形態に係るコンピュータ内のデータ処理装置によるデータ処理の流れの例を示すフローチャートである。
【図４】本発明の一実施形態に係る各産業用装置内のデータ収集装置によるデータ処理の流れの例を示すフローチャートである。
【発明を実施するための形態】
【００１２】
以下、本発明の実施形態について図面を参照しながら説明する。以下に説明する実施形態は、本発明の代表的な実施形態の一例を示したものであり、これにより本発明の範囲が狭く解釈されることはない。
【００１３】
まず、本発明の一実施形態に係るデータ処理システムについて説明する。図１は、本発明の一実施形態に係るデータ処理システム１００の構成例を示す模式図である。
【００１４】
図１に示すように、データ処理システム１００は、一例として、コンピュータ１０１と、産業用ロボット等の産業用装置１１１Ａ〜産業用装置１１１Ｚと、を備えている。なお、産業用装置の台数は、本実施形態に限らず、何台設置していてもよい。
【００１５】
コンピュータ１０１は、一例として、データ処理装置１０２を備えている。データ処理装置１０２は、データやコマンド（要求）を産業用装置１１１Ａ〜産業用装置１１１Ｚ等の外部機器と送受信する第１通信部１０３と、通信先制御処理部１０４と、データ収集処理部１０５と、収集データ格納部（ＤＢ：データベース）１０６と、を備えている。
【００１６】
通信先制御処理部１０４は、第１通信部１０３を介して複数の産業用装置１１１Ａ〜産業用装置１１１Ｚと接続し、各産業用装置１１１Ａ〜１１１Ｚに対してデータ分別設定処理やデータ収集処理の取りまとめを行う。通信先制御処理部１０４の処理は、どの産業用装置１１１Ａ〜１１１Ｚから送信されたデータなのかによって、即時取得する即時タイプの即時データか蓄積しておく蓄積タイプの蓄積データかのデータ分別の内容が異なってくる。
【００１７】
データ収集処理部１０５は、通信先制御処理部１０４と接続され、即時データおよび／または蓄積データのそれぞれのデータを収集するコマンドを各産業用装置１１１Ａ〜１１１Ｚに送信する。また、データ収集処理部１０５は、各産業用装置１１１Ａ〜１１１Ｚから収集した即時データおよび蓄積データのそれぞれのデータを専用の各格納部へ登録する。
【００１８】
収集データ格納部１０６には、即時データ専用の即時データ格納部（ＤＢ）１０７と蓄積データ専用の蓄積データ格納部（ＤＢ）１０８とが設けられている。収集データ格納部１０６は、データ収集処理部１０５と通信接続され、収集した即時データおよび蓄積データを、それぞれ即時データ格納部１０７および蓄積データ格納部１０８にデータを種類ごとに分別して格納している。
【００１９】
産業用装置１１１Ａは、一例として、複数種のデータを収集するデータ収集装置１１２Ａを備えている。データ収集装置１１２Ａは、データ処理装置１０２と接続され、即時データおよび／または蓄積データ並びにコマンドを送受信する第２通信部１１３Ａと、コマンド判別処理部１１４Ａと、即時データ収集処理部１１５Ａと、蓄積データ収集処理部１１６Ａと、内部メモリ１１７Ａと、を備えている。内部メモリ１１７Ａには、蓄積データ専用の蓄積データ格納メモリ１１８Ａが設けられている。
【００２０】
コマンド判別処理部１１４Ａは、第２通信部１１３Ａを介してコンピュータ１０１のデータ処理装置１０２と接続し、データ処理装置１０２から受信した収集コマンドが、即時タイプおよび蓄積タイプのいずれの収集コマンドかの要求判別を行う。
【００２１】
即時データ収集処理部１１５Ａは、コマンド判別処理部１１４Ａと接続され、データ処理装置１０２から受信した収集コマンドのうち即時タイプと判別された即時データを収集して、その即時データをデータ処理装置１０２へ送信する。
【００２２】
蓄積データ収集処理部１１６Ａは、コマンド判別処理部１１４Ａと接続され、データ処理装置１０２から受信した収集コマンドのうち蓄積タイプと判別された蓄積データを収集して、その蓄積データを内部メモリ１１７Ａの蓄積データ格納メモリ１１８Ａに格納する。その後、蓄積データ収集処理部１１６Ａは、蓄積データの収集コマンドを受信した際に、蓄積データを蓄積データ格納メモリ１１８Ａから読み込んでデータ処理装置１０２へ送信する。
【００２３】
産業用装置１１１Ｚは、産業用装置１１１Ａと同様に、データ収集装置１１２Ｚを備えている。データ収集装置１１２Ｚは、データやコマンドを送受信する第２通信部１１３Ｚと、コマンド判別処理部１１４Ｚと、即時データ収集処理部１１５Ｚと、蓄積データ収集処理部１１６Ｚと、内部メモリ１１７Ｚと、を備えている。内部メモリ１１７Ｚには、蓄積データ専用の蓄積データ格納メモリ１１８Ｚが設けられている。なお、データ収集装置１１２Ｚの各構成は、データ収集装置１１２Ａの対応する各構成と同様の機能を有している。また、データ処理装置１０２内の第１通信部１０３と各産業用装置１１１Ａ〜１１１Ｚ内の第２通信部１１３Ａ〜１１３Ｚとは、ネットワークＮＷにより通信接続されている。
【００２４】
次に、図２を用いて、本実施形態に係るデータ処理システム１００を用いたデータ処理の流れの例について説明する。図２は、本実施形態に係るデータ処理システム１００のシーケンス図である。
【００２５】
まず図２に示すように、コンピュータ１０１は、１−１において収集するデータを予め蓄積データと即時データとに分別して決定する。
【００２６】
その後、コンピュータ１０１は、１−２において分別したデータの内容を各産業用装置１１１Ａ〜１１１Ｚへ送信し反映する。
【００２７】
その後、各産業用装置１１１Ａ〜１１１Ｚは、１−３においてデータ収集を開始する。
【００２８】
次に、コンピュータ１０１は、２−１において各産業用装置１１１Ａ〜１１１Ｚに即時データの収集コマンドを発行する。
【００２９】
その後、各産業用装置１１１Ａ〜１１１Ｚは、２−１'において取得した即時データをそれぞれコンピュータ１０１へ送信する。
【００３０】
その後、各産業用装置１１１Ａ〜１１１Ｚは、２−２において蓄積データが取得できたら、それぞれ蓄積データ格納メモリ１１８Ａ〜１１８Ｚに蓄積する。
【００３１】
次に、コンピュータ１０１は、２−３において各産業用装置１１１Ａ〜１１１Ｚへ蓄積データの収集コマンドを発行する。
【００３２】
その後、各産業用装置１１１Ａ〜１１１Ｚは、２−３'において蓄積データ格納メモリ１１８Ａ〜１１８Ｚに蓄積していた各蓄積データを纏めてコンピュータ１０１へ送信する。
【００３３】
次に、図３を用いて、本実施形態に係るコンピュータ１０１内のデータ処理装置１０２によるデータ処理方法の例について説明する。図３は、データ処理システム１００のコンピュータ１０１内のデータ処理装置１０２によるデータ処理の流れの例を示すフローチャートである。
【００３４】
まず、Ｓ３０１において、データ処理装置１０２内のデータ収集処理部１０５は、一例として、データを収集する対象機器を産業用装置１１１Ａと設定する。
【００３５】
Ｓ３０２において、データ処理装置１０２内の通信先制御処理部１０４は、設定した産業用装置１１１Ａを接続先として登録する。
【００３６】
Ｓ３０３において、データ収集処理部１０５は、収集するデータを蓄積データおよび即時データに分別し、設定コマンドを生成して通信先制御処理部１０４へ送信する。
【００３７】
Ｓ３０４において、通信先制御処理部１０４は、受信した設定コマンドを登録済の産業用装置１１１Ａへ送信する。
【００３８】
Ｓ３０５において、データ収集処理部１０５は、データ収集開始コマンドを生成して通信先制御処理部１０４へ送信する。
【００３９】
Ｓ３０６において、通信先制御処理部１０４は、受信したデータ収集開始コマンドを登録済の産業用装置１１１Ａへ送信する。
【００４０】
Ｓ３０７において、データ収集処理部１０５は、蓄積データおよび／または即時データの収集コマンドを生成して通信先制御処理部１０４へ送信する。
【００４１】
Ｓ３０８において、通信先制御処理部１０４は、受信した収集コマンドを登録済の産業用装置１１１Ａへ送信する。
【００４２】
Ｓ３０９において、通信先制御処理部１０４は、登録済の産業用装置１１１Ａが収集コマンドに基づいて収集して送信した収集データを受信する。
【００４３】
Ｓ３１０において、データ収集処理部１０５は、通信先制御処理部１０４から収集データを受信し、その受信した収集データが蓄積データか否かを判定する。判定した収集データが、蓄積データである場合はＳ３１１に進み、蓄積データでない場合は判定したデータが即時データであるためＳ３１２に進む。
【００４４】
Ｓ３１１において、データ収集処理部１０５は、判定した蓄積データを蓄積データ格納部１０８へ登録し、データ処理を終了する。
【００４５】
一方、Ｓ３１２において、データ収集処理部１０５は、判定した即時データを即時データ格納部１０７へ登録し、データ処理を終了する。
【００４６】
次に、図４を用いて、本実施形態に係る各産業用装置１１１Ａ〜１１１Ｚのデータ収集装置１１２Ａ〜１１２Ｚによるデータ処理方法の例について説明する。図４は、データ処理システム１００の各産業用装置１１１Ａ〜１１１Ｚ内のデータ収集装置１１２Ａ〜１１２Ｚに備えられたコンピュータ（制御装置）によるデータ処理の流れの例を示すフローチャートである。なお、各データ収集装置１１２Ａ〜１１２Ｚによるデータ処理の流れは同じであるため、一例として、データ収集装置１１２Ａによるデータ処理の流れについて説明する。
【００４７】
Ｓ４０１において、データ収集装置１１２Ａ内のコマンド判別処理部１１４Ａは、コンピュータ１０１からの蓄積データおよび／または即時データの設定コマンドを受信する。
【００４８】
Ｓ４０２において、コマンド判別処理部１１４Ａは、即時データを内部メモリ１１７Ａに登録する。
【００４９】
Ｓ４０３において、データ収集装置１１２Ａ内の即時データ収集処理部１１５Ａは、コマンド判別処理部１１４Ａから受信した対象データ（即時データ）を内部メモリ１１７Ａに登録する。
【００５０】
Ｓ４０４において、コマンド判別処理部１１４Ａは、蓄積データを内部メモリ１１７Ａの蓄積データ格納メモリ１１８Ａに登録する。
【００５１】
Ｓ４０５において、データ収集装置１１２Ａ内の蓄積データ収集処理部１１６Ａは、コマンド判別処理部１１４Ａから受信した対象データ（蓄積データ）を蓄積データ格納メモリ１１８Ａに登録する。
【００５２】
Ｓ４０６において、コマンド判別処理部１１４Ａは、データ収集開始コマンドをコンピュータ１０１から受信する。
【００５３】
Ｓ４０７において、コマンド判別処理部１１４Ａは、データ収集開始コマンドに基づいて、データ収集を開始する制御命令を生成して蓄積データ収集処理部１１６Ａへ送信する。
【００５４】
Ｓ４０８において、蓄積データ収集処理部１１６Ａは、受信した制御命令によりデータを収集して蓄積データ格納メモリ１１８Ａに格納する。
【００５５】
Ｓ４０９において、コマンド判別処理部１１４Ａは、コンピュータ１０１からの収集コマンドを受信する。
【００５６】
Ｓ４１０において、コマンド判別処理部１１４Ａは、受信した収集コマンドが蓄積タイプか否かを判定する。判定した収集コマンドが、蓄積タイプである場合はＳ４１１に進み、蓄積タイプでない場合は判定した収集コマンドが即時タイプであるためＳ４１２に進む。
【００５７】
Ｓ４１１において、蓄積データ収集処理部１１６Ａは、蓄積タイプの収集コマンドに基づいて、内部メモリ１１７Ａの蓄積データ格納メモリ１１８Ａに登録された蓄積データを読み込む。
【００５８】
一方、Ｓ４１２において、即時データ収集処理部１１５Ａは、即時タイプの収集コマンドに基づいて、内部メモリ１１７Ａに登録された即時データを収集する。
【００５９】
Ｓ４１３において、コマンド判別処理部１１４Ａは、蓄積データ収集処理部１１６Ａから蓄積データを受信するか、または、即時データ収集処理部１１５Ａから即時データを受信し、その受信した収集データをコンピュータ１０１へ送信する。
【００６０】
コマンド判別処理部１１４Ａが、収集データをコンピュータ１０１へ送信したらデータ処理を終了する。
【００６１】
以上より、本実施形態に係るデータ処理システム１００は、収集データを蓄積データと即時データとに分別し、蓄積データを対象機器の蓄積データ格納メモリ１１８Ａに蓄積することでコンピュータ１０１との通信回数を削減しつつ、即時データを随時収集することでリアルタイムでもデータ収集することができる。
【００６２】
したがって、データ処理システム１００によれば、即時データについては、コンピュータ１０１から即時タイプの収集コマンドが発行されるたびに、産業用装置１１１Ａ〜１１１Ｚが収集した即時データをコンピュータへ送信することで、即時データをリアルタイムに確認することが可能となる。
【００６３】
また、データ処理システム１００によれば、蓄積データについては、蓄積タイプの収集コマンドが発行された際に、産業用装置１１１Ａ〜１１１Ｚがこれまで蓄積した蓄積データをコンピュータ１０１へ送信する。これにより、データ処理システム１００は、収集コマンド発行時にのみ蓄積データをコンピュータ１０１へ送信することで、コンピュータ１０１との通信回数を削減し、削減することによりＣＰＵ負荷やネットワーク負荷の増大を防ぐことができる。
【産業上の利用可能性】
【００６４】
本発明は、コンピュータと産業用ロボット等の産業用装置との間でのデータ処理に活用できるデータ処理システムに関するものであり、産業上の利用可能性を有するものである。
【符号の説明】
【００６５】
１００  データ処理システム
１０１  コンピュータ
１０２  データ処理装置
１０３  第１通信部
１０４  通信先制御処理部
１０５  データ収集処理部
１０６  収集データ格納部
１０７  即時データ格納部
１０８、１１８Ａ〜１１８Ｚ  蓄積データ格納部
１１１Ａ〜１１１Ｚ  産業用装置
１１２Ａ〜１１２Ｚ  データ収集装置
１１３Ａ〜１１３Ｚ  第２通信部
１１４Ａ〜１１４Ｚ  コマンド判別処理部
１１５Ａ〜１１５Ｚ  即時データ収集処理部
１１６Ａ〜１１６Ｚ  蓄積データ収集処理部
１１７Ａ〜１１７Ｚ  内部メモリ
【図１】
2020107043.tif 000003
【図２】
2020107043.tif 000004
【図３】
2020107043.tif 000005
【図４】
2020107043.tif 000006