JPH11265359A - 分散処理システム及び分散処理プログラムを記録したコンピュータ読み取り可能な記録媒体 - Google Patents

Abstract

(57)【要約】 【課題】 複数の計算機に格納された情報を統一して管
理できるようにする。 【解決手段】 管理簿保持手段２は、管理簿２ａを保持
している。管理簿２ａには、解析処理に必要となる情報
をシステム内で一意に識別するための情報名と、各情報
の実際の格納先との対応関係が登録されている。解析処
理実行手段３は、情報名によって必要な情報を特定した
解析処理要求を受け取ると、まず作業領域４を生成す
る。そして、管理簿保持手段２内の管理簿２ａにより必
要な情報の実際の格納先を認識し、実際の情報へのアク
セスを可能とするリンク情報４ａ，４ｂを作業領域４内
に登録する。そして、作業領域４内のリンク情報を介し
て実際の情報にアクセスすることで、解析処理を実行す
る。この際、解析処理の途中で生成される中間データ４
ｃは、作業領域４内に保存する。

Description

【発明の詳細な説明】

【０００１】

【発明の属する技術分野】本発明は分散処理システム及
び分散処理プログラムを記録したコンピュータ読み取り
可能な記録媒体に関し、特にデータを複数の計算機で分
散して解析する分散処理システム及び分散処理プログラ
ムを記録したコンピュータ読み取り可能な記録媒体に関
する。

【０００２】

【従来の技術】科学技術分野などでは、大量のデータに
対し、様々な構成処理及び解析処理を行い、研究を推進
している。多くの研究機関では、計算機センター内に多
くの計算機を有し、高速なネットワークで接続された分
散システム環境を構築している。

【０００３】このような研究機関の研究者は、解析処理
を実行する場合、解析処理の手順を決め、入力するデー
タ名、出力データ名、処理エンジン（処理プログラム）
名を指示する。従来、このデータ名、処理エンジン名、
解析処理手順名は、ファイルシステム上のフルパス等に
より指定し、処理を実行していた。

【０００４】

【発明が解決しようとする課題】しかし、この場合、各
計算機のシステム構成が同じであるとは限らないため、
計算機毎にデータ名等の指定を変更する必要があった。
そのため、分散システム環境内の可搬性が保証されてい
なかった。すなわち、ある計算機で行った解析処理手順
データを用いて、他の計算機で解析処理を実行しように
も、入力すべきデータの指定等を変更しなければ解析処
理を実行できなかった。

【０００５】分散システム環境内の可搬性が保証されて
いないと、処理エンジンが存在しない場合や磁気ディス
ク装置のデータ領域が不足した場合に、利用可能な計算
機にデータ及び解析処理の手順を転送し、継続して実行
することが困難となる。

【０００６】また、各研究者が個別にデータ管理を行っ
ていため、分散システム環境内で同じデータを一意に認
識することができず、不要なデータ転送が発生してい
た。その結果、１台の計算機内に同一のデータ複製が複
数存在し、計算機リソースを無駄にしていた。

【０００７】更に、研究者は入力する画像データ、処理
途中の中間データ、解析結果データ及び解析処理の手順
などを個人の環境若しくは計算機の一時領域に配置し
て、利用及び管理を行っている。そのため、研究者の各
種情報は、システム内に分散してしまい、管理が困難と
なる場合がある。また、同じような情報が存在すること
により、混乱が発生し、不要な中間データなどを消すこ
とができず、計算機リソースを無駄に消費する場合が多
かった。

【０００８】本発明はこのような点に鑑みてなされたも
のであり、複数の計算機に格納された情報を、システム
内で統一して管理できる分散処理システムを提供するこ
とを目的とする。

【０００９】また、本発明の他の目的は、複数の計算機
に格納された情報を、コンピュータシステム内で統一し
て管理させるための分散処理プログラムを記録したコン
ピュータ読み取り可能な記録媒体を提供することであ
る。

【００１０】

【課題を解決するための手段】図１は、本発明の原理構
成図である。本発明では上記課題を解決するために、デ
ータを複数の計算機１で分散して解析する分散処理シス
テムにおいて、解析処理に必要となる情報をシステム内
で一意に識別するための情報名と、各情報の実際の格納
先との対応関係が登録された管理簿２ａを保持する管理
簿保持手段２と、前記情報名によって必要な情報を特定
した解析処理要求を受け取ると、前記管理簿保持手段２
内の前記管理簿２ａにより必要な情報の実際の格納先を
認識し、解析処理要求に応じた処理を実行する解析処理
実行手段３と、を有することを特徴とする分散処理シス
テムが提供される。

【００１１】このような分散処理システムによれば、解
析処理実行手段３に対して、解析処理に必要となる情報
をシステム内で一意に識別するための情報名により必要
な情報を特定した解析処理要求を入力すれば、実際の情
報がどの計算機に格納されているかを考えずに、解析処
理を行うことができる。

【００１２】また、本発明は上記課題を解決するため
に、データを複数の計算機で分散して解析する分散処理
プログラムを記録したコンピュータ読み取り可能な記録
媒体において、解析処理に必要となる情報をシステム内
で一意に識別するための情報名と、各情報の実際の格納
先との対応関係が登録された管理簿を保持する管理簿保
持手段、前記情報名によって必要な情報を特定した解析
処理要求を受け取ると、前記管理簿保持手段内の前記管
理簿により必要な情報の実際の格納先を認識し、解析処
理要求に応じた処理を実行する解析処理実行手段、とし
てコンピュータを機能させることを特徴とする分散処理
プログラムを記録したコンピュータ読み取り可能な記録
媒体が提供される。

【００１３】この記録媒体に格納された分散処理プログ
ラムをコンピュータに実行させれば、上記本発明の分散
処理システムの機能がコンピュータ上に構築される。

【００１４】

【発明の実施の形態】以下、本発明の実施の形態を図面
を参照して説明する。図１は、本発明の原理構成図であ
る。データを解析処理するための複数の計算機１が設け
られている。各計算機１には、複数の処理プログラム１
ａと複数のデータ１ｂとが格納されている。

【００１５】管理簿保持手段２は、管理簿２ａを保持し
ている。管理簿２ａには、解析処理に必要となる情報
（データ、解析処理手順データ、及び処理プログラム）
をシステム内で一意に識別するための情報名と、各情報
の実際の格納先（格納計算機名）との対応関係が登録さ
れている。

【００１６】解析処理実行手段３は、情報名によって必
要な情報を特定した解析処理要求を受け取ると、まず作
業領域４を生成する。そして、管理簿保持手段２内の管
理簿２ａにより必要な情報の実際の格納先を認識し、実
際の情報へのアクセスを可能とするリンク情報４ａ，４
ｂを作業領域４内に登録する。このリンク情報４ａ，４
ｂは、虚像であり実際の情報の内容は作業領域内には存
在していない。そして、作業領域４内のリンク情報を介
して実際の情報にアクセスすることで、解析処理を実行
する。この際、解析処理の途中で生成される中間データ
４ｃは、作業領域４内に保存する。

【００１７】このような分散処理システムによれば、各
情報に対して、システム内で一意に識別可能な情報名が
付与されているため、その情報名を指定した解析処理要
求を入力すれば、解析処理実行手段３が目的の解析処理
を実行する。そのため、利用者は、実際の情報がどの計
算機に格納されているのかを意識する必要がない。従っ
て、どの計算機で解析処理を実行する場合にも、解析処
理要求の内容は同じでである。

【００１８】しかも、解析処理実行手段３は、解析処理
を実行するための作業領域４を生成し、解析処理に関係
する情報の管理を作業領域４内だけで行うため、実行し
た解析処理に関する情報と他の情報とが混じり合うこと
がない。そのため、実行した解析処理の情報が不要にな
れば、作業領域ごと削除すればよい。

