ApsaraDB RDS:完全バックアップのクラウドへの移行

SQL Server 2012 以降、またはクラウドディスクを使用する SQL Server 2008 R2

1. 次のコマンドを実行して、ソースデータベースの現在の復旧モデルを確認します。

   SELECT
       name AS DatabaseName,
       recovery_model_desc AS RecoveryModel,
       state_desc AS State
   FROM sys.databases
   ORDER BY name;

   ApsaraDB RDS への移行用に本番バックアップを作成する前に、データベースの復旧モデルを FULL に変更します。

   ALTER DATABASE [db_simple] SET RECOVERY FULL WITH NO_WAIT;

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

3. スクリプトの SELECT ステートメントで、次のパラメーターを変更します。これらのパラメーターは、スクリプト内の YOU HAVE TO INIT PUBLIC VARIABLES HERE の下に記述されています。

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

4. バックアップスクリプトを実行します。

高性能ローカルディスクを使用する SQL Server 2008 R2

1. Microsoft SQL Server Management Studio (SSMS) を開きます。

2. 移行するデータベースにログインします。

3. 次のコマンドを実行して、ソースデータベースの現在の復旧モデルを確認します。

   USE master;
   GO
   SELECT name, CASE recovery_model
   WHEN 1 THEN 'FULL'
   WHEN 2 THEN 'BULK_LOGGED'
   WHEN 3 THEN 'SIMPLE' END model FROM sys.databases
   WHERE name NOT IN ('master','tempdb','model','msdb');
   GO

   • クエリ結果の model の値が FULL ではない場合は、手順 4 に進みます。

   • クエリ結果の model の値が FULL の場合は、手順 5 に進みます。

4. 次のコマンドを実行して、ソースデータベースの復旧モデルを FULL に設定します。

   ALTER DATABASE [dbname] SET RECOVERY FULL;
   GO
   ALTER DATABASE [dbname] SET AUTO_CLOSE OFF;
   GO

   重要

   復旧モデルを FULL に設定すると、生成される SQL Server ログが増加します。十分なディスク領域があることを確認してください。

5. 次のコマンドを実行して、ソースデータベースをバックアップします。

   この例では、dbtest データベースを backup.bak ファイルにバックアップします。

   USE master;
   GO
   BACKUP DATABASE [dbtest] to disk ='d:\backup\backup.bak' WITH COMPRESSION,INIT;
   GO

6. 次のコマンドを実行して、バックアップファイルの完全性を検証します。

   USE master
    GO
    RESTORE FILELISTONLY 
      FROM DISK = N'D:\backup\backup.bak';

   重要

   • 結果セットが返された場合、バックアップファイルは有効です。

   • エラーが報告された場合は、バックアップを再度実行してください。

7. オプション： 次のコマンドを実行して、データベースの復旧モデルを元に戻します。

   重要

   データベースの復旧モデルがすでに FULL の場合は、この手順をスキップしてください。

   ALTER DATABASE [dbname] SET RECOVERY SIMPLE;
   GO

SQL Server 2012 以降、またはクラウドディスクを使用する SQL Server 2008 R2

1. バックアップファイルを OSS にアップロードする前に、OSS にバケットを作成する必要があります。

   • OSS にバケットが既に存在する場合、バケットが次の要件を満たしていることを確認してください：

     • バケットのストレージクラスは 標準ストレージ です。 IA、アーカイブ、コールドアーカイブ、およびディープコールドアーカイブのストレージクラスはサポートされていません。

     • バケットに対して サーバー側の暗号化 が有効になっていないことを確認してください。

   • OSS にバケットが存在しない場合は、まずバケットを作成します。 (OSS が 有効化 されていることを確認してください。)

     1. OSS コンソールにログオンし、バケット をクリックし、次に バケットの作成 をクリックします。

     2. 次の主要なパラメーターを設定し、他のパラメーターはデフォルト値のままにします。

        重要

        • このバケットはこのデータ移行でのみ使用されため、主要なパラメーターのみを設定する必要があります。 移行完了後、データ漏洩や追加料金を防ぐために、バケットを速やかに削除してください。

        • バケット作成時に サーバー側の暗号化 を有効にしないでください。

        パラメーター	説明	例
        [バケット名]	バケットの名前。 名前はグローバルに一意である必要があり、バケット作成後は変更できません。 命名規則： 名前には、小文字、数字、ハイフン (-) のみ使用できます。 名前の先頭と末尾は、小文字または数字である必要があります。 名前の長さは 3～63 文字である必要があります。	migratetest
        [リージョン]	バケットが存在するリージョン。 ECS インスタンスから内部ネットワーク経由でバケットにデータをアップロードし、内部ネットワーク経由でデータを ApsaraDB RDS インスタンスに復元する場合、ECS インスタンス、バケット、ApsaraDB RDS インスタンスが同じリージョンに存在することを確認してください。	中国 (杭州)
        [ストレージタイプ]	[標準ストレージ] を選択します。 このトピックで説明する移行操作は、他のストレージクラスのバケットをサポートしていません。	スタンダード

