(57)【要約】  データ処理装置（１０）は、機器（２０）に接続される装置であって、機器（２０）と通信する通信部（１３０）と、通信部（１３０）によって受信されたデータに施される処理フローの設定を受け付ける受付部（１４０）と、処理フローを構成する部分処理を実行する一又は複数の処理部（１６０）のうちのいずれかに、通信部（１３０）によって受信されたデータを送出して、処理フローに対応する順で一又は複数の処理部（１６０）に部分処理を実行させ、該実行により得る処理結果を送出する制御部（１１０）と、を備える。
2019198221.tif 000002
【特許請求の範囲】
【請求項１】
機器に接続されるデータ処理装置であって、
前記機器と通信する通信手段と、
前記通信手段によって受信されたデータに施される処理フローの設定を受け付ける受付手段と、
前記処理フローを構成する部分処理を実行する一又は複数の処理手段のうちのいずれかに、前記通信手段によって受信されたデータを送出して、前記処理フローに対応する順で前記一又は複数の処理手段に前記部分処理を実行させ、該実行により得る処理結果を送出する制御手段と、
を備えるデータ処理装置。
【請求項２】
前記一又は複数の処理手段はそれぞれ、前記制御手段から送出されたデータに前記部分処理を施して得る部分処理結果を前記制御手段に送出し、
前記制御手段は、いずれか一の処理手段から送出された前記部分処理結果を示すデータを前記処理フローに従って次の処理手段に送出することで、前記一又は複数の処理手段に前記部分処理を実行させる、
請求項１に記載のデータ処理装置。
【請求項３】
前記機器から繰り返し送信されて前記通信手段によって受信されるデータに前記部分処理を施して得る前記部分処理結果を、部分処理の入出力データを識別するためのラベルと関連付けて記憶する記憶手段、をさらに備え、
前記制御手段は、前記部分処理結果に関連付けられた前記ラベルと前記処理フローとを参照して、該部分処理結果を示すデータの送出先である前記次の処理手段を決定する、
請求項２に記載のデータ処理装置。
【請求項４】
前記一又は複数の処理手段の少なくとも１つは、プラグインソフトウェアで実現される、
請求項１から３のいずれか一項に記載のデータ処理装置。
【請求項５】
前記制御手段は、前記処理フローの実行を、前記プラグインソフトウェアで実現される前記処理手段を介したデータの伝送量に応じて制限する、
請求項４に記載のデータ処理装置。
【請求項６】
前記制御手段は、前記処理フローの実行を、データ処理装置と前記機器との間におけるデータの伝送量に応じて制限する、
請求項１から５のいずれか一項に記載のデータ処理装置。
【請求項７】
前記制御手段は、前記処理フローの実行を、予め設定された時刻から経過した時間の長さに応じて制限する、
請求項１から６のいずれか一項に記載のデータ処理装置。
【請求項８】
前記機器から送信されるデータは、センサによるセンシング結果を含む、
請求項１から７のいずれか一項に記載のデータ処理装置。
【請求項９】
前記通信手段は、前記制御手段から送出される前記処理結果を示す情報を出力する出力手段、を備え、
前記出力手段は、前記処理結果を示す情報として、前記機器と、該機器とは異なる他の機器と、の少なくとも一方に対する動作指令を出力する、
請求項１から８のいずれか一項に記載のデータ処理装置。
【請求項１０】
データを受信し、
受信したデータに施される処理フローの設定を受け付け、
前記処理フローを構成する部分処理を実行する一又は複数の処理手段のうちのいずれかに、受信したデータを送出して、前記処理フローに対応する順で前記一又は複数の処理手段に前記部分処理を実行させ、該実行により得る処理結果を送出する、
ことを含むデータ処理方法。
【請求項１１】
コンピュータに、
データを受信し、
受信したデータに施される処理フローの設定を受け付け、
前記処理フローを構成する部分処理を実行する一又は複数の処理手段のうちのいずれかに、受信したデータを送出して、前記処理フローに対応する順で前記一又は複数の処理手段に前記部分処理を実行させ、該実行により得る処理結果を送出する、
ことを実行させるためのプログラム。
【発明の詳細な説明】
【技術分野】
【０００１】
本発明は、データ処理装置、データ処理方法及びプログラムに関する。
【背景技術】
【０００２】
工場に代表される施設では、施設内からデータを収集して処理することで、生産工程、検査工程、その他の工程が実現されている。そして、様々な市場の要求に対応するために、データを処理する装置を置き換えることなく処理の内容を変更することが広く行われている（例えば、特許文献１を参照）。【０００３】
特許文献１には、機械に接続されたコンピュータが、ベースソフトウェアおよび作業ソフトウェアを備える構成が開示されている。ベースソフトウェアは、コンピュータに搭載されていて、新たにインストールされる作業ソフトウェアと機械との間で伝送されるデータを中継する。これにより、新たな作業ソフトウェアをインストールすることで、コンピュータによるデータの処理内容を変更することができる。
【先行技術文献】
【特許文献】
【０００４】
【特許文献１】特開２０１７−１５７１８９号公報
【発明の概要】
【発明が解決しようとする課題】
【０００５】
近年、施設内で収集するデータ量が増加し、処理結果の利用用途も多岐に渡ることから、種々の処理を組み合わせた処理フローがデータに施されるケースが多い。しかしながら、特許文献１では、一つの作業ソフトウェアが、機械からの情報を取得し、出力先の機械を特定して、指示情報を出力するところまでを実施するものであった。このため、データに施す種々の処理を組み合わせた処理フローを変更するためには、変更後の処理フローを一つのソフトウェアで実現する作業ソフトウェアを都度準備する必要があり、その準備作業が煩雑であった。【０００６】
本発明は、上記の事情に鑑みてなされたものであり、種々の処理を組み合わせた処理フローをデータに対して簡便に施すことを目的とする。
【課題を解決するための手段】
【０００７】
上記目的を達成するため、本発明のデータ処理装置は、機器に接続されるデータ処理装置であって、機器と通信する通信手段と、通信手段によって受信されたデータに施される処理フローの設定を受け付ける受付手段と、処理フローを構成する部分処理を実行する一又は複数の処理手段のうちのいずれかに、通信手段によって受信されたデータを送出して、処理フローに対応する順で一又は複数の処理手段に部分処理を実行させ、該実行により得る処理結果を送出する制御手段と、を備える。
【発明の効果】
【０００８】
本発明によれば、データ処理装置は、処理フローを構成する部分処理を実行する一又は複数の処理手段に、設定された処理フローに対応する順で部分処理を実行させる。このため、部分処理の実行順序を変更することで、多様な処理フローを実行することができる。したがって、種々の処理を組み合わせた処理フローをデータに対して簡便に施すことができる。
【図面の簡単な説明】
【０００９】
【図１】本発明の実施の形態１に係るデータ処理システムのブロック図
【図２】実施の形態１に係るデータ処理装置のハードウェア構成を示す図
【図３】実施の形態１に係る処理フローの一例を示す図
【図４】実施の形態１に係るデータ処理装置の機能的な構成を示す図
【図５】実施の形態１に係るデータ処理を示すフローチャート
【図６】実施の形態１に係る管理情報の一例を示す図
【図７】実施の形態１に係る入力画面の第１の例を示す図
【図８】実施の形態１に係る入力画面の第２の例を示す図
【図９】実施の形態１に係る条件テーブルの一例を示す図
【図１０】実施の形態１に係る動作テーブルの一例を示す図
【図１１Ａ】実施の形態１に係る中間情報の第１の例を示す図
【図１１Ｂ】実施の形態１に係る中間情報の第２の例を示す図
【図１１Ｃ】実施の形態１に係る中間情報の第３の例を示す図
【図１２】実施の形態１に係る中間情報の第４の例を示す図
【図１３】実施の形態１に係る中間情報の第５の例を示す図
【図１４】実施の形態２に係るデータ処理装置の機能的な構成を示す図
【図１５】実施の形態２に係る認証情報の一例を示す図
【図１６】実施の形態２に係るデータ処理を示すフローチャート
【図１７】変形例に係る処理フローを示す図
【図１８】変形例に係るデータ処理装置の機能的な構成を示す第１の図
【図１９】変形例に係るデータ処理装置の機能的な構成を示す第２の図
【発明を実施するための形態】
【００１０】
以下、本発明の実施の形態に係るデータ処理システム１０００について、図面を参照しつつ詳細に説明する。
【００１１】
実施の形態１．
本実施の形態に係るデータ処理システム１０００は、機器から送信されたデータを処理するシステムである。データ処理システム１０００は、製品の生産システムとして工場に設置される。データ処理システム１０００によるデータの処理は、例えば、不良品の検出及び製造工程からの除外、材料の分類、又は異常の監視を実現するために実行される。データ処理システム１０００は、データに施す処理の内容をユーザが容易に設計することを可能にする。データ処理システム１０００は、図１に示されるように、製品の製造工程で稼働する機器２１，２２，２３と、機器２１，２２，２３から送信されたデータを処理するデータ処理装置１０と、を有している。
【００１２】
データ処理装置１０は、ネットワーク４１を介して機器２１，２２と接続され、機器２１，２２との間で信号を送受信することにより互いに通信する。また、データ処理装置１０は、ネットワーク４３を介して機器２３と接続され、機器２３との間で信号を送受信することにより互いに通信する。ネットワーク４１とネットワーク４３は、異なる規格の産業用ネットワークである。なお、ネットワーク４１，４３は、シリアル通信を実現するための専用線であってもよい。
【００１３】
機器２１は、製品の製造工程で利用されるセンサ２１ａを有している。センサ２１ａは、例えば、光センサ、圧力センサ、超音波センサ、その他の検出器である。機器２１は、センサ２１ａによるセンシング結果を含むデータを、データ処理装置１０から指定された周期で繰り返しデータ処理装置１０に送信する。この周期は、例えば、１０ｍｓ、１００ｍｓ、又は１ｓｅｃである。
【００１４】
機器２２は、製品の製造工程で利用されるアクチュエータ又はロボットである。機器２２は、データ処理装置１０によるデータの処理結果に応じて稼働する。詳細には、機器２２は、データの処理結果として、稼働モードの指定、稼働開始、及び稼働停止のいずれかを指示する動作指令をデータ処理装置１０から受信すると、この動作指令に従って稼働状態を変更する。
【００１５】
機器２３は、製品の製造工程で利用されるセンサ２３ａに接続される。機器２３は、センサ２３ａによるセンシング結果をセンサ２３ａから取得して、このセンシング結果を含むデータを、データ処理装置１０から指定された周期で繰り返しデータ処理装置１０に送信する。
【００１６】
以下では、データ処理装置１０に接続される機器２１，２２，２３を総称して機器２０と表記する。データ処理装置１０と機器２０とを接続するデータの伝送路４０は、ネットワーク４１及びネットワーク４３のような有線通信の伝送路に限定されず、無線通信のための伝送路であってもよい。
【００１７】
機器２０は、センシング結果を含むデータを送信する機器とデータ処理装置１０からの動作指令に従って稼働する機器とのいずれか一方に限定されない。機器２０は、データ処理装置１０にデータを送信するとともにデータ処理装置１０からの動作指令に従って稼働する機器であってもよい。
【００１８】
データ処理装置１０は、ＰＬＣ又は産業用パソコンであって、機器２０から収集したデータに対して、あらかじめ設定された処理を施して処理結果を出力するＦＡ（Factory Automation）装置である。データ処理装置１０は、処理結果の出力として、機器２０へ動作指令を送信するが、これには限定されず、データを分析又は加工した品質管理情報をユーザに提示してもよいし、データ処理装置１０自体又は外部のサーバ装置へ品質管理情報を蓄積してもよい。
【００１９】
データ処理装置１０は、そのハードウェア構成として、図２に示されるように、プロセッサ１１と、主記憶部１２と、補助記憶部１３と、入力部１４と、出力部１５と、通信部１６と、を有するコンピュータ装置である。主記憶部１２、補助記憶部１３、入力部１４、出力部１５及び通信部１６はいずれも、内部バス１７を介してプロセッサ１１に接続される。
【００２０】
プロセッサ１１は、ＭＰＵ（Micro Processing Unit）を含む。プロセッサ１１は、補助記憶部１３に記憶されるプログラムＰ１を実行することにより、データ処理装置１０の種々の機能を実現して、後述の処理を実行する。
【００２１】
主記憶部１２は、ＲＡＭ（Random Access Memory）を含む。主記憶部１２には、補助記憶部１３からプログラムＰ１がロードされる。そして、主記憶部１２は、プロセッサ１１の作業領域として用いられる。
【００２２】
補助記憶部１３は、ＥＥＰＲＯＭ（Electrically Erasable Programmable Read-Only Memory）に代表される不揮発性メモリを含む。補助記憶部１３は、プログラムＰ１の他に、プロセッサ１１の処理に用いられる種々のデータを記憶する。補助記憶部１３は、プロセッサ１１の指示に従って、プロセッサ１１によって利用されるデータをプロセッサ１１に供給し、プロセッサ１１から供給されたデータを記憶する。なお、図２では、補助記憶部１３に記憶される１つのプログラムＰ１が代表的に示されているが、プログラムＰ１は、複数のプログラムであってもよい。また、プログラムＰ１は、データ処理装置１０に予め設定されたプログラムと、データ処理装置１０のユーザによって追加されたプログラムと、を含んでいてもよい。
【００２３】
入力部１４は、入力キー及びポインティングデバイスに代表される入力デバイスを含む。入力部１４は、データ処理装置１０のユーザによって入力された情報を取得して、取得した情報をプロセッサ１１に通知する。
【００２４】
出力部１５は、ＬＣＤ（Liquid Crystal Display）及びスピーカに代表される出力デバイスを含む。出力部１５は、プロセッサ１１の指示に従って、種々の情報をユーザに提示する。
【００２５】
通信部１６は、外部の機器２０と通信するためのネットワークインタフェース回路を含む。通信部１６は、機器２０から信号を受信して、この信号により示されるデータをプロセッサ１１へ出力する。また、通信部１６は、プロセッサ１１から出力されたデータを示す信号を機器２０へ送信する。
【００２６】
データ処理装置１０は、図２に示されるハードウェア構成が協働することにより、ユーザによって設定されるフローの処理を実行する。データ処理装置１０に設定される処理フローは、図３に例示されるように、複数の部分処理７０１〜７１０が予め設定された順序で実行されることにより達成される。
【００２７】
図３中の矢印は、部分処理の実行の結果として得る出力値を次の部分処理に入力することを意味する。例えば、部分処理７０１から部分処理７０３に向かう矢印は、「機器１からデータ受信」という部分処理により得たデータを「スケーリング」の対象とすることを意味する。矢印は、部分処理７０１〜７１０それぞれの入力及び出力の少なくとも一方のデータに対応し、この入出力データには、データラベルが付されている。例えば、部分処理７０３は、データラベル「＃１」が付されたデータの入力を受けて、データラベル「＃３」が付されたデータを出力する。このデータラベルは、処理フローにおける部分処理の入出力データを識別するために用いられ、データ自体を識別するものではない。例えば、部分処理７０３から繰り返し出力されるデータにはすべてデータラベル「＃３」が付される。データラベルは、ユーザによって任意に設定されてもよいし、データ処理装置１０によって割り振られてもよい。なお、図３中の「機器１」、「機器２」及び「機器３」はそれぞれ、ユーザによって機器２１，２２，２３に付されたラベル名である。
【００２８】
図３において、「機器１からデータ受信」という部分処理７０１及び「機器３からデータ受信」という部分処理７０２はそれぞれ、機器２０から送信されたデータを受信することを表す。
【００２９】
また、「スケーリング」という部分処理７０３は、予め設定された係数を入力値に乗じた上で予め設定されたオフセット値を加算することを表し、いわゆる正規化を含む。「データ間引き」という部分処理７０４は、繰り返し入力される入力値の一部を破棄して、他の入力値をそのまま出力することを表し、例えば、予め設定された周期で入力値を破棄することを含む。「ＦＦＴ」という部分処理７０５は、高速フーリエ変換（Fast Fourier Transform）を意味し、時系列データを周波数表現に変換することを意味する。「平滑化」という部分処理７０６は、入力値の系列からノイズを除去することを表し、例えば、予め定められた個数の入力値の平均値を出力することを含む。これらの部分処理７０３〜７０６は、データの加工処理に相当する。
【００３０】
また、「大小比較」という部分処理７０７は、２つの入力値の大きさを比較することを表す。「閾値判定」という部分処理７０８は、予め設定された閾値と入力値とを比較することを表す。「領域判定」という部分処理７０９は、繰り返し入力される入力値がいずれも、予め設定された基準値から誤差の範囲内にあるか否かを判定することを表し、領域は、複数の入力値のサンプリング時刻を含む時間範囲を意味する。これらの部分処理７０７〜７０９は、データの分析処理及び診断処理に相当する。
【００３１】
なお、図３の例では、データの加工処理を実現する部分処理７０３〜７０６と、データの分析処理及び診断処理を実現する部分処理７０７〜７０９と、を別個の処理としているが、これには限定されない。例えば、ＦＦＴと閾値判定とをまとめた単一の部分処理を設けてもよい。
【００３２】
処理フローは、部分処理７０２，７０４，７１０の出力のように、一の部分処理の出力値を２以上の他の部分処理に入力する分岐部分を含んでいてもよい。また、処理フローは、部分処理７０７，７１０の入力のように、２以上の部分処理の出力を１つの部分処理に入力する合流部分を含んでいてもよい。
【００３３】
また、「指令決定」という部分処理７１０は、入力値が予め設定された条件に合致するかどうかに応じて機器２０への動作指令を決定することを表す。動作指令の決定の詳細については後述する。なお、「機器１に書込」という処理８０１及び「機器２に書込」という処理８０２はそれぞれ、機器２０の記憶領域に指令データを書き込むことにより、動作指令を与えることを表す。
【００３４】
データ処理装置１０は、図３に例示されるような処理フローを実行するために、その機能として、図４に示されるように、データ処理装置１０の構成要素を制御する制御部１１０と、種々のデータを記憶する記憶部１２０と、伝送路４０の種別に応じて設けられて機器２０と通信する通信部１３０と、通信部１３０によって受信されたデータに施される処理フローの設定を受け付ける受付部１４０と、ユーザが処理フローを設定するためのＵＩ（User Interface）部１５０と、処理フローを構成する部分処理を実行する複数の処理部１６１，１６２と、制御部１１０と処理部１６１，１６２との間でデータを伝送する伝送部１７０と、を有している。以下では、処理部１６１，１６２を総称して処理部１６０と表記する。なお、図４では、部分処理を実行する処理部１６１，１６２が代表的に示されているが、図３に例示された処理フローが実行される場合には、データ処理装置１０は、部分処理７０３〜７０９のそれぞれを実行する７個の処理部１６０を有することとなる。ただし、これには限定されず、単一の処理部１６０が、図３に示される複数の部分処理を実行してもよい。処理部１６０の数と部分処理の数とは、異なっていてもよい。
【００３５】
制御部１１０は、処理部１６０を制御することにより、設定された処理フローを実行する。詳細には、制御部１１０は、通信部１３０によって受信されたデータを取得する。そして、制御部１１０は、取得したデータを、伝送部１７０を介して複数の処理部１６０のうちのいずれかに送出して、処理フローに対応する順で複数の処理部１６０に部分処理を実行させる。また、制御部１１０は、図３に示される処理フローを構成する部分処理７１０を実行する。そして、制御部１１０は、複数の部分処理の実行により処理フローの処理結果を得て、通信部１３０の出力部１３２に送出する。制御部１１０は、主としてプロセッサ１１によって実現される。詳細には、制御部１１０は、プロセッサ１１がプログラムＰ１の少なくとも一部を実行することにより実現される。制御部１１０は、請求項の制御手段として機能する。
【００３６】
記憶部１２０に記憶されるデータは、制御部１１０が複数の処理部１６０を管理するための管理情報１２１と、受付部１４０によって設定が受け付けられた処理フローを示すフロー情報１２２と、処理フローの実行中に一時的に生成される中間情報１２３と、を含む。管理情報１２１、フロー情報１２２及び中間情報１２３の詳細については後述する。記憶部１２０は、主として補助記憶部１３によって実現される。ただし、これに限定されず、記憶部１２０は、主記憶部１２によって実現されてもよいし、主記憶部１２と補助記憶部１３との協働によって実現されてもよい。記憶部１２０は、請求項の記憶手段として機能する。
【００３７】
通信部１３０は、制御部１１０の指示に従って、機器２０から送信されたデータを、伝送路４０を介して受信し、受信したデータを制御部１１０に送出する。通信部１３０は、主として通信部１６によって実現される。通信部１３０は、請求項の通信手段として機能する。通信部１３０は、機器２０から送信されるデータを受信する受信部１３１と、処理フローが実行された結果を示す情報を出力する出力部１３２と、伝送路４０に対応する通信プロトコルで伝送されるデータを、制御部１１０に適した共通のプロトコルのデータに変換する変換部１３３と、を有している。
【００３８】
受信部１３１は、制御部１１０の指示に従って、機器２０から送信されたデータを、伝送路４０を介して受信し、受信したデータを制御部１１０に送出する。受信部１３１は、変換部１３３を利用してプロトコルを変換し、プロトコルが変換されたデータを制御部１１０に送出する。受信部１３１によるデータの受信は、図３中の部分処理７０１，７０２に相当する。
【００３９】
出力部１３２は、処理フローの結果として機器２０への動作指令を制御部１１０から取得する。そして、出力部１３２は、機器２０に動作指令を送信する。詳細には、出力部１３２は、制御部１１０の指示に従って、伝送路４０を介して動作指令を示す情報を機器２０に書き込む。出力部１３２は、受信部１３１と同様に、変換部１３３を利用してプロトコルを変換し、プロトコルが変換されたデータを出力する。出力部１３２は、主として通信部１６によって実現される。出力部１３２は、請求項の出力手段として機能する。
【００４０】
受付部１４０は、ユーザによる処理フローの設定を受け付けて、処理フローの内容を示すフロー情報１２２を制御部１１０に送出する。制御部１１０に送出されたフロー情報１２２は、制御部１１０によって記憶部１２０に格納される。受付部１４０は、主としてプロセッサ１１によって実現される。受付部１４０は、請求項の受付手段として機能する。
【００４１】
ＵＩ部１５０は、制御部１１０の指示を、受付部１４０を介して取得し、この指示に従って、処理フローの内容を入力するための画面をユーザに対して提示する。そして、ＵＩ部１５０は、ユーザによって設定された処理フローの内容を受付部１４０に通知する。ＵＩ部１５０は、主としてプロセッサ１１と入力部１４と出力部１５との協働により実現される。ＵＩ部１５０は、処理フローを設定するためのエンジニアリングツールとして開発される。
【００４２】
複数の処理部１６０はそれぞれ、制御部１１０から伝送部１７０を介して入力されたデータに対し部分処理を施した結果を、伝送部１７０を介して制御部１１０に出力する。処理部１６０は、主として、プロセッサ１１がプログラムＰ１の一部を実行することによって実現される。ここで、処理部１６０がデータを送受する相手は伝送部１７０に限られることから、処理部１６０を実現するためのソフトウェアは、独立性の高いソフトウェアコンポーネント又はライブラリとして開発される。すなわち、処理部１６０は、図４に示される伝送部１７０以外の構成要素との間でデータを送受することがない。処理部１６０を実現するためのソフトウェアコンポーネント又はライブラリは、データ処理装置１０の出荷後又は設置後に適宜追加することができる。処理部１６０を実現するためのプログラムは、制御部１１０を実現するためのプログラムとは異なっていてもよい。制御部１１０が、処理部１６０を実現するためのプログラムを順次起動することによって処理部１６０が実現されてもよい。処理部１６０は、請求項の処理手段として機能する。
【００４３】
伝送部１７０は、制御部１１０と処理部１６０との間でデータを伝送するインタフェースである。伝送部１７０は、主としてプロセッサ１１によって実現される。
【００４４】
続いて、データ処理装置１０によって実行されるデータ処理について、図５〜１３を用いて詳細に説明する。図５に示されるデータ処理は、データ処理装置１０の電源が投入されたときに又はユーザによる操作に応じて開始する。
【００４５】
データ処理において、データ処理装置１０は、記憶部１２０に記憶される管理情報１２１を更新する（ステップＳ１）。具体的には、制御部１１０が、制御部１１０自体、通信部１３０及び複数の処理部１６０によって実行可能な部分処理を確認する。例えば、処理部１６０を実現するソフトウェアコンポーネント又はライブラリがユーザによって追加された場合、新たな通信プロトコルに対応するためのファームウェアの更新があった場合、機器２０が伝送路４０を介してデータ処理装置１０に接続された場合、及び、通信部１３０を実現するためのプログラムが追加され又は起動された場合に、制御部１１０は、管理情報１２１を更新する。
【００４６】
管理情報１２１は、図６に例示されるように、部分処理を実行する実行主体と、実行主体のＩＤと、部分処理と、部分処理を実行するためのパラメータを示す設定項目と、を関連付けたテーブルである。図６においては、実行主体である通信部１３０、処理部１６１，１６２及び制御部１１０の符号をＩＤとしている。設定項目は、通信部１３０及び処理部１６０それぞれが保持している設定項目に関する情報を制御部１１０が読み出すことで、管理情報１２１に追加される。
【００４７】
図５に戻り、ステップＳ１に続いて、データ処理装置１０は、処理フローの設定をユーザから受け付ける（ステップＳ２）。具体的には、制御部１１０が記憶部１２０から管理情報１２１を読み出して受付部１４０に通知する。受付部１４０は、管理情報１２１に基づいて、入力画面を生成するための画面データをＵＩ部１５０に送信する。これにより、ユーザは、ＵＩ部１５０を操作して処理フローを設定することができる。
【００４８】
図７には、処理フローを設定するための入力画面の一例が示されている。図７に示される例では、部分処理を示すブロック９１と、部分処理同士の間で授受されるデータの方向を示す矢印９２が、図３と同様に示される。なお、図７における処理フローの内容は、図３に示された処理フローから簡略化されている。ユーザは、左側のリストから部分処理のブロック９１をドラッグして右側に配置する。配置されたブロック９１がユーザによって選択されると、このブロック９１に対応する部分処理の設定項目を入力するためのメニュー９３が表示される。図７に示されるメニュー９３は、「機器３からデータ受信」という部分処理を実行するための設定項目として、データを受信する対象となる機器のＩＤと、データの収集周期と、センサに設定される閾値と、を含んでいる。また、ユーザは、矢印９２の始点及び終点を設定する。これにより、処理フローを構成する部分処理の実行順序と、部分処理のパラメータと、が設定される。
【００４９】
なお、処理フローを設定するための入力画面は、図８に示されるようにテーブル形式の入力欄を表示する画面であってもよい。図８に示される処理フローテーブルは、部分処理に付される番号と、この部分処理の入力データに付されるデータラベルと、この部分処理の出力データに付されるデータラベルと、この部分処理の設定項目と、を関連付けたテーブルである。なお、図８における番号は、図３に示される部分処理の符号に等しい。図８の処理フローテーブルの各行が、図３中の部分処理７０１〜７１０それぞれに対応し、入出力のデータラベルによって規定される部分処理同士のリンクが、図３中の矢印に対応している。
【００５０】
ここで、図７，８に示される処理フローの最後に実行される「指令決定」の設定項目について説明する。「指令決定」の設定項目は、入力値の条件と、条件の成立の有無に応じた動作と、を含む。図９には、入力値の条件を規定する条件テーブルの一例が示され、図１０には、動作を規定する動作テーブルの一例が示されている。
【００５１】
図９の条件テーブルは、「大小比較」、「閾値判定」及び「領域判定」それぞれの部分処理の結果に応じた値を規定している。例えば、「大小比較」の結果がＹＥＳであり、「閾値判定」の結果がＹＥＳであり、「領域判定」の結果がＹＥＳであれば、値は「１」となる。図１０の動作テーブルは、値に応じた各機器への動作指令を規定している。例えば、条件判定の結果として得た値が「１」であれば、稼働状態を「セーフモード」に変更することを「機器１」に指令するとともに、稼働を停止することを「機器２」に指令することとなる。
【００５２】
図５に戻り、ステップＳ２において、受付部１４０は、ユーザによって設定された処理フローの内容を示すフロー情報１２２を制御部１１０に通知する。次に、データ処理装置１０は、機器２０から送信されるデータを受信する（ステップＳ３）。具体的には、通信部１３０が、フロー情報１２２に規定される「データ受信」という部分処理を実行する。例えば、通信部１３０は、図１に示される機器２１，２３から送信されたデータを受信する。より詳細には、通信部１３０は、「データ受信」の設定項目の内容に従ってデータを送信することを機器２０に対して指示することにより、データを受信する。
【００５３】
次に、通信部１３０が、受信したデータを制御部１１０に送出し、制御部１１０が、通信部１３０からデータを取得する（ステップＳ４）。制御部１１０は、取得したデータを中間情報１２３として記憶部１２０に格納する。図１１Ａには、ステップＳ４が実行されたときの中間情報１２３の一例が示されている。中間情報１２３は、データに付されるデータラベルと、処理フローを施すデータを通信部１３０が受信した時刻を示すタイムスタンプと、データの値と、を関連付けた情報である。図１１Ａに示される中間情報１２３は、通信部１３０が１０時４２分００秒に受信したデータに対して図３に示される部分処理７０１を施した結果としてデータラベル「＃１」が付されるデータを得て、そのデータの値が「５２１」であることを示している。機器２１から受信したデータの次処理が部分処理７０４であることを示している。
【００５４】
図５に戻り、ステップＳ４に続いて、制御部１１０が、データの送出先である処理部を決定する（ステップＳ５）。具体的には、制御部１１０が、記憶部１２０に格納されているフロー情報１２２に基づいて、この中間情報１２３に含まれるデータの送出先である処理部１６０を決定する。
【００５５】
次に、制御部１１０は、決定した処理部１６０にデータを送出する（ステップＳ６）。具体的には、制御部１１０は、ステップＳ５で決定した処理部１６０に、中間情報１２３のデータ値を入力する。
【００５６】
次に、制御部１１０からデータを取得した処理部１６０が、部分処理を実行する（ステップＳ７）。そして、処理部１６０は、部分処理の結果を示すデータを制御部１１０に送出する。以下では、処理部１６０によって実行された部分処理の結果を、部分処理結果という。
【００５７】
次に、制御部１１０が、処理部１６０から部分処理結果を示すデータを取得する（ステップＳ８）。制御部１１０は、取得したデータを中間情報として記憶部１２０に格納する。図１２には、ステップＳ８が実行されたときの中間情報１２３の一例が示されている。図１２に示される中間情報１２３は、通信部１３０が１０時４２分００秒に受信したデータに対して図３に示される部分処理７０１，７０３を施した結果としてデータラベル「＃３」が付されるデータを得て、そのデータの値が「１．０２」であることを示している。
【００５８】
図５に戻り、ステップＳ８に続いて、制御部１１０は、処理フローのうち最後の処理部１６０による部分処理が完了したか否かを判定する（ステップＳ９）。具体的には、制御部１１０は、記憶部１２０に格納されている中間情報１２３が、処理フローを構成する部分処理のうち、処理部１６０によって実行される最後の部分処理結果を示す情報か否かを、フロー情報１２２を参照することにより判定する。
【００５９】
最後の処理部１６０による部分処理が完了していないと判定された場合（ステップＳ９；Ｎｏ）、ステップＳ５以降の処理が繰り返される。例えば、図１２に示される中間情報１２３とフロー情報１２２を参照すれば、次処理が部分処理７０４であることがわかる。このため、図１２の中間情報１２３が記憶部１２０に格納されているときには、ステップＳ５にて、フロー情報１２２を参照して、中間情報１２３に含まれるデータの送出先が決定される。このようにして処理部１６０と制御部１１０との間でデータの授受を繰り返されることにより、処理フローを構成する部分処理が順次実行される。
【００６０】
図５に戻り、ステップＳ９にて、最後の処理部１６０による部分処理が完了したと判定された場合（ステップＳ９；Ｙｅｓ）、制御部１１０は、処理フローの結果である処理結果を求める（ステップＳ１０）。例えば、図１３に示される中間情報１２３は、通信部１３０が１０時４２分００秒に受信したデータに対して図３に示される部分処理７０１〜７０４，７０７を施した結果としてデータラベル「＃５」が付されるデータを得て、そのデータの値が「１３」であることを示している。フロー情報１２２を参照することで、処理フローのうち処理部１６０によって実行される最後の部分処理が完了したことがわかる。そこで、制御部１１０は、「指令決定」の部分処理７１０を実行して、動作指令の内容を決定する。
【００６１】
図５に戻り、ステップＳ１０に続いて、制御部１１０は、処理結果を出力部１３２に送出する（ステップＳ１１）。具体的には、制御部１１０が、機器２０に対する動作指令を機器２０に送信することを出力部１３２に指示する。
【００６２】
次に、出力部１３２が、処理フローの処理結果を示す情報を出力する（ステップＳ１２）。具体的には、出力部１３２が、動作指令を機器２０に書き込むための信号を機器２０に送信する。その後、ステップＳ３以降の処理が繰り返される。これにより、データ処理装置１０は、機器２０から繰り返し送信されるデータに処理フローを施した結果を出力することができる。
【００６３】
図１１Ｂ，１１Ｃには、繰り返し実行されるステップＳ４にて生成される中間情報１２３の例が示されている。図１１Ｂ，１１Ｃに示される中間情報１２３は、通信部１３０が１０時４２分０２秒及び１０時４２分０４秒に受信したデータそれぞれに対して図３に示される部分処理７０１を施した結果としてデータラベル「＃１」が付されるデータを得て、それぞれデータの値が「４８０」及び「５１３」であることを示している。
【００６４】
以上、説明したように、データ処理装置１０は、部分処理を実行する複数の処理部１６０を有し、制御部１１０が、処理フローに対応する順で複数の処理部１６０に部分処理を実行させ、該実行により得る処理結果を送出する。このため、部分処理の実行順序を変更することで、多様な処理フローを実行することができる。したがって、種々の処理を組み合わせた処理フローをデータに対して簡便に施すことができる。
【００６５】
また、複数の処理部１６０はそれぞれ、制御部１１０から送出されたデータに部分処理を施して得る部分処理結果を制御部１１０に送出した。そして、制御部１１０は、一の処理部１６０から送出された部分処理結果を示すデータを、フロー情報１２２により示される処理フローに従って次の処理部１６０に送出することで、複数の処理部１６０に部分処理を実行させた。このため、処理部１６０それぞれがデータを送受する相手は、制御部１１０に限られる。従って、処理部１６０を実現するためのプログラムＰ１の開発が容易になり、ユーザが所望の部分処理を追加することが容易になる。ひいては、任意の処理フローをデータに対してより簡便に施すことができる。
【００６６】
また、機器２０からはデータが繰り返し送信された。記憶部１２０は、通信部１３０によって受信されるデータに部分処理を施して得る部分処理結果を、部分処理の入出力データを識別するためのデータラベルと関連付けて、中間情報１２３として記憶した。制御部１１０は、中間情報１２３のデータラベルと処理フローを示すフロー情報１２２とを参照して、部分処理結果を示すデータの送出先である次の処理部１６０を決定した。このため、制御部１１０は、複数の処理部１６０を同時に管理することなく、単に記憶部１２０を参照するだけで適当な処理部にデータを送出することができる。したがって、制御部１１０にかかる負荷を軽減することができる。ひいては、プロセッサ１１にかかる負荷を軽減して、処理部１６０が比較的高負荷の部分処理を実行する余裕ができるため、より多様な処理フローを施すことができるようになる。
【００６７】
また、機器２０から送信されるデータは、センサによるセンシング結果を含む。さらに、出力部１３２は、データを送信した機器２０と、この機器２０とは異なる他の機器２０と、の少なくとも一方に対する動作指令を出力する。このため、データ処理装置１０は、工場に代表される施設に構築されるシステムに適している。
【００６８】
なお、図５では、説明の理解を容易にするため、通信部１３０によるデータの受信と、制御部１１０と処理部１６０との間におけるデータの送受と、出力部１３２による情報の出力と、を順に実行する例を示した。この例では、処理フローが完了した後に機器２０から新たなデータを受信することとなる。しかしながら、データ処理装置１０によるデータ処理は、これに限定されず、処理フローの実行中に機器２０から新たなデータを随時受信してもよい。制御部１１０、通信部１３０、及び出力部１３２は、並行にその機能を発揮してもよい。
【００６９】
すなわち、通信部１３０がデータを随時受信して制御部１１０へ送出するとともに、制御部１１０が各処理部１６０との間でデータを随時送受してもよい。この際に、制御部１１０は、１つの部分処理の完了により生成された中間情報１２３を参照して、随時、次の部分処理を担う処理部１６０へデータを送出する。そして、各処理部１６０に設定されたタイミングで処理部１６０が部分処理を実行する。なお、制御部１１０は、予め規定されたタイミングでデータを送出して、処理部１６０に部分処理を実行させてもよい。
【００７０】
実施の形態２．
続いて、実施の形態２について、上述の実施の形態１との相違点を中心に説明する。なお、上記実施の形態１と同一又は同等の構成については、同等の符号を用いるとともに、その説明を省略又は簡略する。上述の実施の形態１では、処理部１６０がそれぞれ機能を発揮すれば、処理フローの実行には何ら制限がなかった。このため、処理部１６０を実現するソフトウェアは、データ処理装置１０が設置される施設の所有者又は管理者が自ら開発するか、又はオープンソースソフトウェアを利用する必要がある。
【００７１】
しかしながら、一般的には、そのようなソフトウェアよりも、専門の開発業者が配布した有償のプラグインソフトウェアの方が、品質が高く多機能であるケースが多い。このため、処理部１６０を実現するプラグインソフトウェアの利用に制限を設けて、代価を支払ったときにこの制限を外せば、有償ソフトウェアの開発を促進することができ、ユーザは、より多様な処理フローを比較的低いコストで容易に実行することが期待できる。
【００７２】
さらに、プラグインソフトウェア自体は無償であっても、このプラグインソフトウェアに対応する機器２０を開発業者が設定し、この機器２０に関するデータ処理を実行する際に制限を設けることも考えられる。また、プラグインソフトウェアとは関わりなく、専門の製造業者が製造した高品質の機器２０を利用する処理フローに制限を設けることで、ユーザは、より多様な処理フローを比較的低いコストで容易に実行することも期待できる。
【００７３】
そこで、以下では、処理フローの実行に制限を設ける形態について説明する。本実施の形態に係るデータ処理装置１０は、図１４に示されるように、制御部１１０が認証モジュール１１１を有し、記憶部１２０が認証情報１２４を有している点で、実施の形態１に係るものと異なっている。
【００７４】
認証情報１２４は、図１５に例示されるように、処理フローを実行するために利用する利用対象と、利用対象を使用する使用期限と、利用対象を介するデータ伝送量の容量と、を関連付けたテーブルである。認証情報１２４の１行目は、処理部Ａの使用期限が、使用開始から１ヶ月間に制限されることを示す。認証情報１２４の２行目は、処理部Ｂを介したデータ伝送量が１Ｇｂｉｔに制限されることを示す。認証情報１２４の３行目は、機器１の使用期限が、使用開始から１ヶ月間に制限されることを示す。認証情報１２４の４行目は、機器２を介したデータ伝送量が１Ｇｂｉｔに制限されることを示す。
【００７５】
ここで、処理部１６０を介したデータ伝送量は、伝送部１７０を介して伝送される累積のデータ量を意味する。また、機器２０を介したデータ伝送量は、機器２０とデータ処理装置１０との間で伝送される累積のデータ量を意味する。
【００７６】
制御部１１０は、不図示の外部サーバに料金の支払い状況を問い合わせて、料金の支払いがあった場合には、認証情報１２４を更新する。これにより、ユーザは、料金を支払うことで、処理部１６０或いは機器２０を利用することができるようになる。
【００７７】
続いて、データ処理装置１０によって実行されるデータ処理について、図１６を参照して説明する。図１６に示されるデータ処理では、図５と同様のステップＳ１〜Ｓ４が実行される。
【００７８】
ステップＳ４に続いて、制御部１１０は、認証情報１２４に基づいて、処理フローの実行を制限すべきか否かを判定する（ステップＳ２１）。具体的には、制御部１１０が、ステップＳ４で決定した処理部１６０の使用が制限されるか否かを判定するとともに、中間情報１２３が由来するデータを送信した機器２０、及び中間情報１２３からさらに部分処理を施した結果として得る動作指令の送出先となる機器２０の使用が制限されるか否かを判定する。そして、制御部１１０は、少なくとも１つの利用対象の使用が制限されるときに、処理フローの実行を制限すべきと判定する。
【００７９】
ステップＳ２１にて制限すべきでないと判定された場合（ステップＳ２１：Ｎｏ）、ステップＳ５以降の処理が実行される。一方、制限すべきと判定された場合（ステップＳ２１：Ｙｅｓ）、データ処理装置１０は、エラーを出力して（ステップＳ２２）、データ処理を終了する。エラーの出力は、ＵＩ部１５０の画面に表示される警告であってもよいし、スピーカからの警報音であってもよいし、出力部１３２からユーザ端末へのエラーを示す情報の送信であってもよい。
【００８０】
以上、説明したように、複数の処理部１６０の少なくとも１つがプラグインソフトウェアで実現される。これにより、実施の形態１と同様に、プラグインソフトウェアの開発が容易になり、ユーザが所望の部分処理を追加することが容易になる。ひいては、任意の処理フローをデータに対してより簡便に施すことができる。
【００８１】
また、制御部１１０は、処理フローの実行を、プラグインソフトウェアで実現される処理部１６０を介したデータの伝送量に応じて制限した。これにより、専門の開発業者から提供されたプラグインソフトウェアで処理部１６０を実現して、データ処理装置１０のユーザは、より多様な処理フローを比較的低いコストで容易に実行することが期待できる。
【００８２】
また、制御部１１０は、処理フローの実行を、データ処理装置１０と機器２０との間におけるデータの伝送量に応じて制限した。これにより、専門の製造業者によって製造された機器２０を利用して、データ処理装置１０のユーザは、より多様な処理フローを比較的低いコストで容易に実行することが期待できる。
【００８３】
また、制御部１１０は、処理フローの実行を、予め設定された時刻から経過した時間の長さに応じて制限した。具体的には、制御部１１０は、認証情報１２４で規定された処理部１６０又は機器２０を利用する処理フローの実行を、使用開始時刻から現在までの経過時間に応じて制限した。これにより、データ処理装置１０のユーザは、より多様な処理フローを比較的低いコストで容易に実行することが期待できる。
【００８４】
以上、本発明の実施の形態について説明したが、本発明は上記実施の形態によって限定されるものではない。
【００８５】
例えば、上記実施の形態１，２では、データ処理システム１０００が製品の生産システムとして工場に代表される施設に設置される例を説明したが、これには限定されない。データ処理システム１０００は、製品の生産システム、製造システム、加工システム、検査システム、産業用制御システム、その他のシステムであってもよい。また、データ処理システム１０００は、発電プラントを含むプラント、自動車、航空機及び船を含む移動体、オフィスビル、又は、学校に代表される公共施設に設置されてもよい。
【００８６】
また、上記実施の形態では、機器２０の台数が３つである例が示されているが、これには限定されず、３つより少なくてもよいし、３つより多くてもよい。さらに、伝送路４０が双方向の通信路である例を説明したが、伝送路４０は、一方向のみに情報を伝送する通信路であってもよい。
【００８７】
また、機器２０から送信されるデータは、センシング結果を含むデータに限定されず、例えば、機器２０の稼働状態を示すデータ、又は、機器２０による信号処理の結果を含むデータであってもよい。さらに、データ処理装置１０がデータ処理の結果として機器２０に送信する情報は、動作指令に限定されず、データ処理装置１０の稼働状態の通知であってもよい。
【００８８】
また、受信部１３１と出力部１３２とが通信部１３０として一体的に構成されたが、受信部１３１と出力部１３２を別途の構成としてもよい。また、通信部１３０は、伝送路４０の種別ごとに設けられたが、これには限定されない。伝送路４０の複数の種別に対応する単一の通信部１３０を設けてもよいし、伝送路４０の単一の種別に対応する複数の通信部１３０を設けてもよい。
【００８９】
また、処理部１６０は部分処理結果を制御部１１０に送出したが、これには限定されず、制御部１１０の指示に従って記憶部１２０に直接格納してもよい。これにより、複数の処理部１６０は、制御部１１０を介することなく記憶部１２０を介してデータを授受することとなる。
【００９０】
また、上記実施の形態１，２では、制御部１１０が、処理部１６０による部分処理の実行を制御するための中間情報１２３を生成したが、これには限定されない。制御部１１０は、フロー情報１２２を参照することで、中間情報１２３を生成することなく処理フローを実行してもよい。
【００９１】
また、図１７には、処理フローの変形例が示されている。図１７に示されるように、通信部１３０による部分処理１８０２の次に制御部１１０による部分処理１８０５が実行されてもよい。また、処理部１６０による部分処理１８１１が挿入されてもよい。また、同一の処理部１６０による２つの部分処理１８０７，１８０８を含んでいてもよい。さらに、処理部１６０によって「ファイル読出」という部分処理１８０３が実行されてもよいし、「ファイル書込」という部分処理１８０９が実行されてもよい。また、出力部１３２による処理は、機器２０へのデータ書込に限定されず、サーバへの情報の通知をする処理１８１４、又は、情報をＧＵＩにより出力する処理１８１５であってもよい。ただし、処理１８１５を実行する出力部１３２は、図１８に示されるように、通信部１３０とは別途の構成であって、入力部１４と出力部１５とによって実現される。
【００９２】
また、ＵＩ部１５０を省いてデータ処理装置１０を構成し、受付部１４０が外部の端末からフロー情報１２２を取得してもよい。
【００９３】
また、上記実施の形態１，２では、データ処理装置１０が、複数の処理部１６０を有していたが、これには限定されない。例えば、図１９に示されるように、単一の処理部１６０を設けてもよい。この場合に、処理フローは、処理部１６０が実行可能な処理を繰り返す反復処理であってもよい。また、単一の処理部１６０が、設定項目の内容に応じてデータの加工、分析、及び診断処理を実行可能であれば、設定項目を適切に設定することで図３と同様の処理フローを実行することができる。
【００９４】
また、データ処理装置１０の機能は、専用のハードウェアによっても、また、通常のコンピュータシステムによっても実現することができる。
【００９５】
例えば、プロセッサ１１によって実行されるプログラムＰ１を、コンピュータ読み取り可能な非一時的な記録媒体に格納して配布し、そのプログラムＰ１をコンピュータにインストールすることにより、上述の処理を実行する装置を構成することができる。このような記録媒体としては、例えばフレキシブルディスク、ＣＤ−ＲＯＭ（Compact Disc Read−Only Memory）、ＤＶＤ（Digital Versatile Disc）、ＭＯ（Magneto−Optical Disc）が考えられる。
【００９６】
また、プログラムＰ１をインターネットに代表される通信ネットワーク上のサーバ装置が有するディスク装置に格納しておき、例えば、搬送波に重畳させて、コンピュータにダウンロードするようにしてもよい。
【００９７】
また、通信ネットワークを介してプログラムＰ１を転送しながら起動実行することによっても、上述の処理を達成することができる。
【００９８】
さらに、プログラムＰ１の全部又は一部をサーバ装置上で実行させ、その処理に関する情報をコンピュータが通信ネットワークを介して送受信しながらプログラムを実行することによっても、上述の処理を達成することができる。
【００９９】
なお、上述の機能を、ＯＳ（Operating System）が分担して実現する場合又はＯＳとアプリケーションとの協働により実現する場合等には、ＯＳ以外の部分のみを媒体に格納して配布してもよく、また、コンピュータにダウンロードしてもよい。
【０１００】
また、データ処理装置１０の機能を実現する手段は、ソフトウェアに限られず、その一部又は全部を、回路を含む専用のハードウェアによって実現してもよい。
【０１０１】
本発明は、本発明の広義の精神と範囲を逸脱することなく、様々な実施の形態及び変形が可能とされるものである。また、上述した実施の形態は、本発明を説明するためのものであり、本発明の範囲を限定するものではない。つまり、本発明の範囲は、実施の形態ではなく、請求の範囲によって示される。そして、請求の範囲内及びそれと同等の発明の意義の範囲内で施される様々な変形が、本発明の範囲内とみなされる。
【産業上の利用可能性】
【０１０２】
本発明は、収集したデータの処理に適している。
【符号の説明】
【０１０３】
１０００  データ処理システム、  １０  データ処理装置、  １１  プロセッサ、  １２  主記憶部、  １３  補助記憶部、  １４  入力部、  １５  出力部、  １６  通信部、  １７  内部バス、  １１０  制御部、  １１１  認証モジュール、  １２０  記憶部、  １２１  管理情報、  １２２  フロー情報、  １２３  中間情報、  １２４  認証情報、  １３０  通信部、  １３１  受信部、  １３２  出力部、  １３３  変換部、  １４０  受付部、  １５０  ＵＩ部、  １６０〜１６２  処理部、  １７０  伝送部、  ２０〜２３  機器、  ２１ａ，２３ａ  センサ、  ４０  伝送路、  ４１  ネットワーク、  ４３  ネットワーク、  ７０１〜７１０，１８０１〜１８１１  部分処理、  ８０１，８０２，１８１４，１８１５  処理、  ９１  ブロック、  ９２  矢印、  ９３  メニュー、  Ｐ１  プログラム。
【図１】
2019198221.tif 000003
【図２】
2019198221.tif 000004
【図３】
2019198221.tif 000005
【図４】
2019198221.tif 000006
【図５】
2019198221.tif 000007
【図６】
2019198221.tif 000008
【図７】
2019198221.tif 000009
【図８】
2019198221.tif 000010
【図９】
2019198221.tif 000011
【図１０】
2019198221.tif 000012
【図１１Ａ】
2019198221.tif 000013
【図１１Ｂ】
2019198221.tif 000014
【図１１Ｃ】
2019198221.tif 000015
【図１２】
2019198221.tif 000016
【図１３】
2019198221.tif 000017
【図１４】
2019198221.tif 000018
【図１５】
2019198221.tif 000019
【図１６】
2019198221.tif 000020
【図１７】
2019198221.tif 000021
【図１８】
2019198221.tif 000022
【図１９】
2019198221.tif 000023
【手続補正書】
【提出日】令和1年10月29日(2019.10.29)
【手続補正１】
【補正対象書類名】明細書
【補正対象項目名】０００７
【補正方法】変更
【補正の内容】
【０００７】
上記目的を達成するため、本発明のデータ処理装置は、機器に接続されるデータ処理装置であって、機器と通信する通信手段と、通信手段によって受信されたデータに施される処理フローの設定を受け付ける受付手段と、処理フローを構成する部分処理を実行する処理手段であって、データに部分処理を施して得る部分処理結果を送出する一又は複数の処理手段のうちのいずれかに、通信手段によって受信されたデータを送出して、いずれか一の処理手段から送出された部分処理結果を示すデータを処理フローに従って次の処理手段に送出することで、処理フローに対応する順で一又は複数の処理手段に部分処理を実行させ、該実行により得る処理結果を送出する制御手段と、を備え、制御手段から一又は複数の処理手段に送出されるデータ及び一又は複数の処理手段から制御手段に送出されるデータは、通信手段によってデータが受信された時刻を示すタイムスタンプに関連付けられて、処理フローは、機器から繰り返し送信されて通信手段によって受信されるデータそれぞれに対して実行される。
【手続補正２】
【補正対象書類名】特許請求の範囲
【補正対象項目名】全文
【補正方法】変更
【補正の内容】
【特許請求の範囲】
【請求項１】
機器に接続されるデータ処理装置であって、
前記機器と通信する通信手段と、
前記通信手段によって受信されたデータに施される処理フローの設定を受け付ける受付手段と、
前記処理フローを構成する部分処理を実行する処理手段であって、データに前記部分処理を施して得る部分処理結果を送出する一又は複数の処理手段のうちのいずれかに、前記通信手段によって受信されたデータを送出して、いずれか一の処理手段から送出された前記部分処理結果を示すデータを前記処理フローに従って次の処理手段に送出することで、前記処理フローに対応する順で前記一又は複数の処理手段に前記部分処理を実行させ、該実行により得る処理結果を送出する制御手段と、
を備え、
前記制御手段から前記一又は複数の処理手段に送出されるデータ及び前記一又は複数の処理手段から前記制御手段に送出されるデータは、前記通信手段によってデータが受信された時刻を示すタイムスタンプに関連付けられて、
前記処理フローは、前記機器から繰り返し送信されて前記通信手段によって受信されるデータそれぞれに対して実行される、
データ処理装置。
【請求項２】
前記制御手段は、前記通信手段によって受信された新たなデータを、前記処理フローの実行中に、前記一又は複数の処理手段のうちのいずれかに送出する、
請求項１に記載のデータ処理装置。
【請求項３】
前記機器から繰り返し送信されて前記通信手段によって受信されるデータに前記部分処理を施して得る前記部分処理結果を、部分処理の入出力データを識別するためのラベルと関連付けて記憶する記憶手段、をさらに備え、
前記制御手段は、前記部分処理結果に関連付けられた前記ラベルと前記処理フローとを参照して、該部分処理結果を示すデータの送出先である前記次の処理手段を決定する、
請求項１又は２に記載のデータ処理装置。
【請求項４】
前記一又は複数の処理手段の少なくとも１つは、プラグインソフトウェアで実現される、
請求項１から３のいずれか一項に記載のデータ処理装置。
【請求項５】
前記制御手段は、前記処理フローの実行を、前記プラグインソフトウェアで実現される前記処理手段を介したデータの伝送量に応じて制限する、
請求項４に記載のデータ処理装置。
【請求項６】
前記制御手段は、前記処理フローの実行を、データ処理装置と前記機器との間におけるデータの伝送量に応じて制限する、
請求項１から５のいずれか一項に記載のデータ処理装置。
【請求項７】
前記制御手段は、前記処理フローの実行を、予め設定された時刻から経過した時間の長さに応じて制限する、
請求項１から６のいずれか一項に記載のデータ処理装置。
【請求項８】
前記機器から送信されるデータは、センサによるセンシング結果を含む、
請求項１から７のいずれか一項に記載のデータ処理装置。
【請求項９】
前記通信手段は、前記制御手段から送出される前記処理結果を示す情報を出力する出力手段、を備え、
前記出力手段は、前記処理結果を示す情報として、前記機器と、該機器とは異なる他の機器と、の少なくとも一方に対する動作指令を出力する、
請求項１から８のいずれか一項に記載のデータ処理装置。
【請求項１０】
通信手段が、機器からデータを受信し、
受付手段が、前記通信手段によって受信されたデータに施される処理フローの設定を受け付け、
制御手段が、前記処理フローを構成する部分処理を実行する処理手段であって、データに前記部分処理を施して得る部分処理結果を送出する一又は複数の処理手段のうちのいずれかに、前記通信手段によって受信されたデータを送出して、いずれか一の処理手段から送出された前記部分処理結果を示すデータを前記処理フローに従って次の処理手段に送出することで、前記処理フローに対応する順で前記一又は複数の処理手段に前記部分処理を実行させ、該実行により得る処理結果を送出する、
ことを含み、
前記制御手段から前記一又は複数の処理手段に送出されるデータ及び前記一又は複数の処理手段から前記制御手段に送出されるデータは、前記通信手段によってデータが受信された時刻を示すタイムスタンプに関連付けられて、
前記処理フローは、前記機器から繰り返し送信されて前記通信手段によって受信されるデータそれぞれに対して実行される、
データ処理方法。
【請求項１１】
コンピュータを、
機器からデータを受信する通信手段、
前記通信手段によって受信されたデータに施される処理フローの設定を受け付ける受付手段、
前記処理フローを構成する部分処理を実行する処理手段であって、データに前記部分処理を施して得る部分処理結果を送出する一又は複数の処理手段のうちのいずれかに、前記通信手段によって受信されたデータを送出して、いずれか一の処理手段から送出された前記部分処理結果を示すデータを前記処理フローに従って次の処理手段に送出することで、前記処理フローに対応する順で前記一又は複数の処理手段に前記部分処理を実行させ、該実行により得る処理結果を送出する制御手段、
として機能させ、
前記制御手段から前記一又は複数の処理手段に送出されるデータ及び前記一又は複数の処理手段から前記制御手段に送出されるデータは、前記通信手段によってデータが受信された時刻を示すタイムスタンプに関連付けられて、
前記処理フローは、前記機器から繰り返し送信されて前記通信手段によって受信されるデータそれぞれに対して実行される、
プログラム。
【手続補正３】
【補正対象書類名】図面
【補正対象項目名】図１４
【補正方法】変更
【補正の内容】
【図１４】
2019198221.tif 000024
【手続補正４】
【補正対象書類名】図面
【補正対象項目名】図１８
【補正方法】変更
【補正の内容】
【図１８】
2019198221.tif 000025
【手続補正書】
【提出日】令和2年2月3日(2020.2.3)
【手続補正１】
【補正対象書類名】明細書
【補正対象項目名】０００７
【補正方法】変更
【補正の内容】
【０００７】
上記目的を達成するため、本発明のデータ処理装置は、複数の機器に接続されるデータ処理装置であって、複数の機器と通信する通信手段と、通信手段によって受信されたデータに施される処理フローの設定を受け付ける受付手段と、処理フローを構成する部分処理を実行する処理手段であって、データに部分処理を施して得る部分処理結果を送出する一又は複数の処理手段のうちのいずれかに、通信手段によって受信されたデータを送出して、いずれか一の処理手段から送出された部分処理結果を示すデータを処理フローに従って次の処理手段に送出することで、処理フローに対応する順で一又は複数の処理手段に部分処理を実行させ、該実行により得る処理結果を送出する制御手段と、を備え、制御手段から一又は複数の処理手段に送出されるデータ及び一又は複数の処理手段から制御手段に送出されるデータは、通信手段によってデータが受信された時刻を示すタイムスタンプに関連付けられ、複数の機器から、それぞれ指定された周期で繰り返し送信されて通信手段によって受信されるデータは、送信元の機器を識別する機器ＩＤとタイムスタンプとにより識別され、部分処理は、該部分処理を実行する処理手段に設定されたタイミングで実行され、機器それぞれから送信されたデータに対応して部分処理が並列して実行される。
【手続補正２】
【補正対象書類名】特許請求の範囲
【補正対象項目名】全文
【補正方法】変更
【補正の内容】
【特許請求の範囲】
【請求項１】
複数の機器に接続されるデータ処理装置であって、
複数の前記機器と通信する通信手段と、
前記通信手段によって受信されたデータに施される処理フローの設定を受け付ける受付手段と、
前記処理フローを構成する部分処理を実行する処理手段であって、データに前記部分処理を施して得る部分処理結果を送出する一又は複数の処理手段のうちのいずれかに、前記通信手段によって受信されたデータを送出して、いずれか一の処理手段から送出された前記部分処理結果を示すデータを前記処理フローに従って次の処理手段に送出することで、前記処理フローに対応する順で前記一又は複数の処理手段に前記部分処理を実行させ、該実行により得る処理結果を送出する制御手段と、
を備え、
前記制御手段から前記一又は複数の処理手段に送出されるデータ及び前記一又は複数の処理手段から前記制御手段に送出されるデータは、前記通信手段によってデータが受信された時刻を示すタイムスタンプに関連付けられ、
複数の前記機器から、それぞれ指定された周期で繰り返し送信されて前記通信手段によって受信されるデータは、送信元の前記機器を識別する機器ＩＤと前記タイムスタンプとにより識別され、
前記部分処理は、該部分処理を実行する前記処理手段に設定されたタイミングで実行され、
前記機器それぞれから送信されたデータに対応して前記部分処理が並列して実行される、
データ処理装置。
【請求項２】
前記制御手段は、前記通信手段によって受信された新たなデータを、前記処理フローの実行中に、前記一又は複数の処理手段のうちのいずれかに送出する、
請求項１に記載のデータ処理装置。
【請求項３】
複数の前記機器から繰り返し送信されて前記通信手段によって受信されるデータに前記部分処理を施して得る前記部分処理結果を、前記部分処理の入出力データを識別するためのラベルと関連付けて記憶する記憶手段、をさらに備え、
前記制御手段は、前記部分処理結果に関連付けられた前記ラベルと前記処理フローとを参照して、該部分処理結果を示すデータの送出先である前記次の処理手段を決定する、
請求項１又は２に記載のデータ処理装置。
【請求項４】
前記一又は複数の処理手段の少なくとも１つは、プラグインソフトウェアで実現される、
請求項１から３のいずれか一項に記載のデータ処理装置。
【請求項５】
前記制御手段は、前記処理フローの実行を、前記プラグインソフトウェアで実現される前記処理手段を介したデータの伝送量に応じて制限する、
請求項４に記載のデータ処理装置。
【請求項６】
前記制御手段は、前記処理フローの実行を、データ処理装置と前記機器との間におけるデータの伝送量に応じて制限する、
請求項１から５のいずれか一項に記載のデータ処理装置。
【請求項７】
前記制御手段は、前記処理フローの実行を、予め設定された時刻から経過した時間の長さに応じて制限する、
請求項１から６のいずれか一項に記載のデータ処理装置。
【請求項８】
前記機器から送信されるデータは、センサによるセンシング結果を含む、
請求項１から７のいずれか一項に記載のデータ処理装置。
【請求項９】
前記通信手段は、前記制御手段から送出される前記処理結果を示す情報を出力する出力手段、を備え、
前記出力手段は、前記処理結果を示す情報として、前記機器と、該機器とは異なる他の前記機器と、の少なくとも一方に対する動作指令を出力する、
請求項１から８のいずれか一項に記載のデータ処理装置。
【請求項１０】
通信手段が、複数の機器からデータを受信し、
受付手段が、前記通信手段によって受信されたデータに施される処理フローの設定を受け付け、
制御手段が、前記処理フローを構成する部分処理を実行する処理手段であって、データに前記部分処理を施して得る部分処理結果を送出する一又は複数の処理手段のうちのいずれかに、前記通信手段によって受信されたデータを送出して、いずれか一の処理手段から送出された前記部分処理結果を示すデータを前記処理フローに従って次の処理手段に送出することで、前記処理フローに対応する順で前記一又は複数の処理手段に前記部分処理を実行させ、該実行により得る処理結果を送出する、
ことを含み、
前記制御手段から前記一又は複数の処理手段に送出されるデータ及び前記一又は複数の処理手段から前記制御手段に送出されるデータは、前記通信手段によってデータが受信された時刻を示すタイムスタンプに関連付けられ、
複数の前記機器から、それぞれ指定された周期で繰り返し送信されて前記通信手段によって受信されるデータは、送信元の前記機器を識別する機器ＩＤと前記タイムスタンプとにより識別され、
前記部分処理は、該部分処理を実行する前記処理手段に設定されたタイミングで実行され、
前記機器それぞれから送信されたデータに対応して前記部分処理が並列して実行される、
データ処理方法。
【請求項１１】
コンピュータを、
複数の機器からデータを受信する通信手段、
前記通信手段によって受信されたデータに施される処理フローの設定を受け付ける受付手段、
前記処理フローを構成する部分処理を実行する処理手段であって、データに前記部分処理を施して得る部分処理結果を送出する一又は複数の処理手段のうちのいずれかに、前記通信手段によって受信されたデータを送出して、いずれか一の処理手段から送出された前記部分処理結果を示すデータを前記処理フローに従って次の処理手段に送出することで、前記処理フローに対応する順で前記一又は複数の処理手段に前記部分処理を実行させ、該実行により得る処理結果を送出する制御手段、
として機能させ、
前記制御手段から前記一又は複数の処理手段に送出されるデータ及び前記一又は複数の処理手段から前記制御手段に送出されるデータは、前記通信手段によってデータが受信された時刻を示すタイムスタンプに関連付けられ、
複数の前記機器から、それぞれ指定された周期で繰り返し送信されて前記通信手段によって受信されるデータは、送信元の前記機器を識別する機器ＩＤと前記タイムスタンプとにより識別され、
前記部分処理は、該部分処理を実行する前記処理手段に設定されたタイミングで実行され、
前記機器それぞれから送信されたデータに対応して前記部分処理が並列して実行される、
プログラム。
【国際調査報告】
2019198221.tif 000026
2019198221.tif 000027
2019198221.tif 000028
2019198221.tif 000029