【００１９】以下に、本発明を天体観測システムに適用
した場合を例にとり、本発明の実施の形態を説明する。
図２は、天体観測システムを示す図である。この例で
は、天体望遠鏡１１が山頂に設置されている。この天体
望遠鏡１１は、ＣＣＤ(Charge Coupled Device)により
星などの天体の画像データを取得する。天体望遠鏡１１
は、ふもとのコンピュータシステム１００に接続されて
いる。そして、天体望遠鏡が観測した天体の画像データ
は、コンピュータシステム１００に送られる。

【００２０】天体望遠鏡１１から送られた画像データ１
１０は、コンピュータシステム１００内に格納される。
画像データ１１０は、処理の対象となる観測データとな
ったり、標準較正データ作成のための生較正データであ
ったりする。

【００２１】解析処理手順エディタ１２０は、端末装置
からの指令に基づいて解析処理指令を実行コントローラ
１７４に出力するとともに、解析処理手順データ１４０
を生成する。解析処理手順データ１４０には、解析処理
を実行した順番やその解析処理に用いた処理エンジン
（処理プログラム）１３０、解析に用いた画像データ１
１０、中間データ１５０、及び解析結果データ１６０に
関する情報が登録されている。

【００２２】処理エンジン１３０は、処理内容毎に設け
られた処理プログラムである。実行コントローラ１７４
は、解析処理手順エディタ１２０からの指示により、必
要な入力データと解析処理手順が指定されると、指定さ
れた処理エンジン１３０と画像データ１１０を取得し、
指定された内容の解析処理を実行する。処理の結果、中
間データ１５０や解析結果データ１６０が生成される。

【００２３】図３は、コンピュータシステムの構成を示
す図である。コンピュータシステム１００は、複数の計
算機１０１で構成されている。計算機１０１には、ベク
タープロセッサやスカラープロセッサなどがある。この
計算機１０１には、高速のネットワーク１０３を介して
複数の端末装置１０２が接続されている。端末装置１０
２は、ワークステーションやパーソナルコンピュータで
ある。ユーザは、端末装置１０２を操作することによ
り、天体望遠鏡１１の動作を指令したり、観測データの
解析処理の指示を出すことができる。

【００２４】天体観測システムのような超高速処理を必
要とするシステムでは、数十台のコンピュータで構成さ
れることがほとんどである。そのため、画像データ１１
０、中間データ１５０、処理エンジン１３０などが個別
の計算機に分散される。

【００２５】以下に、解析処理の手順、及びその手順の
内容をデータ化した解析処理手順データの内容について
説明する。なお、以下の説明中の観測データと生較正デ
ータが、前述の画像データ１１０に相当し、何らかの処
理（較正処理や、標準較正データ作成処理）を行った後
の処理済データが前述の中間データ１５０に相当する。

【００２６】図４は、解析処理手順の概念図である。こ
こでは、観測データ１１１に「較正処理Ａ」、「較正処
理Ｂ」、「較正処理Ｃ」の計３回の較正処理を施すこと
により、解析結果データ１６１が得られるものとする。

【００２７】観測データ１１１に較正処理Ａを施すに
は、較正処理Ａ用標準較正データ１５１が用いられる。
較正処理Ａの結果、較正処理Ａ済データ１５２が得られ
る。更に、較正処理Ｂ用標準較正データ１５３を用い
て、較正処理Ａ済データ１５２に較正処理Ｂを施す。そ
の結果、較正処理ＡＢ済データ１５４が得られる。同様
に、較正処理Ｃ用標準較正データ１５５を用いて、較正
処理ＡＢ済データ１５４に較正処理Ｃを施す。その結
果、解析結果データ１６１が得られる。

【００２８】一方、各較正処理用の標準較正データを得
るためにも、所定の解析処理が必要である。較正処理Ａ
用標準較正データ１５１を得るには、複数の生較正デー
タ１１２に対して較正処理Ａ用標準較正データ作成処理
を施す。較正処理Ｂ用標準較正データ１５３を得るに
は、複数のＡ済較正データ１５６に対して較正処理Ｂ用
標準較正データ作成処理を施す。較正処理Ｃ用標準較正
データ１５５を得るには、複数のＡＢ済較正データ１５
７に対して較正処理Ｃ用標準較正データ作成処理を施
す。

【００２９】なお、Ａ済較正データ１５６とＡＢ済較正
データ１５７との作成にも、同様の解析処理が必要であ
る。そのため、一連の解析処理は、３次元空間を用いて
表現する事ができる。

【００３０】図５は、３次元構造テーブルで表現された
解析処理手順を示す図である。この例では、ｘ−ｙ−ｚ
の３次元構造テーブルになっており、ｘ軸に同一種別内
のデータ順を、ｙ軸にデータ種別を、ｚ軸に処理レベル
（段）を取っている。ここで処理レベルとは、較正処理
や、標準較正データ作成処理などの解析処置が行われた
回数である。データ種別では、観測データが１つの種別
であり、また、各較正処理（較正処理Ａや較正処理Ｂな
ど）を行うために用いられるデータ群（生較正データや
標準較正データなど）が１つの種別である。同一種別内
のデータ順は、各処理レベルにおける各データ種別ごと
のデータを一列に並べた場合の各データの順番である。

【００３１】このような多次元構造テーブル上に全ての
データを配置させることにより、解析処理手順データ内
で、各種データの関係が把握される。ところが、解析処
理に必要なデータや処理エンジンが、複数の計算機に分
散して格納されていると、従来技術で説明したような問
題が生じる。

【００３２】ここで、情報が分散されることによる従来
技術の問題点を考察する。従来は、各計算機に格納され
たデータは、それぞれの計算機のノード名、ファイルパ
ス、及びファイル名により特定されていた。そのため、
同じファイルパス、及びファイル名のデータが複数の計
算機に個別に存在することが許されていた。また、デー
タを保存する際に、ファイルパスやファイル名などを研
究者が個別に考えていたため、統一されたデータ管理が
難しくなっていた。

【００３３】従って、データを格納している計算機の情
報を含まない情報でアクセスできるようにすることで、
従来技術の問題点を解決をできる。ただし、分散システ
ム環境で一意に認識できるデータ名称と、その名称と実
体との対応付けを行う枠組みが必要となる。

【００３４】そこで、分散システム環境で一意に認識で
いるデータ名称として、処理に関連する情報の命名定義
を定める。本実施の形態では、各データ及び処理エンジ
ンが分散システム内でユニークとなるように、以下のよ
うな命名規則を定義する。

【００３５】解析処理結果データ（解析処理手順の頂
点）は、「******.usr.grp」で表す。ここで、「*****
*」は、利用者が自由に設定可能な名称である。これ
は、利用者毎にユニークであればよい（以下同様）。
「usr 」は、そのデータを作成した利用者のユーザ名を
表し、「grp 」は、そのデータを作成した利用者の属す
るグループ名を表す（以下、同様）。

【００３６】解析処理手順名は、「******.usr.grp.cub
e 」で表す。中間データ（解析処理手順内の中間デー
タ）は、「******.usr.grp.x-y-z」で表す。ここで、
「x-y-z」は、解析処理手順を３次元空間で表現した際
の中間データの座標である。

【００３７】処理エンジン名は、「******.usr.grp.eng
ine.version 」。ここで、「engine」は、エンジン名を
示し、「version 」は、そのプログラムの版数を示す。
画像データ名は、「フレームＩＤ.grp.grp」で表す。
「フレームＩＤ」は、天体望遠鏡１１で観測された各画
像に付けられた識別子である。