2. バックアップファイルを OSS にアップロードします。

   セルフマネージドデータベースのバックアップが完了したら、バックアップファイルを ApsaraDB RDS インスタンスと 同じリージョン にある OSS バケットにアップロードします。 バケットと ApsaraDB RDS インスタンスが同じリージョンにある場合、バケットとインスタンスは内部ネットワーク経由で通信できます。 この場合、インターネットトラフィック料金は発生せず、データはより高速にアップロードされます。 次のいずれかの方法を使用できます：

   ossbrowser を使用したファイルのアップロード (推奨)

   1. ossbrowser をダウンロードします。

   2. この例では、Windows x64 を使用します。 ダウンロードした oss-browser-win32-x64.zip パッケージを解凍し、oss-browser.exe アプリケーションをダブルクリックします。

   3. ログオン方法として アクセスキー を選択し、Access Key ID と Access Key Secret パラメーターを設定し、その他のパラメーターはデフォルト値のままにして、ログイン をクリックします。

      説明

      AccessKey は、データセキュリティを確保するための ID 認証に使用されます。 AccessKey は機密情報として扱ってください。

   4. 移行先のバケットをクリックして、そのバケットに移動します。

   5. をクリックし、アップロードするバックアップファイルを選択して、[開く] をクリックします。 ローカルファイルが OSS にアップロードされます。

   OSS コンソールを使用したファイルのアップロード

   説明

   バックアップファイルのサイズが 5 GB 未満の場合は、OSS コンソールで直接バックアップファイルをアップロードできます。

   1. OSS コンソールにログインします。

   2. バケット をクリックし、移行先のバケットの名前をクリックします。

   3. ファイルリスト で、Upload File をクリックします。

   4. バックアップファイルを アップロードするファイル セクションにドラッグするか、ファイルの選択 をクリックして、アップロードするバックアップファイルを選択します。

   5. ページの下部にあるUpload Fileをクリックします。ローカルバックアップファイルが OSS にアップロードされます。

   OSS API を使用したファイルのアップロード (Python 3 プロジェクトの例)

   説明

   バックアップファイルのサイズが 5 GB を超える場合は、OSS API を呼び出して、マルチパートアップロードを使用してバックアップファイルを OSS バケットにアップロードしてください。

   # -*- coding: utf-8 -*-
   """
   Alibaba Cloud OSS Python SDK v2
   依存関係： pip install alibabacloud-oss-v2
   """
   
   import os
   import sys
   from pathlib import Path
   import alibabacloud_oss_v2 as oss
   from alibabacloud_oss_v2 import exceptions as oss_ex
   
   
   def get_client_from_env(region: str, endpoint: str | None = None) -> oss.Client:
       """
       環境変数から v2 クライアントを作成します。
       - リージョン (推奨) の使用を優先しますが、カスタムエンドポイント (オプション) もサポートします。
       - AK と STS の両方と互換性があります：
           * AK： OSS_ACCESS_KEY_ID / OSS_ACCESS_KEY_SECRET が必要
           * STS： OSS_SESSION_TOKEN も必要 (古い変数 OSS_SECURITY_TOKEN と互換性あり)
       """
       # 互換性： ユーザーが古い変数 OSS_SECURITY_TOKEN を使用している場合、v2 が期待する OSS_SESSION_TOKEN にマッピングします
       sec_token_legacy = os.getenv("OSS_SECURITY_TOKEN")
       if sec_token_legacy and not os.getenv("OSS_SESSION_TOKEN"):
           os.environ["OSS_SESSION_TOKEN"] = sec_token_legacy
   
       ak = os.getenv("OSS_ACCESS_KEY_ID")
       sk = os.getenv("OSS_ACCESS_KEY_SECRET")
       st = os.getenv("OSS_SESSION_TOKEN")  # STS トークン (オプション)
   
       if not (ak and sk):
           raise ValueError("No valid AK found. Set the OSS_ACCESS_KEY_ID and OSS_ACCESS_KEY_SECRET environment variables. "
                            "If using STS, also set OSS_SESSION_TOKEN (or the old name OSS_SECURITY_TOKEN).")
   
       # 使用される認証情報の種類を示します
       if st:
           print("STSトークン (OSS_SESSION_TOKEN) が検出されました。STS認証情報を使用します。")
       else:
           print("STSトークンは検出されませんでした。AccessKey (AK) 認証情報を使用します。")
   
       credentials_provider = oss.credentials.EnvironmentVariableCredentialsProvider()
       cfg = oss.config.load_default()
       cfg.credentials_provider = credentials_provider
   
       # 基本的なネットワーク設定
       cfg.region = region  # 例： 'cn-hangzhou'
       if endpoint:
           # オプション： カスタムエンドポイント (例： 内部ネットワーク、アクセラレーション、専用ドメイン)
           cfg.endpoint = endpoint
   
       # ここに他の設定を追加することもできます。例： cfg.use_accelerate_endpoint = True
       return oss.Client(cfg)
   
   
   def resumable_upload_file_v2(
       client: oss.Client,
       bucket_name: str,
       object_key: str,
       file_path: str,
       part_size: int = 1 * 1024 * 1024,
       parallel_num: int = 4,
       checkpoint_dir: str | None = None,
   ):
       """
       レジュームアップロードを使用して同時マルチパートアップロードを実装します。
   
       :param client: 初期化された oss.Client
       :param bucket_name: 移行先のバケット名
       :param object_key: 移行先のオブジェクトキー (バケット名なし)
       :param file_path: ローカルファイルのフルパス
       :param part_size: パートサイズ (バイト単位)、デフォルトは 1 MB
       :param parallel_num: 同時アップロードスレッド数、デフォルトは 4
       :param checkpoint_dir: ブレークポイント情報を保存するディレクトリ。None の場合、レジュームアップロードは無効になります
       """
       file_path = str(file_path)
       if not Path(file_path).exists():
           raise FileNotFoundError(f"Error: Local file not found. Check the file_path configuration: {file_path}")
   
       # Uploader を構築します。checkpoint_dir が提供されているかどうかに基づいてレジュームアップロードを有効にします
       if checkpoint_dir:
           uploader = client.uploader(
               enable_checkpoint=True,
               checkpoint_dir=checkpoint_dir,
               part_size=part_size,
               parallel_num=parallel_num,
           )
       else:
           uploader = client.uploader(
               part_size=part_size,
               parallel_num=parallel_num,
           )
   
       print(f"ファイルのアップロードを開始します: {file_path}")
       print(f"移行先バケット: {bucket_name}")
       print(f"移行先オブジェクト: {object_key}")
       print(f"パートサイズ: {part_size} バイト, 同時実行数: {parallel_num}")
       if checkpoint_dir:
           print(f"レジュームアップロード: 有効 (checkpoint_dir={checkpoint_dir})")
       else:
           print("レジュームアップロード: 無効 (有効にするには checkpoint_dir を設定してください)")
   
       # アップロードを実行します (Uploader はサイズに基づいてマルチ/シングルパートの同時アップロードを自動的に選択します)
       result = uploader.upload_file(
           oss.PutObjectRequest(bucket=bucket_name, key=object_key),
           filepath=file_path,
       )
   
       print("-" * 30)
       print("ファイルが正常にアップロードされました。")
       print(f"HTTPステータス: {result.status_code}")
       print(f"ETag: {result.etag}")
       print(f"Request ID: {result.request_id}")
       # CRC-64 チェックサム。v2 はデフォルトでデータ検証を有効にします
       print(f"CRC64: {result.hash_crc64}")
       print("-" * 30)
   
   
   def main():
       # コード例を実行する前に、対応する環境変数が設定されていることを確認してください。
       # macOS/Linux：
       #   AK 方式：
       #     export OSS_ACCESS_KEY_ID=YOUR_AK_ID
       #     export OSS_ACCESS_KEY_SECRET=YOUR_AK_SECRET
       #   STS 方式：
       #     export OSS_ACCESS_KEY_ID=YOUR_STS_ID
       #     export OSS_ACCESS_KEY_SECRET=YOUR_STS_SECRET
       #     export OSS_SECURITY_TOKEN=YOUR_STS_TOKEN
       #
       # Windows：
       #   Powershell： $env:OSS_ACCESS_KEY_ID="YOUR_AK_ID"
       #   cmd： set OSS_ACCESS_KEY_ID=YOUR_AK_ID
   
       # ===================== パラメーター (必要に応じて変更) =====================
       # リージョンの例： 'cn-hangzhou'。最初にリージョンを使用することを推奨します
       region = "cn-hangzhou"
   
       # オプション： カスタムエンドポイント (内部ネットワーク、専用ドメイン、アクセラレーションドメイン名など)
       # 例： 'https://oss-cn-hangzhou.aliyuncs.com'
       endpoint = 'https://oss-cn-hangzhou.aliyuncs.com'
   
       # バケットとオブジェクト
       bucket_name = "examplebucket"
       object_key = "test.bak"
   
       # アップロードするローカルファイルのフルパス。
       # Windows の例： r'D:\localpath\examplefile.txt' (先頭の r に注意)
       # macOS/Linux の例： '/Users/test/examplefile.txt'
       file_path = r"D:\oss\test.bak"
   
       # シャーディングと同時実行数
       part_size = 1 * 1024 * 1024  # デフォルトは 1 MB。OSS では最小パートサイズ 100 KB が必要です
       parallel_num = 4
   
       # レジュームアップロードディレクトリ (無効にするには None を渡します。書き込み可能なディレクトリを指定することを推奨します)
       checkpoint_dir = str(Path.cwd() / ".oss_checkpoints")
       # =================== パラメーターの終わり ===================
   
       print("スクリプトの実行を開始します...")
       try:
           client = get_client_from_env(region=region, endpoint=endpoint)
           # レジュームアップロードが有効な場合、ディレクトリが存在することを確認します
           if checkpoint_dir:
               Path(checkpoint_dir).mkdir(parents=True, exist_ok=True)
   
           resumable_upload_file_v2(
               client=client,
               bucket_name=bucket_name,
               object_key=object_key,
               file_path=file_path,
               part_size=part_size,
               parallel_num=parallel_num,
               checkpoint_dir=checkpoint_dir,
           )
       except FileNotFoundError as e:
           print(e)
       except oss_ex.ServiceError as e:
           # OSS サーバーから返されたエラー
           print("\nOSSサーバー側でエラーが発生しました。")
           print(f"HTTPステータス: {getattr(e, 'status_code', 'N/A')}")
           print(f"エラーコード: {getattr(e, 'code', 'N/A')}")
           print(f"メッセージ: {getattr(e, 'message', 'N/A')}")
           print(f"Request ID: {getattr(e, 'request_id', 'N/A')}")
           print(f"Endpoint: {getattr(e, 'request_target', 'N/A')}")
       except oss_ex.BaseError as e:
           # SDK のローカル/シリアル化/デシリアル化/認証情報エラー
           print("\nOSS SDKクライアント側でエラーが発生しました。")
           print(str(e))
       except Exception as e:
           print(f"\n不明なエラーが発生しました: {e}")
   
   
   if __name__ == "__main__":
       main()

