【ノーコード】複数のAzure Blob Storage アカウントのデータを簡単レプリケーション

CData Sync は、いろいろなシナリオのデータレプリケーション（同期）を行うことができるスタンドアロンのアプリケーションです。例えば、sandbox および本番インスタンスのデータをデータベースに同期することができます。CData Sync のウェブインターフェースは複数のAzure Blob Storage コネクションを簡単に管理できます。本記事では、複数のAzure Blob Storage アカウントを一つのデータベースに同期する方法を説明します。

レプリケーションの同期先を設定

CData Sync では、Azure Blob Storage のデータ を何台のデータベースにでも複製できます。データベースはクラウドおよびオンプレミスの双方に対応しています。レプリケーションの同期先の設定には、［接続］タブから行います。

1. ［同期先］タブを選択します。
2. 同期先のアイコンをクリックします。本記事では、SQLite を使います。
3. 必要な接続プロパティを入力します。Azure Blob Storage をSQLite に複製するには、データソースボックスにファイルパスを指定します。
4. ［接続のテスト］をクリックして、正しく接続できているかをテストします。
5. ［変更を保存］をクリックします。

Azure Blob Storage 接続の設定

データソース側にAzure Blob Storage を設定します。［接続］タブをクリックします。

1. ［接続の追加］セクションで［データソース］タブを選択します。
2. Azure Blob Storage アイコンをデータソースとして選択します。プリインストールされたソースにAzure Blob Storage がない場合には、追加データソースとしてダウンロードします。
3. 接続プロパティに入力をします。
   
   

   Azure Blob Storage に接続するには、以下の接続プロパティを設定します。

   • Connection Name：任意の接続名を入力します。
   • File Format：使用するファイル形式を選択します。Sync はCSV、PARQUET、AVRO ファイル形式に対応しています。
   • Azure Storage Account：Azure ストレージアカウント名を入力します。
   • URI：ファイルを含むファイルシステムとフォルダのパスを入力します（例：azureblob://MyContainer/MyBlob）。

   CData Sync はMicrosoft OneLake への認証方法を複数サポートしています。Entra ID（旧Azure AD）での認証方法については以下をご参照ください。

   Entra ID（旧Azure AD）

   Entra ID（旧Azure AD）ユーザーアカウントで接続するには、Auth Scheme で「Entra ID」（旧Azure AD）を選択します。CData Sync には組み込みのOAuth アプリケーションが用意されているため、追加のプロパティを設定する必要はありません。

   その他の認証方法については、ヘルプドキュメントをご参照ください。

   その他の認証方法

   • Azure Service Principal
   • Azure Service Principal Certificate
   • Azure Managed Service Identity
   • Azure Access Key（デフォルト）
   • Azure Storage SAS
   
4. ［接続のテスト］をクリックして、正しく接続できているかをテストします。
5. ［変更を保存］をクリックします。

それぞれのAzure Blob Storage インスタンスのレプリケーションクエリの設定

Data Sync はレプリケーションをコントロールするSQL クエリを簡単なGUI 操作で設定できます。 レプリケーションジョブ設定には、［ジョブ］タブに進み、［ジョブを追加］ボタンをクリックします。 次にデータソースおよび同期先をそれぞれドロップダウンから選択します。

テーブル全体をレプリケーションする

テーブル全体をレプリケーションするには、［テーブル］セクションで［テーブルを追加］をクリックします。表示されたテーブルリストからレプリケーションするテーブルをチェックします。.

テーブルをカスタマイズしてレプリケーションする

SQL クエリを使って、レプリケーションをカスタマイズできます。REPLICATE 構文はデータベースのテーブルにデータをキャッシュし、保存するハイレベルコマンドです。Azure Blob Storage API がサポートするSELECT クエリを定義することができます。レプリケーションのカスタマイズにはテーブルセクションで［カスタムクエリの追加］をクリックして、クエリステートメントを記述します。

Azure Blob Storage のデータ のテーブルを差分更新でキャッシュするステートメントは次のとおり:

REPLICATE MyFolder;

使用するレプリケーションクエリを含むファイルを指定することで特定のデータベースを更新することが可能です。レプリケーションステートメントをセミコロンで区切ります。次のオプションは一つのデータベースに複数のAzure Blob Storage アカウントのデータを同期する例です:

• REPLICATE SELECT ステートメントで異なるtable prefix を使用する:

  REPLICATE PROD_MyFolder SELECT * FROM MyFolder;
  

• 別の方法として、異なるスキーマを使うことも可能です:

  REPLICATE PROD.MyFolder SELECT * FROM MyFolder;
  

レプリケーションのスケジュール起動

［スケジュール］セクションでは、レプリケーションジョブの自動起動スケジュール設定が可能です。反復同期間隔は、15分おきから毎月1回までの間で設定が可能です。

レプリケーションジョブを設定したら、［変更を保存］します。このように複数のAzure Blob Storage アカウントのデータを複製するジョブを作成することができました。