【００３８】「キャッシュデータ名」は、キャッシュ元
のデータ名と同じ名前を使用する。なお、キャッシュデ
ータは、作業領域を作成した計算機上でデータが存在し
ない場合に、処理を実行する計算機へ転送されたデータ
である。このキャッシュデータは、一定の期間保持さ
れ、その後削除される。このキャッシュデータは、実行
制御部で管理され、各利用者が利用できる。このよう
に、キャッシュデータを共用可能とすることにより、ネ
ットワーク上のデータ転送が少なくなる。

【００３９】以上のような命名規則を設けることで、複
数の計算機にデータが分散していても、それらのデータ
を一意に識別することができる。なお、解析処理手順エ
ディタ１２０（図２に示す）により作成される解析処理
手順データの内容も、上記命名規則に従った名前で各種
データが特定される。

【００４０】以下に、解析処理手順データの内容につい
て説明する。図６、図７は、解析処理手順データの例を
示す図である。解析処理手順データには、まず解析処理
手順データ自身の情報が登録されている。

【００４１】「name」は、解析処理手順データの名称を
指名している。この名称は、分散システムで一意に識別
可能な名称である。「status」は、解析処理手順の状態
を示している。「DSave 」は保存されていることを示
し、「DEdit 」は更新若しくは新規作成の状態を示し、
「DExec 」は解析処理を実行中であることを示してい
る。

【００４２】「owner 」は、解析処理手順データの所有
者名を示している。「group 」は、解析処理手順データ
の所有者が属するグループ名を示している。

【００４３】「create＿date」は、作成日時を示してい
る。「permission」は、所有者、グループのメンバ、全
ユーザのそれぞれに対する操作の権限を示している。権
限は「−」、「ｒ」、「ｗ」、「ｘ」の４文字のいずれ
かの文字を９文字並べることで指定している。９つの文
字は、左から順番に以下のような意味を有している。

【００４４】１番目の文字は、所有者に対する参照権限
の有無を示しており、ここが「ｒ」であれば参照権限が
有り、「−」であれば参照権限がない。２番目の文字
は、所有者に対する書き込み権限の有無を示しており、
ここが「ｗ」であれば書き込み権限が有り、「−」であ
れば書き込み権限がない。

【００４５】３番目の文字は、所有者に対する実行権限
の有無を示しており、ここが「ｘ」であれば実行権限が
有り、「−」であれば実行権限がない。４番目の文字
は、グループのメンバに対する参照権限の有無を示して
おり、ここが「ｒ」であれば参照権限が有り、「−」で
あれば参照権限がない。

【００４６】５番目の文字は、グループのメンバに対す
る書き込み権限の有無を示しており、ここが「ｗ」であ
れば書き込み権限が有り、「−」であれば書き込み権限
がない。

【００４７】６番目の文字は、グループのメンバに対す
る実行権限の有無を示しており、ここが「ｘ」であれば
実行権限が有り、「−」であれば実行権限がない。７番
目の文字は、全ユーザに対する参照権限の有無を示して
おり、ここが「ｒ」であれば参照権限が有り、「−」で
あれば参照権限がない。

【００４８】８番目の文字は、全ユーザに対する書き込
み権限の有無を示しており、ここが「ｗ」であれば書き
込み権限が有り、「−」であれば書き込み権限がない。
９番目の文字は、全ユーザに対する実行権限の有無を示
しており、ここが「ｘ」であれば実行権限が有り、
「−」であれば実行権限がない。

【００４９】図の例では、解析処理手順データの所有者
である「ｄａｓｈ１」に対しては、参照、書き込み、及
び実行の権限が与えられているが、その以外の者に対し
ては如何なる権限も与えられていない。

【００５０】「abstract」は、解析処理の概要を示して
いる。「obe 」は、観測装置名を示している。「filte
r」は、観測にあたって使用したフィルタ名を示してい
る。

【００５１】「flame 」は、解析処理後に作成されるデ
ータの種別を示している。「current ＿step」は、現在
の解析処理の段を示している。解析処理の段は、解析処
理に必要なデータを管理する３次元テーブルの高さ方向
の単位である。なにも処理していないデータの段を
「０」として、１つめの処理エンジンで処理された結果
として得られるデータの段を１と数える。また、現在の
段数は、その解析処理手順の処理が済んだ段が示されて
いる。

【００５２】「row ＿num 」は、解析処理で使用するデ
ータの種別数を示している。「irow＿ind 」は、データ
の種別のインデックス番号を示している。「step＿num
」 は、解析処理手順の段数を示している。

【００５３】「engine＿num 」は、解析処理の処理プロ
グラム数を示してる。「imagedata ＿name」は、解析処
理の結果作成されるデータ名を示している。「engine＿
name0 」は、１つめの処理エンジン名とその引数を示し
ている。

【００５４】「engine＿attr0 」は、１つめの処理エン
ジンの種別とその入力ファイル数、出力ファイル数を示
している。プログラムの種別には、「Create」と「Appl
y 」とがある。「Create」は、複数（１以上の自然数）
の入力データから複数（１以上の自然数）のデータを作
成するものである。「Apply 」は、１つのデータに対し
複数（１以上の自然数）のデータを作用させ、１つのデ
ータを作成するものである。

【００５５】入出力データ数は次の定義に従う。入力デ
ータ数は１以上の自然数であるが、Ｎとした場合には、
入力データ数は不定となる。同様に、出力データ数は１
以上の自然数であるが、Ｎとした場合には、入力データ
数は不定となる。

【００５６】「engine＿name1 」は、２つめの処理エン
ジン名とその引数を示している。「engine＿attr1 」
は、２つめの処理エンジンの種別とその入力ファイル
数、出力ファイル数を示している。

【００５７】「engine＿name2 」は、３つめの処理エン
ジン名とその引数を示している。「engine＿attr2 」
は、３つめの処理エンジンの種別とその入力ファイル
数、出力ファイル数を示している。

【００５８】「engine＿name3 」は、４つめの処理エン
ジン名とその引数を示している。「engine＿attr3 」
は、４つめの処理エンジンの種別とその入力ファイル
数、出力ファイル数を示している。

【００５９】以下同様に、処理エンジンに関する情報が
登録されている。「data flag 」以降は、処理エンジン
の入出力を指示するためのフラグである。このフラグ
は、各々のデータの該当する処理プログラムの入力を制
御するフラグであり、「０」、「１」、「２」の数字が
設定される。各数字の意味は次の通りである。「０」
は、入力でないことを意味する。「１」は、入力データ
であることを示す。「２」は、「 Apply 」の場合に、同
時に入力される他の「１」のフラグのついたデータに対
して作用させるデータである。

【００６０】「data name 」以降は、本処理で使用され
るデータの名前を示している。これらのファイル名で指
定されるファイルとフラグにより処理プログラムの実行
の際の入出力ファイルが決定する。なお、ここで指定し
ているデータの名前は、分散システムにおいて一意に識
別可能な名前である。

【００６１】「cube log」以降は、処理エンジンのロギ
ング情報を示している。このような解析処理手順データ
を用いて解析処理を実行するための分散処理システムに
ついて、以下に具体的に説明する。

【００６２】図８は、分散処理システムの機能を示すブ
ロック図である。ＧＵＩ(graphicalUser Interface)コ
ントローラ１７１は、各端末装置１０２（図３に示す）
に設けられており、利用者に対する各種操作画面の表示
と、利用者からの入力の受付とを行うための機能を有し
ている。利用者は、この機能を用いて解析処理手順エデ
ィタ１２０を起動し、解析処理手順データを作成すると
ともに、その実行依頼を実行コントローラ１７４へ送
る。

【００６３】管理簿サーバ１７２は、解析処理に必要な
データがどの倉庫サーバ１８１〜１８３に格納されてい
るのかを管理簿テーブル１７２ａにより管理している。
管理簿テーブル１７２ａは、解析処理手順データを管理
する解析処理手順管理テーブル、処理エンジンを管理す
る処理エンジンテーブル、及び入力データ（画像デー
タ、中間データ）を管理する入力データテーブルからな
る。