高性能ローカルディスクを使用する SQL Server 2008 R2

1. バックアップファイルを OSS にアップロードする前に、OSS にバケットを作成する必要があります。

   • OSS にバケットが既に存在する場合、バケットが次の要件を満たしていることを確認してください：

     • バケットのストレージクラスは 標準ストレージ です。 IA、アーカイブ、コールドアーカイブ、およびディープコールドアーカイブのストレージクラスはサポートされていません。

     • バケットに対して サーバー側の暗号化 が有効になっていないことを確認してください。

   • OSS にバケットが存在しない場合は、まずバケットを作成します。 (OSS が 有効化 されていることを確認してください。)

     1. OSS コンソールにログオンし、バケット をクリックし、次に バケットの作成 をクリックします。

     2. 次の主要なパラメーターを設定し、他のパラメーターはデフォルト値のままにします。

        重要

        • このバケットはこのデータ移行でのみ使用されため、主要なパラメーターのみを設定する必要があります。 移行完了後、データ漏洩や追加料金を防ぐために、バケットを速やかに削除してください。

        • バケット作成時に サーバー側の暗号化 を有効にしないでください。

        パラメーター	説明	例
        [バケット名]	バケットの名前。 名前はグローバルに一意である必要があり、バケット作成後は変更できません。 命名規則： 名前には、小文字、数字、ハイフン (-) のみ使用できます。 名前の先頭と末尾は、小文字または数字である必要があります。 名前の長さは 3～63 文字である必要があります。	migratetest
        [リージョン]	バケットが存在するリージョン。 ECS インスタンスから内部ネットワーク経由でバケットにデータをアップロードし、内部ネットワーク経由でデータを ApsaraDB RDS インスタンスに復元する場合、ECS インスタンス、バケット、ApsaraDB RDS インスタンスが同じリージョンに存在することを確認してください。	中国 (杭州)
        [ストレージタイプ]	[標準ストレージ] を選択します。 このトピックで説明する移行操作は、他のストレージクラスのバケットをサポートしていません。	スタンダード

