WO2024089766A1 - データ複製装置、データ複製システム、データ複製方法、及びデータ複製プログラム - Google Patents

Abstract

即時ファイルに発生した変更を示す第１の差分（Ｄ１）をリアルタイム処理で受信する送受信部（２１３）と、即時ファイル及び非即時ファイルの少なくとも一方に発生した変更を示す第２の差分（Ｄ２）をバッチ処理で受信する送受信部（２２１）と、第１の差分（Ｄ１）の受信時に、第１の差分（Ｄ１）を用いて即時ファイルを更新する一時記憶部（２１４）と、第２の差分（Ｄ２）の受信時に、第２の差分（Ｄ２）を用いて即時ファイル及び非即時ファイルの少なくとも一方を更新する複製データ記憶部（２２２）と、一時記憶部（２１４）及び複製データ記憶部（２２２）に重複する即時ファイルが存在するか否かを判定する同一ファイル判定部（２１３）と、重複する即時ファイルが存在すると判定された場合に、一時記憶部（２１４）または複製データ記憶部（２２２）に記憶された即時ファイルを、隠蔽または削除する隠蔽処理部（表示制御部、削除制御部）を備える。

Description

データ複製装置、データ複製システム、データ複製方法、及びデータ複製プログラム

　本発明は、データ複製装置、データ複製システム、データ複製方法、及びデータ複製プログラムに関する。

　非特許文献１には、送信先となるサーバ（以下、「送信先サーバ」という）において、送信元となるサーバ（以下、「送信元サーバ）という）のデータ記憶装置に記憶されている原本データから同期をとって複製データを取得し、該複製データに基づいて利用者が要求するファイルをオンデマンドで提供することが開示されている。

　原本データはキャッシュシステムなどで使用する複数のファイルを含んでおり、新規ファイルの追加、既存ファイルの変更、削除などの変更が発生した場合には、変更後のファイルを送信元サーバから送信先サーバに送信する。送信先サーバは、送信された変更後のファイルに基づいて、原本データと複製データとの間で同期をとり、複製データを更新する。

Alluxio Introduction、https://docs.alluxio.io/os/user/stable/en/Overview.html

　原本データに含まれるファイルには、即時性を有する即時ファイル、及び即時性を有しない非即時ファイルが含まれる。即時ファイルに変更が発生した際には、この即時ファイルを送信元サーバから送信先サーバにリアルタイム処理（オンライン処理）で送信してファイルを更新する。原本データに含まれる非即時ファイルに変更が発生した際には、一定の時間間隔或いは任意のタイミングにて、ファイル全体（即時ファイル及び非即時ファイル）の差分情報をバッチ処理にて送信元サーバから送信先サーバに送信してファイルを更新する。

　非特許文献１に開示された技術では、送信元サーバから変更が発生した即時ファイルがリアルタイム処理で送信された際には、この即時ファイルにより一時記憶部に記憶された該当する即時ファイルが更新される。また、送信元サーバから変更が発生したファイルがバッチ処理で送信された際には、このファイルにより、送信先サーバの複製データ記憶部に記憶されたファイル（即時ファイル、非即時ファイル）が更新される。

　このため、ファイルの利用者は、同一の即時ファイルが複数のディレクトリに存在するものと認識してしまい、混乱を招くという問題が生じる。更に、一つの即時ファイルが一時記憶部及び複製データ記憶部にそれぞれ記憶されることになり、不必要に記憶領域のリソースを使用するという問題が発生する。

　本発明は、上記事情に鑑みてなされたものであり、その目的とするところは、同一のファイルに対して複数の記憶部に重複してアクセスすることを回避することが可能なデータ複製装置、データ複製システム、データ複製方法、及びデータ複製プログラムを提供することにある。

　本発明の一態様のデータ複製装置は、原本データの複製データを生成するデータ複製装置であって、前記原本データに含まれる即時ファイルに発生した変更を示す第１の差分をリアルタイム処理で受信し、前記原本データに含まれる即時ファイル及び非即時ファイルの少なくとも一方に発生した変更を示す第２の差分をバッチ処理で受信する受信部と、前記即時ファイルの複製データを記憶し、前記第１の差分の受信時に、前記第１の差分を用いて即時ファイルを更新する一時記憶部と、前記即時ファイル及び前記非即時ファイルの少なくとも一方の複製データを記憶し、前記第２の差分の受信時に、前記第２の差分を用いて即時ファイル及び非即時ファイルの少なくとも一方を更新する複製データ記憶部と、前記一時記憶部及び前記複製データ記憶部に重複する即時ファイルが存在するか否かを判定する判定部と、重複する即時ファイルが存在すると判定された場合に、前記一時記憶部または前記複製データ記憶部に記憶された即時ファイルを、隠蔽または削除する隠蔽処理部とを備える。