【００６４】図９は、解析処理手順管理テーブルの例を
示す図である。解析処理手順管理テーブル１７２ａａに
は、以下の項目が設けられ、倉庫サーバ１８１〜１８３
に登録されている全ての解析処理手順データに関する情
報が登録されている。

【００６５】「name」、「abstract」、「owner 」、
「group 」、「create＿date」、「imagedata ＿nam
e」、「obe 」、「frame 」、及び「permission」は、
解析処理手順データの説明に示した通りである。

【００６６】「warehousename 」は、その解析処理手順
データが実際に格納されている倉庫サーバ名を示してい
る。「datatype」は、そのデータの種別を示しており、
このテーブル内では、全て解析処理手順データであるこ
とを示す名称「PROCEDURE 」が登録されている。

【００６７】図１０は、処理エンジン管理テーブルの例
を示す図である。処理エンジン管理テーブル１７２ａｂ
には、以下の項目が設けられ、倉庫サーバ１８１〜１８
３に格納されている全ての処理エンジンに関する情報が
登録されている。

【００６８】「name」「abstract」、「owner 」、「gr
oup 」、「create＿date」、「permission」、「wareho
usename 」、及び「datatype」については、解析処理手
順管理テーブル１７２ａａと同じ内容である。ただし、
「datatype」には、処理エンジンであることを示す名称
「ＥＮＧＩＮＥ」が登録されている。

【００６９】「arg 」は、処理エンジンを実行する際に
指定する引数を示している。 図１１は、入力データ管
理テーブルの例を示す図である。入力データ管理テーブ
ル１７２ａｃには、以下の項目が設けられ、倉庫サーバ
１８１〜１８３に格納されている全ての入力データに関
する情報が登録されている。

【００７０】「name」、「abstract」、「frame 」、
「owner 」、「group 」、「create＿date」、「permis
sion」、「warehousename 」、及び「datatype」につい
ては、解析処理手順管理テーブル１７２ａａと同じ内容
である。ただし、「datatype」には、入力データである
ことを示す名称「ＩＭＡＧＥＤＡＴＡ」が登録されてい
る。「procube ＿name」は、そのデータの解析に用いら
れた解析処理手順データ名を示している。

【００７１】以上のような管理簿テーブル１７２ａを用
いることで、「name」と「warehousename 」との対応付
けにより、管理簿サーバ１７２は、実行コントローラ１
７４から解析処理手順データの所在確認要求を受けた際
に、該当するデータを格納している倉庫サーバ名を応答
することができる。

【００７２】図８に戻り、キャッシュ管理簿サーバ１７
３は、キャッシュデータがどの倉庫サーバ１８１〜１８
３に格納されているのかをキャッシュ管理簿テーブル１
７３ａで管理している。

【００７３】図１２は、キャッシュ管理簿テーブルの例
を示す図である。キャッシュ管理簿テーブル１７３ａに
は、「name」、「Create＿date」、及び「Warehousenam
e 」の項目が設けられており、各倉庫サーバ１８１〜１
８３がキャッシュデータとして保持しているデータの情
報が登録されている。

【００７４】「name」は、キャッシュされたデータの名
前である。この名前は、元のデータの名前（分散システ
ムで一意に識別する名前）と同じである。「Create＿da
te」は、キャッシュデータが生成された日付である。

【００７５】「Warehousename 」は、キャッシュデータ
を保持している倉庫サーバの名称である。図８に戻り、
実行コントローラ１７４は、解析処理の実行要求ととも
に解析処理手順データ名が入力されると、その解析処理
の実行環境を構築する。実行コントローラ１７４が行う
処理としては、実行を行うべき倉庫サーバの選択と、選
択した倉庫サーバへの処理の依頼等がある。

【００７６】倉庫サーバ１８１〜１８３は、解析処理に
必要な各種データを格納している。倉庫サーバ１８１〜
１８３が格納するデータとしては、登録済データ１８１
ａ，１８２ａ，１８３ａとキャッシュデータ１８１ｂ，
１８２ｂ，１８３ｂとがある。登録済データ１８１ａ，
１８２ａ，１８３ａは、解析処理手順データ、画像デー
タ、中間データ、解析結果データ、及び処理エンジンな
どである。キャッシュデータ１８１ｂ，１８２ｂ，１８
３ｂは、他の倉庫サーバ１８１〜１８３から取得したデ
ータである。

【００７７】また、倉庫サーバ１８１〜１８３には、倉
庫内データ管理テーブル１８１ｃ，１８２ｃ，１８３ｃ
と倉庫状態テーブル１８１ｄ，１８２ｄ，１８３ｄとが
設けられている。

【００７８】図１３は、倉庫内データ管理テーブルの例
を示す図である。倉庫内データ管理テーブル１８１ｃに
は、「status」、「name」、「abstract」、「owner
」、「group 」、「permission」、「create＿dat
e」、「last＿access＿time」、「cashing ＿time」、
「Path」、「arg 」、「obe 」、及び「frame 」の項目
が設けられており、登録済データ１８１ａとキャッシュ
データ１８１ｂとに関する情報が登録されている。

【００７９】「name」、「abstract」、「owner 」、
「group 」、「permission」、「create＿date」、「ar
g 」、「obe 」、及び「frame 」については前述の通り
である。

【００８０】「status」は、そのデータの種別を示して
いる。処理エンジンであれば「engine」と設定され、画
像データであれば「image 」と設定され、解析処理手順
データであれば「procedure 」と設定される。

【００８１】「last＿access＿time」は、そのデータに
最後にアクセスがあった時刻である。 「cashing ＿ti
me」は、キャッシュデータに関して設定され、そのデー
タがキャッシングされた時刻を示している。

【００８２】「Path」は、そのデータの計算機内での位
置がフルパス（ルートディレクトリからのパス）で示さ
れている。図１４は、倉庫状態テーブルの例を示す図で
ある。倉庫状態テーブル１８１ｄは、「時刻」、「作業
領域容量」、「使用状況」、「CPU 負荷」、及び「ネッ
トワーク負荷」の項目が設けられており、その倉庫サー
バ１８１の稼働状態に関する情報が登録されている。
「時刻」は、その情報を取得した時刻である。「作業領
域容量」は、作業領域として使用可能なハードディスク
装置の空き容量である。「使用状況」は、作業領域内の
使用中の容量を、全体の容量に対する割合で示してい
る。「ＣＰＵ負荷」は、その倉庫サーバ１８１が設けら
れている計算機の負荷を示している。「ネットワーク負
荷」は、その倉庫サーバ１８１が設けられている計算機
が他の計算機とデータ通信を行うときの伝送性能に対す
る負荷を示している。

【００８３】図８に示した各要素は、ＣＯＲＢＡ(Commo
n Object Request Broker Architecture) のような分散
システム環境における共通仕様で互いに情報交換を行っ
ている。また、実行コントローラ１７４から作業領域作
成要求を受け取った倉庫サーバは、自己の管理する領域
内に作業領域を構築し、作業領域サーバ１８３ｅを起動
する。

【００８４】以下、分散処理システムにおける解析処理
の手順を説明する。なお、フローチャートを用いた説明
においては、ステップ番号に沿って説明する。図１５
は、解析処理に必要な機能の構築処理を示すフローチャ
ートである。これは、利用者が、ＧＵＩコントローラ１
７１を用いて実行コントローラ１７４に対して命令を出
すことで、実行コントローラ１７４が実行する処理であ
る。 ［Ｓ１］各計算機に設けられている倉庫サーバ１８１〜
１８３を起動し、各種データを登録する。以後、倉庫サ
ーバ１８１〜１８３は、登録されたデータを管理する。 ［Ｓ２］管理簿サーバ１７２を起動し、全ての倉庫サー
バ１８１〜１８３に格納されている情報を登録する。 ［Ｓ３］キャッシュ管理簿サーバ１７３を起動する。起
動時には、キャッシュデータを０件とする。そして、キ
ャッシュ管理簿サーバ１７３は、全倉庫サーバ１８１〜
１８３にキャッシュデータとして格納されているデータ
の情報を登録し、管理する。

