ApsaraDB RDS:増分バックアップデータの移行（SQL Server 2008 R2（クラウドディスク搭載）および SQL Server 2012 以降向け）

仕組み

移行は以下の 2 つのフェーズで実行されます。

1. 完全データ移行： ソースデータベースをバックアップし、完全バックアップファイルを OSS バケットにアップロードして、ApsaraDB RDS コンソールから RDS インスタンスにリストアします。

2. 増分フェーズ： ログバックアップまたは差分バックアップファイルを繰り返しバックアップ・アップロードしてデータギャップを縮小します。最終ログバックアップのサイズが 500 MB 未満になったら、ソースデータベースへの書き込みを停止し、最終ログバックアップをアップロードしてからターゲットデータベースを開きます。

前提条件

セルフマネージド SQL Server インスタンス：

• FULL 復元モード を使用していること。SIMPLE 復元モードではトランザクションログバックアップがサポートされておらず、増分移行に必要なログバックアップが実行できません。

• ソースデータベースで DBCC CHECKDB を実行し、割り当てエラーまたは整合性エラーが報告されていないことを確認してください。

  CHECKDB found 0 allocation errors and 0 consistency errors in database 'xxx'.
  DBCC execution completed. If DBCC printed error messages, contact your system administrator.

RDS インスタンス：

• SQL Server 2012 以降、またはクラウドディスク搭載の SQL Server 2008 R2 を実行していること。

• RDS インスタンス上に、ソースデータベースと同じ名前の既存データベースや、同じ名前の未アタッチデータベースファイルが存在しないこと。名前が重複すると、リストアが失敗します。

• 利用可能なストレージ容量が、移行対象のデータファイルのサイズより大きいこと。ストレージ容量を拡張する必要がある場合は、事前に実施してください。

権限付与：

ApsaraDB RDS サービスアカウントがご利用の OSS バケットにアクセスできる必要があります。権限付与を確認・実施するには、以下の手順に従ってください。

1. RDS インスタンスの バックアップと復元 ページで、OSS バックアップデータを RDS に移行 をクリックします。

2. インポートガイド ウィザードで、次へ を 2 回クリックして、ステップ 3. データのインポート に進みます。

3. ページ左下隅を確認します。You have authorized RDS official service account to access your OSS と表示されている場合は、権限付与は完了しています。表示されていない場合は、Authorization URL リンクをクリックして権限を付与してください。

Resource Access Management (RAM) ユーザーをご利用の場合、以下の追加要件が適用されます。

• RAM ユーザーには AliyunOSSFullAccess および AliyunRDSFullAccess 権限が付与されていること。RAM を使用した OSS 権限の管理 および RAM を使用した ApsaraDB RDS 権限の管理 をご参照ください。

