(57)【要約】【課題】ネットワーク上に分散された計算資源に対して適切にデータを振り分ける。【解決手段】ネットワークにおいてデータに対する処理を複数の計算資源を用いて行う分散システムにおいて、複数のデータ処理手段にデータを振り分ける振り分け手段と、各データ処理手段におけるデータ処理時間、及び、前記振り分け手段と各データ処理手段との間の通信時間を収集し、収集したデータ処理時間及び通信時間に基づいて、各データ処理手段へのデータの振り分けを決定し、決定した振り分けの情報を前記振り分け手段に通知する判断手段とを備える。【選択図】図１
2020135548.tif 000002
【特許請求の範囲】
【請求項１】
ネットワークにおいてデータに対する処理を複数の計算資源を用いて行う分散システムであって、
複数のデータ処理手段にデータを振り分ける振り分け手段と、
各データ処理手段におけるデータ処理時間、及び、前記振り分け手段と各データ処理手段との間の通信時間を収集し、収集したデータ処理時間及び通信時間に基づいて、各データ処理手段へのデータの振り分けを決定し、決定した振り分けの情報を前記振り分け手段に通知する判断手段と
を備える分散システム。
【請求項２】
前記振り分け手段からデータを受信し、受信したデータをデータ処理手段に渡すデータ送受信手段を更に備え、
前記データ送受信手段は、前記通信時間、及び前記データ処理時間を算出する
請求項１に記載の分散システム。
【請求項３】
ネットワークのリソースの利用情報を取得する監視手段を更に備え、
前記判断手段は、前記データ処理時間及び前記通信時間に加えて、前記監視手段により取得したリソースの利用情報を用いて前記振り分けを決定する
請求項１又は２に記載の分散システム。
【請求項４】
前記判断手段は、
あるデータ処理手段で処理可能なデータの数と、当該データ処理手段に対して通信可能なデータの数のうち、小さいほうの数を、当該データ処理手段への振り分けデータ数として決定する
請求項１ないし３のうちいずれか１項に記載の分散システム。
【請求項５】
ネットワークにおいてデータに対する処理を複数の計算資源を用いて行う分散システムが実行するデータ振り分け方法であって、
前記分散システムは、複数のデータ処理手段にデータを振り分ける振り分け手段を備えており、
各データ処理手段におけるデータ処理時間、及び、前記振り分け手段と各データ処理手段との間の通信時間を収集するステップと、
収集したデータ処理時間及び通信時間に基づいて、各データ処理手段へのデータの振り分けを決定し、決定した振り分けの情報を前記振り分け手段に通知するステップと
を備えるデータ振り分け方法。
【請求項６】
コンピュータを、請求項１ないし４のうちいずれか１項に記載の分散システムにおける判断手段として機能させるためのプログラム。
【発明の詳細な説明】
【技術分野】
【０００１】
本発明は、通信リソースの使用量を考慮に入れたストリーム処理の並列化のためのシステムに関連するものである。
【背景技術】
【０００２】
広域ネットワークにおいて、階層構造を持つコンピューティングリソースを地理的に分散したエッジコンピューティングが注目されている。また、近年、フルマネージドなアプリケーション実行環境を活用することで、開発や運用における「サーバ」という単位を廃し、クラウド上のコンポーネントをイベント駆動で結びつけて最大限活用していくシステムアーキテクチャであるＦａａＳ（Function as a Service）により、エッジコンピューティング上でのストリームプロセシングを実現する検討が進められている。
【０００３】
ここで、エッジコンピューティングにおける各地点のコンピューティングリソースには制限があり、柔軟にリソース活用できることが必要である。また、ＦａａＳにおいて、ファンクションをＥＣ上で運用するためには、限られた計算資源及び通信資源を効率的に利用することが必要であり、そのためにはファンクションの分散展開、動的な制御が可能なジョブスケジューリング、迅速なスケールイン／スケールアウトをできる仕組みが必要である。
【０００４】
上記の課題に関する従来技術として、例えば、非特許文献１に開示された技術がある。非特許文献１に開示された技術は、ストリーム処理を並列化・分散化するミドルウェアであり、分散処理を行うファンクションの処理時間をもとに分散する方式である。
【０００５】
また、非特許文献２は、広域ネットワークを想定したストリーム処理に関する先行研究であり、分散した場所で分析した結果を収集するファンクション、あるいは次の分析を行うファンクションに情報を渡すためのルーティングを、限られた帯域の広域ネットワーク環境で決定するアルゴリズムを開示している。
【先行技術文献】
【非特許文献】
【０００６】
【非特許文献１】Apache Storm http://storm.apache.org/
【非特許文献２】Wenxin Li et. al., "Wide-Area Spark Streaming: Automated Routing and Batch Sizing", IEEE Transactions on Parallel and Distributed Systems, 2018
【発明の概要】
【発明が解決しようとする課題】
【０００７】
非特許文献１に開示されているように、従来、処理を分散する際の処理の振り分けは、振り分け先の計算資源の空きリソース、処理速度等により決定していた。しかし、従来技術では、分散先の計算資源までの通信リソースを考慮していなかったため、通信リソースが不足した計算資源へ処理を分散すると全体の処理速度が劣化する、効率的な計算資源の利用ができないといった課題があった。
【０００８】
本発明は上記の点に鑑みてなされたものであり、ネットワーク上に分散された計算資源に対して適切にデータを振り分けることを可能とする技術を提供することを目的とする。
【課題を解決するための手段】
【０００９】
開示の技術によれば、ネットワークにおいてデータに対する処理を複数の計算資源を用いて行う分散システムであって、
複数のデータ処理手段にデータを振り分ける振り分け手段と、
各データ処理手段におけるデータ処理時間、及び、前記振り分け手段と各データ処理手段との間の通信時間を収集し、収集したデータ処理時間及び通信時間に基づいて、各データ処理手段へのデータの振り分けを決定し、決定した振り分けの情報を前記振り分け手段に通知する判断手段と
を備える分散システムが提供される。
【発明の効果】
【００１０】
開示の技術によれば、ネットワーク上に分散された計算資源に対して適切にデータを振り分けることを可能とする技術が提供される。
【図面の簡単な説明】
【００１１】
【図１】本発明の実施の形態におけるシステム構成及び処理の流れを示す図である。
【図２】情報処理サーバのハードウェア構成例を示す図である。
【図３】システムの動作を説明するためのフローチャートである。
【図４】実施例１のシステム構成を示す図である。
【図５】実施例２のシステム構成を示す図である。
【発明を実施するための形態】
【００１２】
以下、図面を参照して本発明の実施の形態（本実施の形態）を説明する。以下で説明する実施の形態は一例に過ぎず、本発明が適用される実施の形態は、以下の実施の形態に限られるわけではない。
【００１３】
（システム全体構成）
図１に、本実施の形態におけるシステム構成を示す。本システムは、データストリーム（例：映像データストリーム）の処理を実行する複数の情報処理サーバ（コンピュータ）がネットワーク上に備えられる構成を有するが、図１は、情報処理サーバに含まれる機能に着目して図示している。図１に示す各部は、どの情報処理サーバに備えられていてもよい。また、図１に示す各部をそれぞれ装置（コンピュータ）と見なしてもよい。
【００１４】
図１に示すように、本システムは、振り分け部１０、代理送受信部２０Ａ〜２０Ｃ、関数処理部３０Ａ〜３０Ｃ、統合部４０、判断部５０、監視部６０を有する。
【００１５】
実装の一例として、例えば、代理送受信部２０Ａと関数処理部３０Ａの組、代理送受信部２０Ｂと関数処理部３０Ｂの組、代理送受信部２０Ｃと関数処理部３０Ｃの組がそれぞれ１つの情報処理サーバに備えられ、これらの情報処理サーバにおいて、データの処理が分散して行われる。なお、１つ又は複数の情報処理サーバを分散システムと称してもよい。また、分散システムを分散装置と称してもよい。
【００１６】
また、監視部６０については、情報処理サーバに備えられてもよいし、情報処理サーバとは別の資源監視サーバに備えられてもよい。
【００１７】
なお、代理送受信部２０Ａ〜２０Ｃ、関数処理部３０Ａ〜３０Ｃにおいて、Ａ〜Ｃに共通の動作を説明する場合には、代理送受信部２０、関数処理部３０と記述する。また、以下、処理対象のデータを処理対象データと呼び、通信時間等の計算結果の情報が含まれるデータを情報データと呼ぶ。また、以下で説明する処理において、「送信」、「受信」は、ネットワークを介した「送信」、「受信」のみでなく、情報処理サーバ内部の「送信」、「受信」である場合もある。各部の機能の概要は下記のとおりである。
【００１８】
振り分け部１０は、データ発生元から処理対象データを受信し、判断部５０からの振り分け情報に基づいて、処理対象データを代理送受信部２０に振り分ける。振り分け時に、処理対象データにタイムスタンプを付ける。
【００１９】
代理送受信部２０は、振り分け部１０から処理対象データを受信し、当該データを関数処理部３０に渡し、関数処理部３０からの返り値に元の処理対象データのタイムスタンプ等の情報を付与して統合部４０へ送信する。また、代理送受信部２０は、データ受信時に通信時間を算出するとともに、返り値を得て、処理時間に関する情報を算出する。
【００２０】
関数処理部３０は、処理対象データを引数に取り値を返す関数である。一例として、関数処理部３０は、映像データを入力とし、ＡＩによる画像認識等の処理を行う関数である。
【００２１】
統合部４０は、代理送受信部２０から受信する情報データの到着時刻をもとに通信時間を算出し、算出した情報を含む情報データを判断部５０に送信する。
【００２２】
判断部５０は、リソースの利用情報、通信時間、処理時間をもとに、処理対象のデータの振り分けを判断し、振り分けを判断した情報を振り分け部１０に送信する。なお、振り分け判断において、リソースの利用情報を使用しないこととしてもよい。
【００２３】
監視部６０は、ＳＮＭＰ／Ｎｅｔｆｌｏｗなどを用いてネットワークのリソースの利用情報を取得し、判断部５０に送信する。
【００２４】
（ハードウェア構成例）
図１に示される複数の機能部のうちのいずれか１つ又は複数を備える情報処理サーバは、例えば、コンピュータに、本実施の形態で説明する処理内容を記述したプログラムを実行させることにより実現可能である。当該コンピュータは、物理マシンであってもよいし、仮想マシンであってもよい。前述したように、情報処理サーバは、図１に示した機能部のうちのいずれの機能部を含んでもよい。例えば、図１に示した機能部のうち判断部５０のみを備える情報処理サーバが存在してもよい。
【００２５】
情報処理サーバは、コンピュータに内蔵されるＣＰＵやメモリ等のハードウェア資源を用いて、当該情報処理サーバで実施される処理に対応するプログラムを実行することによって実現することが可能である。上記プログラムは、コンピュータが読み取り可能な記録媒体（可搬メモリ等）に記録して、保存したり、配布したりすることが可能である。また、上記プログラムをインターネットや電子メール等、ネットワークを通して提供することも可能である。
【００２６】
図２は、本実施の形態における上記コンピュータのハードウェア構成例を示す図である。図２のコンピュータは、それぞれバスＢで相互に接続されているドライブ装置１０００、補助記憶装置１００２、メモリ装置１００３、ＣＰＵ１００４、インタフェース装置１００５、表示装置１００６、及び入力装置１００７等を有する。
【００２７】
当該コンピュータでの処理を実現するプログラムは、例えば、ＣＤ−ＲＯＭ又はメモリカード等の記録媒体１００１によって提供される。プログラムを記憶した記録媒体１００１がドライブ装置１０００にセットされると、プログラムが記録媒体１００１からドライブ装置１０００を介して補助記憶装置１００２にインストールされる。但し、プログラムのインストールは必ずしも記録媒体１００１より行う必要はなく、ネットワークを介して他のコンピュータよりダウンロードするようにしてもよい。補助記憶装置１００２は、インストールされたプログラムを格納すると共に、必要なファイルやデータ等を格納する。
【００２８】
メモリ装置１００３は、プログラムの起動指示があった場合に、補助記憶装置１００２からプログラムを読み出して格納する。ＣＰＵ１００４は、メモリ装置１００３に格納されたプログラムに従って、当該情報処理サーバに係る機能を実現する。インタフェース装置１００５は、ネットワークに接続するためのインタフェースとして用いられる。表示装置１００６はプログラムによるＧＵＩ（Ｇｒａｐｈｉｃａｌ  Ｕｓｅｒ  Ｉｎｔｅｒｆａｃｅ）等を表示する。入力装置１００７はキーボード及びマウス、ボタン、又はタッチパネル等で構成され、様々な操作指示を入力させるために用いられる。
【００２９】
（システムの動作例）
以下、図１に示したシステムの動作例を図３のフローチャートの手順に沿って説明する。
【００３０】
Ｓ１０１において、振り分け部１０に処理対象データが到着する。本実施の形態では、データストリームの処理を想定しているため、振り分け部１０には処理対象データが順次到着する。
【００３１】
Ｓ１０２において、振り分け部１０は、判断部５０からの振り分け情報に基づいて、到着した処理対象データを代理送受信部２０に振り分ける。処理対象データには、送信時に、代理送受信部２０への送信時刻を示すタイムスタンプが付される。
【００３２】
例えば、ある時間間隔の各ステップで振り分けを行うことを考え、あるステップで、振り分け部１０から経路Ａで接続される代理送受信部２０Ａに対する割り当て数がＳ個であるとすると、そのステップで到着した処理対象データのうちのＳ個が代理送受信部２０Ａに送信される。
【００３３】
Ｓ１０３において、代理送受信部２０が処理対象データを受信し、処理対象データを関数処理部３０に渡す。関数処理部３０は、処理対象データの処理を行って、処理の結果得られた値を代理送受信部２０に返す。
【００３４】
Ｓ１０４において、代理送受信部２０は、通信時間と処理時間を算出し、算出して得られた情報を有する情報データを判断部５０に送信するとともに、算出して得られた情報と、元のデータに付されていたタイムスタンプを有する情報データを統合部４０に送信する。なお、代理送受信部２０からは、通信時間と処理時間を判断部５０に送らないこととしてもよい。その場合、判断に必要なデータは全て統合部４０により収集され、統合部４０から判断部５０に送信される。
【００３５】
代理送受信部２０は、例えば、下記の式１で、データｉに関する経路ｋの通信時間（往路通信時間：Ｔｋ，ｉｏｕｔ）を算出する。ｉは例えばデータに付されたシーケンス番号である。
【００３６】
Ｔｋ，ｉｏｕｔ＝代理送受信部２０に到着した時刻−タイムスタンプ      ・・・式１
また、代理送受信部２０は、例えば、下記の式２で、データｉに関する経路ｋの処理時間：Ｔｋ，ｉｐｒｏｃを算出する。
【００３７】
Ｔｋ，ｉｐｒｏｃ＝代理送受信部２０が関数処理部３０から値を受け取った時刻−代理送受信部２０が関数処理部３０に処理対象データｉを渡した時刻      ・・・式２
Ｓ１０５において、統合部４０は、代理送受信部２０から受信した情報データと、当該情報データの到着時刻とをもとに通信時間を算出し、算出した情報を含む情報データを判断部５０に送信する。
【００３８】
統合部４０は、例えば、下記の式３で、データｉに関する経路ｋの通信時間（復路通信時間：Ｔｋ，ｉｉｎ）を算出する。
【００３９】
Ｔｋ，ｉｉｎ＝統合部４０に到着した時刻−タイムスタンプ−往路通信時間−処理時間・・・式３
なお、この例では、振り分け部１０と統合部４０が同じ情報処理サーバに存在することを想定しているので、振り分け部１０から代理送受信部２０へのデータ送信が経路ｋの往路に相当し、代理送受信部２０から統合部４０へのデータ送信が経路ｋの復路に相当する。
【００４０】
Ｓ１０６において、判断部５０は、代理送受信部２０から受信する情報データ、統合部４０から受信する情報データ、及び監視部６０から受信するリソースの利用情報とに基づいて、振り分けの判断を行う。振り分けのための計算例を以下に説明する。
【００４１】
ここでは、処理対象データが時間間隔Ｉで振り分け部１０に入力されるものとし、１ステップでの処理対象データの数がＮであるとする。
【００４２】
判断部５０は、ステップｎ＋１における経路ｋへの処理対象データ数（ジョブ数と呼んでもよい）を、以下に説明するＴｋｐｒｏｃ（ｎ）、Ｔｋｏｕｔ（ｎ）、Ｔｋｉｎ（ｎ）、Ｊｋ（ｎ）、Ｃｋ（ｎ）を算出することで算出する。以下、それぞれを説明する。
【００４３】
Ｊｋ（ｎ）は、ステップｎにおける経路ｋへの処理対象データの振り分け数である。
【００４４】
Ｔｋｐｒｏｃ（ｎ）は、ステップｎにおいて計測された処理時間の特徴量である。これは、例えば、１／ＮΣｎＮ≦ｉ＜（ｎ＋１）ＮＴｋ，ｉｐｒｏｃにより算出される。この式は、経路ｋでの１処理対象データの処理時間のＮ個での平均を示す。
【００４５】
Ｔｋｉｎ／ｏｕｔ（ｎ）は、ステップｎにおいて計測された往路（ｏｕｔ）または復路（ｉｎ）の通信時間の特徴量である。これは、例えば、１／ＮΣｎＮ≦ｉ＜（ｎ＋１）ＮＴｋ，ｉｉｎ／ｏｕｔにより算出される。この式は、経路ｋでの１処理対象データの通信時間のＮ個の平均を示す。
【００４６】
Ｃｋ（ｎ）は、ステップｎにおいて計測された経路ｋに関するリソースの特徴量であり、例えば、経路ｋで利用可能な通信帯域である。
【００４７】
判断部５０は、ステップｎ＋１における経路ｋへの処理対象データの振り分け数であるＪｋ（ｎ＋１）を下記の式４により算出する。
【００４８】
Ｊｋ（ｎ＋１）＝ｍｉｎ（ｆ（Ｔｋｐｒｏｃ（ｎ）），ｇ（Ｔｋｏｕｔ（１），…，Ｔｋｏｕｔ（ｎ），Ｔｋｉｎ（１），…，Ｔｋｉｎ（ｎ），Ｃｋ（１），…，Ｃｋ（ｎ）））    ・・・式４
式４に示すように、Ｊｋ（ｎ＋１）は、ｆ（Ｔｋｐｒｏｃ（ｎ））とｇ（Ｔｋｏｕｔ（１），…，Ｔｋｏｕｔ（ｎ），Ｔｋｉｎ（１），…，Ｔｋｉｎ（ｎ），Ｃｋ（１），…，Ｃｋ（ｎ））のうちの小さいほうである。
【００４９】
ここで、ｆ（Ｔｋｐｒｏｃ（ｎ））は、ステップｎ＋１において経路ｋで処理可能な処理対象データの数である。ｆ（Ｔｋｐｒｏｃ（ｎ））は、ステップｎにおける経路ｋの処理時間の特徴量から算出されるものであり、例えば、ＮＩ（Ｔｋｐｒｏｃ（ｎ））−１により算出される。この式は、１処理対象データの処理時間（平均値）で１ステップの時間長ＮＩを割った値であり、これにより、１ステップ当たりの処理対象データの処理数が算出される。
【００５０】
ｇ（Ｔｋｏｕｔ（１），…，Ｔｋｏｕｔ（ｎ），Ｔｋｉｎ（１），…，Ｔｋｉｎ（ｎ），Ｃｋ（１），…，Ｃｋ（ｎ））は、過去のステップの通信時間、通信帯域等の情報をもとに、ステップｎ＋１で経路ｋにおいて通信可能な処理対象データの数を算出することを意味している。例えば、通信可能な処理対象データの数を線形回帰によって近似して推定値を算出する。
【００５１】
例えば、経路ｋにおいて、処理可能な処理対象データの数が１００と算出され、通信可能な処理対象データの数が８０と算出された場合、経路ｋでのステップｎ＋１の処理対象データの振り分け数は８０になる。
【００５２】
以上より、Ｓ１０６において、各経路での振り分け数（割当数）が算出され、その情報が振り分け部１０に通知される。
【００５３】
（実施例１）
図４は、実施例１を示す。実施例１は、複数のエッジ拠点と大規模な計算資源を有する少数の中央拠点から成るある単一管理者のネットワークの実施例である。
【００５４】
図４に示すように、実施例１では、エッジ拠点Ａ、エッジ拠点Ｂ、エッジ拠点Ｃのそれぞれに情報処理サーバ１００が備えられ、各サーバには図示のとおりの機能部が備えられる。
【００５５】
図４に示すように、エッジ拠点Ａの情報処理サーバ１００には、振り分け部１０、統合部４０、判断部５０が含まれる。そのため、エッジ拠点Ａの情報処理サーバ１００は、情報発生源デバイス３００から処理対象のデータを受信し、それを他の拠点の情報処理サーバ１００に振り分け、当該他の拠点の情報処理サーバ１００から処理後のデータを受信し、前述した振り分け判断を実行する。また、エッジ拠点Ｃはオフロードを受け付けないエッジ拠点であるため、他のエッジ拠点からのオフロードのデータを受信しないことが示されている。
【００５６】
（実施例２）
図５は、実施例２を示す。実施例２は、複数のネットワークが繋がり、それぞれのネットワーク上にある計算資源を利用する実施例である。実施例２において、他の管理者が有しているネットワークでは、通信リソースの情報を取得できない場合があるので、代理送受信部２０で計測した通信時間を収集し、振り分け判断に利用している。
【００５７】
図５に示すように、実施例２では、ネットワークＡ、ネットワークＢ、ネットワークＣが存在し、それぞれに情報処理サーバ１００が備えられ、各サーバには図示のとおりの機能部が備えられる。
【００５８】
図５に示すように、ネットワークＡの情報処理サーバ１００には、振り分け部１０、統合部４０、判断部５０が含まれる。そのため、ネットワークＡの情報処理サーバ１００は、情報発生源デバイス３００から処理対象のデータを受信し、それを他のネットワークの情報処理サーバ１００に振り分け、当該他のネットワークの情報処理サーバ１００から処理後のデータを受信し、前述した振り分け判断を実行する。また、資源監視サーバ２００は、ネットワークＢ、ネットワークＣのリソース情報を収集できないので、ネットワークＡの情報処理サーバ１００は、ネットワークＢ、ネットワークＣのリソース情報を使用せずに振り分け判断を実行する。
【００５９】
（実施の形態の効果）
以上、説明したように、本実施の形態では、ストリームのデータに付与されたタイムスタンプ／シーケンス番号をもとにインチャネルで計測した通信時間及び処理時間と、キャリアが持つ広域ネットワークの通信リソースの情報をもとにストリーム処理のジョブスケジューリングを行うこととしたので、広域ネットワーク上に分散された計算資源に対して適切にジョブの割り当てが可能となり、効率的な計算資源の利用を実現することができる。
【００６０】
（実施の形態のまとめ）
本明細書には少なくとも下記の各項の分散システム、データ振り分け方法、プログラムが記載されている。
（第１項）
ネットワークにおいてデータに対する処理を複数の計算資源を用いて行う分散システムであって、
複数のデータ処理手段にデータを振り分ける振り分け手段と、
各データ処理手段におけるデータ処理時間、及び、前記振り分け手段と各データ処理手段との間の通信時間を収集し、収集したデータ処理時間及び通信時間に基づいて、各データ処理手段へのデータの振り分けを決定し、決定した振り分けの情報を前記振り分け手段に通知する判断手段と
を備える分散システム。
関数処理部３０（あるいは代理送受信部２０＋関数処理部３０）はデータ処理手段の例であり、振り分け部１０は振り分け手段の例であり、判断部５０は判断手段の例である
（第２項）
前記振り分け手段からデータを受信し、受信したデータをデータ処理手段に渡すデータ送受信手段を更に備え、
前記データ送受信手段は、前記通信時間、及び前記データ処理時間を算出する
第１項に記載の分散システム。
（第３項）
ネットワークのリソースの利用情報を取得する監視手段を更に備え、
前記判断手段は、前記データ処理時間及び前記通信時間に加えて、前記監視手段により取得したリソースの利用情報を用いて前記振り分けを決定する
第１項又は第２項に記載の分散システム。
（第４項）
前記判断手段は、
あるデータ処理手段で処理可能なデータの数と、当該データ処理手段に対して通信可能なデータの数のうち、小さいほうの数を、当該データ処理手段への振り分けデータ数として決定する
第１項ないし第３項のうちいずれか１項に記載の分散システム。
（第５項）
ネットワークにおいてデータに対する処理を複数の計算資源を用いて行う分散システムが実行するデータ振り分け方法であって、
前記分散システムは、複数のデータ処理手段にデータを振り分ける振り分け手段を備えており、
各データ処理手段におけるデータ処理時間、及び、前記振り分け手段と各データ処理手段との間の通信時間を収集するステップと、
収集したデータ処理時間及び通信時間に基づいて、各データ処理手段へのデータの振り分けを決定し、決定した振り分けの情報を前記振り分け手段に通知するステップと
を備えるデータ振り分け方法。
（第６項）
コンピュータを、第１項ないし第４項のうちいずれか１項に記載の分散システムにおける判断手段として機能させるためのプログラム。
【００６１】
以上、本実施の形態について説明したが、本発明はかかる特定の実施形態に限定されるものではなく、特許請求の範囲に記載された本発明の要旨の範囲内において、種々の変形・変更が可能である。
【符号の説明】
【００６２】
１０  振り分け部
２０Ａ〜２０Ｃ  代理送受信部
３０Ａ〜３０Ｃ  関数処理部
４０  統合部
５０  判断部
６０  監視部
１００  情報処理サーバ
２００  資源監視サーバ
３００  情報発生源デバイス
１０００  ドライブ装置
１００２  補助記憶装置
１００３  メモリ装置
１００４  ＣＰＵ
１００５  インタフェース装置
１００６  表示装置
１００７  入力装置
【図１】
2020135548.tif 000003
【図２】
2020135548.tif 000004
【図３】
2020135548.tif 000005
【図４】
2020135548.tif 000006
【図５】
2020135548.tif 000007