2. バックアップファイルを OSS にアップロードします。

   セルフマネージドデータベースのバックアップが完了したら、バックアップファイルを ApsaraDB RDS インスタンスと 同じリージョン にある OSS バケットにアップロードします。 バケットと ApsaraDB RDS インスタンスが同じリージョンにある場合、バケットとインスタンスは内部ネットワーク経由で通信できます。 この場合、インターネットトラフィック料金は発生せず、データはより高速にアップロードされます。 次のいずれかの方法を使用できます：

   ossbrowser を使用したファイルのアップロード (推奨)

   1. ossbrowser をダウンロードします。

   2. この例では、Windows x64 を使用します。 ダウンロードした oss-browser-win32-x64.zip パッケージを解凍し、oss-browser.exe アプリケーションをダブルクリックします。

   3. ログオン方法として アクセスキー を選択し、Access Key ID と Access Key Secret パラメーターを設定し、その他のパラメーターはデフォルト値のままにして、ログイン をクリックします。

      説明

      AccessKey は、データセキュリティを確保するための ID 認証に使用されます。 AccessKey は機密情報として扱ってください。

   4. 移行先のバケットをクリックして、そのバケットに移動します。

   5. をクリックし、アップロードするバックアップファイルを選択して、[開く] をクリックします。 ローカルファイルが OSS にアップロードされます。

   OSS コンソールを使用したファイルのアップロード

   説明

   バックアップファイルのサイズが 5 GB 未満の場合は、OSS コンソールで直接バックアップファイルをアップロードできます。

   1. OSS コンソールにログインします。

   2. バケット をクリックし、移行先のバケットの名前をクリックします。

   3. ファイルリスト で、Upload File をクリックします。

   4. バックアップファイルを アップロードするファイル セクションにドラッグするか、ファイルの選択 をクリックして、アップロードするバックアップファイルを選択します。

   5. ページの下部にあるUpload Fileをクリックします。ローカルバックアップファイルが OSS にアップロードされます。

   OSS API を使用したファイルのアップロード (Python 3 プロジェクトの例)

   説明

   バックアップファイルのサイズが 5 GB を超える場合は、OSS API を呼び出して、マルチパートアップロードを使用してバックアップファイルを OSS バケットにアップロードしてください。

   # -*- coding: utf-8 -*-
   """
   Alibaba Cloud OSS Python SDK v2
   依存関係： pip install alibabacloud-oss-v2
   """
   
   import os
   import sys
   from pathlib import Path
   import alibabacloud_oss_v2 as oss
   from alibabacloud_oss_v2 import exceptions as oss_ex
   
   
   def get_client_from_env(region: str, endpoint: str | None = None) -> oss.Client:
       """
       環境変数から v2 クライアントを作成します。
       - リージョン (推奨) の使用を優先しますが、カスタムエンドポイント (オプション) もサポートします。
       - AK と STS の両方と互換性があります：
           * AK： OSS_ACCESS_KEY_ID / OSS_ACCESS_KEY_SECRET が必要
           * STS： OSS_SESSION_TOKEN も必要 (古い変数 OSS_SECURITY_TOKEN と互換性あり)
       """
       # 互換性： ユーザーが古い変数 OSS_SECURITY_TOKEN を使用している場合、v2 が期待する OSS_SESSION_TOKEN にマッピングします
       sec_token_legacy = os.getenv("OSS_SECURITY_TOKEN")
       if sec_token_legacy and not os.getenv("OSS_SESSION_TOKEN"):
           os.environ["OSS_SESSION_TOKEN"] = sec_token_legacy
   
       ak = os.getenv("OSS_ACCESS_KEY_ID")
       sk = os.getenv("OSS_ACCESS_KEY_SECRET")
       st = os.getenv("OSS_SESSION_TOKEN")  # STS トークン (オプション)
   
       if not (ak and sk):
           raise ValueError("No valid AK found. Set the OSS_ACCESS_KEY_ID and OSS_ACCESS_KEY_SECRET environment variables. "
                            "If using STS, also set OSS_SESSION_TOKEN (or the old name OSS_SECURITY_TOKEN).")
   
       # 使用される認証情報の種類を示します
       if st:
           print("STSトークン (OSS_SESSION_TOKEN) が検出されました。STS認証情報を使用します。")
       else:
           print("STSトークンは検出されませんでした。AccessKey (AK) 認証情報を使用します。")
   
       credentials_provider = oss.credentials.EnvironmentVariableCredentialsProvider()
       cfg = oss.config.load_default()
       cfg.credentials_provider = credentials_provider
   
       # 基本的なネットワーク設定
       cfg.region = region  # 例： 'cn-hangzhou'
       if endpoint:
           # オプション： カスタムエンドポイント (例： 内部ネットワーク、アクセラレーション、専用ドメイン)
           cfg.endpoint = endpoint
   
       # ここに他の設定を追加することもできます。例： cfg.use_accelerate_endpoint = True
       return oss.Client(cfg)
   
   
   def resumable_upload_file_v2(
       client: oss.Client,
       bucket_name: str,
       object_key: str,
       file_path: str,
       part_size: int = 1 * 1024 * 1024,
       parallel_num: int = 4,
       checkpoint_dir: str | None = None,
   ):
       """
       レジュームアップロードを使用して同時マルチパートアップロードを実装します。
   
       :param client: 初期化された oss.Client
       :param bucket_name: 移行先のバケット名
       :param object_key: 移行先のオブジェクトキー (バケット名なし)
       :param file_path: ローカルファイルのフルパス
       :param part_size: パートサイズ (バイト単位)、デフォルトは 1 MB
       :param parallel_num: 同時アップロードスレッド数、デフォルトは 4
       :param checkpoint_dir: ブレークポイント情報を保存するディレクトリ。None の場合、レジュームアップロードは無効になります
       """
       file_path = str(file_path)
       if not Path(file_path).exists():
           raise FileNotFoundError(f"Error: Local file not found. Check the file_path configuration: {file_path}")
   
       # Uploader を構築します。checkpoint_dir が提供されているかどうかに基づいてレジュームアップロードを有効にします
       if checkpoint_dir:
           uploader = client.uploader(
               enable_checkpoint=True,
               checkpoint_dir=checkpoint_dir,
               part_size=part_size,
               parallel_num=parallel_num,
           )
       else:
           uploader = client.uploader(
               part_size=part_size,
               parallel_num=parallel_num,
           )
   
       print(f"ファイルのアップロードを開始します: {file_path}")
       print(f"移行先バケット: {bucket_name}")
       print(f"移行先オブジェクト: {object_key}")
       print(f"パートサイズ: {part_size} バイト, 同時実行数: {parallel_num}")
       if checkpoint_dir:
           print(f"レジュームアップロード: 有効 (checkpoint_dir={checkpoint_dir})")
       else:
           print("レジュームアップロード: 無効 (有効にするには checkpoint_dir を設定してください)")
   
       # アップロードを実行します (Uploader はサイズに基づいてマルチ/シングルパートの同時アップロードを自動的に選択します)
       result = uploader.upload_file(
           oss.PutObjectRequest(bucket=bucket_name, key=object_key),
           filepath=file_path,
       )
   
       print("-" * 30)
       print("ファイルが正常にアップロードされました。")
       print(f"HTTPステータス: {result.status_code}")
       print(f"ETag: {result.etag}")
       print(f"Request ID: {result.request_id}")
       # CRC-64 チェックサム。v2 はデフォルトでデータ検証を有効にします
       print(f"CRC64: {result.hash_crc64}")
       print("-" * 30)
   
   
   def main():
       # コード例を実行する前に、対応する環境変数が設定されていることを確認してください。
       # macOS/Linux：
       #   AK 方式：
       #     export OSS_ACCESS_KEY_ID=YOUR_AK_ID
       #     export OSS_ACCESS_KEY_SECRET=YOUR_AK_SECRET
       #   STS 方式：
       #     export OSS_ACCESS_KEY_ID=YOUR_STS_ID
       #     export OSS_ACCESS_KEY_SECRET=YOUR_STS_SECRET
       #     export OSS_SECURITY_TOKEN=YOUR_STS_TOKEN
       #
       # Windows：
       #   Powershell： $env:OSS_ACCESS_KEY_ID="YOUR_AK_ID"
       #   cmd： set OSS_ACCESS_KEY_ID=YOUR_AK_ID
   
       # ===================== パラメーター (必要に応じて変更) =====================
       # リージョンの例： 'cn-hangzhou'。最初にリージョンを使用することを推奨します
       region = "cn-hangzhou"
   
       # オプション： カスタムエンドポイント (内部ネットワーク、専用ドメイン、アクセラレーションドメイン名など)
       # 例： 'https://oss-cn-hangzhou.aliyuncs.com'
       endpoint = 'https://oss-cn-hangzhou.aliyuncs.com'
   
       # バケットとオブジェクト
       bucket_name = "examplebucket"
       object_key = "test.bak"
   
       # アップロードするローカルファイルのフルパス。
       # Windows の例： r'D:\localpath\examplefile.txt' (先頭の r に注意)
       # macOS/Linux の例： '/Users/test/examplefile.txt'
       file_path = r"D:\oss\test.bak"
   
       # シャーディングと同時実行数
       part_size = 1 * 1024 * 1024  # デフォルトは 1 MB。OSS では最小パートサイズ 100 KB が必要です
       parallel_num = 4
   
       # レジュームアップロードディレクトリ (無効にするには None を渡します。書き込み可能なディレクトリを指定することを推奨します)
       checkpoint_dir = str(Path.cwd() / ".oss_checkpoints")
       # =================== パラメーターの終わり ===================
   
       print("スクリプトの実行を開始します...")
       try:
           client = get_client_from_env(region=region, endpoint=endpoint)
           # レジュームアップロードが有効な場合、ディレクトリが存在することを確認します
           if checkpoint_dir:
               Path(checkpoint_dir).mkdir(parents=True, exist_ok=True)
   
           resumable_upload_file_v2(
               client=client,
               bucket_name=bucket_name,
               object_key=object_key,
               file_path=file_path,
               part_size=part_size,
               parallel_num=parallel_num,
               checkpoint_dir=checkpoint_dir,
           )
       except FileNotFoundError as e:
           print(e)
       except oss_ex.ServiceError as e:
           # OSS サーバーから返されたエラー
           print("\nOSSサーバー側でエラーが発生しました。")
           print(f"HTTPステータス: {getattr(e, 'status_code', 'N/A')}")
           print(f"エラーコード: {getattr(e, 'code', 'N/A')}")
           print(f"メッセージ: {getattr(e, 'message', 'N/A')}")
           print(f"Request ID: {getattr(e, 'request_id', 'N/A')}")
           print(f"Endpoint: {getattr(e, 'request_target', 'N/A')}")
       except oss_ex.BaseError as e:
           # SDK のローカル/シリアル化/デシリアル化/認証情報エラー
           print("\nOSS SDKクライアント側でエラーが発生しました。")
           print(str(e))
       except Exception as e:
           print(f"\n不明なエラーが発生しました: {e}")
   
   
   if __name__ == "__main__":
       main()