• Alibaba Cloud アカウントでカスタムアクセスポリシーを作成し、それを RAM ユーザーにアタッチしています。

  import com.aliyun.oss.*;
  import com.aliyun.oss.common.auth.*;
  import com.aliyun.oss.common.comm.SignVersion;
  import com.aliyun.oss.internal.Mimetypes;
  import com.aliyun.oss.model.*;
  import java.io.File;
  import java.io.FileInputStream;
  import java.io.InputStream;
  import java.util.ArrayList;
  import java.util.List;
  
  public class Demo {
  
      public static void main(String[] args) throws Exception {
          // ご使用のバケットのリージョンに対応するエンドポイントに置き換えてください。
          String endpoint = "https://oss-cn-hangzhou.aliyuncs.com";
          // 認証情報は、環境変数 OSS_ACCESS_KEY_ID および OSS_ACCESS_KEY_SECRET から読み込まれます。
          EnvironmentVariableCredentialsProvider credentialsProvider = CredentialsProviderFactory.newEnvironmentVariableCredentialsProvider();
          String bucketName = "examplebucket";
          // バケット内の完全なオブジェクトパス（バケット名を除く）。
          String objectName = "exampledir/exampleobject.txt";
          // アップロードするバックアップファイルの完全なローカルパス。
          String filePath = "D:\\localpath\\examplefile.txt";
          // バケットのリージョン識別子（例：「cn-hangzhou」）。
          String region = "cn-hangzhou";
  
          ClientBuilderConfiguration clientBuilderConfiguration = new ClientBuilderConfiguration();
          clientBuilderConfiguration.setSignatureVersion(SignVersion.V4);
          OSS ossClient = OSSClientBuilder.create()
                  .endpoint(endpoint)
                  .credentialsProvider(credentialsProvider)
                  .clientConfiguration(clientBuilderConfiguration)
                  .region(region)
                  .build();
  
          try {
              // マルチパートアップロードを開始します。
              InitiateMultipartUploadRequest request = new InitiateMultipartUploadRequest(bucketName, objectName);
              ObjectMetadata metadata = new ObjectMetadata();
              if (metadata.getContentType() == null) {
                  metadata.setContentType(Mimetypes.getInstance().getMimetype(new File(filePath), objectName));
              }
              request.setObjectMetadata(metadata);
              InitiateMultipartUploadResult upresult = ossClient.initiateMultipartUpload(request);
              String uploadId = upresult.getUploadId();
  
              List<PartETag> partETags = new ArrayList<PartETag>();
              // 各パートのサイズは 1 MB です。ファイルサイズおよびネットワーク状況に応じて調整してください。
              final long partSize = 1 * 1024 * 1024L;
  
              final File sampleFile = new File(filePath);
              long fileLength = sampleFile.length();
              int partCount = (int) (fileLength / partSize);
              if (fileLength % partSize != 0) {
                  partCount++;
              }
  
              // 各パートを順次アップロードします。
              for (int i = 0; i < partCount; i++) {
                  long startPos = i * partSize;
                  long curPartSize = (i + 1 == partCount) ? (fileLength - startPos) : partSize;
                  UploadPartRequest uploadPartRequest = new UploadPartRequest();
                  uploadPartRequest.setBucketName(bucketName);
                  uploadPartRequest.setKey(objectName);
                  uploadPartRequest.setUploadId(uploadId);
                  InputStream instream = new FileInputStream(sampleFile);
                  instream.skip(startPos);
                  uploadPartRequest.setInputStream(instream);
                  // 最後のパートは 100 KB より小さくても構いませんが、他のすべてのパートは最低でも 100 KB である必要があります。
                  uploadPartRequest.setPartSize(curPartSize);
                  // パート番号は 1 ～ 10,000 の範囲です。
                  uploadPartRequest.setPartNumber(i + 1);
                  UploadPartResult uploadPartResult = ossClient.uploadPart(uploadPartRequest);
                  partETags.add(uploadPartResult.getPartETag());
                  instream.close();
              }
  
              // アップロードを完了します。OSS はすべてのパートを順序通りにアセンブルします。
              CompleteMultipartUploadRequest completeMultipartUploadRequest =
                      new CompleteMultipartUploadRequest(bucketName, objectName, uploadId, partETags);
              CompleteMultipartUploadResult completeMultipartUploadResult = ossClient.completeMultipartUpload(completeMultipartUploadRequest);
              System.out.println("アップロード成功、ETag: " + completeMultipartUploadResult.getETag());
  
          } catch (OSSException oe) {
              System.out.println("OSS がリクエストを拒否しました: " + oe.getErrorMessage()
                      + " (コード: " + oe.getErrorCode() + ", リクエスト ID: " + oe.getRequestId() + ")");
          } catch (ClientException ce) {
              System.out.println("OSS との通信でクライアントエラーが発生しました: " + ce.getMessage());
          } finally {
              if (ossClient != null) {
                  ossClient.shutdown();
              }
          }
      }
  }

注意事項

移行タイムラインの例

以下の例では、アプリケーションのダウンタイムを 5 分未満で移行を完了する方法を示しています。

ステップ 1：ソースデータベースのバックアップ

1. バックアップスクリプトをダウンロードし、SQL Server Management Studio (SSMS) で開きます。

2. 以下のパラメーターを設定します。

   パラメーター	説明
   @backup_databases_list	ソースデータベースの名前。複数のデータベース名を指定する場合は、セミコロン (;) またはカンマ (,) で区切ります。
   @backup_type	バックアップタイプ：FULL（完全バックアップ）、DIFF（差分バックアップ）、または LOG（ログバックアップ）。
   @backup_folder	バックアップファイルを保存するセルフマネージドインスタンス上のディレクトリ。ディレクトリが存在しない場合は自動的に作成されます。
   @is_run	1 を指定してバックアップを実行します; 0 を指定すると、チェックのみを実行します。

3. バックアップスクリプトを実行します。バックアップタイプに関係なく、.bak ファイルが生成されます。

ステップ 2：バックアップファイルを OSS にアップロード