【００８５】このようにして、解析処理の準備ができた
ら、利用者は解析処理を実行する。図１６は、解析処理
の動作イメージを示す図である。この図を参照しなが
ら、以下のフローチャートを説明する。

【００８６】図１７は、解析処理の手順を示すフローチ
ャートである。 ［Ｓ１１］利用者は、解析処理手順エディタを起動し、
解析処理手順を作成する。作成した解析処理手順は、解
析処理手順データとしていずれかの倉庫サーバに格納す
る。 ［Ｓ１２］ＧＵＩコントローラ１７１から実行コントロ
ーラ１７４に、解析処理手順名を指定して、実行を指示
する（図１６のＳ１０１）。 ［Ｓ１３］実行コントローラ１７４は、まず、管理簿サ
ーバ１７２に対して指定された解析処理手順がどの倉庫
サーバに格納されているのかを問い合わせる。そして、
該当する倉庫サーバから解析処理手順を取得する。次
に、取得した解析処理手順の内容を解析し、その解析処
理に必要な入力データと処理エンジンとの所在を管理簿
サーバ１７２に問い合わせる（図１６のＳ１０２）。

【００８７】管理簿サーバ１７２は、入力データと処理
エンジンとが格納されている倉庫サーバを特定するとと
もに、キャッシュ管理簿サーバ１７３へ、入力データと
処理エンジンとの所在を問い合わせる（図１６のＳ１０
３）。キャッシュ管理簿サーバ１７３は、該当するデー
タがいずれかの倉庫サーバにキャッシュされていれば、
データがどの倉庫サーバにキャッシングされているのか
の情報を応答する。このとき、複数の倉庫サーバにキャ
ッシュされていれば、複数の倉庫サーバの情報を応答す
ることになる。

【００８８】管理簿サーバ１７２は、キャッシュ管理簿
サーバ１７３からの応答を、自身が特定した倉庫サーバ
の情報に追加し、実行コントローラ１７４に返す。 ［Ｓ１４］実行コントローラ１７４は、実行先倉庫を決
定する。この処理の詳細は後述する。ここでは、処理に
必要な解析手順データ１４１、処理エンジン１３１，及
び画像データ１１１が格納されている倉庫サーバ１８３
に決定したものとする。 ［Ｓ１５］実行コントローラ１７４は、ステップＳ１４
において決定した倉庫サーバ１８３に、解析処理手順を
実行するための作業領域の作成を依頼する（図１６のＳ
１０４）。このとき、各入力データの所在情報も同時に
送付する。 ［Ｓ１６］作業領域作成依頼を受け取った倉庫サーバ
は、作業領域を作成可能か否かを判断する。作業領域を
作成可能であればステップＳ１７に進み、作業領域を作
成できなければステップＳ１４に進む。 ［Ｓ１７］倉庫サーバ１８３は、解析処理手順に対応す
る作業領域として、ディレクトリを作成する。以後、倉
庫サーバ１８３が、そのディレクトリの名称とパス名管
理する。また、作成したディレクトリを利用して処理を
実行する作業領域サーバ１８３ｅを、倉庫サーバ１８３
と同じ計算機内で起動し、初期化する（図１６のＳ１０
５）。 ［Ｓ１８］倉庫サーバ１８３は、作業領域を準備する。
具体的には、まず、倉庫サーバ１８３自身が管理してい
ない入力データ、処理エンジンを、他の倉庫サーバ１８
１，１８２へ要求する（図１６のＳ１０６）。必要であ
れば解析処理手順データも取り寄せる。倉庫サーバ１８
１，１８２は、要求に応じてデータを返す（図１６のＳ
１０７）。

【００８９】次に、取り寄せた入力データを、倉庫サー
バ１８３内でキャッシュデータ１１２として保存・管理
する（図１６のＳ１０８）。また、キャッシュしたデー
タの情報をキャッシュ管理簿サーバ１７３に渡す（図１
６のＳ１０９）。キャッシュ管理簿サーバ１７３は、倉
庫サーバ１８３でキャッシュされたデータ名と倉庫名と
を、キャッシュ管理簿に登録する。

【００９０】更に、倉庫サーバ１８３は、解析処理に必
要な入力データや処理エンジンを、ＵＮＩＸのリンクコ
マンドにより作業領域にリンクする（図１６のＳ１１
０）。リンクするときの名称は、分散システム内で一意
に識別可能な名称である。リンクされたことにより、作
業領域には、処理に必要なデータを指し示すリンク情報
１１１ａ，１１２ａ，１１３ａ，１１４ａが存在するこ
とになる。

【００９１】作業領域が準備できたら、実行コントロー
ラ１７４からの作業領域作成依頼の回答として、作業領
域サーバの情報を返す（図１６のＳ１１１）。 ［Ｓ１９］実行コントローラ１７４は、倉庫サーバ１８
３から応答された作業領域サーバ１８３ｃに対して解析
処理を依頼する（図１６のＳ１１２）。 ［Ｓ２０］作業領域サーバは、作業領域ディレクトリ内
の解析処理手順データ１４１ａを読み込み、そのディレ
クトリ配下の画像データ１１１ａ，１１２ａを使用し、
処理エンジン１３１ａにより解析処理を行い中間データ
１５１を作成する。更に中間データ１５１を読み込み、
処理エンジンにより解析処理を継続する。すべての中間
データは、作業領域ディレクトリに解析処理手順で指定
された名前で作成され、その名称で利用・参照できる。

【００９２】図１８は、実行先倉庫決定処理のフローチ
ャートである。この処理は、全て実行コントローラ１７
４が行う。 ［Ｓ３１］解析処理手順データ１４１を読み込む。 ［Ｓ３２］管理簿サーバ１７２の管理簿テーブル１７２
ａと、キャッシュ管理簿サーバ１７３のキャッシュ管理
簿テーブル１７３ａとを参照し、入力データ及び処理エ
ンジンが存在する倉庫サーバを検索する。 ［Ｓ３３］実行可能な倉庫サーバ１８１〜１８３での入
力データ保存数を求める。 ［Ｓ３４］実行可能な倉庫サーバ１８１〜１８３での処
理エンジンの保持数を求める。 ［Ｓ３５］以下の条件で実行先倉庫サーバの候補の優先
順位を決定する。 ・入力データ数が最も多い。 ・開始段（処理レベルが０のデータに対して処理を行
う）の処理エンジンがある。 ・処理エンジンの連続実行の長さが長い。 これらの条件を満たした倉庫サーバを優先的に選択す
る。 ［Ｓ３６］各倉庫サーバの倉庫状態テーブル１８１ｄ、
１８２ｄ、１８３ｄを参照し、実行先倉庫の優先順位の
高い順に以下の内容を評価し、適合した倉庫サーバを実
行先として特定する。 ・作業ディスク領域の空き容量が十分にあること。 ・ＣＰＵ(Central Processing Unit) の負荷状態を評価
し、処理能力に余裕があること。 ・ネットワークの負荷状態を評価し、伝送能力に余裕が
あること。

【００９３】次に、実行結果の管理処理について説明す
る。図１９は、実行結果の管理処理のフローチャートで
ある。 ［Ｓ４１］処理を実行した後の解析結果データ若しく
は、中間データを参照する。それには、解析処理手順エ
ディタ１２０に解析処理手順データ１４１を取り込み、
解析処理手順エディタ１２０から中間データ１５１を指
定し、作業領域ディレクトリにある中間データ１５１を
参照する。 ［Ｓ４２］必要な中間データを登録する。具体的には、
中間データをポイントし、処理済みデータとして倉庫サ
ーバ内の別領域に移動し、登録する。 ［Ｓ４３］作業領域を削除する。具体的には、倉庫サー
バ１８３に作業領域の削除を指示して、作業領域ディレ
クトリを削除することで、処理の失敗及び登録して不要
となった中間データを全て削除する。