　本発明の一態様のデータ複製システムは、一のサーバ及び前記一のサーバに接続された他のサーバを備えたデータ複製システムであって、前記他のサーバは、複数のファイルを含む原本データを記憶する原本データ記憶部と、前記複数のファイルのうち、変更が発生したファイルを判定する差分判定部と、前記変更が発生したファイルが即時ファイルであるか、非即時ファイルであるかを判定する即時性判定部と、即時ファイルに発生した変更を示す第１の差分をリアルタイム処理で前記一のサーバに送信し、即時ファイル及び非即時ファイルの少なくとも一方に発生した変更を示す第２の差分をバッチ処理にて前記一のサーバに送信する送信部と、を備え、前記一のサーバは、前記第１の差分及び第２の差分を受信する受信部と、前記即時ファイルの複製データを記憶し、前記第１の差分の受信時に、前記第１の差分を用いて即時ファイルを更新する一時記憶部と、前記即時ファイル及び前記非即時ファイルの少なくとも一方の複製データを記憶し、前記第２の差分の受信時に、前記第２の差分を用いて即時ファイル及び非即時ファイルの少なくとも一方を更新する複製データ記憶部と、前記一時記憶部及び前記複製データ記憶部に重複する即時ファイルが存在するか否かを判定する判定部と、重複する即時ファイルが存在すると判定された場合に、前記一時記憶部または前記複製データ記憶部に記憶された即時ファイルを、隠蔽または削除する隠蔽処理部とを備える。

　本発明の一態様のデータ複製方法は、原本データに含まれる即時ファイルに発生した変更を示す第１の差分をリアルタイム処理で受信するステップと、前記原本データに含まれる即時ファイル及び非即時ファイルの少なくとも一方に発生した変更を示す第２の差分をバッチ処理で受信するステップと、前記即時ファイルの複製データを一時記憶部に記憶し、前記第１の差分の受信時に、前記第１の差分を用いて即時ファイルを更新するステップと、前記即時ファイル及び前記非即時ファイルの少なくとも一方の複製データを複製データ記憶部に記憶し、前記第２の差分の受信時に、前記第２の差分を用いて即時ファイル及び非即時ファイルの少なくとも一方を更新するステップと、前記一時記憶部及び前記複製データ記憶部に重複する即時ファイルが存在するか否かを判定するステップと、重複する即時ファイルが存在すると判定された場合に、前記一時記憶部または前記複製データ記憶部に記憶された即時ファイルを、隠蔽または削除するステップとを備える。

　本発明の一態様は、上記データ複製装置としてコンピュータを機能させるためのデータ覆製プログラムである。

　本発明によれば、同一のファイルに対して複数の記憶部に重複してアクセスすることを回避することが可能になる。

図１は、実施形態に係るデータ複製システムの構成を示すブロック図である。 図２は、実施形態に係るデータ複製システムの処理手順を示すフローチャートである。 図３は、第１変形例に係るデータ複製システムの構成を示すブロック図である。 図４は、第１変形例に係るデータ複製システムの処理手順を示すフローチャートである。 図５は、第２変形例に係るデータ複製システムの構成を示すブロック図である。 図６は、本実施形態のハードウェア構成を示すブロック図である。

　［実施形態の説明］
　以下、図面を参照して実施形態について説明する。図１は、実施形態に係るデータ複製システムの構成を示すブロック図である。図１に示すようにデータ複製システム１００は、送信元サーバ１（他のサーバ）と、送信先サーバ２（一のサーバ、データ複製装置）を備えており、送信元サーバ１と送信先サーバ２はネットワーク３により接続されている。送信先サーバ２は、ユーザクライアント４に接続される。データ複製システム１００は、送信元サーバ１に記憶されているファイルを送信先サーバ２に送信して複製ファイルを生成する。

　送信元サーバ１は、原本データ記憶部１１と、制御部１２を備えている。

　原本データ記憶部１１は、後述するキャッシュシステム２１で使用する複数のファイルを含む原本データを記憶する。原本データ記憶部１１に記憶されているファイルは、外部からのアクセスにより一定の時間間隔或いは任意のタイミングで変更処理が実行される。変更処理は、原本データへの新規ファイルの追加、原本データに含まれる既存ファイルの修正、削除を含む。

　原本データには、即時性を有する即時ファイル、及び即時性を有しない非即時ファイルが含まれる。以下では、原本データに含まれる複数のファイルのうち、変更処理された即時ファイルを「第１の差分Ｄ１」という。また、原本データに含まれる複数のファイルのうち、変更処理されたファイル（即時ファイル、非即時ファイル）を「第２の差分Ｄ２」という。即時ファイルは、変更処理が発生したときに即時に参照する必要性が高いファイルであり、例えば、「ｃｓｖ」ファイル、或いは「ｊｐｅｇ」、「ｍｐｅｇ」などの画像データを含むファイルである。即時ファイルは、原本データの内容、所在を管理するためのファイルであってもよい。非即時ファイルは即時性が必要とされないファイルである。

　制御部１２は、差分判定部１２１と、即時性判定部１２２と、送信部１２３を備えている。

　差分判定部１２１は、原本データ記憶部１１に記憶されている複数のファイルのうち、変更処理が発生したファイル（第２の差分）を判定する。

　即時性判定部１２２は、差分判定部１２１において変更処理が発生したと判定されたファイルが、即時ファイルであるか或いは非即時ファイルであるかを判定する。