バックアップファイルは、RDS インスタンスと同一リージョンの OSS バケット内に配置する必要があります。同一リージョンでの転送は内部ネットワークを使用するため、インターネットのアウトバウンド料金が発生せず、アップロード速度も向上します。

import com.aliyun.oss.*;
import com.aliyun.oss.common.auth.*;
import com.aliyun.oss.common.comm.SignVersion;
import com.aliyun.oss.internal.Mimetypes;
import com.aliyun.oss.model.*;
import java.io.File;
import java.io.FileInputStream;
import java.io.InputStream;
import java.util.ArrayList;
import java.util.List;

public class Demo {

    public static void main(String[] args) throws Exception {
        // バケットのリージョンに対応するエンドポイントに置き換えます。
        String endpoint = "https://oss-cn-hangzhou.aliyuncs.com";
        // 認証情報は環境変数 OSS_ACCESS_KEY_ID および OSS_ACCESS_KEY_SECRET から読み取ります。
        EnvironmentVariableCredentialsProvider credentialsProvider = CredentialsProviderFactory.newEnvironmentVariableCredentialsProvider();
        String bucketName = "examplebucket";
        // バケット内のオブジェクトのフルパス（バケット名を除く）。
        String objectName = "exampledir/exampleobject.txt";
        // アップロードするバックアップファイルのローカルフルパス。
        String filePath = "D:\\localpath\\examplefile.txt";
        // バケットのリージョン識別子（例："cn-hangzhou"）。
        String region = "cn-hangzhou";

        ClientBuilderConfiguration clientBuilderConfiguration = new ClientBuilderConfiguration();
        clientBuilderConfiguration.setSignatureVersion(SignVersion.V4);
        OSS ossClient = OSSClientBuilder.create()
                .endpoint(endpoint)
                .credentialsProvider(credentialsProvider)
                .clientConfiguration(clientBuilderConfiguration)
                .region(region)
                .build();

        try {
            // マルチパートアップロードを開始します。
            InitiateMultipartUploadRequest request = new InitiateMultipartUploadRequest(bucketName, objectName);
            ObjectMetadata metadata = new ObjectMetadata();
            if (metadata.getContentType() == null) {
                metadata.setContentType(Mimetypes.getInstance().getMimetype(new File(filePath), objectName));
            }
            request.setObjectMetadata(metadata);
            InitiateMultipartUploadResult upresult = ossClient.initiateMultipartUpload(request);
            String uploadId = upresult.getUploadId();

            List<PartETag> partETags = new ArrayList<PartETag>();
            // 各パーツは 1 MB。ファイルサイズやネットワーク状況に応じて調整してください。
            final long partSize = 1 * 1024 * 1024L;

            final File sampleFile = new File(filePath);
            long fileLength = sampleFile.length();
            int partCount = (int) (fileLength / partSize);
            if (fileLength % partSize != 0) {
                partCount++;
            }

            // 各パーツを順次アップロードします。
            for (int i = 0; i < partCount; i++) {
                long startPos = i * partSize;
                long curPartSize = (i + 1 == partCount) ? (fileLength - startPos) : partSize;
                UploadPartRequest uploadPartRequest = new UploadPartRequest();
                uploadPartRequest.setBucketName(bucketName);
                uploadPartRequest.setKey(objectName);
                uploadPartRequest.setUploadId(uploadId);
                InputStream instream = new FileInputStream(sampleFile);
                instream.skip(startPos);
                uploadPartRequest.setInputStream(instream);
                // 最後のパーツは 100 KB 未満でも構いません。それ以外のパーツは 100 KB 以上である必要があります。
                uploadPartRequest.setPartSize(curPartSize);
                // パーツ番号は 1 から 10,000 の範囲です。
                uploadPartRequest.setPartNumber(i + 1);
                UploadPartResult uploadPartResult = ossClient.uploadPart(uploadPartRequest);
                partETags.add(uploadPartResult.getPartETag());
                instream.close();
            }

            // アップロードを完了します。OSS はすべてのパーツを順序通りにアセンブルします。
            CompleteMultipartUploadRequest completeMultipartUploadRequest =
                    new CompleteMultipartUploadRequest(bucketName, objectName, uploadId, partETags);
            CompleteMultipartUploadResult completeMultipartUploadResult = ossClient.completeMultipartUpload(completeMultipartUploadRequest);
            System.out.println("アップロード成功、ETag：" + completeMultipartUploadResult.getETag());

        } catch (OSSException oe) {
            System.out.println("OSS がリクエストを拒否しました：" + oe.getErrorMessage()
                    + "（コード：" + oe.getErrorCode() + "、リクエスト ID：" + oe.getRequestId() + "）");
        } catch (ClientException ce) {
            System.out.println("OSS との通信でクライアントエラーが発生しました：" + ce.getMessage());
        } finally {
            if (ossClient != null) {
                ossClient.shutdown();
            }
        }
    }
}