【００９４】以上のように、実体名を意識しない「作業
領域」を１台の計算機上に作成し、作業領域のなかに、
入力データ、処理エンジン、及び解析処理手順データを
ＵＮｌＸコマンド「ｌｉｎｋ」により、作業領域内の名
称でシンボリックリンクした。そのため、作業領域内に
おいて、解析処理手順データ内の名前によりすべての処
理が実行可能となる。

【００９５】また、作成された中間データは、「作業領
域」内のみに存在し、解析処理手順データで指定した名
称で作成されるため、その解析処理内容全体が不要にな
った場合には、その「作業領域」を削除することで、す
べてのテンポラリなデータを削除することができる。こ
のとき、入力データ、処理エンジン、及び解析処理手順
データは、リンクのみの削除であり実体は削除されな
い。

【００９６】更に、作業領域は、基本的に解析処理手順
データと１対１に対応して作成される。そのため、ある
解析処理手順内で不要になったデータは、対応する作業
領域を削除することで、全て削除できる。

【００９７】なお、分散システム内で一意に識別可能な
名称を用いて、各データを検索することもできる。この
データ検索機能は、解析処理手順エディタの機能に含ま
れている。

【００９８】以下に、解析処理手順エディタの操作手順
について説明する。図２０は、解析処理手順エディタの
検索画面を示す図である。検索画面２００の上部にはツ
ールバー２１０が設けられており、各種命令を入力する
ことができる。ツールバー２１０の下には、複数のボタ
ン２２１〜２２５が設けられている。「Ｎｅｗ」と表記
されたボタン２２１が押されると、検索画面２００が初
期化される。「Ｑｕｉｔ」と表記されたボタン２２２が
押されると、検索画面２００が閉じる。「Ｓｔａｒｔ」
と表記されたボタン２２３が押されると、検索処理が開
始される。「Ｒｅｌｏａｄ」と表記されたボタン２２４
が押されると、検索結果表示画面２４０で指定されてい
るデータが読み込まれ、その内容が表示される。「Ｈｅ
ｌｐ」と表記されたボタン２２５が押されると、検索機
能の操作方法の説明書きが表示される。

【００９９】検索キー入力部２３０には、情報の種類別
にキーワードを入力することができる。例えば、「nam
e」、「abstract」などに対して、個別にキーワードを
指定することができる。複数の種類の情報に対してキー
ワードが入力された場合には、それらの全ての条件を満
たしたデータ（論理積）が検索される。

【０１００】検索結果表示部２４０には、検索条件に適
合したデータに関する情報がリストアップされる。この
検索結果表示部２４０に表示されたデータから必要なデ
ータを選択することで、そのデータの情報を検索処理手
順エディタの編集画面へ取り込むことができる。

【０１０１】図２１は、検索処理手順エディタの編集画
面を示す図である。編集画面３００の上部にはツールバ
ー３１０が設けられており、各種命令を入力することが
できる。このツールバー３１０内の「Execute 」のコマ
ンドを指定すると、編集画面３００で編集されている処
理手順に従った処理の実行要求が、実行コントローラ１
７４に出力される。

【０１０２】ツールバー３１０の下には、複数のボタン
３２１〜３２８が設けられている。「Ｎｅｗ」と表記さ
れたボタン３２１が押されると、編集画面３００が初期
化される。「Ｑｕｉｔ」と表記されたボタン３２２が押
されると、編集画面３００が閉じる。「Ｌｏａｄ」と表
記されたボタン３２３が押されると、解析処理手順デー
タ解析処理手順データの内容が、解析処理手順エディタ
がアクセス可能なメモリ内にロードされ、所定のデータ
が編集画面３００内の各種表示部に表示される。「Ｓａ
ｖｅ」と表記されたボタン３２４が押されると、解析処
理手順エディタで編集中のデータがハードディスク装置
などの媒体に保存される。「（，）」と表記されたボタ
ン３２５が押されると、その時選択されているデータ
が、処理プログラムに入力されないデータとして設定さ
れる。「（−）」と表記されたボタン３２６が押される
と、その時選択されているデータは処理プログラムに入
力すべきデータとして設定される。「（＊）」と表記さ
れているボタン３２７が押されると、その時選択されて
いるデータが、他の入力データに作用させるデータ（例
えば、標準較正データ）として設定される。「Ｈｅｌ
ｐ」と表記されたボタン３２８が押されると、編集画面
における操作方法の説明書きが表示される。

【０１０３】「Ｌｅｖｅｌ」と表記されている段指定部
３３１は、データ表示部３３４に表示すべき段（図５に
示す処理レベル）を指定するための領域である。「Ｅｎ
ｇｉｎｅ」と表記された処理プログラム入力部３３２
は、現在表示されている段のデータから次の段のデータ
を生成するための処理プログラム名を入力するための領
域である。

【０１０４】データ種別表示部３３３には、データ表示
部３３４の各列のデータの種別が表示されている。例え
ば、バイアス補正を行うためのデータであれば「Ｂｉａ
ｓ」と表示される。

【０１０５】データ表示部３３４には、入力データが、
解析処理手順を図５に示したような３次元構造テーブル
上の座標値で表示されている。データ名表示部３３５
は、データ表示部３３４で指定されたデータの名称が表
示される。

【０１０６】利用者は、このような編集画面３００で解
析処理手順を作成し、ツールバー３１０の「Execute 」
を指定することで実行内容指定画面が表示される。図２
２は、実行内容指定画面を示す図である。実行内容指定
画面４００には、開始ステップ指定部４１０と終了ステ
ップ指定部４２０とがあり、任意のステップの処理のみ
を実行させることができる。また、モード指定部４３０
で実行モードを指定することで、解析処理の精度などを
変更することができる。

【０１０７】実行内容指定画面４００の下部には、２つ
のボタン４４０，４５０が設けられている。「Execute
」と表記されたボタン４４０を押すと、解析処理が開
始され、「Cancel」と表記されたボタン４５０を押す
と、実行中の解析処理が中止される。

【０１０８】これにより、分散システムの利用者は、デ
ータが複数の計算機に分散して格納されていることを意
識せずに解析処理手順の作成、及び作成した解析処理手
順による解析処理の実行を容易に行うことができる。

【０１０９】また、解析処理に必要な情報が分散処理シ
ステム内で一意に識別可能であるため、中断した処理を
他の計算機に引き継がせることもできる。この場合、中
断した処理の作業領域内の情報を他の計算機に移動し、
移動先の計算機で解析処理を再開させればよい。このよ
うな制御を実行コントローラが自動的に行う。これによ
り、解析処理を中断している間に、その計算機の負荷が
増大してしまった場合には、他の計算機に処理を引き継
がせることができる。しかも、利用者は、中断前に解析
を実行していた計算機と、その解析処理を引き継いだ計
算機とが異なることを意識する必要はない。

【０１１０】なお、上記の処理機能は、コンピュータに
よって実現することができる。その場合、上記分散シス
テムの各機能の処理内容は、コンピュータで読み取り可
能な記録媒体に記録されたプログラムに記述されてお
り、このプログラムをコンピュータで実行することによ
り、上記処理がコンピュータで実現される。コンピュー
タで読み取り可能な記録媒体としては、磁気記録装置や
半導体メモリ等がある。市場を流通させる場合には、Ｃ
Ｄ−ＲＯＭ(Compact Disk Read Only Memory) やフロッ
ピーディスク等の可搬型記録媒体にプログラムを格納し
て流通させたり、ネットワークを介して接続されたコン
ピュータの記憶装置に格納しておき、ネットワークを通
じて他のコンピュータに転送することもできる。コンピ
ュータで実行する際には、コンピュータ内のハードディ
スク装置等にプログラムを格納しておき、メインメモリ
にロードして実行する。