　送信部１２３は、即時性判定部１２２における判定結果に基づいて、変更処理が発生した即時ファイル（第１の差分Ｄ１）、及び変更処理が発生した即時ファイル及び非即時ファイル（第２の差分Ｄ２）を、送信先サーバ２に送信する。詳細には、送信部１２３は、第１の差分Ｄ１をリアルタイム処理により、ネットワーク３を経由して送信先サーバ２のキャッシュシステム２１に送信する。送信部１２３は、第２の差分Ｄ２を一定時間間隔或いは任意のタイミングで送信するバッチ処理により、ネットワーク３を経由して送信先サーバ２の複製処理部２２に送信する。

　送信先サーバ２は、キャッシュシステム２１と、複製処理部２２と、同一ファイル処理部２３を備えている。キャッシュシステム２１、複製処理部２２、及び同一ファイル処理部２３により、本発明のデータ複製装置が構成される。

　キャッシュシステム２１は、キャッシュ判定部２１１と、キャッシュ処理部２１２と、送受信部２１３（受信部）と、一時記憶部２１４を備えている。

　キャッシュ判定部２１１は、ユーザクライアント４においてユーザが要求する要求ファイルが、一時記憶部２１４に記憶されているキャッシュデータに存在するか否かを判定する。

　キャッシュ処理部２１２は、キャッシュ判定部２１１にて上記要求ファイルがキャッシュデータに存在すると判定された場合に、この要求ファイルのキャッシュデータをユーザクライアント４に送信する制御指令を送受信部２１３に出力する。

　キャッシュ処理部２１２は、キャッシュ判定部２１１にて上記要求ファイルがキャッシュデータに存在しないと判定された場合に、後述する複製データ記憶部２２２から要求ファイルを取得し、一時記憶部２１４に記憶する。キャッシュ処理部２１２は、この要求ファイルのキャッシュデータを、ユーザクライアント４に送信するための制御指令を送受信部２１３に出力する。ユーザクライアント４のユーザは、キャッシュシステム２１から提供されるファイルを用いて各種の処理を実行することができる。

　送受信部２１３は、送信元サーバ１の送信部１２３から送信された第１の差分Ｄ１を受信し、一時記憶部２１４に出力して該当する即時ファイルを更新する。この際、即時ファイルの属性をマスタデータとして記憶する。「マスタデータ」は、キャッシュシステム２１に永続的に保存される属性である。送受信部２１３は、原本データに含まれる即時ファイルに変更が発生し、変更が発生した即時ファイルである第１の差分Ｄ１がリアルタイム処理で送信された際に第１の差分を受信する受信部としての機能を備えている。

　送受信部２１３は、ユーザクライアント４の要求によりキャッシュ処理部２１２で読み出されたファイルのキャッシュデータを、ユーザクライアント４に送信する。

　一時記憶部２１４は、キャッシュシステム２１で使用するキャッシュデータを記憶する。キャッシュデータは、原本データに含まれる即時ファイルの複製データを含む。一時記憶部２１４は、即時ファイルの複製データを記憶し、送受信部２１３にて第１の差分Ｄ１が受信された際に、この第１の差分Ｄ１に該当する即時ファイルを更新する。一時記憶部２１４は、ユーザクライアント４から要求される要求ファイル（即時ファイル、非即時ファイル）が後述する複製データ記憶部２２２に記憶されている際には、この要求ファイルを複製データ記憶部２２２から取得して記憶する。

　複製処理部２２は、送受信部２２１（受信部）と、複製データ記憶部２２２を備えている。

　送受信部２２１は、送信元サーバ１から送信される第２の差分Ｄ２を受信する。上述したように、第２の差分Ｄ２は、変更が発生した即時ファイル及び非即時ファイルである。送受信部２２１は、キャッシュ処理部２１２からファイルの読み込み指令が出力された際には、これを受信し、複製データ記憶部２２２に記憶されている該当するファイルを読み出して、キャッシュシステム２１に送信する。このファイルは、一時記憶部２１４に記憶される。送受信部２２１は、原本データに含まれる即時ファイル及び非即時ファイルの少なくとも一方に変更が発生し、変更が発生したファイルである第２の差分Ｄ２がバッチ処理で送信された際に、第２の差分Ｄ２を受信する受信部としての機能を備えている。

　複製データ記憶部２２２は、原本データ記憶部１１に記憶されている原本データに含まれる即時ファイル、及び非即時ファイルの複製データを記憶する。複製データ記憶部２２２は、即時ファイル及び非即時ファイルの複製データを記憶し、第２の差分Ｄ２が受信された際には、第２の差分Ｄ２に該当する即時ファイル及び非即時ファイルの少なくとも一方を更新する。

　同一ファイル処理部２３は、同一ファイル判定部２３１と、表示制御部２３２（隠蔽処理部）を備えている。同一ファイル処理部２３は、例えばキャッシュシステム２１のプログラムの一部を変更することにより、キャッシュシステム２１のプログラムに設定することができる。また、同一ファイル処理部２３は、キャッシュシステム２１とインターフェースを介して連携されている外部システムにプログラムを実装することにより設定することができる。