ステップ 3：移行タスクの作成

1. インスタンス ページに移動します。上部ナビゲーションバーで RDS インスタンスのリージョンを選択し、インスタンス ID をクリックします。

2. 左側のナビゲーションウィンドウで、バックアップと復元 をクリックします。

3. ページ上部で、OSS バックアップデータを RDS に移行 をクリックします。

4. インポートガイド ウィザードで、次へ を 2 回クリックして データのインポート ステップに進みます。

   移行ウィザードを初めて使用する場合は、権限付与 をクリックして権限付与プロセスを完了してください。権限付与が行われていないと、OSS バケット ドロップダウンリストが空のままになります。

5. 以下のパラメーターを設定して、OK をクリックします。

   パラメーター	説明
   データベース名	RDS インスタンス上のターゲットデータベース名。インスタンス上に既存のデータベースまたは未アタッチデータベースファイルと名前が重複しないようにしてください。
   OSS バケット	完全バックアップファイルを含む OSS バケット。
   OSS ファイル	虫眼鏡アイコンをクリックして、ファイル名のプレフィックスでバックアップファイルを検索します。検索結果にはファイル名、サイズ、最終更新時刻が表示されます。
   クラウド移行方法	アクセス保留中（増分バックアップ） を選択します。これにより、データベースはリストア中の状態を維持し、増分バックアップを適用できるようになります（BackupMode = UPDF、IsOnlineDB = False）。即時アクセス（完全バックアップ） は選択しないでください。このオプションは完全バックアップ後にすぐにデータベースを開き、増分バックアップを受け付けません（BackupMode = FULL、IsOnlineDB = True）。

6. 更新 をクリックしてタスクステータスを監視します。タスクが失敗した場合は、「トラブルシューティング」をご参照ください。

ステップ 4：ログまたは差分バックアップファイルのインポート

完全バックアップのリストア後、データギャップを埋めるために増分バックアップを適用します。

1. インスタンス ページに移動し、ご利用のリージョンを選択してインスタンス ID をクリックします。

2. 左側のナビゲーションウィンドウで、バックアップと復元 をクリックしてから、バックアップデータのクラウド移行レコード タブをクリックします。

3. ターゲットデータベースを検索し、タスク操作 列の 増分ファイルのアップロード をクリックします。増分ファイルを選択して、OK をクリックします。

各ログバックアップファイルについて、このステップを繰り返し、時系列順にアップロードしてください。

最終ログまたは差分バックアップファイルのサイズを 500 MB 未満に保つようにしてください。データ整合性を確保するため、最終バックアップを生成する前にソースデータベースへのすべての書き込みを停止してください。

ステップ 5：データベースを開く

すべてのバックアップファイルのインポート後、ターゲットデータベースを開いて読み取り・書き込みを可能にします。

1. インスタンス ページに移動し、ご利用のリージョンを選択してインスタンス ID をクリックします。

2. 左側のナビゲーションウィンドウで、バックアップと復元 をクリックしてから、バックアップデータのクラウド移行レコード タブをクリックします。

3. ターゲットデータベースを検索し、タスク操作 列の データベースを開く をクリックします。

4. 整合性チェックモードを選択して、OK をクリックします。

   モード	動作	適用条件
   非同期 DBCC	データベースを即時に開き、その後バックグラウンドで DBCC CHECKDB を実行します。ダウンタイムを最小限に抑えます。（CheckDBMode = AsyncExecuteDBCheck）	ダウンタイムに敏感だが、整合性チェックの結果が即座に重要ではない場合。
   同期 DBCC	データベースを開く前に DBCC CHECKDB を実行します。データベースを開くまでの時間が長くなります。（CheckDBMode = SyncExecuteDBCheck）	データベースが本番稼働する前に、整合性チェックの結果が必要です。

ステップ 6：移行レコードの確認

バックアップと復元 ＞ バックアップデータのクラウド移行レコード に移動して、すべての移行タスクを確認できます。タスク操作 列の ファイル詳細の表示 をクリックすると、タスクに関連付けられた各バックアップファイルのステータスと詳細を確認できます。

