(57)【特許請求の範囲】
【請求項１】
順次実行される部分処理を含む処理フローのうちのいずれかの前記部分処理を実行する第１処理手段に、該部分処理の対象である処理データを送出することで、前記部分処理を前記第１処理手段に実行させる制御手段と、
前記制御手段から送出された前記処理データを、前記第１処理手段及び他の処理手段を含む予め定められた送信先へ伝送する伝送手段と、を備え、
前記制御手段は、前記処理データに施されるべき前記部分処理を示す処理情報を、前記処理データとともに送出する、データ処理装置。
【請求項２】
前記伝送手段は、前記第１処理手段によって実行される前記部分処理の前に他の部分処理を実行する第２処理手段から送出される前記処理データ及び前記他の部分処理を示す前処理情報を前記制御手段に伝送し、
前記制御手段は、前記処理データ及び前記前処理情報を取得すると、前記処理フローに従って前記前処理情報から前記処理情報を特定して、特定した前記処理情報を、取得した前記処理データとともに送出する、
請求項１に記載のデータ処理装置。
【請求項３】
前記伝送手段は、出版／購読型モデルに従って前記処理データ及び前記処理情報を伝送する、
請求項１又は２に記載のデータ処理装置。
【請求項４】
前記伝送手段は、前記制御手段から送出された前記処理データを、前記処理フローを構成する前記部分処理を実行するすべての処理手段に伝送する、
請求項１から３のいずれか一項に記載のデータ処理装置。
【請求項５】
機器に接続されるデータ処理装置であって、
前記処理フローを構成する前記部分処理のうちのいずれかの前記部分処理は、前記機器から機器データを収集すること及び前記機器に送信データを送信することの少なくとも一方を含む、
請求項１から４のいずれか一項に記載のデータ処理装置。
【請求項６】
順次実行される部分処理を含む処理フローのうちのいずれかの前記部分処理を実行する処理手段と、
前記処理手段に前記部分処理を実行させる請求項１から５のいずれか一項に記載のデータ処理装置と、
を含むデータ処理システム。
【請求項７】
前記データ処理装置は、前記部分処理の対象である処理データとともに、該処理データに施されるべき前記部分処理を示す処理情報を送出し、
前記処理手段は、前記処理データ及び前記処理情報を取得すると、取得した前記処理情報に基づいて前記部分処理を実行するか否かを決定する、
請求項６に記載のデータ処理システム。
【請求項８】
制御手段が、順次実行される部分処理を含む処理フローのうちのいずれかの前記部分処理を実行する処理手段に、該部分処理の対象である処理データを送出することで、前記部分処理を前記処理手段に実行させる制御ステップと、
伝送手段が、前記制御手段から送出された前記処理データを、前記処理手段及び他の処理手段を含む予め定められた送信先へ伝送する伝送ステップと、を含み、
前記制御ステップでは、前記処理データに施されるべき前記部分処理を示す処理情報を、前記処理データとともに送出する、データ処理方法。
【請求項９】
コンピュータを、
順次実行される部分処理を含む処理フローのうちのいずれかの前記部分処理を実行する処理手段に、該部分処理の対象である処理データを送出することで、前記部分処理を前記処理手段に実行させる制御手段、
前記制御手段から送出された前記処理データを、前記処理手段及び他の処理手段を含む予め定められた送信先へ伝送する伝送手段、として機能させ、
前記制御手段は、前記処理データに施されるべき前記部分処理を示す処理情報を、前記処理データとともに送出する、プログラム。
【発明の詳細な説明】
【技術分野】
【０００１】
本発明は、データ処理装置、データ処理システム、データ処理方法及びプログラムに関する。
【背景技術】
【０００２】
工場に代表される施設では、生産工程、検査工程、その他の種々の工程を実現するために、施設内からリアルタイムに収集したデータを処理することが広く行われている（例えば、特許文献１を参照）。特許文献１には、センサからゲートウェイデバイスを介してサーバがセンサデータを収集する技術について記載されている。この技術では、ゲートウェイデバイスが、サーバから設定されたルールに従ってデータに対し複数の加工処理を施してから処理結果を示すデータをサーバに送信する。これにより大量のセンサからデータを収集するサーバの負荷を軽減することができる。
【先行技術文献】
【特許文献】
【０００３】
【特許文献１】特開２０１５−２８７４２号公報
【発明の概要】
【発明が解決しようとする課題】
【０００４】
通常、データに施される処理は、ユーザの要望に応じて異なり、複雑なものとなる場合もある。このため、データに施される処理の変更及び拡張を容易にするために、この処理をモジュール化するとともに、ユーザによる設定作業を簡略化することが望ましい。しかしながら、特許文献１に記載の技術では、データに対して施されるすべての処理をサーバから予め設定する必要があり、ユーザの作業負担が重くなるおそれがあった。【０００５】
本発明は、上記の事情に鑑みてなされたものであり、データを処理するためのユーザの作業負担を軽減することを目的とする。
【課題を解決するための手段】
【０００６】
上記目的を達成するため、本発明のデータ処理装置は、順次実行される部分処理を含む処理フローのうちのいずれかの部分処理を実行する第１処理手段に、該部分処理の対象である処理データを送出することで、部分処理を第１処理手段に実行させる制御手段と、制御手段から送出された処理データを、第１処理手段及び他の処理手段を含む予め定められた送信先へ伝送する伝送手段と、を備え、制御手段は、処理データに施されるべき部分処理を示す処理情報を、処理データとともに送出する。
【発明の効果】
【０００７】
本発明によれば、制御手段は、処理データを送出することで部分処理を第１処理手段に実行させる。このため、処理フローをモジュール化することができる。また、伝送手段は、制御手段から送出されたデータを第１処理手段及び他の処理手段を含む予め定められた送信先へ伝送し、制御手段は、処理データに施されるべき部分処理を示す処理情報を、処理データとともに送出する。このため、第１処理手段及び他の処理手段は、処理情報に基づいて部分処理を実行すべきか否かを決定することができる。これにより、制御手段がデータの送信先である第１処理手段を特定する必要がなく、第１処理手段がデータの送信元に応じた処理を実行する必要がない。したがって、処理手段の設計が容易になるとともにその設定を簡略にすることができる。ひいては、データを処理するためのユーザの作業負担を軽減することができる。
【図面の簡単な説明】
【０００８】
【図１】本発明の実施の形態に係るデータ処理システムの構成を示すブロック図
【図２】実施の形態に係るデータ処理装置のハードウェア構成を示す図
【図３】実施の形態に係る処理フローの設定の一例を示す図
【図４】実施の形態に係るデータ処理装置の機能的な構成を示す図
【図５】実施の形態に係る処理部、伝送部及びフロー制御部の間におけるデータの授受について説明するための図
【図６】実施の形態に係る処理部及び実行制御部の機能的な構成の詳細を示す図
【図７】実施の形態に係るフロー実行処理を示すフローチャート
【図８】実施の形態に係るＩＤ置換テーブルを示す図
【図９】実施の形態に係るフロー制御送信処理を示すフローチャート
【図１０】実施の形態に係る伝送処理を示すフローチャート
【図１１】実施の形態に係るフロー制御受信処理を示すフローチャート
【図１２】実施の形態に係る実行処理を示すフローチャート
【図１３】変形例に係るデータ処理装置の機能的な構成を示す図
【図１４】変形例に係る処理部、伝送部及びフロー制御部の間におけるデータの授受について説明するための第１の図
【図１５】変形例に係る処理部及びフロー制御部の間におけるデータの授受について説明するための第２の図
【図１６】変形例に係る処理フローの設定例を示す図
【図１７】変形例に係るデータ処理システムの構成を示すブロック図
【発明を実施するための形態】
【０００９】
以下、本発明の実施の形態に係るデータ処理装置１０について、図面を参照しつつ詳細に説明する。
【００１０】
実施の形態．
本実施の形態に係るデータ処理装置１０は、例えば、工場に配置されるＩＰＣ（Industrial Personal Computer）である。データ処理装置１０は、図１に示されるように、工場の製造ラインに配置された機器２１，２２と産業用のネットワーク２０を介して接続され、ＦＡ（Factory Automation）システムとしてのデータ処理システム１００を構成する。そして、データ処理装置１０は、ネットワーク２０を介して機器２１から収集したデータを処理して、処理結果に応じた制御命令を機器２２に出力する。機器２１は、センサであって、機器２２は、アクチュエータ又はロボットである。
【００１１】
データ処理装置１０は、そのハードウェア構成として、図２に示されるように、プロセッサ１１と、主記憶部１２と、補助記憶部１３と、入力部１４と、出力部１５と、通信部１６と、を有する。主記憶部１２、補助記憶部１３、入力部１４、出力部１５及び通信部１６はいずれも、内部バス１７を介してプロセッサ１１に接続される。
【００１２】
プロセッサ１１は、ＣＰＵ（Central Processing Unit）を含む。プロセッサ１１は、補助記憶部１３に記憶されるプログラムＰ１を実行することにより、データ処理装置１０の種々の機能を実現して、後述の処理を実行する。
【００１３】
主記憶部１２は、ＲＡＭ（Random Access Memory）を含む。主記憶部１２には、補助記憶部１３からプログラムＰ１がロードされる。そして、主記憶部１２は、プロセッサ１１の作業領域として用いられる。
【００１４】
補助記憶部１３は、ＥＥＰＲＯＭ（Electrically Erasable Programmable Read-Only Memory）及びＨＤＤ（Hard Disk Drive）に代表される不揮発性メモリを含む。補助記憶部１３は、プログラムＰ１の他に、プロセッサ１１の処理に用いられる種々のデータを記憶する。補助記憶部１３は、プロセッサ１１の指示に従って、プロセッサ１１によって利用されるデータをプロセッサ１１に供給し、プロセッサ１１から供給されたデータを記憶する。なお、図２では、１つのプログラムＰ１が代表的に示されているが、補助記憶部１３は、複数のプログラムを記憶してもよいし、主記憶部１２には、複数のプログラムがロードされてもよい。
【００１５】
入力部１４は、入力キー及びポインティングデバイスに代表される入力デバイスを含む。入力部１４は、データ処理装置１０のユーザによって入力された情報を取得して、取得した情報をプロセッサ１１に通知する。
【００１６】
出力部１５は、ＬＣＤ（Liquid Crystal Display）及びスピーカに代表される出力デバイスを含む。出力部１５は、プロセッサ１１の指示に従って、種々の情報をユーザに提示する。
【００１７】
通信部１６は、外部の装置と通信するためのネットワークインタフェース回路を含む。通信部１６は、外部から信号を受信して、この信号により示されるデータをプロセッサ１１へ出力する。また、通信部１６は、プロセッサ１１から出力されたデータを示す信号を外部の装置へ送信する。
【００１８】
図２に示されるハードウェア構成が協働することにより、データ処理装置１０は、データの処理を含む種々の機能を発揮する。データ処理装置１０によるデータの処理は、図３に例示されるように、順次実行される一連の部分処理３０，３１，３２，３３を含む処理フロー３００として、ユーザによって任意に規定される。
【００１９】
処理フロー３００は、機器２１から出力されたデータに対し順次施される部分処理を含む。詳細には、処理フロー３００は、データ収集を実行する部分処理３０と、部分処理３１と、部分処理３２と、部分処理３３と、データ出力３９と、をこの順で実行することにより達成される。図３中の矢印は、データの伝送を示す。例えば、部分処理３０の実行によりデータ処理装置１０の外部から取得されたデータが部分処理３１に入力され、このデータに対して部分処理３１が施される。また、部分処理３１の処理結果を示すデータが部分処理３１から出力されてから部分処理３２に入力され、このデータに対して部分処理３２が施される。そして、部分処理３３の処理結果を示すデータが、部分処理３３から出力され、データ出力３９の処理対象となってデータ処理装置１０の外部へ出力される。
【００２０】
部分処理３０は、図１に示されるネットワーク２０を介して機器２１からデータを受信することで処理対象となるデータを収集する処理に相当する。機器２１はセンシング結果を示すデータを周期的に送信するため、部分処理３０は、周期的に実行される。この周期は、例えば１０ｍｓ、１００ｍｓ又は１ｓｅｃである。また、センシング結果を示すデータは、例えば８ビット又は１６ビットのデジタル値である。
【００２１】
部分処理３１〜３３はそれぞれ、部分処理３０の実行に応じて繰り返し実行される処理である。部分処理３１〜３３はそれぞれ、例えば、移動平均の算出処理、処理対象の値が予め規定された閾値を超えるか否かを判定する判定処理、及び、図１中の機器２２に対する制御命令の内容を決定する処理である。これらの部分処理３１〜３３によれば、センシング結果から移動平均によりノイズを除去して得る値が閾値を超えたときに限って特定の制御命令を出力することができる。
【００２２】
ただし、部分処理３１〜３３は、上述の処理に限定されない。例えば、部分処理３１〜３３は、値を予め定められた範囲内に収める端数処理若しくは正規化処理、入力値に予め規定された定数を乗じるスケーリング処理、予め規定されたオフセット値を加算するシフト処理、移動平均の算出処理とは異なるフィルタ処理若しくは統計処理、又は、ＦＦＴ（Fast Fourier Transform）に代表される変換処理であってもよいし、他の加工処理又は診断処理であってもよいし、その他の処理であってもよい。また、図３では、処理フローを構成する４つの部分処理３０〜３３が代表的に示されているが、部分処理の数は、３つ以下であってもよいし、５つ以上であってもよい。
【００２３】
データ出力３９は、図１に示されるネットワーク２０を介して部分処理３３の処理結果を機器２２に送信する処理に相当する。なお、データ出力３９は、機器２２へのデータの送信に限られず、予め指定されたプログラムの実行指令の出力、処理フローを実行した結果の画面への表示、他の装置へのデータの送信、又はその他の出力処理であってもよい。以下では、処理フロー３００の実行により得たデータを機器２２へ制御命令として出力する例を中心に説明する。
【００２４】
データ処理装置１０は、図３に示される処理フロー３００を実行するために、図４に示されるような機能的な構成を有する。詳細には、データ処理装置１０は、ユーザとの間で情報を授受するＵＩ（User Interface）部１１０と、処理フローの設定を受け付ける受付部１２０と、部分処理を実行する処理部１３１，１３２，１３３と、処理フローの実行を制御する実行制御部１４０と、種々のデータを記憶する記憶部１５０と、データの収集及び制御命令の出力を実行する収集部１６０と、を有する。
【００２５】
ＵＩ部１１０は、主として入力部１４と出力部１５との協働により実現される。ＵＩ部１１０は、受付部１２０を介して実行制御部１４０からの表示命令を受けて、この表示命令に従って処理フローの入力をユーザに促す画面を表示する。ユーザは、表示された画面を操作することで任意の部分処理を組み合わせて、データ処理装置１０に実行させる処理フローを設計する。そして、ＵＩ部１１０は、ユーザによって入力された処理フローの設定を受付部１２０に通知する。
【００２６】
受付部１２０は、主としてプロセッサ１１によって実現される。受付部１２０は、データに対し順次施される部分処理を規定する処理フローの設定を受け付ける。受付部１２０は、処理フローの設定を実行制御部１４０に通知する。処理フローの設定内容を示す情報は、実行制御部１４０によって記憶部１５０に格納される。
【００２７】
処理部１３１〜１３３はそれぞれ、主としてプロセッサ１１及び主記憶部１２の協働により実現され、部分処理３１〜３３を実行する。詳細には、処理部１３１〜１３３はそれぞれ、補助記憶部１３に記憶されたソフトウェアモジュールをプロセッサ１１が実行することにより実現される。このソフトウェアモジュールは、ユーザによって補助記憶部１３に格納されたプラグインソフトウェアであってもよい。さらに、このプラグインソフトウェアは、ユーザによって設計されたものであってもよいし、ユーザが購入したソフトウェア或いはオープンソースのソフトウェアとして入手したものであってもよい。以下では、処理部１３１〜１３３を総称して処理部１３０と表記する。処理部１３０は、データ処理装置１０においてデータに部分処理を施す第１処理手段、第２処理手段その他の処理手段の一例である。
【００２８】
なお、処理部１３０は、図３に示される処理フロー３００を構成する部分処理と一対一に対応するとは限らない。例えば、同一の部分処理をデータに対して２回施す場合には、処理フロー３００内では、２つの部分処理が連結することになるが、これらの部分処理はいずれも単一の処理部１３２によって実行されてもよい。
【００２９】
実行制御部１４０は、主としてプロセッサ１１によって実現される。実行制御部１４０は、処理部１３０と他の処理部１３０との間におけるデータの授受を仲介することで、設定された処理フローに対応する順で処理部１３０に部分処理を実行させる。実行制御部１４０は、処理フローの設定に基づいてデータに施すべき部分処理を決定してデータフローを制御するフロー制御部１４１と、処理部１３０とフロー制御部１４１との間でデータの伝送を中継する伝送部１４２と、を有する。
【００３０】
フロー制御部１４１は、収集部１６０によって収集されたデータを取得して、このデータを伝送部１４２に送出することにより、伝送部１４２からデータが伝送される処理部１３１に部分処理を実行させる。また、フロー制御部１４１は、処理部１３０から伝送部１４２を介して部分処理の結果を示すデータを取得すると、このデータを伝送部１４２に送出することにより、伝送部１４２からデータが伝送される処理部１３０に次の部分処理を実行させる。ただし、フロー制御部１４１は、処理部１３３から伝送部１４２を介して最後の部分処理の結果を示すデータを取得すると、このデータを機器２２に送信すべき制御命令として収集部１６０に送出する。なお、機器２２への制御命令の送信とは異なる出力処理が処理フローの結果の出力として規定されている場合に、フロー制御部１４１は、規定された出力処理を実現するための処理を実行する。例えば、処理フローの結果を画面表示することが規定されている場合に、フロー制御部１４１は、ＬＣＤを含む出力部１５に結果を表示させるためのデータを送出してもよい。フロー制御部１４１は、データ処理装置１０において処理部１３０に部分処理を実行させる制御手段の一例である。
【００３１】
伝送部１４２は、サーバとして実装される機能であって、処理部１３０それぞれから送出されるデータをフロー制御部１４１に伝送し、フロー制御部１４１から送出されるデータを、予め定められた送信先である複数の処理部１３０に伝送する。詳細には、伝送部１４２は、出版／購読型モデル或いはＰｕｂｌｉｓｈ／Ｓｕｂｓｃｒｉｂｅモデルに従ってデータを伝送する。ここで、フロー制御部１４１が、処理部１３０それぞれから出版されるデータを購読することが処理フローに関わらず予め設定され、すべての処理部１３０が、フロー制御部１４１から出版されるデータを購読することが処理フローに関わらず予め設定される。伝送部１４２からは、宛先を特定することなく不特定多数の処理部１３０に、フロー制御部１４１からのデータが伝送される。処理部１３０はそれぞれ、伝送されたデータに部分処理を施すべきか否かを、データとともに伝送される後述の情報に基づいて決定する。伝送部１４２は、データ処理装置１０において制御手段から送出されたデータを予め定められた送信先に伝送する伝送手段の一例である。
【００３２】
詳細には、伝送部１４２に予め設定された購読の設定に基づいて、伝送部１４２によるデータの配信先が決定される。この購読の設定は、データ処理装置１０の出荷時に設定されてもよいし、データ処理装置１０のユーザによって処理フローを実行する前に任意に設定されてもよい。また、この購読の設定には、いわゆるトピックの設定が含まれ得る。トピックの設定によっては、すべての処理部１３０が、フロー制御部１４１から出版されるデータを購読するとは限らない。例えば、データ処理装置１０が複数の異なる処理フローを並列に実行する場合において、処理フロー毎に異なるトピックを設定することが考えられる。具体的には、処理部１３０の一例である処理部Ａ，Ｂ，Ｃが順に部分処理を実行することで第１の処理フローが実現され、処理部１３０の一例である処理部Ｄ，Ｅ，Ｆが順に部分処理を実行することで第２の処理フローが実現される場合において、第１の処理フローに関しては、伝送部１４２がフロー制御部１４１から送出されたデータを処理部Ａ，Ｂ，Ｃに配信し、第２の処理フローに関しては、伝送部１４２がフロー制御部１４１から送出されたデータを処理部Ｄ，Ｅ，Ｆに配信することが、トピックにより設定されてもよい。なお、処理部１３０からフロー制御部１４１へ伝送されるデータについては、通常、配信先がフロー制御部１４１に限られるため、トピックにより処理フロー毎に異なる配信先として設定されもよいし、同一の配信先として設定されてもよい。
【００３３】
記憶部１５０は、主として主記憶部１２によって実現される。記憶部１５０は、受付部１２０によって受け付けられた処理フローの設定を示す情報が格納される記憶領域と、実行制御部１４０によってバッファとして利用される記憶領域と、を有する。
【００３４】
収集部１６０は、主として通信部１６によって実現される。収集部１６０は、図３に示される部分処理３０を実行する。詳細には、収集部１６０は、機器２１から繰り返し送信される情報を実行制御部１４０に送出する。また、収集部１６０は、図３に示されるデータ出力３９を実行する。詳細には、収集部１６０は、実行制御部１４０から出力される制御命令を機器２２へ送信する。
【００３５】
続いて、処理部１３０と実行制御部１４０との間における情報の授受について、図５を用いて説明する。図５に示されるように、フロー制御部１４１は、部分処理の対象となるデータとともに、当該データに施すべき部分処理を示す処理情報としてＩＤ（Idendifier）を送出する。また、処理部１３０は、部分処理の結果を示すデータとともに、当該データに施された部分処理を示す前処理情報としてＩＤを送出する。図５においては、ＩＤは、部分処理を識別する識別情報であって、部分処理３１〜３３に対応するＩＤはそれぞれ、「０１」〜「０３」である。
【００３６】
詳細には、フロー制御部１４１は、部分処理３１の対象となる処理データ４１に「０１」というＩＤ５１を付加して伝送部１４２に送出する。以下では、部分処理の対象となるデータ及び部分処理の結果を示すデータを処理データと適宜表記し、処理データとＩＤとを含む情報を伝送データと適宜表記する。すなわち、フロー制御部１４１は、処理データ４１とＩＤ５１とを含む伝送データ６１を伝送部１４２に送出する。この伝送データ６１は、部分処理を識別するＩＤを含むが、送信先である処理部１３１を特定する情報、及び送信元であるフロー制御部１４１を特定する情報を含まなくてもよい。伝送部１４２は、伝送データ６１をすべての処理部１３１〜１３３に伝送する。
【００３７】
処理部１３２，１３３は、伝送データ６１のＩＤ５１により示される部分処理３１が、自身の実行する部分処理３２，３３とは異なるため、伝送部１４２から取得した伝送データ６１を破棄する。詳細には、処理部１３２，１３３は、伝送データ６１のＩＤ５１が、自身が実行する部分処理３２，３３を示すものとして予め設定されたＩＤ「０２」「０３」と異なるため、伝送データ６１を破棄する。処理部１３１は、伝送データ６１のＩＤ５１が、自身の実行する部分処理３１を示すため、伝送データ６１に含まれる処理データ４１に部分処理３１を施す。
【００３８】
そして、処理部１３１は、部分処理３１の結果を示す処理データ４２にＩＤ５１を付加して得た伝送データ６２を伝送部１４２に送出する。伝送部１４２は、伝送データ６２をフロー制御部１４１に伝送する。フロー制御部１４１は、伝送データ６２を取得すると、設定された処理フローに従って、次に実行すべき部分処理３２を特定し、伝送データ６２のうちのＩＤ５１を、特定した部分処理３２を示す「０２」というＩＤ５２に置き換える。そして、フロー制御部１４１は、置き換えにより生成された伝送データ６３を伝送部１４２に送出する。
【００３９】
その後、伝送部１４２が伝送データ６３を処理部１３１〜１３３に伝送するが、処理部１３１，１３３は伝送データ６３を破棄し、処理部１３２が伝送データ６３に含まれる処理データ４２に部分処理３２を施して処理データ４３を得る。処理部１３２は、処理データ４３にＩＤ５２を付加した伝送データ６４を伝送部１４２に送出し、伝送部１４２は、伝送データ６４をフロー制御部１４１に伝送する。そして、フロー制御部１４１は、次の部分処理３３を示すＩＤ５３を処理データ４３に付した伝送データ６５を送出し、処理部１３３は、処理データ４３に部分処理３３を施して得た処理データ４４にＩＤ５３を付した伝送データ６６を返送する。
【００４０】
図５に示されたようなデータの授受を実現するための処理部１３０及び実行制御部１４０の機能的な構成の詳細について、図６を用いて説明する。
【００４１】
図６に示されるように、処理部１３０は、伝送部１４２と通信するためのＩ／Ｆ（Interface）部７１と、伝送データと処理データを相互に変換する変換部７２と、ＩＤを照合して処理データに部分処理を施すか否かを決定する照合部７３と、部分処理を実行する実行部７４と、処理すべき処理データに付されるＩＤの設定値を記憶する記憶部７５と、を有する。なお、記憶部７５は、図４に示される記憶部１５０と実質的に同一の構成であってもよいし、異なってもよい。
【００４２】
変換部７２は、Ｉ／Ｆ部７１を介して伝送データを受信すると、伝送データからＩＤを分離して、分離したＩＤを照合部７３に通知する。また、変換部７２は、伝送データからＩＤが分離された処理データを記憶部７５に格納する。照合部７３は、予め設定されたＩＤの値を記憶部７５から読み出して、変換部７２から通知されたＩＤと照合する。照合部７３は、ＩＤが異なる場合に、通知されたＩＤ及び記憶部７５に格納された処理データを破棄し、ＩＤが一致する場合に、実行部７４に部分処理を実行させる。実行部７４は、照合部７３から実行の指示を得ると、記憶部７５から処理データを読み出して、処理データに部分処理を施した結果を示す新たな処理データを生成して変換部７２に送出する。変換部７２は、実行部７４から送出された処理データにＩＤを結合させて伝送データを生成し、Ｉ／Ｆ部７１を介して伝送部１４２に送信する。伝送データから分離されたＩＤが、記憶部７５に記憶されるＩＤの設定値に等しいため、処理データに結合されるＩＤは、分離されたＩＤ及びＩＤの設定値のいずれであってもよい。
【００４３】
フロー制御部１４１は、伝送部１４２と通信するためのＩ／Ｆ部８１と、伝送データと処理データを相互に変換する変換部８２と、処理データに施すべき次の部分処理を特定する特定部８３と、を有する。変換部８２及び特定部８３は、図４に示される記憶部１５０を適宜利用する。
【００４４】
変換部８２は、Ｉ／Ｆ部８１を介して伝送データを受信すると、伝送データからＩＤを分離して、分離したＩＤを特定部８３に通知する。特定部８３は、記憶部１５０から処理フローの設定を読み出して、通知されたＩＤにより示される部分処理の次の部分処理を示すＩＤを取得し、取得したＩＤを変換部８２に通知する。変換部８２は、伝送データから分離された処理データを、特定部８３から通知されたＩＤに結合することで生成した伝送データを、Ｉ／Ｆ部８１を介して伝送部１４２に送信する。
【００４５】
ただし、処理フローを開始する際には、変換部８２は、収集部１６０から得た処理データに、最初に実行すべき部分処理に対応するＩＤを結合させて伝送データを生成する。また、処理フローを終了する際には、変換部８２は、伝送データから分離した処理データを、機器２２に対する制御命令として収集部１６０に送出する。なお、機器２２に対する制御命令とは異なる出力処理が規定されている場合に、変換部８２は、出力処理を実現する送信先に処理データを送信する。例えば、処理フローの結果を表示することが規定されている場合に、変換部８２は、ＵＩ部１１０へ処理データを送信してもよい。その際には、実行制御部１４０が処理データを画面表示のために加工してから加工結果をＵＩ部１１０に送出してもよい。
【００４６】
続いて、データ処理装置１０によって実行される処理について、図７〜１２を用いて説明する。図７には、処理フローを実行するためのフロー実行処理が示されている。このフロー実行処理は、データ処理装置１０の電源が投入されることで開始する。
【００４７】
フロー実行処理では、データ処理装置１０は、処理フローの設定を受け付ける（ステップＳ１）。具体的には、受付部１２０が、ＵＩ部１１０に入力された処理フローの設定を受け付ける。
【００４８】
次に、データ処理装置１０は、処理フローの設定に従い、ＩＤ置換テーブルを生成して記憶部１５０に格納する（ステップＳ２）。具体的には、実行制御部１４０が、ステップＳ１で受け付けられた処理フローの設定から、フロー制御部１４１が伝送データのＩＤを置換するためのＩＤ置換テーブルを生成する。
【００４９】
ＩＤ置換テーブルは、図８に例示されるように、処理フローを構成する１つの部分処理である前処理と、その次に実行される部分処理である後処理と、を対応付けた情報である。詳細には、ＩＤ置換テーブルは、前処理のＩＤと、前処理としての部分処理の名称と、次処理のＩＤと、次処理としての部分処理の名称と、を関連付けるテーブルデータである。図８においては、部分処理の名称が、部分処理の参照符号に等しいものとされている。なお、部分処理の名称を省略してＩＤ置換テーブルを構成してもよい。
【００５０】
図７に戻り、ステップＳ２に続いて、データ処理装置１０は、処理フローを構成する部分処理を実行する処理部１３０に、処理すべき処理データに付されるＩＤを設定する（ステップＳ３）。具体的には、実行制御部１４０が、処理部１３０それぞれに対して、実行する部分処理に対応するＩＤを通知して、図６に示された記憶部７５に設定値として記憶させる。例えば、部分処理３１を実行する処理部１３１には、「０１」というＩＤの値が設定される。これにより、処理部１３０は、それぞれが実行すべき部分処理のＩＤをフロー制御部１４１と共有することとなる。
【００５１】
次に、データ処理装置１０は、処理フローの開始指示があるか否かを判定する（ステップＳ４）。開始指示は、ＵＩ部１１０に入力されるユーザの指示であってもよいし、収集部１６０によって特定のデータが取得されることであってもよいし、予め定められた時刻に実行制御部１４０によって生成されるトリガーであってもよい。
【００５２】
開始指示がないと判定した場合（ステップＳ４；Ｎｏ）、データ処理装置１０は、ステップＳ４の判定を繰り返して、開始指示が生じるまで待機する。一方、開始指示があると判定した場合（ステップＳ４；Ｙｅｓ）、データ処理装置１０は、処理フローに従ったデータ処理を実行する（ステップＳ５）。具体的には、収集部１６０がデータを収集し、フロー制御部１４１、伝送部１４２及び処理部１３０がデータを授受することで、部分処理が順次実行される。
【００５３】
次に、データ処理装置１０は、処理フローの終了指示があるか否かを判定する（ステップＳ６）。終了指示は、開始指示と同様に、ユーザの指示であってもよいし、収集部１６０によって特定のデータが取得されることであってもよいし、実行制御部１４０によって生成されるトリガーであってもよい。
【００５４】
終了指示がないと判定した場合（ステップＳ６；Ｎｏ）、データ処理装置１０は、ステップＳ５の処理を繰り返して、データ処理を続行する。一方、終了指示があると判定した場合（ステップＳ６；Ｙｅｓ）、フロー実行処理が終了する。
【００５５】
続いて、フロー制御部１４１によって実行されるフロー制御送信処理について図９を用いて説明する。フロー制御送信処理は、フロー制御部１４１が処理フローの対象となるデータを伝送部１４２に送信することで、当該データに関する処理フローを開始するための処理である。フロー制御送信処理は、図７中のステップＳ５にて実行されるデータ処理に含まれる。
【００５６】
フロー制御送信処理では、フロー制御部１４１が、処理フローが施されるデータを取得する（ステップＳ１１）。具体的には、フロー制御部１４１は、収集部１６０からデータを取得する。
【００５７】
次に、フロー制御部１４１は、処理フローを構成する最初の部分処理に対応するＩＤを特定する（ステップＳ１２）。具体的には、特定部８３が、ＩＤ置換テーブルを記憶部１５０から読み出して、最初の部分処理３１に対応するＩＤを特定する。
【００５８】
次に、フロー制御部１４１は、特定したＩＤをデータに付加する（ステップＳ１３）。具体的には、変換部８２が、ステップＳ１２で特定されたＩＤを、ステップＳ１１で取得されたデータである処理データに結合させて伝送データを生成する。
【００５９】
次に、フロー制御部１４１は、データをＩＤとともに伝送部１４２に送信する（ステップＳ１４）。具体的には、変換部８２が、ステップＳ１３で生成した伝送データを、Ｉ／Ｆ部８１を介して伝送部１４２に送出する。その後、フロー制御送信処理が終了する。以上のフロー制御送信処理が、収集部１６０からデータが送出されるたびにフロー制御部１４１によって実行される。
【００６０】
続いて、伝送部１４２によって実行される伝送処理について図１０を用いて説明する。伝送処理は、伝送部１４２が処理部１３０とフロー制御部１４１との間でデータを伝送する処理である。伝送処理は、図７中のステップＳ５にて実行されるデータ処理に含まれる。
【００６１】
伝送処理では、伝送部１４２が、フロー制御部１４１から送出されたデータを取得したか否かを判定する（ステップＳ２１）。データを取得していないと判定した場合（ステップＳ２１；Ｎｏ）、伝送部１４２による処理は、ステップＳ２３へ移行する。一方、データを取得したと判定した場合（ステップＳ２１；Ｙｅｓ）、伝送部１４２は、取得したデータを予め定められた処理部１３０に伝送する（ステップＳ２２）。具体的には、伝送部１４２は、フロー制御部１４１から取得した伝送データを、すべての処理部１３０に伝送する。
【００６２】
次に、伝送部１４２は、処理部１３０から送出されたデータを取得したか否かを判定する（ステップＳ２３）。データを取得していないと判定した場合（ステップＳ２３；Ｎｏ）、伝送部１４２は、ステップＳ２１以降の処理を繰り返す。一方、データを取得したと判定した場合（ステップＳ２３；Ｙｅｓ）、伝送部１４２は、取得したデータをフロー制御部１４１に伝送する（ステップＳ２４）。その後、伝送部１４２は、ステップＳ２１以降の処理を繰り返す。これにより、伝送部１４２は、処理部１３０及びフロー制御部１４１から伝送データが送出されるたびに、この伝送データを伝送する。
【００６３】
続いて、フロー制御部１４１によって実行されるフロー制御受信処理について図１１を用いて説明する。フロー制御受信処理は、フロー制御部１４１が処理部１３０からのデータを受信することで開始する。フロー制御受信処理は、図７中のステップＳ５にて実行されるデータ処理に含まれる。
【００６４】
フロー制御受信処理では、フロー制御部１４１は、伝送部１４２からデータ及びＩＤを取得する（ステップＳ３１）。具体的には、変換部８２が、伝送部１４２からＩ／Ｆ部８１を介して、処理データ及びＩＤを含む伝送データを受信する。
【００６５】
次に、フロー制御部１４１は、データとＩＤを分離する（ステップＳ３２）。具体的には、変換部８２が、伝送データに含まれる処理データとＩＤとをそれぞれ抽出する。
【００６６】
次に、フロー制御部１４１は、ＩＤにより示される部分処理が処理フローに含まれるか否かを判定する（ステップＳ３３）。具体的には、特定部８３が、記憶部１５０からＩＤ置換テーブルを読み出して、ステップＳ３２にて分離されたＩＤがＩＤ置換テーブルに前処理のＩＤとして含まれるか否かを判定する。
【００６７】
ＩＤにより示される部分処理が処理フローに含まれないと判定した場合（ステップＳ３３：Ｎｏ）、フロー制御部１４１は、データ及びＩＤを破棄する（ステップＳ３４）。その後、フロー制御受信処理が終了する。一方、ＩＤにより示される部分処理が処理フローに含まれると判定した場合（ステップＳ３３；Ｙｅｓ）、フロー制御部１４１は、分離されたＩＤから次のＩＤを特定する（ステップＳ３５）。具体的には、特定部８３が、ステップＳ３２にて分離されたＩＤとＩＤ置換テーブルにおいて対応する次処理のＩＤを特定する。
【００６８】
次に、フロー制御部１４１は、次のＩＤがあるか否かを判定する（ステップＳ３６）。具体的には、特定部８３が、ステップＳ３２にて分離されたＩＤに対応する次処理のＩＤを特定することができたか否かを判定する。
【００６９】
次のＩＤがないと判定した場合（ステップＳ３６；Ｎｏ）、フロー制御部１４１は、処理フローが終了したと判断して、出力処理を実行する（ステップＳ３９）。例えば、特定部８３が、ステップＳ３２における分離により得た処理データが、処理フローの最後の部分処理の結果であると判断して、当該処理データを収集部１６０に送出する。その後、フロー制御受信処理が終了する。
【００７０】
一方、次のＩＤがあると判定した場合（ステップＳ３６；Ｙｅｓ）、フロー制御部１４１は、特定したＩＤをデータに付加する（ステップＳ３７）。具体的には、変換部８２が、ステップＳ３５にて特定した次のＩＤに、ステップＳ３２で分離された処理データを結合させて、伝送データを生成する。
【００７１】
次に、フロー制御部１４１は、データをＩＤとともに伝送部１４２に送信する（ステップＳ３８）。具体的には、変換部８２が、ステップＳ３７で生成した伝送データを、Ｉ／Ｆ部８１を介して伝送部１４２に送出する。その後、フロー制御受信処理が終了する。以上のフロー制御受信処理が、伝送部１４２からフロー制御部１４１にデータが伝送されるたびに実行される。
【００７２】
続いて、処理部１３０それぞれによって実行される実行処理について図１２を用いて説明する。この実行処理は、部分処理を実行する処理であって、処理部１３０がフロー制御部１４１からのデータを受信することで開始する。実行処理は、図７中のステップＳ５にて実行されるデータ処理に含まれる。
【００７３】
実行処理では、処理部１３０が、伝送部１４２からデータ及びＩＤを取得する（ステップＳ４１）。具体的には、変換部７２が、伝送部１４２からＩ／Ｆ部７１を介して、処理データ及びＩＤを含む伝送データを受信する。
【００７４】
次に、処理部１３０は、データとＩＤを分離する（ステップＳ４２）。具体的には、変換部７２が、伝送データに含まれる処理データとＩＤとをそれぞれ抽出する。
【００７５】
次に、処理部１３０は、ＩＤにより示される部分処理を実行可能であるか否かを判定する（ステップＳ４３）。具体的には、照合部７３が、記憶部７５からＩＤの設定値を読み出して、ステップＳ４２にて分離されたＩＤが、読み出した設定値に等しいか否かを判定する。
【００７６】
ＩＤにより示される部分処理を実行可能でないと判定した場合（ステップＳ４３；Ｎｏ）、処理部１３０は、データ及びＩＤを破棄する（ステップＳ４４）。その後、実行処理が終了する。一方、ＩＤにより示される部分処理を実行可能であると判定した場合（ステップＳ４３；Ｙｅｓ）、処理部１３０は、部分処理を実行する（ステップＳ４５）。具体的には、実行部７４が、ステップＳ４２にて分離された処理データに対して部分処理を施して、処理結果を示す新たな処理データを生成する。
【００７７】
次に、処理部１３０は、処理結果を示すデータにＩＤを付加する（ステップＳ４６）。具体的には、変換部７２が、ステップＳ４５にて生成された処理データに、ステップＳ４２で分離されたＩＤを結合させて伝送データを生成する。
【００７８】
次に、処理部１３０は、データをＩＤとともに伝送部１４２に送信する（ステップＳ４７）。具体的には、変換部７２が、ステップＳ４６にて生成した伝送データを伝送部１４２に送出する。その後、実行処理が終了する。以上の実行処理が、伝送部１４２から処理部１３０にデータが伝送されるたびに実行される。
【００７９】
以上、説明したように、フロー制御部１４１は、処理データを送出することで部分処理を処理部１３０に実行させる。このため、処理フローをモジュール化することができる。
【００８０】
また、伝送部１４２は、フロー制御部１４１から送出された処理データを複数の処理部１３０を含む予め定められた送信先へ伝送し、フロー制御部１４１は、処理データに施されるべき部分処理を示す処理情報としてのＩＤを、処理データとともに送出する。
【００８１】
このため、処理部１３０は、ＩＤに基づいて部分処理を実行すべきか否かを決定することができる。これにより、フロー制御部１４１が処理データの送信先である処理部１３０を特定する必要がなく、処理部１３０が処理データの送信元に応じた処理を実行する必要がない。したがって、処理部１３０の設計が容易になるとともにその設定を簡略にすることができる。ひいては、データを処理するためのユーザの作業負担を軽減することができる。さらに、処理フローの変更及び拡張が容易になる。
【００８２】
また、フロー制御部１４１は、伝送部１４２から処理データとともにＩＤを取得すると、処理フローの設定に従って次の部分処理に対応するＩＤを特定し、特定したＩＤを処理データとともに伝送部１４２に送出する。これにより、処理フローの設定に従って部分処理を順次実行することができる。
【００８３】
また、伝送部１４２は、処理部１３０によって実行される部分処理の前に他の部分処理を実行する他の処理部から送出される、処理データ及び当該他の部分処理を示す前処理情報としてのＩＤを、フロー制御部１４１に伝送する。フロー制御部１４１は、処理データ及びＩＤを伝送部１４２から取得すると、設定された処理フローに従って、前処理情報としてのＩＤから、ＩＤ置換テーブルを利用して、次に実行すべき部分処理を示すＩＤを特定する。そして、フロー制御部１４１は、特定したＩＤを、取得した処理データとともに送出する。これにより、フロー制御部１４１へ伝送された処理データは、適当なＩＤが付与されてフロー制御部１４１から送出されることとなる。また、処理フローの実行前にＩＤ置換テーブルを設定すれば、フロー制御部１４１は、適当なＩＤを処理データに付与することができる。
【００８４】
また、伝送部１４２は、予め設定された送信先にデータを伝送する。詳細には、伝送部１４２は、出版／購読型モデルに従って処理データ及びＩＤを伝送する。このため、処理部１３０及びフロー制御部１４１が処理データの送信元及び送信先に応じた処理を実行する必要がない。これにより、処理フローの設定を変更する際には、実行制御部１４０に処理フローの設定を適用して、ＩＤ置換テーブル及び処理部１３０それぞれのＩＤの設定値を変更するだけで、新たな処理フローを実行する準備が整う。したがって、処理部１３０によって実行される部分処理の内容を変更する必要がなく、処理フローの変更が容易になる。
【００８５】
また、伝送部１４２は、フロー制御部１４１から送出されたデータを、処理フローを構成する部分処理を実行するすべての処理部１３０に伝送する。このため、伝送部１４２がデータを伝送する送信先の設定が容易になる。
【００８６】
また、処理部１３０は、該処理部１３０を送信先として伝送されたデータを、該データに施されるべき部分処理を示すＩＤとともに取得すると、取得したＩＤに基づいて部分処理を実行するか否かを決定する。このため、処理部１３０が適当なデータに対して部分処理を施すことができる。
【００８７】
また、処理データとともに伝送されるＩＤは、処理フローを構成する部分処理を示し、当該部分処理を実行する処理部１３０を示す情報ではない。このため、例えば図３，５に示される処理フローを、２回連続で実行される部分処理３１を含むフローに変更する際には、処理部１３１にＩＤの設定値「０１」及び「０２」を設定するだけで、変更後の処理フローを実行する準備が整う。
【００８８】
なお、伝送部１４２は、制御手段から送出されるデータを第１処理手段及び他の処理手段を含む予め定められた送信先へ伝送し、第２処理手段から送出されるデータを制御手段に伝送する伝送手段の一例である。ここで、第１処理手段に相当する処理部１３０は、第２処理手段に相当する処理部１３０と同一であってもよいし異なってもよい。また、第２処理手段に相当する処理部１３０は、他の処理手段に相当する処理部１３０と同一であってもよいし異なってもよい。
【００８９】
以上、本発明の実施の形態について説明したが、本発明は上記実施の形態によって限定されるものではない。
【００９０】
例えば、伝送部１４２は、処理部１３０とフロー制御部１４１との通信を中継したが、これには限定されない。伝送部１４２は、図１３に示されるように、処理部１３０、フロー制御部１４１及び収集部１６０の間でデータの伝送を中継してもよい。伝送部１４２が収集部１６０とデータを授受する場合には、図３に示される部分処理３０及びデータ出力３９を処理フローに含めて、処理部１３０による部分処理３１〜３３の実行と同様に、収集部１６０が部分処理３０及びデータ出力３９を実行すればよい。そして、収集部１６０は、処理部１３０と同様にＩＤを含む伝送データを伝送部１４２との間で授受すればよい。この場合、処理フローを構成する複数の部分処理のうちのいずれかの部分処理が、機器２１から機器データを収集すること及び機器２２に送信データを送信することの少なくとも一方を含むこととなる。ここで、機器データは、機器２１から出力された情報を含むデータであって、送信データは、機器２２へ送信される情報を含むデータである。
【００９１】
また、データ処理装置１０は、処理部１３０とフロー制御部１４１との通信を中継する伝送部１４２と、収集部１６０との通信を中継する他の伝送部とを別個に有してもよい。
【００９２】
また、上記実施の形態では、伝送部１４２が、フロー制御部１４１から処理部１３０へのデータの伝送と、処理部１３０からフロー制御部１４１へのデータの伝送と、を区別する例について説明したが、これには限定されない。伝送部１４２は、フロー制御部１４１及び処理部１３０をすべて同等のノードとして扱って、１つのノードから送出されたデータを他のすべてのノードに伝送してもよい。
【００９３】
また、上記実施の形態では、処理部１３０が取得する伝送データに含まれるＩＤが、この処理部１３０が送出する伝送データに含まれるＩＤに等しい例について説明したが、これには限定されない。図１４に示されるように、処理部１３０は、取得した伝送データとは異なるＩＤを含む伝送データを送出してもよい。処理部１３０が送信する処理データに付与するＩＤを、フロー制御部１４１が予め処理部１３０に対して指定すれば、処理部１３０は、取得したＩＤとは異なるＩＤを処理データに付して送出することができる。
【００９４】
また、上記実施の形態では、伝送部１４２が、フロー制御部１４１と処理部１３０との間で出版／購読型モデルに従って双方向にデータを伝送する例について説明したが、これには限定されない。図１５に示されるように、フロー制御部１４１から処理部１３０へのデータが出版／購読型モデルに従って伝送され、反対方向では、出版／購読型モデルのプロトコルとは異なる一対一通信のプロトコルに従ってデータが伝送されてもよい。この場合、処理部１３０からフロー制御部１４１へ伝送される処理データには、ＩＤが付されることなくアドレスが付されることになる。
【００９５】
また、上記実施の形態では、図３に示されるような比較的簡素な処理フローを例に説明したが、これには限定されず、処理フローは複雑であってもよい。例えば、図１６に示されるように、処理フローは、部分処理３０から部分処理３１，３１ａへのフローの分岐、及び、部分処理３１，３１ａから部分処理３２ａへのフローの集約を含んでもよい。
【００９６】
また、上記実施の形態では、処理部１３０がデータ処理装置１０に含まれる例について説明したが、これには限定されない。図１７に示されるように、データ処理装置１０の外部の処理部１３１を有するデータ処理システム１００を構成してもよい。
【００９７】
また、上記実施の形態では、処理部１３０それぞれに１つのＩＤが設定される例を中心に説明したが、これには限定されない。処理部１３０の記憶部７５に、ＩＤの設定値が複数格納される場合も考えられる。この場合には、図１２のステップＳ４３にて、照合部７３が、受信したＩＤと、いずれかの設定値とが一致するかを判定すればよい。これにより、１つの処理部１３０が実行可能な部分処理が処理フローに複数含まれる場合、及び、１つの処理部１３０が実行可能な部分処理が、同時に実行される複数の処理フローそれぞれに含まれる場合に、この処理部１３０による部分処理を実行することができる。
【００９８】
また、上記実施の形態では、ＩＤが、部分処理を識別する情報である例について説明したが、これには限定されない。ＩＤは、データの送信元、送信先、及び、その他のデータの属性或いは種別のうちの１つ又は２つ以上の組合せを一意に特定する情報であってもよい。
【００９９】
また、データ処理装置１０の機能は、専用のハードウェアによっても、また、通常のコンピュータシステムによっても実現することができる。
【０１００】
例えば、プロセッサ１１によって実行されるプログラムＰ１を、コンピュータ読み取り可能な非一時的な記録媒体に格納して配布し、そのプログラムＰ１をコンピュータにインストールすることにより、上述の処理を実行する装置を構成することができる。このような記録媒体としては、例えばフレキシブルディスク、ＣＤ−ＲＯＭ（Compact Disc Read−Only Memory）、ＤＶＤ（Digital Versatile Disc）、ＭＯ（Magneto−Optical Disc）が考えられる。
【０１０１】
また、プログラムＰ１をインターネットに代表される通信ネットワーク上のサーバ装置が有するディスク装置に格納しておき、例えば、搬送波に重畳させて、コンピュータにダウンロードするようにしてもよい。
【０１０２】
また、通信ネットワークを介してプログラムＰ１を転送しながら起動実行することによっても、上述の処理を達成することができる。
【０１０３】
さらに、プログラムＰ１の全部又は一部をサーバ装置上で実行させ、その処理に関する情報をコンピュータが通信ネットワークを介して送受信しながらプログラムを実行することによっても、上述の処理を達成することができる。
【０１０４】
なお、上述の機能を、ＯＳ（Operating System）が分担して実現する場合又はＯＳとアプリケーションとの協働により実現する場合には、ＯＳ以外の部分のみを媒体に格納して配布してもよく、また、コンピュータにダウンロードしてもよい。
【０１０５】
また、データ処理装置１０の機能を実現する手段は、ソフトウェアに限られず、その一部又は全部を、回路を含む専用のハードウェアによって実現してもよい。
【０１０６】
本発明は、本発明の広義の精神と範囲を逸脱することなく、様々な実施の形態及び変形が可能とされるものである。また、上述した実施の形態は、本発明を説明するためのものであり、本発明の範囲を限定するものではない。つまり、本発明の範囲は、実施の形態ではなく、請求の範囲によって示される。そして、請求の範囲内及びそれと同等の発明の意義の範囲内で施される様々な変形が、本発明の範囲内とみなされる。
【産業上の利用可能性】
【０１０７】
本発明は、データの処理に適している。
【符号の説明】
【０１０８】
１００  データ処理システム、  １０  データ処理装置、  １１  プロセッサ、  １２  主記憶部、  １３  補助記憶部、  １４  入力部、  １５  出力部、  １６  通信部、  １７  内部バス、  １１０  ＵＩ部、  １２０  受付部、  １３０〜１３３  処理部、  １４０  実行制御部、  １４１  フロー制御部、  １４２  伝送部、  １５０  記憶部、  １６０  収集部、  ２０  ネットワーク、  ２１，２２  機器、  ３００  処理フロー、  ３０〜３３，３１ａ，３２ａ  部分処理、  ３９  データ出力、  ４１〜４４  処理データ、  ６１〜６６  伝送データ、  ７１  Ｉ／Ｆ部、  ７２  変換部、  ７３  照合部、  ７４  実行部、  ７５  記憶部、  ８１  Ｉ／Ｆ部、  ８２  変換部、  ８３  特定部、  Ｐ１  プログラム。
【要約】
データ処理装置（１０）は、順次実行される部分処理を含む処理フローのうちのいずれかの部分処理を実行する処理部（１３１）に、該部分処理の対象である処理データを送出することで、部分処理を処理部（１３１）に実行させるフロー制御部（１４１）と、フロー制御部（１４１）から送出された処理データを、処理部（１３１）及び他の処理部（１３０）を含む予め定められた送信先へ伝送する伝送部（１４２）と、を備える。フロー制御部（１４１）は、処理データに施されるべき部分処理を示すＩＤを、処理データとともに伝送部（１４２）に送出する。【図１】
0006608572.tif 000002
【図２】
0006608572.tif 000003
【図３】
0006608572.tif 000004
【図４】
0006608572.tif 000005
【図５】
0006608572.tif 000006
【図６】
0006608572.tif 000007
【図７】
0006608572.tif 000008
【図８】
0006608572.tif 000009
【図９】
0006608572.tif 000010
【図１０】
0006608572.tif 000011
【図１１】
0006608572.tif 000012
【図１２】
0006608572.tif 000013
【図１３】
0006608572.tif 000014
【図１４】
0006608572.tif 000015
【図１５】
0006608572.tif 000016
【図１６】
0006608572.tif 000017
【図１７】
0006608572.tif 000018