　同一ファイル判定部２３１は、一時記憶部２１４に記憶されている即時ファイル（属性がマスタデータとして記憶されているキャッシュデータ）と、複製データ記憶部２２２に記憶されている即時ファイルが同一であるか否かを判定する。前述したように、一時記憶部２１４に記憶されている即時ファイルは、第１の差分Ｄ１により更新されるので、複製データ記憶部２２２において第２の差分Ｄ２により更新された即時ファイルと重複する。即ち、同一の即時ファイルが、一時記憶部２１４及び複製データ記憶部２２２に重複して記憶されることになる。

　同一ファイル判定部２３１は、例えば、所定時間が経過するごとに同一性の判定処理を実行してもよい。同一ファイル判定部２３１は、複製データ記憶部２２２において、第２の差分Ｄ２によるファイルの更新が完了したことをトリガーとして、同一性の判定処理を実行してもよい。

　同一ファイル判定部２３１は、例えば下記（Ａ）～（Ｃ）に示す方法を採用して同一ファイルであるか否かを判定する。

（Ａ）一時記憶部２１４に記憶されているキャッシュデータと、複製データ記憶部２２２に記憶されている即時ファイルの、ファイル名を対比して同一性を判定する。
（Ｂ）一時記憶部２１４に記憶されているキャッシュデータと、複製データ記憶部２２２に記憶されている即時ファイルの、ファイルサイズ、ファイルの作成日時、ファイルの更新日時などのメタ情報を対比して同一性を判定する。
（Ｃ）一時記憶部２１４に記憶されているキャッシュデータと、複製データ記憶部２２２に記憶されている即時ファイルの、ハッシュ値を比較して同一性を判定する。

　即ち、同一ファイル判定部２３１は、即時ファイルのファイル名、ファイルサイズ、ファイルの作成日時、ファイルの更新日時、及びファイルのハッシュ値のうちの少なくとも一つを用いて、一時記憶部２１４と複製データ記憶部２２２に同一の即時ファイルが存在するか否かを判定する。

　上述したキャッシュ処理部２１２は、同一ファイル判定部２３１にて同一ファイルが存在すると判定された場合には、一時記憶部２１４に記憶されている該当する即時ファイルのキャッシュデータの属性を、キャッシュシステムに永続的に保存される属性である「マスタデータ」から、所定の条件に基づいて当該ファイルを削除する属性である「キャッシュ」に変更する。所定の条件は、例えばファイルの使用期間が一定期間に達した場合、ファイルを使用していない期間が一定期間に達した場合、一時記憶部２１４の記憶容量が所定の閾値に達した場合、の少なくとも一つの場合とすることができる。

　表示制御部２３２は、ディスプレイなどの表示部にユーザクライアント４が使用可能なファイルを表示する。ユーザクライアント４のユーザは、使用可能なファイルを閲覧して使用するファイルを選択することができる。なお、ファイルは表示部に表示する以外にも、音声などで提示してもよい。表示制御部２３２は、同一ファイル判定部２３１にて、同一ファイルが存在すると判定された場合には、複製データ記憶部２２２に記憶されている該当するファイルを、ユーザが閲覧できないように隠蔽する。ファイルを隠蔽する処理として、キャッシュシステム２１のＡＣＬ（Access Control List）機能で、隠蔽の対象となる即時ファイルを全てのファイル利用者に参照できないようにする方法を用いることができる。

　このため、一時記憶部２１４に記憶されている即時ファイル、及び、複製データ記憶部２２２に記憶されている同一の即時ファイルが重複して表示部に表示されることを回避できる。即ち、表示制御部２３２は、同一ファイル判定部２３１にて同一の即時ファイルが存在すると判定された際に、複製データ記憶部２２２に記憶された該当する即時ファイルを隠蔽する隠蔽処理部としての機能を備えている。

　表示制御部２３２は、対象となる即時ファイルが一時記憶部２１４から削除された際には、この即時ファイルの隠蔽を解除する。即ち、表示制御部２３２は、隠蔽した即時ファイルに対してユーザからの取得要求が一定期間発生していない、或いは、隠蔽した即時ファイルが一定期間使用されていない場合に、一時記憶部２１４に記憶されている隠蔽した即時ファイルを削除し、複製データ記憶部２２２に記憶されている隠蔽した即時ファイルの隠蔽を解除する機能を備えている。

　［第１実施形態の動作］
　次に、第１実施形態に係るデータ複製システム１００の動作を、図２に示すフローチャートを参照して説明する。

　初めに、図２のステップＳ１１において、送信元サーバ１の差分判定部１２１は、原本データ記憶部１１に記憶されている原本データに含まれる各種のファイルに、変更処理が発生したか否かを判定する。

　変更処理が発生した場合には（Ｓ１１；ＹＥＳ）、ステップＳ１２において即時性判定部１２２は、変更が発生したファイルが即時ファイルであるか、非即時ファイルであるかを判定する。

　ステップＳ１３において送信部１２３は、変更処理が発生した即時ファイル（第１の差分Ｄ１）をリアルタイム処理で送信先サーバ２のキャッシュシステム２１に送信する。送信部１２３は、変更処理が発生した即時ファイル及び非即時ファイル（第２の差分Ｄ２）を一定の時間間隔、或いは任意のタイミングでバッチ処理により送信先サーバ２の複製処理部２２に送信する。