移行完了後、ApsaraDB RDS はご利用のインスタンスに設定された自動バックアップポリシーに従ってデータベースを自動的にバックアップします。即時にバックアップを実行するには、手動バックアップを実行してください。

トラブルシューティング

完全バックアップ移行中に発生するエラーについては、本トピックの「トラブルシューティング」をご参照ください。

以下は増分バックアップ移行に特有のエラーです。

ターゲットデータベースが開けない

*ソースの SQL Server エディションがターゲット RDS エディションより上位ですか？*

エラーメッセージ：Failed to open database xxx.

セルフマネージド SQL Server インスタンスが、ターゲット RDS SQL Server エディションでサポートされていない機能（データ圧縮やテーブルパーティションなど）を使用しています。たとえば、ソースが Enterprise Edition で動作しており、ターゲットが Web Edition の場合、Enterprise 版専用の機能がこのエラーの原因となります。

解決策：

• セルフマネージドインスタンスでサポートされていない機能を無効化し、再度データベースをバックアップして移行を再試行します。

• ソースと同じ SQL Server エディションを実行する RDS インスタンスに切り替えます。「ApsaraDB RDS for SQL Server インスタンスの作成と使用」および「SQL Server のバージョンおよびエディション別のサポート機能」をご参照ください。

バックアップチェーン内の LSN 不一致

*増分バックアップが時系列順にアップロードされましたか？*

エラーメッセージ: このバックアップセットのログはログシーケンス番号 XXX から開始されており、データベースに適用するには新しすぎます。RESTORE LOG は異常に終了しています。

増分バックアップファイル内のログシーケンス番号（LSN）が、直前のバックアップからの連続性を維持していません。これは、増分ファイルが誤ったベースバックアップに対して適用された場合や、順序を守らずにアップロードされた場合に発生します。

解決策：増分バックアップファイルを、作成された順序に厳密に従って時系列順にアップロードしてください。

非同期 DBCC 実行後に整合性エラーが検出された

*ターゲットデータベースで DBCC CHECKDB が整合性エラーを報告しましたか？*

エラーメッセージ：asynchronously DBCC checkdb failed: CHECKDB found 0 allocation errors and 2 consistency errors in table 'XXX' (object ID XXX).

バックグラウンドで実行された整合性チェックにより、ターゲットデータベースにエラーが検出されました。これはソースデータに破損があることを示しています。

解決策：

• 以下のコマンドをターゲットデータベースで実行してエラーを修復します（データ損失が発生する可能性があります）。

  重要

  この文はデータ損失を引き起こす可能性があります。許容可能な場合にのみ使用してください。

  DBCC CHECKDB (DBName, REPAIR_ALLOW_DATA_LOSS)

• あるいは、まずソースデータベースを修復してから再度移行を実施します。

  DBCC CHECKDB (DBName, REPAIR_ALLOW_DATA_LOSS)

増分ファイルが期待される場面で完全バックアップファイルが選択された

*[増分ファイルのアップロード] ステップで完全バックアップファイルを選択しましたか？*

エラーメッセージ: バックアップセット (xxx) はデータベースのフルバックアップであり、トランザクションログまたは差分バックアップのみを受け付けます。

完全バックアップのリストア後、増分ファイルのアップロード ステップではログバックアップまたは差分バックアップファイルのみを受け付けます。

解決策：ログバックアップまたは差分バックアップファイルを選択してください。

データベース数の上限超過

*RDS インスタンスがデータベース数の上限に達しましたか？*

エラーメッセージ：The database (xxx) migration failed due to databases count limitation.

解決策：別の RDS インスタンスに移行するか、不要なデータベースを削除してください。

RAM ユーザーの権限に関する問題

*移行タスクの設定時に [OK] ボタンが選択不可になっていますか？*

RAM ユーザーに必要な権限が付与されていない可能性があります。AliyunOSSFullAccess、AliyunRDSFullAccess、およびカスタムの AliyunRDSImportRole ポリシーがすべて付与されていることを確認してください（「前提条件」をご参照ください）。

*RAM ユーザーが AliyunRDSImportRole 権限の付与時に no permission エラーを受けていますか？*

Alibaba Cloud アカウントを使用して、一時的に RAM ユーザーに AliyunRAMFullAccess 権限を付与してください。「RAM を使用した ApsaraDB RDS 権限の管理」をご参照ください。セットアップ完了後は、この権限を削除してください。

API リファレンス