3. バックアップファイルの URL の有効期間を設定し、バックアップファイルの URL を取得します。

   1. OSS コンソールにログインします。

   2. バケット をクリックし、移行先のバケットの名前をクリックします。

   3. 左側のナビゲーションペインで、ファイル管理 > ファイルリスト を選択します。

   4. 宛先データベースのバックアップファイルの「操作」列で詳細をクリックし、表示されるパネルで[有効期限 (秒)]を 28800 秒 (8 時間) に変更します。

      重要

      バックアップファイルの URL は、バックアップファイルを OSS から ApsaraDB RDS に移行する際に必要です。 移行完了前に URL の有効期限が切れると、データ移行は失敗します。

   5. オブジェクト URL のコピー をクリックして、バックアップファイルの URL を取得します。

   6. バックアップファイルの URL を変更します。

      取得した URL は、デフォルトでファイルのパブリック URL です。 内部ネットワーク経由でデータを移行するには、ファイル URL のエンドポイントを内部エンドポイントに変更してください。

      たとえば、バックアップファイルの URL が http://rdstest.oss-cn-shanghai.aliyuncs.com/testmigraterds_20170906143807_FULL.bak?Expires=15141****&OSSAccessKeyId=TMP**** の場合、URL の oss-cn-shanghai.aliyuncs.com を oss-cn-shanghai-internal.aliyuncs.com に変更してください。

      重要

      内部エンドポイントは、ネットワークタイプとリージョンによって異なります。 詳細については、「リージョンとエンドポイントリージョンとエンドポイント」をご参照ください。