　ステップＳ１４においてキャッシュシステム２１の送受信部２１３は、リアルタイム処理で送信された第１の差分Ｄ１を受信する。複製処理部２２の送受信部２２１は、バッチ処理で送信された第２の差分Ｄ２を受信する。

　ステップＳ１５においてキャッシュシステム２１のキャッシュ処理部２１２は、第１の差分Ｄ１に基づいて、一時記憶部２１４に記憶されているキャッシュデータの該当する即時ファイルを更新する。即ち、一時記憶部２１４に記憶されている即時ファイルのキャッシュデータは、変更処理された即時ファイルに更新される。即時ファイルは、キャッシュシステムに永続的に保存される属性であるマスタデータとして記憶される。

　ステップＳ１６において複製処理部２２の送受信部２２１は、第２の差分Ｄ２に基づいて、複製データ記憶部２２２に記憶されている各ファイル（即時ファイル、非即時ファイル）の該当するファイルを更新する。即ち、複製データ記憶部２２２に記憶されている複製データの該当する即時ファイル及び非即時ファイルは、変更処理されたファイルに更新される。

　ステップＳ１７において同一ファイル判定部２３１は、一時記憶部２１４に記憶されている即時ファイルと、複製データ記憶部２２２に記憶されている即時ファイルの同一性を判定する。同一性の判定は、上述した（Ａ）～（Ｃ）に示した方法を採用することができる。

　ステップＳ１８において、同一の即時ファイルが存在すると判定された場合には（Ｓ１８；ＹＥＳ）、ステップＳ１９に処理を進め、そうでなければ（Ｓ１８；ＮＯ）、本処理を終了する。

　ステップＳ１９において表示制御部２３２は、複製データ記憶部２２２に記憶されている該当する即時ファイルを隠蔽し、一時記憶部２１４の即時ファイルのみを優先して表示するように、キャッシュシステム２１に対して表示情報を出力する。その結果、ユーザクライアント４では、重複する即時ファイルのうち一時記憶部２１４の即時ファイルのみが閲覧可能となる。

　例えば、キャッシュシステム２１のＡＣＬ機能で当該即時ファイルを全てのファイル利用者に参照できないようにすることにより、ユーザが一時記憶部２１４の即時ファイルのみを閲覧可能な状態にすることができる。この状態でユーザクライアント４のユーザがファイルの取得要求を行った場合に、一時記憶部２１４に記憶されている即時ファイルがユーザクライアント４に転送され、ユーザは即時ファイルを取得することが可能になる。

　ステップＳ２０においてキャッシュ処理部２１２は、一時記憶部２１４に記憶されている即時ファイルのキャッシュデータの属性を、キャッシュシステムに永続的に保存される属性であるマスタデータから、所定の条件に基づいて当該ファイルを削除する属性であるキャッシュに変更する。

　ステップＳ２１においてキャッシュ処理部２１２は、上述した所定の条件により一時記憶部２１４に記憶されている即時データのキャッシュを削除する。例えば、ファイルの使用期間が一定期間に達した場合、ファイルを使用していない期間が一定期間に達した場合、或いは、一時記憶部２１４の記憶容量が所定の閾値に達した場合に、一時記憶部２１４に記憶されている即時データのキャッシュを削除する。

　ステップＳ２２において、表示制御部２３２は、複製データ記憶部２２２に記憶されている隠蔽された即時ファイルの隠蔽を解除し、ユーザクライアント４のユーザが閲覧可能な状態にする。従って、ユーザは一時記憶部２１４から削除された即時ファイルを引き続き閲覧することが可能になる。即ち、一時記憶部２１４に記憶されている即時ファイルが削除された際に、複製データ記憶部２２２に記憶されている該当する即時ファイルの隠蔽状態を解除されるので、ユーザはこの即時ファイルを閲覧することが可能になる。

　その後、ユーザクライアント４のユーザからファイル取得要求があった場合は、複製データ記憶部２２２に記憶されている対象となる即時ファイルがキャッシュシステム２１を経由して、一時記憶部２１４にキャッシュを格納される。その結果、ユーザは要求するファイルを取得することが可能になる。その後、本処理を終了する。

　このように、本実施形態に係るデータ複製装置は、原本データの複製データを生成するデータ複製装置であって、原本データに含まれる即時ファイルに発生した変更を示す第１の差分をリアルタイム処理で受信し、原本データに含まれる即時ファイル及び非即時ファイルの少なくとも一方に発生した変更を示す第２の差分をバッチ処理で受信する受信部（送受信部２１３、２２１）と、即時ファイルの複製データを記憶し、第１の差分の受信時に、第１の差分を用いて即時ファイルを更新する一時記憶部２１４と、即時ファイル及び非即時ファイルの少なくとも一方の複製データを記憶し、第２の差分の受信時に、第２の差分を用いて即時ファイル及び非即時ファイルの少なくとも一方を更新する複製データ記憶部２２２と、一時記憶部２１４及び複製データ記憶部２２２に重複する即時ファイルが存在するか否かを判定する判定部（同一ファイル判定部２３１）と、重複する即時ファイルが存在すると判定された場合に、一時記憶部２１４または複製データ記憶部２２２に記憶された即時ファイルを、隠蔽または削除する表示制御部２３２（隠蔽処理部）と、を備える。

