(57)【特許請求の範囲】
【請求項１】
機器から繰り返し送信される機器データそれぞれに処理を施し、前記処理に関する処理情報を受信装置に送信するデータ処理装置であって、
前記処理が実行される際に生成される生成データを前記受信装置に送信するための条件が成立するか否かを示す条件情報を、前記生成データが生成される毎に取得し、前記生成データについての前記条件が成立することが前記条件情報によって示されるときに、該生成データの前回及び次回の少なくとも一方に生成された他の前記生成データについての前記条件の成否に関する付加情報を出力する出力手段と、
前記条件が成立する前記生成データと前記付加情報とを含む前記処理情報を前記受信装置に送信する送信手段と、
を備えるデータ処理装置。
【請求項２】
前記生成データが生成される毎に前記条件情報を取得して、前記条件情報によって示される前記条件の成否の切り替わりを検出する検出手段、をさらに備え、
前記出力手段は、前記生成データについての前記条件が成立することが前記条件情報によって示され、前記検出手段によって前記条件の成否の切り替わりが検出されたときに、該生成データが、連続して生成されて前記条件が成立する複数の前記生成データのうちの最初又は最後の前記生成データであることを示す前記付加情報を生成して出力する、
請求項１に記載のデータ処理装置。
【請求項３】
前記送信手段は、前記条件が成立する前記生成データと、タイムスタンプと、を関連付けて送信し、
前記出力手段は、前記生成データについての前記条件が成立することが前記条件情報によって示され、前記検出手段によって前記条件の成立から前記条件の不成立への切り替わりが検出されたときに、該生成データと、該生成データに関連付けられて送信されるタイムスタンプと、の複製を前記付加情報として生成して出力する、
請求項２に記載のデータ処理装置。
【請求項４】
前記条件を受け付ける第１受付手段と、
前記生成データが生成される毎に前記条件が成立するか否かを判定して前記条件情報を出力する判定手段と、
をさらに備える請求項１から３のいずれか一項に記載のデータ処理装置。
【請求項５】
前記第１受付手段は、前記生成データの前記受信装置への送信を開始するための開始条件と、前記生成データの前記受信装置への送信を終了するための終了条件と、の少なくとも一方を含む前記条件を受け付ける、
請求項４に記載のデータ処理装置。
【請求項６】
前記機器データそれぞれに対して施される一連の部分処理を含む処理フローである前記処理の設定を受け付ける第２受付手段と、
前記設定に従って前記部分処理を処理手段に実行させる実行制御手段と、
をさらに含み、
前記生成データは、前記部分処理の結果を示すデータである、
請求項１から５のいずれか一項に記載のデータ処理装置。
【請求項７】
機器から繰り返し送信される機器データそれぞれに処理を施し、前記処理に関する処理情報を受信装置に送信するデータ処理装置によって実行されるデータ送信方法であって、
前記処理が実行される際に生成される生成データを前記受信装置に送信するための条件が成立するか否かを示す条件情報を、前記生成データが生成される毎に取得する取得ステップと、
前記生成データについての前記条件が成立することが前記条件情報によって示されるときに、該生成データの前回及び次回の少なくとも一方に生成された他の前記生成データについての前記条件の成否に関する付加情報を出力する出力ステップと、
前記条件が成立する前記生成データと前記付加情報とを含む前記処理情報を前記受信装置に送信する送信ステップと、
を含むデータ送信方法。
【請求項８】
機器から繰り返し送信される機器データそれぞれに処理を施し、前記処理に関する処理情報を受信装置に送信するコンピュータを、
前記処理が実行される際に生成される生成データを前記受信装置に送信するための条件が成立するか否かを示す条件情報を、前記生成データが生成される毎に取得し、前記生成データについての前記条件が成立することが前記条件情報によって示されるときに、該生成データの前回及び次回の少なくとも一方に生成された他の前記生成データについての前記条件の成否に関する付加情報を出力する出力手段、
前記条件が成立する前記生成データと前記付加情報とを含む前記処理情報を前記受信装置に送信する送信手段、
として機能させるためのプログラム。
【発明の詳細な説明】
【技術分野】
【０００１】
本開示は、データ処理装置、データ送信方法及びプログラムに関する。
【背景技術】
【０００２】
ＦＡ（Factory Automation）の現場では、センサに代表される機器から収集したデータをリアルタイムに処理する処理システムが構築される。近年の通信技術の発展に伴い、この種の処理システムによる処理に関するデータを遠隔から利用したいという要望がある。この要望に対して、処理に関するデータを外部に送信するときには、不要なデータの送信を省略すれば遠隔におけるデータの利用が容易になるため、一部のデータを選別して送信することが望ましい。そこで、あらかじめ定められた出力条件に従ってデータを外部に送信する技術を処理システムに適用することが考えられる（例えば、特許文献１を参照）。【０００３】
特許文献１には、機器に備わるセンサによって測定されたセンサデータを含むパケットを受信し、プロトコル処理とクエリ処理とを並列に実行するストリーム処理装置について記載されている。このストリーム処理装置は、クエリ処理において、センサデータの値が許容範囲内である場合には、機器が正常であると判定して正常通知信号を送信し、その他の場合には、機器が異常であると判定して機器停止信号を送信する。ただし、ストリーム処理装置は、出力条件に従って、プロトコル処理においてエラーと判定されたパケットに対応するクエリ処理の結果を出力せずに廃棄する。この装置によれば、プロトコル処理においてエラーが発生するような不完全なデータの送信が省略される。
【先行技術文献】
【特許文献】
【０００４】
【特許文献１】特開２０１４−５００９１号公報
【発明の概要】
【発明が解決しようとする課題】
【０００５】
特許文献１に記載の技術では、データの受信側では、繰り返し実行されたクエリ処理の結果が連続して出力されているか、或いは出力が一旦中止してから再開したのかを判断することができない。このため、連続して実行された処理であるか否かに応じて受信側においてデータを異なる用途に利用することが困難になる。したがって、機器から収集したデータに施される処理に関する情報を遠隔で利用する際の利便性を向上させる余地があった。【０００６】
本開示は、機器から収集したデータに施される処理に関する情報を遠隔で利用する際の利便性を向上させることを目的とする。
【課題を解決するための手段】
【０００７】
上記目的を達成するため、本開示のデータ処理装置は、機器から繰り返し送信される機器データそれぞれに処理を施し、処理に関する処理情報を受信装置に送信するデータ処理装置であって、処理が実行される際に生成される生成データを受信装置に送信するための条件が成立するか否かを示す条件情報を、生成データが生成される毎に取得し、生成データについての条件が成立することが条件情報によって示されるときに、該生成データの前回及び次回の少なくとも一方に生成された他の生成データについての条件の成否に関する付加情報を出力する出力手段と、条件が成立する生成データと付加情報とを含む処理情報を受信装置に送信する送信手段と、を備える。
【発明の効果】
【０００８】
本開示によれば、生成データについての条件が成立することが条件情報によって示されるときに、出力手段が、当該生成データの前回及び次回の少なくとも一方に生成された他の生成データについての条件の成否に関する付加情報を出力し、送信手段が、条件が成立する生成データと付加情報とを含む処理情報を受信装置に送信する。このため、受信装置では、生成データが他の生成データと連続して送信されたものであるか否かを付加情報により判断することができる。したがって、機器から収集したデータに施される処理に関する情報を遠隔で利用する際の利便性を向上させることができる。
【図面の簡単な説明】
【０００９】
【図１】実施の形態１に係るデータ処理システムの構成を示す図
【図２】実施の形態１に係るデータ処理装置のハードウェア構成を示す図
【図３】実施の形態１に係るデータ処理装置によって実行される処理フローを説明するための図
【図４】実施の形態１に係る処理情報の送信について説明するための図
【図５】実施の形態１に係るデータ処理装置の機能的な構成を示す図
【図６】実施の形態１に係る条件設定情報の一例を示す図
【図７】実施の形態１に係る出力部によって取得及び生成される情報の一例を示す図
【図８】実施の形態１に係るデータ処理装置によって実行されるデータ送信処理を示すフローチャート
【図９】実施の形態２に係るデータ処理装置の機能的な構成を示す図
【図１０】実施の形態２に係る出力部によって取得及び生成される情報の一例を示す図
【図１１】変形例に係る条件設定情報を示す図
【図１２】変形例に係る出力部によって取得及び生成される情報の一例を示す図
【図１３】変形例に係るデータ処理装置の機能的な構成を示す図
【発明を実施するための形態】
【００１０】
以下、実施の形態に係るデータ処理システム１０００について、図面を参照しつつ詳細に説明する。
【００１１】
実施の形態１．
本実施の形態に係るデータ処理システム１０００は、図１に示されるように、機器２０から繰り返し送信されるデータをデータ処理装置１００により逐次処理することで、工場１００１において生産ラインを稼働させる生産システムである。データ処理システム１０００におけるデータの処理は、例えば、生産ラインに設置されたアクチュエータ、ロボット及び工作機械に代表される種々の機械の制御、並びに、異常の監視を含む。データ処理システム１０００は、データに処理を施すデータ処理装置１００と、処理対象のデータをデータ処理装置１００に送信する機器２０と、データ処理装置１００による処理の内容を設定するための端末２１と、データ処理装置１００から処理に関する情報を受信して利用する受信装置３０と、を有する。このデータ処理システム１０００においては、データ処理装置１００によって繰り返し実行される処理のうちの一部の処理に関する情報が受信装置３０に送信されるとともに、当該一部の処理が連続して実行されたものであるか否かを示す情報が受信装置３０に通知される。
【００１２】
データ処理装置１００と機器２０とは、産業用のＦＡネットワークを介して接続される。データ処理装置１００と端末２１とは、ＵＳＢ（Universal Serial Bus）ケーブル及びＬＡＮ（Local Area Network）ケーブルに代表される通信線で接続される。データ処理装置１００と受信装置３０とは、インターネットに代表される通信網を介して接続される。データ処理装置１００は、機器２０、端末２１及び受信装置３０との間で、信号を送受信することにより互いに通信する。なお、データ処理装置１００と、機器２０、端末２１及び受信装置３０と、の通信形態は、これに限定されず任意に変更してもよい。
【００１３】
機器２０は、生産ラインに設置される不図示のセンサを有している。このセンサは、例えば、光センサ、圧力センサ、超音波センサ、その他の検出器である。機器２０は、センサによるセンシング結果を含むデータを、データ処理装置１００から指定された周期で繰り返しデータ処理装置１００に送信する。
【００１４】
データ処理装置１００は、ＩＰＣ（Industrial Personal Computer）又はＰＬＣ（Programmable Logic Controller）であって、機器２０から収集したデータに対して、あらかじめ設定された処理を施して処理結果を出力するＦＡ装置である。データ処理装置１００は、処理結果の出力として、機械に動作指令を送信するが、これには限定されず、データを分析又は加工した品質管理情報をユーザに提示してもよいし、その他の処理結果を出力してもよい。
【００１５】
データ処理装置１００は、そのハードウェア構成として、図２に示されるように、プロセッサ１１と、主記憶部１２と、補助記憶部１３と、入力部１４と、出力部１５と、通信部１６と、を有するコンピュータ装置である。主記憶部１２、補助記憶部１３、入力部１４、出力部１５及び通信部１６はいずれも、内部バス１７を介してプロセッサ１１に接続される。
【００１６】
プロセッサ１１は、ＭＰＵ（Micro Processing Unit）を含む。プロセッサ１１は、補助記憶部１３に記憶されるプログラムＰ１を実行することにより、データ処理装置１００の種々の機能を実現して、後述の処理を実行する。
【００１７】
主記憶部１２は、ＲＡＭ（Random Access Memory）を含む。主記憶部１２には、補助記憶部１３からプログラムＰ１がロードされる。そして、主記憶部１２は、プロセッサ１１の作業領域として用いられる。
【００１８】
補助記憶部１３は、ＥＥＰＲＯＭ（Electrically Erasable Programmable Read-Only Memory）に代表される不揮発性メモリを含む。補助記憶部１３は、プログラムＰ１の他に、プロセッサ１１の処理に用いられる種々のデータを記憶する。補助記憶部１３は、プロセッサ１１の指示に従って、プロセッサ１１によって利用されるデータをプロセッサ１１に供給し、プロセッサ１１から供給されたデータを記憶する。なお、図２では、補助記憶部１３に記憶される１つのプログラムＰ１が代表的に示されているが、プログラムＰ１は、複数のプログラムであってもよい。また、プログラムＰ１は、データ処理装置１００に予め設定されたプログラムと、データ処理装置１００のユーザによって追加されたプログラムと、を含んでいてもよい。
【００１９】
入力部１４は、入力キー及びポインティングデバイスに代表される入力デバイスを含む。入力部１４は、データ処理装置１００のユーザによって入力された情報を取得して、取得した情報をプロセッサ１１に通知する。
【００２０】
出力部１５は、ＬＣＤ（Liquid Crystal Display）及びスピーカに代表される出力デバイスを含む。出力部１５は、プロセッサ１１の指示に従って、種々の情報をユーザに提示する。
【００２１】
通信部１６は、外部の機器２０と通信するためのネットワークインタフェース回路を含む。通信部１６は、機器２０から信号を受信して、この信号により示されるデータをプロセッサ１１へ出力する。また、通信部１６は、プロセッサ１１から出力されたデータを示す信号を機器２０へ送信する。なお、図２では、１つの通信部１６が代表的に例示されているが、データ処理装置１００は、接続される通信路に対応して複数の通信部１６を有してもよい。
【００２２】
図２に示されるハードウェア構成が協働することにより、データ処理装置１００は、データの処理を含む種々の機能を発揮する。データ処理装置１００によるデータの処理は、図３に例示されるように、順次実行される一連の部分処理を含む処理フロー３００として、ユーザによって任意に規定される。
【００２３】
処理フロー３００は、機器２０から出力されたデータに対し順次施される部分処理を含む。詳細には、処理フロー３００は、部分処理として、処理フロー３００が施されるデータを機器２０から収集する収集処理３１と、収集したデータに第１の加工を施す第１加工処理３２と、第１の加工が施されたデータに第２の加工を施す第２加工処理３３と、第２の加工が施されたデータに基づく診断を下す診断処理３４と、第１の加工が施されたデータに第３の加工を施す第３加工処理３５と、を含む。さらに、処理フロー３００は、これらの部分処理に加えて、受信装置３０に情報を送信する部分処理として、収集処理３１の結果を送信する外部送信処理４１と、第３加工処理３５の結果を送信する外部送信処理４２と、診断処理の結果を送信する外部送信処理４３と、のいずれか１つを、図３中の矢印で示される順で実行することにより達成される。
【００２４】
図３中の矢印は、各部分処理の対象であるデータの伝送を示す。例えば、収集処理３１の実行によりデータ処理装置１００の外部から取得されたデータが第１加工処理３２に入力され、このデータに対して第１加工処理３２が施される。また、第１加工処理３２の処理結果を示すデータが第２加工処理３３及び第３加工処理３５に入力され、このデータに対して第２加工処理３３及び第３加工処理３５が施される。また、第２加工処理３３の処理結果を示すデータが診断処理３４に入力され、このデータに対して診断処理３４が施される。
【００２５】
収集処理３１は、機器２０から信号を受信することでデータを収集する処理に相当する。収集処理３１は、予め設定されるパラメータに従って周期的に実行され、機器２０から送信されるセンシング結果を取得する。この周期は、例えば１０ミリ秒間、１００ミリ秒間又は１秒間である。また、センシング結果を示すデータは、例えば８ビット又は１６ビットのデジタル値である。収集処理３１によって機器２０からデータを受信する度に、後続の部分処理が実行されて、処理フロー３００が繰り返し実行される。
【００２６】
第１加工処理３２は、移動平均の算出によりノイズを除去する処理である。第２加工処理３３は、処理対象の値を予め規定された範囲内に収める正規化処理である。診断処理３４は、第２加工処理３３の結果に応じて機械に対する制御命令の内容を決定して出力する処理である。これらの部分処理によれば、センシング結果に応じて機械を制御することができる。
【００２７】
第３加工処理３５は、処理対象の値から異常値を抽出して記録する処理である。第３加工処理３５によれば、品質管理情報を生成して、生産ラインの効率向上を図ることができる。
【００２８】
外部送信処理４１は、収集処理３１の結果を示すデータが生成される度に実行される。外部送信処理４２は、第３加工処理３５の結果を示すデータが生成される度に実行される処理であって、第３加工処理３５により記録される情報と同等の情報を送信する処理である。外部送信処理４３は、診断処理３４の結果を示すデータが生成される度に実行される処理であって、診断処理３４により出力される制御命令と同等の情報を送信する処理である。外部送信処理４１〜４３はいずれも、生成されたデータをリアルタイムに受信装置３０に送信する処理である。処理フロー３００は、複数の外部送信処理４１〜４３を含んでもよいが、以下では、処理フロー３００が外部送信処理４２を含み、外部送信処理４１，４３が省略される例を中心に説明する。
【００２９】
ただし、処理フロー３００の構成は、上述の処理に限定されない。例えば、第１加工処理３２、第２加工処理３３、診断処理３４及び第３加工処理３５は、上述の処理とは異なる処理であってもよい。また、部分処理の数を任意に変更してもよいし、図３において矢印により示される部分処理同士の接続を任意に変更してもよい。さらに、処理フロー３００は、単一の部分処理の結果を３以上の他の部分処理に入力する分岐部分を含んでもよいし、複数の部分処理の結果を単一の部分処理に入力する統合部分を含んでもよい。
【００３０】
処理フロー３００は、処理フロー３００の対象であるデータそれぞれの入力に応じて実行され、処理フロー３００を構成する部分処理はそれぞれ、当該処理フローの一部として実行される。例えば、機器２０から送信された一のデータについて複数の部分処理が順次実行され、次に送信された他のデータについて同様の部分処理が別途実行される。なお、一のデータに対する部分処理と、次のデータに対する部分処理とは、並列に実行される。換言すると、一のデータに対する処理フロー３００が完了する前に次のデータに対する処理フロー３００が開始する。ただし、これに限定されるものではなく、データ処理装置１００は、前回の処理フロー３００が終了してから次回の処理フロー３００を開始してもよい。
【００３１】
データ処理装置１００は、図４に示されるように、処理フローを実行する際に部分処理の結果として生成される生成データを、予め規定された条件が当該生成データについて成立するときには、付加情報とともに処理情報として受信装置３０に送信する。付加情報は、一の生成データの前後に生成された他の生成データが、当該一の生成データとともに受信装置３０に送信されるか否かを示す情報である。図４において、データ処理装置１００は、条件が成立する生成データを生成する毎に、生成した生成データに付加情報を付加して送信する（ステップＳ１〜Ｓ２，Ｓ５）。また、データ処理装置１００は、条件が成立しない生成データを生成した場合（ステップＳ３〜Ｓ４，Ｓ６）、当該生成データの送信を中止する（ステップＳ３１，Ｓ４１）。
【００３２】
なお、図４は、データ処理装置１００による処理情報の送信を模式的に示すものであって、処理情報を送信する形態は、これに限定されない。例えば、データ処理装置１００は通常、条件が成立しない生成データの送信を中止するが、後述するように、条件が成立しないときであっても条件が成立する生成データを送信した直後であれば（ステップＳ３，Ｓ６）、処理情報を送信してもよい。
【００３３】
データ処理装置１００は、処理フロー及び当該処理フローに関する処理情報の送信を実行するために、その機能として、図５に示されるように、生成データを受信装置３０に送信するための送信条件の設定を受け付ける第１受付部１１１と、処理フローの設定を受け付ける第２受付部１１２と、設定に従って処理フローの実行を制御する実行制御部１１３と、種々のデータを記憶する記憶部１１４と、生成データが生成される毎に送信条件が成立するか否かを判定する判定部１１５と、順次生成される生成データについて送信条件の成否の切り替わりを検出する検出部１１６と、処理フローに関する処理情報を生成して出力する出力部１１７と、ＧＷ（Gateway）通信部１４０に処理情報を送出するＧＷ接続部１１８と、を有する。これらの第１受付部１１１、第２受付部１１２、実行制御部１１３、記憶部１１４、判定部１１５、検出部１１６、出力部１１７及びＧＷ接続部１１８は、ユーザが所望の処理フローを実行するためのプラットフォーム１１０を構成する。
【００３４】
データ処理装置１００は、さらに、機器２０からデータを収集する収集部１２０と、部分処理を実行する複数の部分処理部１３０と、受信装置３０に処理情報を送信するためのゲートウェイとして機能するＧＷ通信部１４０と、を有する。
【００３５】
第１受付部１１１は、ユーザが端末２１を操作することで入力された送信条件の設定を端末２１から受け付ける。例えば、第１受付部１１１は、図３中の第３加工処理３５の結果を示す生成データを受信装置３０に送信するための送信条件を受け付ける。送信条件は、部分処理の結果を示す生成データが生成される度に成否が変化し得る条件であって、例えば、生成データの値が予め規定された範囲から外れることである。ただし、送信条件はこれに限定されず、例えば、第３加工処理３５によって生成データが生成される時点における他の部分処理の結果に応じて成否が定まる条件であってもよいし、予め定められた時刻を経過したことであってもよい。第１受付部１１１は、受け付けた送信条件の設定を示す条件設定情報５１を実行制御部１１３に送出し、条件設定情報５１は、実行制御部１１３によって記憶部１１４に格納される。
【００３６】
第２受付部１１２は、ユーザによる処理フローの設定を受け付ける。そして、第２受付部１１２は、処理フローの内容を示すフロー設定情報５２を実行制御部１１３に送出し、フロー設定情報５２は、実行制御部１１３によって記憶部１１４に格納される。
【００３７】
第１受付部１１１及び第２受付部１１２はそれぞれ、主としてプロセッサ１１及び通信部１６の協働により実現される。第１受付部１１１は、データ処理装置１００において、処理が実行される際に生成される生成データを受信装置３０に送信するための条件を受け付ける第１受付手段の一例に相当する。第２受付部１１２は、データ処理装置１００において、機器２０から送信される機器データそれぞれに対して施される処理フローの設定を受け付ける第２受付手段の一例に相当する。
【００３８】
なお、端末２１は、データ処理装置１００のユーザが情報を入力するためのＧＵＩ（Graphical User Interface）端末である。端末２１は、処理フローを設定するためのエンジニアリングツールと呼称されるアプリケーションソフトウェアを実行することにより、ＧＵＩとしての機能を実現する。
【００３９】
実行制御部１１３は、収集部１２０及び部分処理部１３０を制御することにより、設定された処理フローを実行する。詳細には、実行制御部１１３は、収集部１２０によって収集されたデータを取得する。そして、実行制御部１１３は、取得したデータを複数の部分処理部１３０のいずれかに送出し、部分処理の結果を部分処理部１３０から取得して、処理フローに対応する順で部分処理部１３０に部分処理を実行させる。また、実行制御部１１３は、生成データを判定部１１５及び出力部１１７に送出することで、図３中の外部送信処理４２を実行する。
【００４０】
記憶部１１４は、主として主記憶部１２及び補助記憶部１３の少なくとも一方により実現される。記憶部１１４は、条件設定情報５１及びフロー設定情報５２に加えて、実行制御部１１３によって扱われるデータを一時的に記憶してもよい。図６には、記憶部１１４に格納される条件設定情報５１の一例として、生成データの値がゼロ以上のときに成立する送信条件を示す情報が示されている。
【００４１】
判定部１１５は、記憶部１１４から条件設定情報５１を読み出し、生成データが生成される毎に実行制御部１１３から生成データを取得する。そして、判定部１１５は、取得した生成データについて送信条件が成立するか否かを判定して、送信条件が成立するか否かを示す条件情報を検出部１１６及び出力部１１７に送出する。例えば、判定部１１５は、生成データを取得する度に、当該生成データの値が予め規定された範囲内であれば送信条件が満たされないことを示す条件情報を出力し、当該生成データの値が予め規定された範囲外であれば送信条件が満たされることを示す条件情報を出力する。条件情報は、例えば、送信条件の成立に対応するＴｒｕｅの値、又は送信条件の不成立に対応するＦａｌｓｅの値を有する。
【００４２】
検出部１１６は、判定部１１５から条件情報を繰り返し取得して、条件情報により示される送信条件の成否の切り替わりを検出する。検出部１１６は、送信条件の成立から不成立への切り替わりと、送信条件の不成立から成立への切り替わりと、の少なくとも一方を検出すればよい。送信条件の成立から不成立への切り替わりは、送信すべき単独の又は連続する複数の生成データのうちの最後の生成データに対応し、送信条件の不成立から成立への切り替わりは、送信すべき単独の又は連続する複数の生成データのうちの最初の生成データに対応する。これら最初の生成データ及び最後の生成データをそれぞれ、以下では、始端及び終端という。検出部１１６は、このような始端と終端との少なくとも一方であるエッジを検出する。そして、検出部１１６は、検出結果を出力部１１７に送出する。検出結果は、例えば、終端の検出に対応するＴｒｕｅの値、又は、終端の不検出に対応するＦａｌｓｅの値である。なお、検出結果は、始端の検出に対応するＴｒｕｅの値、又は、始端の不検出に対応するＦａｌｓｅの値を含んでもよい。
【００４３】
出力部１１７は、受信装置３０に送信すべき処理情報を生成して出力する。詳細には、出力部１１７は、実行制御部１１３から生成データを取得し、当該生成データに関する条件情報を判定部１１５から取得し、当該条件情報に基づく検出部１１６による検出結果を検出部１１６から取得する。そして、出力部１１７は、条件情報及び検出結果に基づいて付加情報を生成し、送信条件が成立するときには生成データ及び付加情報を含む処理情報をＧＷ接続部１１８に送出する。
【００４４】
図７には、出力部１１７によって取得される情報と、出力部１１７によって生成される付加情報と、が時系列で示されている。図７中のタイムスタンプは、生成データそれぞれに関連付けられて実行制御部１１３から出力部１１７に伝送される。このタイムスタンプは、生成データが生成された時刻、生成データを生成する処理フローが開始した時刻、又は、当該処理フローの対象であるデータを機器２０から受信した時刻であってもよい。
【００４５】
図７における検出結果は、送信条件の成立から不成立への切り替わりを示す。詳細には、「Ｆａｌｓｅ」である条件情報の直前に取得された条件情報が「Ｔｒｕｅ」である場合に、検出結果は「Ｔｒｕｅ」となり、その他の場合には検出結果は「Ｆａｌｓｅ」となる。
【００４６】
図７における付加情報は、互いに関連付けられた送信フラグ、始端フラグ及び終端フラグを含む。送信フラグは、条件情報が「Ｔｒｕｅ」であるときに「１」の値を有し、条件情報が「Ｆａｌｓｅ」であるときに「ゼロ」の値を有する１ビットのフラグである。送信フラグは、実質的に条件情報に等しい情報である。始端フラグは、当該始端フラグに関連付けられた送信フラグが「１」であって、その直前の送信フラグが「ゼロ」である場合に「１」の値を有し、その他の場合には「ゼロ」の値を有する１ビットのフラグである。なお、検出部１１６が送信条件の不成立から成立への切り替わりの検出結果を出力する場合には、始端フラグは、実質的にこの検出結果に等しい情報である。終端フラグは、図７に示される検出結果が「Ｔｒｕｅ」であるときに「１」の値を有し、検出結果が「Ｆａｌｓｅ」であるときに「ゼロ」の値を有する１ビットのフラグである。終端フラグは、実質的に図７中の検出結果に等しい情報である。
【００４７】
生成データ及び付加情報は、送信フラグが「１」である場合、及び、送信フラグが「ゼロ」であっても終端フラグが「１」である場合には出力され、その他の場合には出力されずに破棄される。すなわち、送信フラグ、始端フラグ及び終端フラグのいずれか１つが「１」であれば、生成データ及び付加情報はデータ処理装置１００から出力される。図７においては、出力部１１７によって出力される情報に対応する部分に下線が付されている。なお、終端フラグ「１」が付された生成データは送信条件を満たさないが、その直前に生成された生成データが終端であることを示す情報として送信される。送信条件を満たす終端の生成データには、当該生成データに関連付けて図７に示されるように生成された３つのフラグに加えて、次に生成された生成データ及び更に３つのフラグが、終端であることを示す付加情報として付与されるといえる。
【００４８】
図５に戻り、ＧＷ接続部１１８は、プラットフォーム１１０のインタフェースとして機能する。ＧＷ接続部１１８は、生成データと当該生成データに関連付けられた付加情報とを含む処理情報を出力部１１７から取得して、ＧＷ通信部１４０に送出する。
【００４９】
実行制御部１１３、判定部１１５、検出部１１６、出力部１１７及びＧＷ接続部１１８はそれぞれ、主としてプロセッサ１１により実現される。実行制御部１１３は、データ処理装置１００において、設定に従って部分処理を処理手段に実行させる実行制御手段の一例に相当する。判定部１１５は、データ処理装置１００において、生成データが生成される毎に条件が成立するか否かを判定して条件情報を出力する判定手段の一例に相当する。検出部１１６は、データ処理装置１００において、生成データが生成される毎に条件情報を取得して、条件情報によって示される条件の成否の切り替わりを検出する検出手段の一例に相当する。出力部１１７は、生成データが生成される毎に条件情報を取得し、一の生成データについての条件が成立することが条件情報によって示されるときに、該一の生成データの前回及び次回の少なくとも一方に生成された他の生成データについての条件の成否に関する付加情報を出力する出力手段の一例に相当する。
【００５０】
収集部１２０は、主としてプロセッサ１１及び通信部１６の協働により実現される。詳細には、収集部１２０は、プロセッサ１１がプログラムＰ１としてプラグインソフトウェアを実行することにより実現される。収集部１２０は、機器２０から繰り返し送信されるデータを受信して、受信したデータを実行制御部１１３に送出する。詳細には、収集部１２０は、産業用ネットワークのプロトコルに従って伝送されたデータを取得して、取得したデータを、実行制御部１１３が扱うのに適した形式に変換してから実行制御部１１３に出力する。収集部１２０を実現するためのプラグインソフトウェアは、産業用ネットワークの種別に応じて開発される。新たなプロトコルに従う産業用ネットワークにデータ処理装置１００を接続する必要があるときには、新たに開発されたプラグインソフトウェアにより実現される収集部１２０が追加される。なお、収集部１２０は、実行制御部１１３の指示に従って、処理フローの結果である制御命令を、産業用ネットワークを介して機械に送信してもよい。
【００５１】
部分処理部１３０は、主としてプロセッサ１１により実現される。詳細には、部分処理部１３０は、プロセッサ１１がプログラムＰ１としてプラグインソフトウェアを実行することにより実現される。部分処理部１３０を実現するためのプラグインソフトウェアは、データ処理装置１００のユーザによって開発されてもよいし、他の開発者から提供されてユーザによりデータ処理装置１００に格納されてもよい。このため、部分処理部１３０による部分処理の結果は、データ処理装置１００のユーザによって利用される他、当該ユーザとは異なる開発者に対するフィードバックとして利用され得る。部分処理部１３０は、実行制御部１１３から入力されたデータに対して部分処理を施した結果を実行制御部１１３に送出する。
【００５２】
なお、図５に示される複数の部分処理部１３０はそれぞれ、図３に示される部分処理に対応してもよいが、これには限定されない。例えば、単一の部分処理部１３０が、実行制御部１１３から渡されたパラメータに応じて第２加工処理３３及び第３加工処理３５を実行してもよい。部分処理部１３０の数と処理フローを構成する部分処理の数とは、異なっていてもよい。部分処理部１３０は、データ処理装置１００において、部分処理を実行する処理手段の一例に相当する。
【００５３】
ＧＷ通信部１４０は、主として通信部１６により実現される。ＧＷ通信部１４０は、ＧＷ接続部１１８から送出された処理情報を受信装置３０に送信する。ＧＷ通信部１４０は、データ処理装置１００において、一の生成データと付加情報とを含む処理情報を受信装置に送信する送信手段の一例に相当する。
【００５４】
受信装置３０は、インターネット上のいわゆるクラウドサーバに相当する。なお、受信装置３０によって生成データを処理した結果は、ＧＷ通信部１４０を介して実行制御部１１３に伝送されてもよい。すなわち、受信装置３０は、部分処理部１３０と同様に、処理フローを構成する部分処理を実行してもよい。
【００５５】
続いて、データ処理装置１００によるデータの送信処理について、図８を用いて説明する。図８に示されるデータ送信処理は、データ処理装置１００が処理フローを実行することで開始する。
【００５６】
データ送信処理において、データ処理装置１００は、生成データを生成する（ステップＳ１１）。具体的には、実行制御部１１３が、フロー設定情報５２に従って部分処理を部分処理部１３０に実行させて生成データを部分処理部１３０から取得する。
【００５７】
次に、データ処理装置１００は、ステップＳ１１で生成された生成データについて、条件設定情報５１に規定される送信条件が成立するか否かを判定する（ステップＳ１２）。具体的には、判定部１１５が、生成データの値が予め規定された範囲外であるか否かを判定して、送信条件の成否を示す条件情報を出力部１１７に送出する。
【００５８】
送信条件が成立すると判定した場合（ステップＳ１２；Ｙｅｓ）、データ処理装置１００は、送信フラグを１にセットする（ステップＳ１３）。具体的には、出力部１１７が、「Ｔｒｕｅ」の値を示す条件情報を判定部１１５から取得した場合に、送信フラグの値を「１」に設定する。
【００５９】
次に、データ処理装置１００は、前回の送信フラグがセットされていたか否かを判定する（ステップＳ１４）。具体的には、出力部１１７が、前回のステップＳ１２の判定に従って設定された送信フラグが「１」にセットされたか否かを判定する。なお、検出部１１６から始端の検出結果が通知される場合には、出力部１１７は、ステップＳ１４において、始端の不検出が通知されたか否かを判定してもよい。
【００６０】
前回の送信フラグがセットされていなかったと判定した場合（ステップＳ１４；Ｎｏ）、出力部１１７は、送信条件が不成立の状態から成立の状態に変化したと判断して、始端フラグを１にセットする（ステップＳ１５）。その後、出力部１１７は、今回の送信フラグを、次回のステップＳ１４，Ｓ１９において参照するために保存する（ステップＳ１６）。
【００６１】
一方、前回の送信フラグがセットされていたと判定した場合（ステップＳ１４；Ｙｅｓ）、出力部１１７は、送信条件が前回から引き続き成立していると判断して、始端フラグをゼロにリセットする（ステップＳ１７）。その後、出力部１１７は、ステップＳ１６に処理を移行する。
【００６２】
ステップＳ１２において、送信条件が成立しないと判定した場合（ステップＳ１２；Ｎｏ）、データ処理装置１００は、送信フラグをゼロにリセットする（ステップＳ１８）。具体的には、出力部１１７が、「Ｆａｌｓｅ」の値を示す条件情報を判定部１１５から取得した場合に、送信フラグの値を「ゼロ」に設定する。ステップＳ１３，１８は、データ処理装置１００によって実行されるデータ処理方法において、条件情報を取得する取得ステップに対応する。
【００６３】
次に、データ処理装置は、前回の送信フラグがセットされていたか否かを判定する（ステップＳ１９）。なお、検出部１１６から終端の検出結果が通知される場合には、出力部１１７は、ステップＳ１９において、終端の検出が通知されたか否かを判定してもよい。
【００６４】
前回の送信フラグがセットされていたと判定した場合（ステップＳ１９；Ｙｅｓ）、出力部１１７は、送信条件が成立の状態から不成立の状態に変化したと判断して、終端フラグを１にセットする（ステップＳ２０）。その後、出力部１１７は、ステップＳ１６に処理を移行する。
【００６５】
一方、前回の送信フラグがセットされていなかったと判定した場合（ステップＳ１９；Ｎｏ）、出力部１１７は、送信条件が前回から引き続き成立していないと判断して、終端フラグをゼロにリセットする（ステップＳ２１）。その後、出力部１１７は、ステップＳ１６に処理を移行する。
【００６６】
ステップＳ１６に続いて、データ処理装置１００は、送信フラグ、始端フラグ及び終端フラグのうちのいずれかのフラグがセットされているか否かを判定する（ステップＳ２２）。具体的には、出力部１１７が、ステップＳ１３、ステップＳ１５、及びステップＳ２０のいずれか１つが実行されたか否かを判定する。
【００６７】
いずれのフラグもセットされていないと判定した場合（ステップＳ２２；Ｎｏ）、出力部１１７は、生成データを破棄する（ステップＳ２４）。一方、いずれかのフラグがセットされていると判定した場合（ステップＳ２２；Ｙｅｓ）、データ処理装置１００は、ステップＳ１１で生成された生成データと、送信フラグ、始端フラグ及び終端フラグと、を含む処理情報を送信する（ステップＳ２３）。具体的には、出力部１１７が、生成データ及び付加情報を出力し、ＧＷ通信部１４０が処理情報を受信装置３０に送信する。これにより、検出部１１６によって送信条件の成否の切り替わりが検出されたときに、生成データが、単独の、又は、連続して生成されて送信条件が成立する複数の生成データのうちの最初の生成データであることを示す始端フラグと、最後の生成データであることを示す終端フラグと、の少なくとも一方を含む付加情報が生成されて受信装置３０に伝送される。ステップＳ２３は、データ処理装置１００によって実行されるデータ処理方法において、出力部１１７が付加情報を出力する出力ステップと、ＧＷ通信部１４０が処理情報を送信する送信ステップと、に対応する。その後、データ処理装置１００は、ステップＳ１１以降の処理を繰り返す。
【００６８】
以上、説明したように、本実施の形態に係るデータ処理装置１００によれば、出力部１１７が、一の生成データの前回及び次回の少なくとも一方に生成された他の生成データについての送信条件の成否に関する付加情報を出力し、ＧＷ通信部１４０が、一の生成データと付加情報とを含む処理情報を受信装置３０に送信する。このため、受信装置３０では、一の生成データが他の生成データと連続して送信されたものであるか否かを付加情報により判断することができる。したがって、機器２０から収集したデータに施される処理フローに関する情報を遠隔で利用する際の利便性を向上させることができる。
【００６９】
また、データ処理装置１００は、ユーザによる任意の処理フローを実行するためのプラットフォーム１１０を有し、このプラットフォーム１１０が、記憶部１１４、判定部１１５、検出部１１６及び出力部１１７を有する。このため、個別に開発されるプラグインソフトウェアにより実現される収集部１２０及び部分処理部１３０が、記憶部１１４、判定部１１５、検出部１１６及び出力部１１７の機能を有する必要はなく、プラグインソフトウェアの開発が容易になる。
【００７０】
また、ひとまとまりの情報を送りつつ当該情報の大きさを通知する手法として、ペイロード長を示すヘッダを有するパケットのように、予め情報の大きさを宣言する手法が一般的に知られている。しかしながら、ＦＡの現場で実行される処理フローに関しては、送信条件が無制限に連続して成立するケースがある。また、ＦＡの現場ではリアルタイム性が求められるため、生成データが生成されたときに速やかに生成データを送信する必要があり、送信条件が成立する生成データがどの程度連続するかを予め予測することが難しい。
【００７１】
これに対して、本実施の形態に係るデータ処理装置１００によれば、送信条件が成立する生成データの連続送信の開始及び終了を受信装置３０に通知することができる。具体的には、検出部１１６によって検出された始端及び終端の少なくとも一方が受信装置３０に通知される。このため、受信装置３０は、連続的に生成されて送信されたひとまとまりの生成データを、他の生成データから区別することができる。
【００７２】
実施の形態２．
続いて、実施の形態２について、上述の実施の形態１との相違点を中心に説明する。なお、上記実施の形態１と同一又は同等の構成については、同等の符号を用いる。本実施の形態は、付加情報を、フラグに代えて、直前に送信された処理情報の複製とする点で、実施の形態１とは異なる。
【００７３】
本実施の形態に係るデータ処理装置１００の出力部１１７は、図９に示されるように、処理情報を複製する複製部１１７１を有する。複製部１１７１は、検出部１１６から終端の検出が通知されたときに、前回の生成データと、当該生成データに関連付けられたタイムスタンプと、を複製して、付加情報として出力する。
【００７４】
図１０には、出力部１１７から出力される情報が示されている。図１０の左から１，２列目において下線により示されるように、出力部１１７は、生成データとタイムスタンプとを関連付けて逐次出力する。これにより、ＧＷ通信部１４０からは、生成データとタイムスタンプとが関連付けられて受信装置３０に送信される。
【００７５】
図１０中の矢印は、終端に相当する生成データを含むレコードを示している。この終端に相当する生成データの直後において、終端の生成データ及び終端の生成データに関連付けられたタイムスタンプが、付加情報として出力部１１７によって生成されて出力され、ＧＷ通信部１４０によって受信装置３０に送信される。このように送信される付加情報は、図１０の右から１，２列目に下線を付して示されている。これにより、検出部１１６によって送信条件の成立から不成立への切り替わりが検出されたときには、終端である生成データと、当該生成データに関連付けられて送信されるタイムスタンプと、の複製が付加情報として生成され、受信装置３０へ伝送される。
【００７６】
以上、説明したように、出力部１１７は、終端が検出された場合に、終端の生成データとタイムスタンプとを複製して出力する。受信装置３０は、通常は、重複するタイムスタンプを受信することがない。しかしながら、受信装置３０は、同一時刻を示すタイムスタンプを受信すると、このタイムスタンプとともに受信した生成データが終端に相当することを判別して、単独又は連続するひとまとまりの生成データを他の生成データから区別することができる。なお、受信装置３０が、重複するタイムスタンプを受信したときに、当該タイムスタンプが終端を示す付加情報であると判断するために、データ処理装置１００において生成される生成データにはそれぞれ、異なるタイムスタンプが関連付けられる。
【００７７】
以上、実施の形態について説明したが、本開示は上記実施の形態によって限定されるものではない。
【００７８】
例えば、上記実施の形態では、送信条件が、生成データの値が予め規定された範囲外である例を中心に説明したが、これには限定されない。例えば図１１に示されるように、送信条件は、生成データの送信を開始するための送信開始条件と、生成データの送信を終了するための送信終了条件と、の少なくとも一方を含んでもよい。図１１に示される例では、予め規定された時刻以降に、値がゼロ以上である生成データが送信される。これにより、特定の時間帯に着目して受信装置３０が処理情報を毎日利用することが可能になる。
【００７９】
また、上記実施の形態１では、付加情報に送信フラグが含まれたが、付加情報から送信フラグを省略してもよい。また、終端に相当する生成データの直後には、データ処理装置１００は、条件が成立しない生成データを送信することなく付加情報のみを送信してもよい。また、値が「ゼロ」である始端フラグ及び値が「ゼロ」である終端フラグの送信を省略してもよい。データ処理装置１００は、始端と終端との少なくとも一方に相当する生成データにのみ付加情報を付与してもよい。また、データ処理装置１００は、始端フラグと終端フラグとのいずれか一方の送信を省略してもよい。受信装置３０は、始端又は終端の一方を判別することができれば、ひとまとまりの単独又は連続する複数の生成データを他の生成データから区別することができる。
【００８０】
また、付加情報は、上記実施の形態１，２で説明したものに限定されない。例えば図１２に示されるように、付加情報は、連続して生成されて送信される生成データに対して、１から順にインクリメントされて割り振られる番号であってもよい。受信装置３０は、このような番号を参照して、ひとまとまりの生成データを認識することができる。付加情報は、その他、一の生成データの前回及び次回の少なくとも一方に生成された他の生成データについて送信条件が成立するかを示す情報であって、受信装置３０がひとまとまりの単独又は連続する複数の生成データを他の生成データから区別することができる情報であればよい。
【００８１】
また、上記実施の形態では、データ処理装置１００が部分処理部１３０を有していたが、これには限定されず、図１３に示されるように、一部又はすべての部分処理部１３０がデータ処理装置１００の外部にあってもよい。また、この部分処理部１３０により判定部１１５の機能を実現してもよい。
【００８２】
また、検出部１１６を省略してデータ処理装置１００を構成し、送信フラグのみを付加情報としてもよい。受信装置３０は、検出部１１６と同等の機能を備えれば、送信フラグが付された生成データから、始端及び終端を判別することができる。
【００８３】
また、データ処理装置１００の機能は、専用のハードウェアによっても、また、通常のコンピュータシステムによっても実現することができる。
【００８４】
例えば、プロセッサ１１によって実行されるプログラムＰ１を、コンピュータ読み取り可能な非一時的な記録媒体に格納して配布し、そのプログラムＰ１をコンピュータにインストールすることにより、上述の処理を実行する装置を構成することができる。このような記録媒体としては、例えばフレキシブルディスク、ＣＤ−ＲＯＭ（Compact Disc Read−Only Memory）、ＤＶＤ（Digital Versatile Disc）、ＭＯ（Magneto−Optical Disc）が考えられる。
【００８５】
また、プログラムＰ１をインターネットに代表される通信ネットワーク上のサーバ装置が有するディスク装置に格納しておき、例えば、搬送波に重畳させて、コンピュータにダウンロードするようにしてもよい。
【００８６】
また、通信ネットワークを介してプログラムＰ１を転送しながら起動実行することによっても、上述の処理を達成することができる。
【００８７】
さらに、プログラムＰ１の全部又は一部をサーバ装置上で実行させ、その処理に関する情報をコンピュータが通信ネットワークを介して送受信しながらプログラムを実行することによっても、上述の処理を達成することができる。
【００８８】
なお、上述の機能を、ＯＳ（Operating System）が分担して実現する場合又はＯＳとアプリケーションとの協働により実現する場合等には、ＯＳ以外の部分のみを媒体に格納して配布してもよく、また、コンピュータにダウンロードしてもよい。
【００８９】
また、データ処理装置１００の機能を実現する手段は、ソフトウェアに限られず、その一部又は全部を、回路を含む専用のハードウェアによって実現してもよい。
【００９０】
本開示は、本開示の広義の精神と範囲を逸脱することなく、様々な実施の形態及び変形が可能とされるものである。また、上述した実施の形態は、この開示を説明するためのものであり、本開示の範囲を限定するものではない。すなわち、本開示の範囲は、実施の形態ではなく、請求の範囲によって示される。そして請求の範囲内及びそれと同等の開示の意義の範囲内で施される様々な変形が、この開示の範囲内とみなされる。
【産業上の利用可能性】
【００９１】
本開示は、機器から収集したデータの処理に関する情報の遠隔における利用に適している。
【符号の説明】
【００９２】
１０００  データ処理システム、  １００１  工場、  １１  プロセッサ、  １２  主記憶部、  １３  補助記憶部、  １４  入力部、  １５  出力部、  １６  通信部、  １７  内部バス、  １００  データ処理装置、  １１０  プラットフォーム、  １１１  第１受付部、  １１２  第２受付部、  １１３  実行制御部、  １１４  記憶部、  １１５  判定部、  １１６  検出部、  １１７  出力部、  １１７１  複製部、  １１８  ＧＷ接続部、  １２０  収集部、  １３０  部分処理部、  １４０  ＧＷ通信部、  ２０  機器、  ２１  端末、  ３０  受信装置、  ３００  処理フロー、  ３１  収集処理、  ３２  第１加工処理、  ３３  第２加工処理、  ３４  診断処理、  ３５  第３加工処理、  ４１〜４３  外部送信処理、  ５１  条件設定情報、  ５２  フロー設定情報、  Ｐ１  プログラム。
【要約】
データ処理装置（１００）は、機器（２０）から繰り返し送信されるデータそれぞれに処理を施し、処理に関する処理情報を受信装置（３０）に送信する装置であって、出力部（１１７）と、ＧＷ通信部（１４０）と、を備える。出力部（１１７）は、処理が実行される際に生成される生成データを受信装置（３０）に送信するための送信条件が成立するか否かを示す条件情報を、生成データが生成される毎に取得し、生成データについての送信条件が成立することが条件情報によって示されるときに、該生成データの前回及び次回の少なくとも一方に生成された他の生成データについての送信条件の成否に関する付加情報を出力する。ＧＷ通信部（１４０）は、条件が成立する生成データと付加情報とを含む処理情報を受信装置（３０）に送信する。【図１】
0006790309.tif 000002
【図２】
0006790309.tif 000003
【図３】
0006790309.tif 000004
【図４】
0006790309.tif 000005
【図５】
0006790309.tif 000006
【図６】
0006790309.tif 000007
【図７】
0006790309.tif 000008
【図８】
0006790309.tif 000009
【図９】
0006790309.tif 000010
【図１０】
0006790309.tif 000011
【図１１】
0006790309.tif 000012
【図１２】
0006790309.tif 000013
【図１３】
0006790309.tif 000014