【０１１１】

【発明の効果】以上説明したように本発明の分散処理シ
ステムでは、管理簿により、データをシステム内で一意
に識別するためのデータ名と実際の格納先との対応関係
を管理し、解析処理実行手段が管理簿を参照しながら必
要なデータを取得するため、必要なデータのデータ名を
特定した解析処理要求を入力すれば、実際のデータがど
の計算機に格納されているかを考えずに、解析処理を行
うことができる。

【０１１２】また、本発明の分散処理プログラムを記録
したコンピュータ読み取り可能な記録媒体では、各デー
タをシステム内で一意に識別するためのデータ名と実際
の格納先との対応関係を管理簿で管理し、その管理簿を
参照しながら必要なデータを取得するような処理内容が
記述された分散処理プログラムが格納されているため、
このプログラムをコンピュータに実行させれば、上記本
発明の分散処理システムの処理を、コンピュータで実行
することが可能となる。

【図面の簡単な説明】

【図１】本発明の原理構成図である。

【図２】天体観測システムを示す図である。

【図３】コンピュータシステムの構成を示す図である。

【図４】解析処理手順の概念図である。

【図５】３次元構造テーブルで表現された解析処理手順
を示す図である。

【図６】解析処理手順データの例を示す図である。

【図７】解析処理手順データの例を示す図である。

【図８】分散処理システムの機能を示すブロック図であ
る。

【図９】解析処理手順管理テーブルの例を示す図である

【図１０】処理エンジン管理テーブルの例を示す図であ
る。

【図１１】入力データ管理テーブルの例を示す図であ
る。

【図１２】キャッシュ管理簿テーブルの例を示す図であ
る。

【図１３】倉庫内データ管理テーブルの例を示す図であ
る。

【図１４】倉庫状態テーブルの例を示す図である。

【図１５】解析処理に必要な機能の構築処理を示すフロ
ーチャートである。

【図１６】解析処理の動作イメージを示す図である。

【図１７】解析処理の手順を示すフローチャートであ
る。

【図１８】実行先倉庫決定処理のフローチャートであ
る。

【図１９】実行結果の管理処理のフローチャートであ
る。

【図２０】解析処理手順エディタの検索画面を示す図で
ある。

【図２１】検索処理手順エディタの編集画面を示す図で
ある。

【図２２】実行内容指定画面を示す図である。

【符号の説明】

１ 計算機 １ａ 処理プログラム １ｂ 観測データ ２ 管理簿保持手段 ２ａ 管理簿 ３ 解析処理実行手段 ４ 作業領域 ４ａ 処理プログラム ４ｂ 観測データ ４ｃ 中間データ

【手続補正書】

【提出日】平成１１年４月１日

【手続補正１】

【補正対象書類名】明細書

【補正対象項目名】０００２

【補正方法】変更

【補正内容】

【０００２】

【従来の技術】科学技術分野などでは、大量のデータに
対し、様々な較正処理及び解析処理を行い、研究を推進
している。多くの研究機関では、計算機センター内に多
くの計算機を有し、高速なネットワークで接続された分
散システム環境を構築している。

【手続補正２】

【補正対象書類名】明細書

【補正対象項目名】００２１

【補正方法】変更

【補正内容】

【００２１】解析処理手順エディタ１２０は、端末装置
（図示せず）からの指令に基づいて解析処理指令を実行
コントローラ１７４に出力するとともに、解析処理手順
データ１４０を生成する。解析処理手順データ１４０に
は、解析処理を実行した順番やその解析処理に用いた処
理エンジン（処理プログラム）１３０、解析に用いた画
像データ１１０、中間データ１５０、及び解析結果デー
タ１６０に関する情報が登録されている。

【手続補正３】

【補正対象書類名】明細書

【補正対象項目名】００３４

【補正方法】変更

【補正内容】

【００３４】そこで、分散システム環境で一意に認識で
きるデータ名称として、処理に関連する情報の命名定義
を定める。本実施の形態では、各データ及び処理エンジ
ンが分散システム内でユニークとなるように、以下のよ
うな命名規則を定義する。

【手続補正４】

【補正対象書類名】明細書

【補正対象項目名】００３７

【補正方法】変更

【補正内容】

【００３７】処理エンジン名は、「******.usr.grp.eng
ine.version 」。ここで、「engine」は、エンジン名を
示し、「version 」は、そのプログラムの版数を示す。
画像データ名は、「フレームＩＤ.usr.grp」で表す。
「フレームＩＤ」は、天体望遠鏡１１で観測された各画
像に付けられた識別子である。

【手続補正５】

【補正対象書類名】明細書

【補正対象項目名】００５１

【補正方法】変更

【補正内容】

【００５１】「frame 」は、解析処理後に作成されるデ
ータの種別を示している。「current ＿step」は、現在
の解析処理の段を示している。解析処理の段は、解析処
理に必要なデータを管理する３次元テーブルの高さ方向
の単位である。なにも処理していないデータの段を
「０」として、１つめの処理エンジンで処理された結果
として得られるデータの段を１と数える。また、現在の
段数は、その解析処理手順の処理が済んだ段が示されて
いる。

【手続補正６】

【補正対象書類名】明細書

【補正対象項目名】００７８

【補正方法】変更

【補正内容】

【００７８】図１３は、倉庫内データ管理テーブルの例
を示す図である。倉庫内データ管理テーブル１８１ｃに
は、「status」、「name」、「abstract」、「owner
」、「group 」、「permission」、「create＿dat
e」、「last＿access＿time」、「caching＿time」、
「path」、「arg 」、「obe 」、及び「frame 」の項目
が設けられており、登録済データ１８１ａとキャッシュ
データ１８１ｂとに関する情報が登録されている。

【手続補正７】

【補正対象書類名】明細書

【補正対象項目名】００８１

【補正方法】変更

【補正内容】

【００８１】「last＿access＿time」は、そのデータに
最後にアクセスがあった時刻である。 「caching＿tim
e」は、キャッシュデータに関して設定され、そのデー
タがキャッシングされた時刻を示している。

【手続補正８】

【補正対象書類名】明細書

【補正対象項目名】００８２

【補正方法】変更

【補正内容】

【００８２】「path」は、そのデータの計算機内での位
置がフルパス（ルートディレクトリからのパス）で示さ
れている。図１４は、倉庫状態テーブルの例を示す図で
ある。倉庫状態テーブル１８１ｄは、「時刻」、「作業
領域容量」、「使用状況」、「CPU 負荷」、及び「ネッ
トワーク負荷」の項目が設けられており、その倉庫サー
バ１８１の稼働状態に関する情報が登録されている。
「時刻」は、その情報を取得した時刻である。「作業領
域容量」は、作業領域として使用可能なハードディスク
装置の空き容量である。「使用状況」は、作業領域内の
使用中の容量を、全体の容量に対する割合で示してい
る。「ＣＰＵ負荷」は、その倉庫サーバ１８１が設けら
れている計算機の負荷を示している。「ネットワーク負
荷」は、その倉庫サーバ１８１が設けられている計算機
が他の計算機とデータ通信を行うときの伝送性能に対す
る負荷を示している。

【手続補正９】

【補正対象書類名】明細書

【補正対象項目名】００８８

【補正方法】変更

【補正内容】

