"時系列データを時々刻々と発生させる情報源からデータ受け付けて追記する追記クライアントACと、データ記憶装置を具備し、追記クライアントACから追記されたデータを受け取ってキューイングする追記部Qと、前記追記部Qからデータを取得して予め定義された処理を実行するフィルタ部Fと、前記追記クライアントACからの接続要求に応じて追記部Qの払い出しを行う情報部Iが存在するネットワーク環境における分散データ管理システムであって、前記追記クライアントACは、前記情報部Iに接続要求を行い、情報源IDとともに接続先となる追記部Qの接続情報IPアドレス、ポート番号などを取得する接続要求手段と、前記情報源からデータを受け付けて情報源IDとともに前記追記部Qにデータを追記するデータ送信手段と、を具備し、前記追記部Qは、前記追記クライアントACによって追記されたデータを受け取って管理用のレコードIDを付与するとともに、受け取りの時刻印を付与し、データをFIFO順にデータ記憶装置にキューイングするデータ受付手段と、前記追記クライアントACからのデータ受付時に追記クライアントACに自身追記部Qあるいは自身が動作するサーバの状態を通知する状態通知手段と、を具備し、前記フィルタ部Fは、少なくとも1つ以上の追記部Qから自律的分散データ取得処理を行って追記部Qを1つ選択し、該追記部Qのデータ記憶装置から情報源IDとともにデータを取得Pullするデータ取得手段と、取得した前記データに対して情報源ID毎に予め定義された処理を実行するデータ処理手段と、を具備し、前記情報部Iは、前記追記クライアントからの接続要求を受け付け、未使用の追記部Qの中から少なくとも1つ以上の追記部Qを選択し、1つの情報源IDと前記少なくとも1つ以上の追記部Qの接続情報を返却する接続要求受付手段を具備することを特徴とする無停止分散データ管理システム。時系列データを時々刻々と発生させる情報源からデータ受け付けて追記する追記クライアントACとデータ記憶装置を具備し、追記クライアントACから追記されたデータを受け取ってキューイングする追記部Qと、前記追記部Qからデータを取得して予め定義された処理を実行するフィルタ部Fと、前記追記クライアントACからの接続要求に応じて前記追記部Qの払い出しを行う情報部Iが存在するネットワーク環境において、前記追記クライアントACは、接続要求手段により前記情報部Iに接続要求を行い、情報源IDとともに接続先となる追記部Qの接続情報IPアドレス、ポート番号などを取得し、データ送信手段により該追記部Qにデータを追記し、前記追記部Qは、前記追記クライアントACから送信されたデータをデータ受付手段により受け取り、管理用のレコードIDおよび時刻印を付与した後でデータ記憶装置にFIFO順に蓄積し、前記フィルタ部Fは、データ取得手段により自律的分散データ取得処理を行って追記部Qを1つ選択し、該追記部Qのデータ記憶装置から情報源IDとともにデータを取得Pullし、データ処理手段により情報源IDごとに予め定義された処理を行うステップを繰り返し、前記情報部Iは、接続要求受付手段により前記追記クライアントACからの接続要求を受け付け、未使用の追記部Qの中から少なくとも1つ以上の追記部Qを選択し、1つの情報源IDと前記少なくとも1つ以上の追記部Qの接続情報IPアドレス、ポート番号などを返却し、前記追記部Qは、状態通知手段により前記追記クライアントACからのデータ受付時に該追記クライアントACに自身追記部Qあるいは自身が動作するサーバの状態を通知することを特徴とする分散データ管理方法。第1の追記部Qに対してスイッチオーバー命令を通知すると、前記第1の追記部Qがスイッチオーバー状態へ移行し、前記追記クライアントACからの次回のデータ追記時に前記追記部の状態通知手段により該第1の追記部Qから該追記クライアントACに対して自身追記部QのIPアドレスと該第1の追記部Qがスイッチオーバー状態であることを通知し、通知を受けた追記クライアントACが、前記情報部Iに対して前記接続要求手段により第1の追記部QのIPアドレスを通知して新たな接続要求を行い、前記情報部Iは、前記接続要求受付手段により前記追記クライアントACから通知された第1の追記部QのIPアドレス以外で動作する第2の追記部Qの少なくとも1つ以上の接続情報と1つの情報源IDを追記クライアントACに返却し、前記第2の追記部Qの払い出しを受けた追記クライアントACが、該第2の追記部Qに対して前記データ送信手段によりデータ追記を再開する請求項2記載の分散データ管理方法。第1の追記部Qに対してスイッチオーバー命令を通知する際に併せてスイッチオーバー先のIPアドレスを指定すると、前記第1の追記部Qがスイッチオーバー状態へ移行し、前記追記クライアントACからの次回のデータ追記時に前記追記部の状態通知手段により該第1の追記部Qから該追記クライアントACに対してスイッチオーバー先のIPアドレスと該第1の追記部Qがスイッチオーバー状態であることを通知し、通知を受けた前記追記クライアントACが、前記情報部Iに対して前記接続要求手段によりスイッチオーバー先のIPアドレスを通知して新たな接続要求を行い、前記情報部Iは、前記接続要求受付手段により追記クライアントACから通知されたIPアドレスで動作する第2の追記部Qの少なくとも1つ以上の接続情報IPアドレス、ポート番号などと1つの情報源IDを追記クライアントACに返却し、前記第2の追記部Qの払い出しを受けた追記クライアントACが、該第2の追記部Qに対して前記データ送信手段によりデータ追記を再開する請求項2記載の分散データ管理方法。第1の追記部Qに対してデータ受付待機命令を通知すると、前記第1の追記部Qがデータ受付待機状態へ移行し、前記追記クライアントACからの次回のデータ追記時に前記追記部の状態通知手段により第1の追記部Qから追記クライアントACに対して第1の追記部Qがデータ受付待機状態であることを通知し、通知を受けた追記クライアントACが、指定された時間経過後あるいは指定されたサーバ状態に変化した後で前記第1の追記部Qに対してデータ追記を再開する請求項2記載の分散データ管理方法。しかしながら、上記の非特許文献1の方式は、追記クライアントからデータの書き込みを受けている追記部では、追記クライアントからのデータ書き込みが止まらない限り追記部を停止させたり、別の追記部へ書き込み先を切り替えスイッチオーバーさせたりすることができないOSのバージョンアップやパッチ適用に伴うサーバの計画停止に対応できない。また、追記部には追記クライアントからのデータ書き込みを抑止する手段がないため、追記部を動作させているサーバの空きメモリ容量が不足している状況で追記クライアントからデータサイズが大きいデータの書き込みがあるとサーバ異常やサーバ停止を引き起こすことも考えられる。本発明の目的は、Webカメラやセンシング機器、GPS機能付き携帯端末などから時々刻々と発生する時系列データデータストリームをネットワーク上で収集蓄積し、利用者の目的に合った形のデータ処理を無停止で実行可能な分散データ管理システムを実現することである。本発明は、上記目的を達成するために、Webカメラやセンシング機器、GPS機能付き携帯端末などの時系列データを時々刻々と発生させる情報源からデータ受け付けて追記する追記クライアントACと、データ記憶装置を具備し、追記クライアントACから追記されたデータを受け取ってキューイングする追記部Qと、追記部Qからデータを取得して予め定義された処理を実行するフィルタ部Fと、追記クライアントACからの接続要求に応じて追記部Qの払い出しを行う情報部Iが存在するネットワーク環境において、追記クライアントACは、接続要求手段により情報部Iに接続要求を行い、情報源IDとともに接続先となる追記部Qの接続情報IPアドレス、ポート番号などを取得し、データ送信手段により追記部Qにデータを追記し、追記部Qは、追記クライアントACから送信されたデータをデータ受付手段により受け取り、管理用のレコードIDおよび時刻印を付与した後でデータ記憶装置にFIFO順に蓄積し、フィルタ部Fは、データ取得手段により自律的分散データ取得処理例えばラウンドロビンアルゴリズムなどを行って追記部Qを1つ選択し、追記部Qのデータ記憶装置から情報源IDとともにデータを取得Pullし、データ処理手段により情報源IDごとに予め定義された処理を行うステップを繰り返し、情報部Iは、接続要求受付手段により追記クライアントACからの接続要求を受け付け、未使用の追記部Qの中から少なくとも1つ以上の追記部Qを選択し、1つの情報源IDと前記少なくとも1つ以上の追記部Qの接続情報IPアドレス、ポート番号などを返却し、追記部Qが状態通知手段により追記クライアントACからのデータ受付時に追記クライアントACに自身追記部Qあるいは自身が動作するサーバの状態を通知することで、Webカメラやセンシング機器、GPS機能付き携帯端末などから時々刻々と発生する時系列データデータストリームをネットワーク上で収集蓄積し、利用者の目的に合った形で処理を実行して結果を提供する無停止分散データ管理システムを提供する。以上説明したように、本発明請求項1、2によれば、Webカメラやセンシング機器、GPS機能付き携帯端末などから時々刻々と発生する時系列データデータストリームをネットワーク上の追記部Qで収集蓄積し、フィルタ部Fが利用者の目的に合った形で処理を実行して結果を提供する無停止分散データ管理システムを実現することができる。また、本発明請求項3,4によれば、追記部Qが追記クライアントACからのデータ受付時に追記クライアントACに対して追記部Qがスイッチオーバー状態であることを通知することで、追記クライアントACは新たな追記部Qの払い出し要求を行い、払い出された追記部Qに対してデータの追記を再開することで無停止分散データ管理システムを実現することができる。また、本発明請求項5によれば、追記部Qが追記クライアントACからのデータ受付時に追記クライアントACに対して追記部Qがデータ受付待機状態であることを通知することで、追記クライアントACは指定された条件を満たすまで追記部Qに対するデータ追記を待機するため、追記部Qが動作しているサーバのメモリあふれなどによるサーバ異常やサーバ停止を抑止した無停止分散データ管理システムを実現することができる。以下、本発明の実施形態を図面を参照して説明する。図1は、本発明の一実施形態の無停止分散データ管理システムの構成図である。同図に示す無停止分散データ管理システムは、追記クライアント100、追記部Q200、フィルタ部F300、情報部I400から構成される。追記クライアントAC100は、接続要求部110、データ送信部120を有し、追記部200はデータ受付部210、データ記憶装置220、状態通知部230を有し、フィルタ部F300はデータ取得部310、データ処理部320を有し、情報部I400は接続要求受付部410を有する。本実施形態の無停止分散データ管理システムは、追記クライアント100がWebカメラやセンシング機器、GPS機能付き携帯端末などの時系列データを時々刻々と発生させる情報源からデータを受け取り、接続要求部110から情報部I400に対して接続要求を行った結果、払い出された追記部Q200にデータ送信部120がデータを追記する。追記部Q200では、データ受付部210が、追記クライアントAC100から追記されたデータを例えばキューなどとして実装されたデータ記憶装置220にFIFO順にキューイングする。フィルタ部F300は、データ取得部310でデータ記憶装置220からデータを取得し、データ処理部320において情報源IDごとに予め定義された処理を実行するステップを繰り返す。尚、本実施形態の分散データ管理システムは、追記部Q200の各プロセスが自身が管理するデータ記憶装置220を保持しているが、データ記憶装置を追記部Qプロセスの外部に配置することも可能である。また、情報部I400、追記クライアントAC100、追記部Q200、フィルタ部F300を複数配置した構成とすることも可能である。図2は、本発明の一実施形態の無停止分散データ管理システムの構成例である。追記部Q200は物理サーバ上に1プロセス配置することも複数プロセス配置することも可能である。フィルタ部F300も物理サーバ上に1プロセス配置することも複数プロセス配置することも可能である。また、追記部Q200とフィルタ部F300のプロセスを同一サーバ上に混在して配置することも可能である。各物理サーバ上にポートマッパPなるプロセスを配置して追記部Q200およびフィルタ部F300を管理し、管理下にある追記部Q200およびフィルタ部F300の各プロセスに対して各種命令例えば、起動、停止、生存確認、指定コマンド実行などを通知する構成とすることも可能である。また、本実施形態では情報部I400を異なる物理サーバ上に配置した例を示しているが、追記部Q200やフィルタ部F300と同一サーバ上に配置した構成とすることも可能である。図3は、本発明の一実施形態の追記クライアントACの動作のフローチャートである。同図のフローチャートでは、追記クライアントAC100が接続要求部110により情報部I400に接続要求を行う際の動作とデータ送信部120により追記部Q200へデータを追記する際の動作を示す。ステップ101追記クライアントAC100の接続要求部110は、情報部I400に追記部Q払い出しの接続要求を行う。ステップ102追記クライアント100のデータ送信部120は、情報源IDとともに情報部I400から追記部Qの接続情報IPアドレス、ポート番号などを取得する。ステップ103情報源からのデータが存在しなければ、ステップ103を繰り返し、データが存在すれば次のステップへ進む。ステップ104追記クライアント100のデータ送信部120は、情報源IDとともに追記部Q200にデータを追記する。ステップ105追記部Q200からスイッチオーバー状態通知があれば次のステップへ進み、なければステップ109へ進む。ステップ106スイッチオーバー状態通知を受け取った際にスイッチオーバー先のIPアドレスの通知があれば次のステップへ進み、なければステップ108へ進む。ステップ107スイッチオーバー先のIPアドレスを通知して情報部I400に接続要求を行い、ステップ102へ戻る。ステップ108接続要求部110は、スイッチオーバー状態を通知してきた追記部Q200のIPアドレスを指定して情報部I400に接続要求を行い、ステップ102へ戻る。ステップ109追記部Q200からデータ受付待機状態通知があれば次のステップへ進み、なければステップ103へ戻る。ステップ110指定された時間経過後もしくは指定されたサーバ状態に変化するまで例えば、指定された空きメモリ容量になるまで待機し、ステップ103へ戻る。次に、追記部Q200に関する動作について説明する。図4は、本発明の一実施形態の追記部Qの動作のフローチャートである。追記部Q200がデータ受付部210により追記クライアントAC100からデータを受け付けてデータ記憶装置220に蓄積する際の動作と、状態通知部230により追記クライアントAC100からのデータ受付時に追記クライアントAC100に自身追記部Q200あるいは自身が動作するサーバの状態を通知する際の動作を示す。ステップ201データ受付部210は、自身のデータ記憶装置220に空きがあれば次のステップへ進み、なければステップ207へ進む。ステップ202データ受付部210は、追記クライアントAC100から情報源IDとともに追記されたデータを受け取る。ステップ203データ受付部210は、管理用のレコードIDを付与する。ステップ204データ受付部210は、受け取り時の時刻印を付与する。ステップ205データ受付部210は、データをFIFO順にデータ記憶装置220に蓄積する。ステップ206コマンドなどを通じて停止命令が通知されていれば終了し、通知されていなければステップ208へ進む。ステップ207エラーログを出力するなどの例外処理を実行してステップ201に戻る。ステップ208スイッチオーバー状態であれば次のステップへ進み、スイッチオーバー状態でなければステップ213へ進む。ステップ209スイッチオーバー先のIPアドレスの通知があれば次のステップへ進み、なければステップ211へ進む。当該ステップ209~ステップ212の処理がスイッチオーバー先サーバのIPアドレス指定がある場合の処理請求項3に対応となる。ステップ210追記クライアントAC100にスイッチオーバー先のIPアドレスを指定してスイッチオーバー状態を通知しステップ212に進む。ステップ211追記クライアント100に自身のIPアドレスを指定してスイッチオーバー情報を通知する。ステップ212自身のデータ記憶装置220にレコードが存在しなければ終了し、存在すればステップ212を繰り返す。ステップ213データ受付待機状態であれば次のステップへ進み、データ受付待機状態でなければステップ201へ戻る。ステップ214追記クライアントAC100にデータ受付待機状態を通知し、ステップ201へ戻る。当該ステップのデータ受付待機状態通知の処理請求項5に対応となる。次に、フィルタ部300の動作について説明する。図5は、本発明の一実施形態のフィルタ部の動作のフローチャートである。フィルタ部F300がデータ取得部310により自律的分散データ取得処理例えばラウンドロビンアルゴリズムなどを行って追記部Q200を1つ選択し、追記部Q200のデータ記憶装置220から情報源IDと共にデータを取得Pullする際の動作とデータ処理部310により取得したデータに対して情報源IDごとに予め定義された処理を行う際の動作を示す。ステップ301データ取得部310は、自律的分散データ取得処理例えばラウンドロビンアルゴリズムなどにより追記部Q200を1つ選択する。ステップ302当該追記部Q200のデータ記憶装置220にレコードがあれば次のステップへ進み、なければステップ301へ戻る。ステップ303データ取得部310は、当該追記部Q200のデータ記憶装置220から情報源IDとともにFIFO順にデータを取得する。ステップ304データ処理部320は、取得したデータに対して情報源IDごとに予め定義された処理を行う。ステップ305コマンドなどを通じて停止命令が通知されていれば終了し、通知されていなければステップ301へ戻る。次に、情報部400の動作について説明する。図6は、本発明の一実施形態における情報部の動作のフローチャートである。以下に、情報部I400が接続要求受付部410により追記クライアントAC100から接続要求を受け付け、少なくとも1つ以上の追記部Qの接続情報と1つの情報源IDを返却する際の動作を示す。ステップ401接続要求受付部410は、追記クライアントAC100からの接続要求があれば次のステップへ進み、なければステップ401に戻る。なお、接続要求としては、1追記部200のIPアドレス指定の接続要求;2スイッチオーバー先のIPアドレス指定の接続要求;3IPアドレス指定無しの接続要求;がある。ステップ402第1の追記部Q2001のIPアドレスを通知した接続要求であれば次のステップへ進み、そうでなければステップ404へ進む。ステップ403接続要求が上記の1である場合は、第1の追記部Q2001のIPアドレス以外で動作する第2の追記部Q2002の少なくとも1つ以上の接続情報と1つの情報源IDを追記クライアントAC100に返却し、ステップ401へ戻る。ステップ404スイッチオーバー先のIPアドレスを通知した接続要求であれば次のステップへ進み、そうでなければステップ406へ進む。ステップ405接続要求が上記である場合は、通知されたIPアドレスで動作する第2の追記部Q2002の少なくとも1つ以上の接続情報と1つの情報源IDを追記クライアントAC100に返却し、ステップ401へ戻る。ステップ406接続要求が上記である場合は、未使用の追記部Q200nのうち少なくとも1つ以上の接続情報と1つの情報源IDを追記クライアントAC100に返却し、ステップ401へ戻る。なお、上記の分散データ管理システムの追記クライアントAC100、追記部Q200、フィルタ部F300、情報部400の各々が有する構成要素の動作をプログラムとして構築し、コンピュータにインストールして実行させる、または、ネットワークを介して流通させることが可能である。本発明は、上記の実施形態に限定されることなく、特許請求の範囲内において種々変更応用が可能である。"