SQL Server 2012 以降、またはクラウドディスクを使用する SQL Server 2008 R2

1. RDSインスタンスにアクセスし、上部のリージョンを選択し、対象のRDSインスタンスのIDをクリックします。

2. 左側のナビゲーションペインで、復元 を選択します。

3. ページの上部にあるOSS バックアップデータをクラウド上で復元するをクリックします。

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

   説明

   • OSS バックアップデータ移行機能を初めて使用する場合、ApsaraDB RDS サービスアカウントによる OSS へのアクセスを承認する必要があります。権限付与アドレス をクリックして、承認を確定します。そうしないと、権限の問題が原因で OSS バケット ドロップダウンリストが空になります。

   • 目的のファイルがページに表示されない場合は、OSS 内のバックアップファイルの拡張子が要件を満たしているかどうかを確認し (拡張子の要件はこのトピックの注意事項で確認できます)、ApsaraDB RDS インスタンスと OSS バケットが同じリージョンにあることを確認してください。

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

   パラメーター	説明
   [データベース名]	移行先 ApsaraDB RDS インスタンスにおいて、バックアップデータをインポートするデータベースの名前。名前は、SQL Server の公式命名規則に準拠している必要があります。 重要 データをクラウドに移行する前に、バックアップファイルから復元するデータベースと同じ名前のデータベースが移行先インスタンスに存在しないこと、および同じ名前のアタッチされていないデータベースファイルが存在しないことを確認してください。どちらも存在しない場合、バックアップセット内のターゲットデータベース名と同じ名前のデータベースファイルを使用してデータベースを復元できます。 バックアップファイルから復元するデータベースと同じ名前のデータベースが移行先インスタンスに存在する場合、または同じ名前のアタッチされていないデータベースファイルが存在する場合、移行は失敗します。
   [OSS バケット]	バックアップファイルが保存されている OSS バケットを選択します。
   [OSS ファイル]	右側の アイコンをクリックして、ファイル名のプレフィックスを指定してバックアップファイルを検索します。各ファイルのファイル名、ファイルサイズ、および更新時刻が表示されます。移行するバックアップファイルを選択します。
   [クラウド移行計画]	データベースを開く (完全バックアップファイルは 1 件のみ): 完全移行。 このオプションは、1 つの完全バックアップファイルのみを使用して移行するシナリオに適しています。 この例では、データベースを開く (完全バックアップファイルは 1 件のみ) が選択されています。 この場合、CreateMigrateTask 操作では BackupMode = FULL および IsOnlineDB = True となります。 [データベースを開かない (差分バックアップまたはログファイルがあります)]: 増分移行です。このオプションは、完全バックアップファイルと、ログバックアップファイルまたは差分バックアップファイルを一緒に使用して移行するシナリオに適しています。この場合、CreateMigrateTask 操作では BackupMode = UPDF および IsOnlineDB = False となります。
   [整合性のチェックメソッド]	非同期 DBCC：システムは、データベースを開く際に DBCC CHECKDB を実行しません。代わりに、データベースを開くタスクが完了した後、システムは非同期で DBCC CHECKDB を実行します。これにより、データベースを開く際の所要時間が短縮され (DBCC CHECKDB は大規模なデータベースでは時間がかかります)、サービス停止時間が短縮されます。サービスのダウンタイムを最小限に抑える必要があり、DBCC CHECKDB の結果が重要でない場合は、非同期 DBCC を使用してください。この場合、CreateMigrateTask API で CheckDBMode = AsyncExecuteDBCheck となります。 同期 DBCC：非同期 DBCC と比較して、同期 DBCC は DBCC CHECKDB の結果を重視し、セルフマネージドデータベースのデータ整合性エラーを特定したいユーザーに適しています。この場合、データベースを開くために必要な時間が増加します。この場合、CreateMigrateTask API で CheckDBMode = SyncExecuteDBCheck となります。