　本実施形態に係るデータ複製システム１００では、原本データ記憶部１１に記憶されている即時ファイルに変更が発生した際に、変更された即時ファイル（第１の差分Ｄ１）をリアルタイム処理にてキャッシュシステム２１に送信し、一時記憶部２１４に記憶されている該当する即時ファイルを更新する。このため、ユーザクライアント４のユーザは、更新後の即時ファイルを迅速に取得して使用することが可能になる。

　また、原本データ記憶部１１に記憶されている即時ファイル及び非即時ファイルに変更が発生した際に、変更された即時ファイル及び非即時ファイル（第２の差分Ｄ２）をバッチ処理により複製処理部２２に送信し、複製データ記憶部２２２に記憶されている即時ファイル及び非即時ファイルを更新する。このため、ユーザクライアント４のユーザは、バッチ処理による第２の差分Ｄ２の送信後において、更新後の即時ファイル及び非即時ファイルを使用することが可能になる。

　更に、一時記憶部２１４、及び複製データ記憶部２２２に同一の即時ファイルが存在する場合には、複製データ記憶部２２２に記憶されている該当する即時ファイルを隠蔽する。このため、ユーザクライアント４のユーザは、一時記憶部２１４に記憶されている即時ファイルのキャッシュを検索することができる。また、複製データ記憶部２２２に記憶されている即時ファイルは検索できなくなる。従って、複数の同一ファイルが重複して検索され、ユーザが混乱するというトラブルを回避できる。

　一時記憶部２１４にキャッシュとして記憶されている即時ファイルは、一定時間の経過などの所定の条件が成立した場合には、一時記憶部２１４から削除される。この際、複製データ記憶部２２２に記憶されている該当する即時ファイルの隠蔽が解除され、ユーザクライアント４のユーザが検索可能な状態に変更される。

　従って、同一のファイルが重複して記憶されることを回避でき、不必要に記憶領域のリソースを使用することを回避できる。また、一時記憶部２１４にキャッシュとして記憶されている即時ファイルが削除された後において、この即時ファイルは複製データ記憶部２２２に記憶されるので、ユーザはこの即時ファイルを引き続き検索することが可能になる。

　［第１変形例の説明］
　次に、第１変形例について説明する。上述した実施形態では、一時記憶部２１４に記憶されている即時ファイルと同一の即時ファイルが複製データ記憶部２２２に記憶されている際には、この複製データ記憶部２２２に記憶されている即時ファイルの重複表示を行わないことにより、同一の即時ファイルが重複してユーザに検索されることを回避した。

　これに対して、第１変形例に係るデータ複製システムでは、複製データ記憶部２２２に即時ファイルが記憶された際に、この即時ファイルと同一の即時ファイルが一時記憶部２１４に記憶されている場合には、一時記憶部２１４に記憶されている該当する即時ファイルを削除することにより、同一の即時ファイルが重複してユーザに検索することを回避する。以下、詳細に説明する。

　図３は、第１変形例に係るデータ複製システム１０１の構成を示すブロック図である。図３に示すデータ複製システム１０１は、前述した図１と対比して、表示制御部２３２の代わりに削除制御部２３２ａを設けている点で相違する。それ以外の構成は図１と同様であるので、同一符号を付して構成説明を省略する。

　図３に示す削除制御部２３２ａは、複製データ記憶部２２２に記憶されている即時ファイルと同一の即時ファイルが、一時記憶部２１４に記憶された際に、一時記憶部２１４に記憶されている該当する即時ファイルを削除する。即ち、削除制御部２３２ａは、同一ファイル判定部２３１にて同一の即時ファイルが存在すると判定された際に、一時記憶部２１４に記憶された即時ファイルを削除する隠蔽処理部としての機能を備えている。

　前述したように、第２の差分Ｄ２はバッチ処理により送信されるので、リアルタイム処理で送信される第１の差分Ｄ１よりも遅れて送信先サーバ２にて受信される。従って、一時記憶部２１４においてリアルタイムで即時ファイルが更新されてから、複製データ記憶部２２２に記憶されている即時ファイルが更新されるまでに、時間差が生じることになる。

　第２の差分Ｄ２により複製データ記憶部２２２に記憶されているファイルが更新されるとき、即ち、リアルタイム処理により第１の差分Ｄ１が送信されてから一定時間の経過後には、既に即時ファイルの利用頻度が低下している可能性が高い。このため、一時記憶部２１４に記憶されている即時ファイルを削除しても大きな影響は発生しないものと想定される。

　従って、複製データ記憶部２２２に即時ファイルが記憶された際に、一時記憶部２１４に記憶されている同一の即時ファイルを削除することにより、即時ファイルが重複して存在することを回避する。即ち、削除制御部２３２ａは、一時記憶部２１４に記憶されている即時ファイルを削除する隠蔽処理部としての機能を備えている。