【００８８】管理簿サーバ１７２は、キャッシュ管理簿
サーバ１７３からの応答を、自身が特定した倉庫サーバ
の情報に追加し、実行コントローラ１７４に返す。 ［Ｓ１４］実行コントローラ１７４は、実行先倉庫を決
定する。この処理の詳細は後述する。ここでは、処理に
必要な解析手順データ１４１、処理エンジン１３１，及
び画像データ１１１が格納されている倉庫サーバ１８３
に決定したものとする。 ［Ｓ１５］実行コントローラ１７４は、ステップＳ１４
において決定した倉庫サーバ１８３に、解析処理手順を
実行するための作業領域の作成を依頼する（図１６のＳ
１０４）。このとき、各入力データの所在情報も同時に
送付する。 ［Ｓ１６］作業領域作成依頼を受け取った倉庫サーバ
は、作業領域を作成可能か否かを判断する。作業領域を
作成可能であればステップＳ１７に進み、作業領域を作
成できなければステップＳ１４に進む。 ［Ｓ１７］倉庫サーバ１８３は、解析処理手順に対応す
る作業領域として、ディレクトリを作成する。以後、倉
庫サーバ１８３が、そのディレクトリの名称とパス名を
管理する。また、作成したディレクトリを利用して処理
を実行する作業領域サーバ１８３ｅを、倉庫サーバ１８
３と同じ計算機内で起動し、初期化する（図１６のＳ１
０５）。 ［Ｓ１８］倉庫サーバ１８３は、作業領域を準備する。
具体的には、まず、倉庫サーバ１８３自身が管理してい
ない入力データ、処理エンジンを、他の倉庫サーバ１８
１，１８２へ要求する（図１６のＳ１０６）。必要であ
れば解析処理手順データも取り寄せる。倉庫サーバ１８
１，１８２は、要求に応じてデータを返す（図１６のＳ
１０７）。

【手続補正１０】

【補正対象書類名】明細書

【補正対象項目名】００９４

【補正方法】変更

【補正内容】

【００９４】以上のように、実体名を意識しない「作業
領域」を１台の計算機上に作成し、作業領域のなかに、
入力データ、処理エンジン、及び解析処理手順データを
ＵＮＩＸコマンド「ｌｉｎｋ」により、作業領域内の名
称でシンボリックリンクした。そのため、作業領域内に
おいて、解析処理手順データ内の名前によりすべての処
理が実行可能となる。

【手続補正１１】

【補正対象書類名】明細書

【補正対象項目名】００９８

【補正方法】変更

【補正内容】

【００９８】以下に、解析処理手順エディタの操作手順
について説明する。図２０は、解析処理手順エディタの
検索画面を示す図である。検索画面２００の上部にはツ
ールバー２１０が設けられており、各種命令を入力する
ことができる。ツールバー２１０の下には、複数のボタ
ン２２１〜２２５が設けられている。「Ｎｅｗ」と表記
されたボタン２２１が押されると、検索画面２００が初
期化される。「Ｑｕｉｔ」と表記されたボタン２２２が
押されると、検索画面２００が閉じる。「Ｓｔａｒｔ」
と表記されたボタン２２３が押されると、検索処理が開
始される。「Ｒｅｌｏａｄ」と表記されたボタン２２４
が押されると、検索結果表示部２４０で指定されている
データが読み込まれ、その内容が表示される。「Ｈｅｌ
ｐ」と表記されたボタン２２５が押されると、検索機能
の操作方法の説明書きが表示される。

【手続補正１２】

【補正対象書類名】明細書

【補正対象項目名】０１０１

【補正方法】変更

【補正内容】

【０１０１】図２１は、解析処理手順エディタの編集画
面を示す図である。編集画面３００の上部にはツールバ
ー３１０が設けられており、各種命令を入力することが
できる。このツールバー３１０内の「Execute 」のコマ
ンドを指定すると、編集画面３００で編集されている処
理手順に従った処理の実行要求が、実行コントローラ１
７４に出力される。

【手続補正１３】

【補正対象書類名】明細書

【補正対象項目名】図２１

【補正方法】変更

【補正内容】

【図２１】解析処理手順エディタの編集画面を示す図で
ある。

【手続補正１４】

【補正対象書類名】図面

【補正対象項目名】図５

【補正方法】変更

【補正内容】

【図５】

【手続補正１５】

【補正対象書類名】図面

【補正対象項目名】図１３

【補正方法】変更

【補正内容】

【図１３】

Claims (10)

【特許請求の範囲】
1. 【請求項１】 データを複数の計算機で分散して解析す
   る分散処理システムにおいて、 解析処理に必要となる情報をシステム内で一意に識別す
   るための情報名と、各情報の実際の格納先との対応関係
   が登録された管理簿を保持する管理簿保持手段と、 前記情報名によって必要な情報を特定した解析処理要求
   を受け取ると、前記管理簿保持手段内の前記管理簿によ
   り必要な情報の実際の格納先を認識し、解析処理要求に
   応じた処理を実行する解析処理実行手段と、 を有することを特徴とする分散処理システム。
2. 【請求項２】 前記解析処理実行手段は、必要な情報が
   他の計算機に格納されている場合には、必要な情報を自
   己の計算機内に複写した後、解析処理を実行することを
   特徴とする請求項１記載の分散処理システム。
3. 【請求項３】 前記解析処理実行手段は、要求された解
   析処理を実行するための作業領域を生成し、実際の情報
   へのアクセスを可能とするリンク情報を前記作業領域内
   に登録し、解析処理の途中で生成される中間データを前
   記作業領域内に保存することを特徴とする請求項１記載
   の分散処理システム。
4. 【請求項４】 前記解析処理実行手段は、複数の計算機
   の中から適当な計算機を選択し、選択した計算機上で解
   析処理を実行することを特徴とする請求項１記載の分散
   処理システム。
5. 【請求項５】 前記解析処理実行手段は、必要な情報が
   多く格納されている計算機を、解析処理を実行する計算
   機として選択することを特徴とする請求項４記載の分散
   処理システム。
6. 【請求項６】 解析処理実行のために転送され一時的に
   保持されている情報に関する事項が登録されたキャッシ
   ュ管理簿を保持するキャッシュ管理簿保持手段を更に有
   し、 前記解析処理実行手段は、必要な情報が多く格納されて
   いる計算機を判断する際には、前記管理簿と前記キャッ
   シュ管理簿との内容から判断することを特徴とすること
   を特徴とする請求項５記載の分散処理システム。
7. 【請求項７】 前記解析処理実行手段は、処理の負荷の
   少ない計算機を、解析処理を実行する計算機として選択
   することを特徴とする請求項４記載の分散処理システ
   ム。
8. 【請求項８】 前記解析処理実行手段は、解析途中で、
   解析処理を実行する計算機の変更の必要が生じた場合に
   は、他の計算機を新たに選択し、前記作業領域を新たに
   選択した計算機内に移動することで、以後の処理を新た
   に選択した計算機に実行させることを特徴とする請求項
   ４記載の分散処理システム。
9. 【請求項９】 システム内で一意に識別するための情報
   名を用いて解析の処理手順を構築し、構築した解析処理
   手順に従った解析処理要求を前記解析処理実行手段に対
   して出力する解析処理手順作成手段を更に有することを
   特徴とする請求項１記載の分散処理システム。
10. 【請求項１０】 データを複数の計算機で分散して解析
    する分散処理プログラムを記録したコンピュータ読み取
    り可能な記録媒体において、 解析処理に必要となる情報をシステム内で一意に識別す
    るための情報名と、各情報の実際の格納先との対応関係
    が登録された管理簿を保持する管理簿保持手段、 前記情報名によって必要な情報を特定した解析処理要求
    を受け取ると、前記管理簿保持手段内の前記管理簿によ
    り必要な情報の実際の格納先を認識し、解析処理要求に
    応じた処理を実行する解析処理実行手段、 としてコンピュータを機能させることを特徴とする分散
    処理プログラムを記録したコンピュータ読み取り可能な
    記録媒体。