6. OK をクリックします。

   移行タスクが完了するまでお待ちください。 更新 をクリックすると、タスクの最新のステータスを表示できます。 移行タスクが失敗した場合は、タスクの説明にあるメッセージに基づいて問題をトラブルシューティングしてください。 詳細については、このトピックの「一般的なエラー」をご参照ください。

   説明

   データ移行が完了すると、システムは ApsaraDB RDS インスタンスの自動バックアップポリシーに基づいて、指定されたバックアップ時間にバックアップを開始します。バックアップ時間は手動で変更できます。生成されたバックアップセットには移行されたデータが含まれており、ApsaraDB RDS インスタンスの復元 ページで表示できます。

   バックアップ時刻に達していないが、できるだけ早くクラウド上にバックアップを生成したい場合は、手動バックアップを実行できます。

SQL Server 2008 R2 (高性能ローカルディスク)

1. RDSインスタンスにアクセスし、上部のリージョンを選択し、対象のRDSインスタンスのIDをクリックします。

2. 左側のナビゲーションペインで、データベース管理 をクリックします。

3. 移行先データベースを探し、OSSからバックアップファイルを移行します を、アクション 列内でクリックします。

4. インポートガイド ダイアログボックスでメッセージを読み、次へ をクリックします。

5. OSS アップロードに関するメッセージを読み、次へ をクリックします。

6. バックアップファイルOSS URL フィールドにバックアップファイルの OSS URL を入力し、OK をクリックします。

   説明

   高性能ローカルディスクを使用する ApsaraDB RDS for SQL Server インスタンス (SQL Server 2008 R2) は、完全バックアップファイルを一度にクラウドに移行するソリューションのみをサポートします。

SQL Server 2012 以降、またはクラウドディスクを使用する SQL Server 2008 R2

ApsaraDB RDS インスタンスの左側のナビゲーションウィンドウで 復元 ページに移動し、クラウド上へのデータバックアップの記録 タブでバックアップ移行の履歴を確認できます。 履歴には、タスクステータス、タスク開始時刻、タスク終了時刻が含まれます。 デフォルトでは、先週の履歴が表示されます。 必要に応じて時間範囲を変更できます。

高性能ローカルディスクを使用する SQL Server 2008 R2

ApsaraDB RDS インスタンスの左側のナビゲーションウィンドウでデータ移行ページに移動し、対象の移行タスクを見つけてデータ移行の進捗を確認します。