　次に、図４に示すフローチャートを参照して、第１変形例の動作について説明する。図４に示すステップＳ３１～Ｓ３８は、図２に示したステップＳ１１～Ｓ１８と同様であるので、説明を省略する。

　第１変形例では、ステップＳ３８において、一時記憶部２１４及び複製データ記憶部２２２に同一の即時ファイルが存在すると判定された際に（Ｓ３８；ＹＥＳ）、ステップＳ３９において削除制御部２３２ａは、一時記憶部２１４に記憶されている該当する即時ファイルを削除する。

　従って、一時記憶部２１４に記憶されている即時ファイルと複製データ記憶部２２２に記憶されている即時ファイルが重複することを回避でき、ユーザが混乱するという問題の発生を回避することができる。

　［第２変形例の説明］
　次に、第２変形例について説明する。上述した実施形態では一つの送信先サーバ２（データ複製装置）にキャッシュシステム２１、複製処理部２２、及び同一ファイル処理部２３が設けられる例について説明した。第２変形例では、キャッシュシステム２１及び同一ファイル処理部２３が設けられるサーバと、複製処理部２２が設けられるサーバが異なる点で上述した実施形態と相違する。

　図５は、第２変形例に係るデータ複製システム１０２の構成を示すブロック図である。図５に示すように第２変形例に係るデータ複製システム１０２は、送信元サーバ１と、サーバ２Ａと、サーバ２Ｂを備えており、各サーバ１、２Ａ、２Ｂは、ネットワーク３により接続されている。サーバ２Ａは、ユーザクライアント４に接続されている。２つのサーバ２Ａ、２Ｂにより、本発明のデータ複製装置が構成される。

　サーバ２Ａは、キャッシュシステム２１と、同一ファイル処理部２３を備えている。サーバ２Ｂは、複製処理部２２を備えている。キャッシュシステム２１、複製処理部２２、同一ファイル処理部２３は、前述した実施形態と同様の構成を備えている。

　第２変形例に係るデータ複製システム１０２は、サーバ２Ａとサーバ２Ｂの間の通信がネットワークなどの通信網を経由している以外は、構成、動作共に前述した図１に示した実施形態と同様であるので同一符号を付して詳細な説明を省略する。

　このように、第２変形例に係るデータ複製システム１０２では、複製処理部２２が設置されているサーバ２Ｂとは異なる場所に設置されたサーバ２Ａのキャッシュシステム２１により、キャッシュによる処理を実行することが可能になる。このため、各構成要素の設置場所が制限されることを回避することができ、融通性を向上させることが可能になる。

　上記説明した本実施形態のデータ複製装置（送信先サーバ２）には、図６に示すように例えば、ＣＰＵ（Central Processing Unit、プロセッサ）９０１と、メモリ９０２と、ストレージ９０３（ＨＤＤ：Hard Disk Drive、ＳＳＤ：Solid StateDrive）と、通信装置９０４と、入力装置９０５と、出力装置９０６とを備える汎用的なコンピュータシステムを用いることができる。メモリ９０２およびストレージ９０３は、記憶装置である。このコンピュータシステムにおいて、ＣＰＵ９０１がメモリ９０２上にロードされた所定のプログラムを実行することにより、データ複製装置（サーバ２）の各機能が実現される。

　なお、データ複製装置（サーバ２）は、１つのコンピュータで実装されてもよく、あるいは複数のコンピュータで実装されても良い。また、データ複製装置（サーバ２）は、コンピュータに実装される仮想マシンであっても良い。データ複製装置（サーバ２）は、クラウド上に構成されてもよい。サーバ１（送信元サーバ）についても同様に、クラウド上に構成されてもよい。

　なお、データ複製装置（サーバ２）用のプログラムは、ＨＤＤ、ＳＳＤ、ＵＳＢ（Universal Serial Bus）メモリ、ＣＤ (Compact Disc)、ＤＶＤ (Digital Versatile Disc)などのコンピュータ読取り可能な記録媒体に記憶することも、ネットワークを介して配信することもできる。コンピュータ読取り可能な記録媒体は、例えば非一時的な（non-transitory）記録媒体である。

　なお、本発明は上記実施形態に限定されるものではなく、その要旨の範囲内で数々の変形が可能である。

　１　送信元サーバ（他のサーバ）
　２　送信先サーバ（一のサーバ、データ複製装置）
　２Ａ、２Ｂ　サーバ
　３　ネットワーク
　４　ユーザクライアント
　１１　原本データ記憶部
　１２　制御部
　２１　キャッシュシステム
　２２　複製処理部
　２３　同一ファイル処理部
　１００、１０１、１０２　データ複製システム
　１２１　差分判定部
　１２２　即時性判定部
　１２３　送信部
　２１１　キャッシュ判定部
　２１２　キャッシュ処理部
　２１３　送受信部（受信部）
　２１４　一時記憶部
　２２１　送受信部（受信部）
　２２２　複製データ記憶部
　２３１　同一ファイル判定部（判定部）
　２３２　表示制御部（隠蔽処理部）
　２３２ａ　削除制御部（隠蔽処理部）
　Ｄ１　第１の差分
　Ｄ２　第２の差分

Claims (8)

1. 　原本データの複製データを生成するデータ複製装置であって、
   　前記原本データに含まれる即時ファイルに発生した変更を示す第１の差分をリアルタイム処理で受信し、前記原本データに含まれる即時ファイル及び非即時ファイルの少なくとも一方に発生した変更を示す第２の差分をバッチ処理で受信する受信部と、
   　前記即時ファイルの複製データを記憶し、前記第１の差分の受信時に、前記第１の差分を用いて即時ファイルを更新する一時記憶部と、
   　前記即時ファイル及び前記非即時ファイルの少なくとも一方の複製データを記憶し、前記第２の差分の受信時に、前記第２の差分を用いて即時ファイル及び非即時ファイルの少なくとも一方を更新する複製データ記憶部と、
   　前記一時記憶部及び前記複製データ記憶部に重複する即時ファイルが存在するか否かを判定する判定部と、
   　重複する即時ファイルが存在すると判定された場合に、前記一時記憶部または前記複製データ記憶部に記憶された即時ファイルを、隠蔽または削除する隠蔽処理部と、
   　を備えたデータ複製装置。
2. 　前記隠蔽処理部は、重複する即時データが存在すると判定された場合に、前記複製データ記憶部に記憶された前記重複する即時ファイルを隠蔽して参照できないようにする
   　請求項１に記載のデータ複製装置。
3. 　前記隠蔽処理部は、重複する即時ファイルに対してユーザからの取得要求が一定期間発生していない場合、重複する即時ファイルが一定期間使用されていない場合、及び前記一時記憶部の記憶容量が所定の閾値に達した場合の、少なくとも一つの場合に、前記一時記憶部に記憶されている重複する即時ファイルを削除し、前記複製データ記憶部に記憶され、隠蔽された即時ファイルの隠蔽を解除する
   　請求項２に記載のデータ複製装置。
4. 　前記隠蔽処理部は、重複する即時データが存在すると判定された際に、前記一時記憶部に記憶された即時ファイルを削除する
   　請求項１に記載のデータ複製装置。
5. 　前記判定部は、前記即時ファイルのファイル名、ファイルサイズ、ファイルの作成日時、ファイルの更新日時、及びファイルのハッシュ値のうちの少なくとも一つを用いて、前記一時記憶部と前記複製データ記憶部に同一の即時ファイルが存在するか否かを判定する
   　請求項１に記載のデータ複製装置。
6. 　一のサーバ及び前記一のサーバに接続された他のサーバを備えたデータ複製システムであって、
   　前記他のサーバは、
   　複数のファイルを含む原本データを記憶する原本データ記憶部と、
   　前記複数のファイルのうち、変更が発生したファイルを判定する差分判定部と、
   　前記変更が発生したファイルが即時ファイルであるか、非即時ファイルであるかを判定する即時性判定部と、
   　即時ファイルに発生した変更を示す第１の差分をリアルタイム処理で前記一のサーバに送信し、即時ファイル及び非即時ファイルの少なくとも一方に発生した変更を示す第２の差分をバッチ処理にて前記一のサーバに送信する送信部と、を備え、
   　前記一のサーバは、
   　前記第１の差分及び第２の差分を受信する受信部と、
   　前記即時ファイルの複製データを記憶し、前記第１の差分の受信時に、前記第１の差分を用いて即時ファイルを更新する一時記憶部と、
   　前記即時ファイル及び前記非即時ファイルの少なくとも一方の複製データを記憶し、前記第２の差分の受信時に、前記第２の差分を用いて即時ファイル及び非即時ファイルの少なくとも一方を更新する複製データ記憶部と、
   　前記一時記憶部及び前記複製データ記憶部に重複する即時ファイルが存在するか否かを判定する判定部と、
   　重複する即時ファイルが存在すると判定された場合に、前記一時記憶部または前記複製データ記憶部に記憶された即時ファイルを、隠蔽または削除する隠蔽処理部と、
   　を備えたデータ複製システム。
7. 　原本データに含まれる即時ファイルに発生した変更を示す第１の差分をリアルタイム処理で受信するステップと、
   　前記原本データに含まれる即時ファイル及び非即時ファイルの少なくとも一方に発生した変更を示す第２の差分をバッチ処理で受信するステップと、
   　前記即時ファイルの複製データを一時記憶部に記憶し、前記第１の差分の受信時に、前記第１の差分を用いて即時ファイルを更新するステップと、
   　前記即時ファイル及び前記非即時ファイルの少なくとも一方の複製データを複製データ記憶部に記憶し、前記第２の差分の受信時に、前記第２の差分を用いて即時ファイル及び非即時ファイルの少なくとも一方を更新するステップと、
   　前記一時記憶部及び前記複製データ記憶部に重複する即時ファイルが存在するか否かを判定するステップと、
   　重複する即時ファイルが存在すると判定された場合に、前記一時記憶部または前記複製データ記憶部に記憶された即時ファイルを、隠蔽または削除するステップと、
   　を備えたデータ複製方法。
8. 　請求項１に記載のデータ複製装置としてコンピュータを機能させるデータ複製プログラム。

Images