ApsaraDB RDS:Migrasi cadangan penuh ke cloud

SQL Server 2012 atau versi lebih baru, atau SQL Server 2008 R2 dengan cloud disk

1. Jalankan perintah berikut untuk memeriksa model recovery saat ini dari database sumber:

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

   Sebelum membuat cadangan produksi untuk migrasi ke ApsaraDB RDS, ubah model recovery database menjadi FULL:

   ALTER DATABASE [db_simple] SET RECOVERY FULL WITH NO_WAIT;

2. Unduh skrip pencadangan, lalu buka skrip pencadangan tersebut di SQL Server Management Studio (SSMS).

3. Ubah parameter berikut dalam pernyataan SELECT skrip. Parameter tersebut berada di bawah YOU HAVE TO INIT PUBLIC VARIABLES HERE dalam skrip.

   Parameter	Deskripsi
   @backup_databases_list	Database yang ingin Anda cadangkan. Pisahkan beberapa database dengan titik koma (;) atau koma (,).
   @backup_type	Jenis pencadangan. Nilai yang valid: FULL: cadangan penuh. DIFF: backup diferensial. LOG: cadangan log.
   @backup_folder	Direktori lokal tempat file cadangan disimpan. Jika direktori tidak ada, direktori akan dibuat secara otomatis.
   @is_run	Menentukan apakah pencadangan dilakukan. Nilai yang valid: 1: melakukan pencadangan. 0: hanya melakukan pemeriksaan dan tidak melakukan pencadangan.

4. Jalankan skrip pencadangan.

SQL Server 2008 R2 dengan high-performance local disk

1. Buka Microsoft SQL Server Management Studio (SSMS).

2. Login ke database yang ingin Anda migrasikan.

3. Jalankan perintah berikut untuk memeriksa model recovery saat ini dari database sumber:

   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

   • Jika nilai model dalam hasil kueri bukan FULL, lakukan Langkah 4.

   • Jika nilai model dalam hasil kueri adalah FULL, lakukan Langkah 5.

4. Jalankan perintah berikut untuk mengatur model recovery database sumber menjadi FULL:

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

   Penting

   Setelah model recovery diatur ke FULL, lebih banyak log SQL Server yang dihasilkan. Pastikan ruang disk yang tersedia mencukupi.

5. Jalankan perintah berikut untuk mencadangkan database sumber.

   Dalam contoh ini, database dbtest dicadangkan ke file backup.bak.

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

6. Jalankan perintah berikut untuk memverifikasi integritas file cadangan:

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

   Penting

   • Jika set hasil dikembalikan, file cadangan valid.

   • Jika terjadi error, lakukan pencadangan ulang.

7. Opsional: Jalankan perintah berikut untuk mengembalikan model recovery database:

   Penting

   Jika model recovery database sudah FULL, lewati langkah ini.

   ALTER DATABASE [dbname] SET RECOVERY SIMPLE;
   GO

SQL Server 2012 atau versi lebih baru, atau SQL Server 2008 R2 dengan cloud disk

1. Sebelum mengunggah file cadangan ke OSS, Anda harus membuat bucket di OSS.

   • Jika bucket sudah ada di OSS, pastikan bucket memenuhi persyaratan berikut:

     • storage class bucket adalah Standard. Kelas penyimpanan IA, Archive, Cold Archive, dan Deep Cold Archive tidak didukung.

     • Server-side encryption tidak diaktifkan untuk bucket tersebut.

   • Jika belum ada bucket di OSS, buat bucket terlebih dahulu. (Pastikan OSS telah diaktifkan.)

     1. Login ke Konsol OSS, klik Buckets, lalu klik Create bucket.

     2. Konfigurasi parameter kunci berikut dan gunakan nilai default untuk parameter lainnya.

        Penting

        • Bucket hanya digunakan untuk migrasi data ini, sehingga Anda hanya perlu mengonfigurasi parameter kunci. Setelah migrasi selesai, segera hapus bucket untuk mencegah kebocoran data dan biaya tambahan.

        • Jangan aktifkan server-side encryption saat membuat bucket.

        Parameter	Deskripsi	Contoh
        Bucket Name	Nama bucket. Nama harus unik secara global dan tidak dapat diubah setelah bucket dibuat. Aturan penamaan: Nama hanya boleh berisi huruf kecil, angka, dan tanda hubung (-). Nama harus diawali dan diakhiri dengan huruf kecil atau angka. Nama harus terdiri dari 3 hingga 63 karakter.	migratetest
        Region	Wilayah tempat bucket berada. Jika Anda mengunggah data ke bucket dari instans ECS melalui jaringan internal dan memulihkan data ke instans ApsaraDB RDS melalui jaringan internal, pastikan instans ECS, bucket, dan instans ApsaraDB RDS berada di wilayah yang sama.	China (Hangzhou)
        Storage Type	Pilih Standard. Operasi migrasi yang dijelaskan dalam topik ini tidak mendukung bucket dengan kelas penyimpanan lain.	Standard

2. Unggah file cadangan ke OSS.

   Setelah pencadangan database yang dikelola sendiri selesai, unggah file cadangan ke bucket OSS yang berada di wilayah yang sama dengan instans ApsaraDB RDS Anda. Jika bucket dan instans ApsaraDB RDS berada di wilayah yang sama, bucket dan instans dapat berkomunikasi melalui jaringan internal. Dalam hal ini, tidak ada biaya lalu lintas Internet yang dikenakan dan data diunggah dengan kecepatan lebih tinggi. Anda dapat menggunakan salah satu metode berikut:

   Unggah file menggunakan ossbrowser (direkomendasikan)

   1. Unduh ossbrowser.

   2. Dalam contoh ini, Windows x64 digunakan. Ekstrak paket oss-browser-win32-x64.zip yang diunduh, lalu klik ganda aplikasi oss-browser.exe.

   3. Pilih AK sebagai metode login, konfigurasi parameter Access Key ID dan Access Key Secret, gunakan nilai default untuk parameter lainnya, lalu klik Log On.

      Catatan

      AccessKey digunakan untuk otentikasi identitas guna memastikan keamanan data. Simpan AccessKey Anda secara rahasia.

      

   4. Klik bucket tujuan untuk membuka bucket tersebut.

   5. Klik , pilih file cadangan yang ingin Anda unggah, lalu klik Open. File lokal diunggah ke OSS.

   Unggah file menggunakan Konsol OSS

   Catatan

   Jika ukuran file cadangan kurang dari 5 GB, unggah file cadangan langsung di Konsol OSS.

   1. Login ke Konsol OSS.

   2. Klik Buckets, lalu klik nama bucket tujuan.

   3. Di bagian Files, klik Upload File.

   4. Seret file cadangan ke bagian Files to Upload, atau klik Select Files dan pilih file cadangan yang ingin Anda unggah.

   5. Klik Upload File di bagian bawah halaman. File cadangan lokal diunggah ke OSS.

   Unggah file menggunakan API OSS (contoh proyek Python 3)

   Catatan

   Jika ukuran file cadangan lebih dari 5 GB, panggil operasi API OSS untuk mengunggah file cadangan ke bucket OSS menggunakan unggah multi-bagian.

   # -*- coding: utf-8 -*-
   """
   Alibaba Cloud OSS Python SDK v2
   Dependency: 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:
       """
       Create a v2 client from environment variables.
       - Prioritize using Region (recommended), but also support custom Endpoints (optional).
       - Compatible with both AK and STS:
           * AK: Requires OSS_ACCESS_KEY_ID / OSS_ACCESS_KEY_SECRET
           * STS: Also requires OSS_SESSION_TOKEN (compatible with the old variable OSS_SECURITY_TOKEN)
       """
       # Compatibility: If the user uses the old variable OSS_SECURITY_TOKEN, map it to the v2 expected 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 Token (optional)
   
       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).")
   
       # Indicate the type of credential used
       if st:
           print("STS Token (OSS_SESSION_TOKEN) detected. Using STS credentials.")
       else:
           print("No STS Token detected. Using AccessKey (AK) credentials.")
   
       credentials_provider = oss.credentials.EnvironmentVariableCredentialsProvider()
       cfg = oss.config.load_default()
       cfg.credentials_provider = credentials_provider
   
       # Basic network configuration
       cfg.region = region  # Example: 'cn-hangzhou'
       if endpoint:
           # Optional: Custom Endpoint (e.g., internal network, accelerated, dedicated domain)
           cfg.endpoint = endpoint
   
       # You can also add other configurations here, such as: 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,
   ):
       """
       Implement concurrent multipart upload with resumable upload.
   
       :param client: Initialized oss.Client
       :param bucket_name: Destination bucket name
       :param object_key: Destination object key (without bucket name)
       :param file_path: Full path of the local file
       :param part_size: Part size in bytes, default is 1 MB
       :param parallel_num: Number of concurrent upload threads, default is 4
       :param checkpoint_dir: Directory to store breakpoint information; if None, resumable upload is disabled
       """
       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}")
   
       # Construct the Uploader; enable resumable upload based on whether checkpoint_dir is provided
       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"Starting to upload file: {file_path}")
       print(f"Destination Bucket: {bucket_name}")
       print(f"Destination Object: {object_key}")
       print(f"Part size: {part_size} bytes, Concurrency: {parallel_num}")
       if checkpoint_dir:
           print(f"Resumable upload: Enabled (checkpoint_dir={checkpoint_dir})")
       else:
           print("Resumable upload: Disabled (set checkpoint_dir to enable)")
   
       # Execute the upload (Uploader automatically chooses between multi/single part concurrent upload based on size)
       result = uploader.upload_file(
           oss.PutObjectRequest(bucket=bucket_name, key=object_key),
           filepath=file_path,
       )
   
       print("-" * 30)
       print("File uploaded successfully!")
       print(f"HTTP Status: {result.status_code}")
       print(f"ETag: {result.etag}")
       print(f"Request ID: {result.request_id}")
       # CRC-64 checksum; v2 enables data validation by default
       print(f"CRC64: {result.hash_crc64}")
       print("-" * 30)
   
   
   def main():
       # Before running the code example, make sure you have set the corresponding environment variables.
       # macOS/Linux:
       #   AK method:
       #     export OSS_ACCESS_KEY_ID=YOUR_AK_ID
       #     export OSS_ACCESS_KEY_SECRET=YOUR_AK_SECRET
       #   STS method:
       #     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
   
       # ===================== Parameters (modify as needed) =====================
       # Region example: 'cn-hangzhou'; we recommend using Region first
       region = "cn-hangzhou"
   
       # Optional: Custom Endpoint (for internal network, dedicated domain, accelerated domain name, etc.)
       # Example: 'https://oss-cn-hangzhou.aliyuncs.com'
       endpoint = 'https://oss-cn-hangzhou.aliyuncs.com'
   
       # Bucket and Object
       bucket_name = "examplebucket"
       object_key = "test.bak"
   
       # Full path of the local file to upload.
       # Windows example: r'D:\localpath\examplefile.txt'  (note the r at the beginning)
       # macOS/Linux example: '/Users/test/examplefile.txt'
       file_path = r"D:\oss\test.bak"
   
       # Sharding and concurrency
       part_size = 1 * 1024 * 1024  # Default is 1 MB; OSS requires a minimum part size of 100 KB
       parallel_num = 4
   
       # Resumable upload directory (pass None to disable; we recommend specifying a writable directory)
       checkpoint_dir = str(Path.cwd() / ".oss_checkpoints")
       # =================== End of parameters ===================
   
       print("Script execution starts...")
       try:
           client = get_client_from_env(region=region, endpoint=endpoint)
           # If resumable upload is enabled, make sure the directory exists
           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:
           # Error returned by the OSS server
           print("\nAn OSS server-side error occurred.")
           print(f"HTTP Status: {getattr(e, 'status_code', 'N/A')}")
           print(f"Error Code: {getattr(e, 'code', 'N/A')}")
           print(f"Message: {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 local/serialization/deserialization/credential errors
           print("\nAn OSS SDK client-side error occurred.")
           print(str(e))
       except Exception as e:
           print(f"\nAn unknown error occurred: {e}")
   
   
   if __name__ == "__main__":
       main()

SQL Server 2008 R2 dengan high-performance local disk

1. Sebelum mengunggah file cadangan ke OSS, Anda harus membuat bucket di OSS.

   • Jika bucket sudah ada di OSS, pastikan bucket memenuhi persyaratan berikut:

     • storage class bucket adalah Standard. Kelas penyimpanan IA, Archive, Cold Archive, dan Deep Cold Archive tidak didukung.

     • Server-side encryption tidak diaktifkan untuk bucket tersebut.

   • Jika belum ada bucket di OSS, buat bucket terlebih dahulu. (Pastikan OSS telah diaktifkan.)

     1. Login ke Konsol OSS, klik Buckets, lalu klik Create bucket.

     2. Konfigurasi parameter kunci berikut dan gunakan nilai default untuk parameter lainnya.

        Penting

        • Bucket hanya digunakan untuk migrasi data ini, sehingga Anda hanya perlu mengonfigurasi parameter kunci. Setelah migrasi selesai, segera hapus bucket untuk mencegah kebocoran data dan biaya tambahan.

        • Jangan aktifkan server-side encryption saat membuat bucket.

        Parameter	Deskripsi	Contoh
        Bucket Name	Nama bucket. Nama harus unik secara global dan tidak dapat diubah setelah bucket dibuat. Aturan penamaan: Nama hanya boleh berisi huruf kecil, angka, dan tanda hubung (-). Nama harus diawali dan diakhiri dengan huruf kecil atau angka. Nama harus terdiri dari 3 hingga 63 karakter.	migratetest
        Region	Wilayah tempat bucket berada. Jika Anda mengunggah data ke bucket dari instans ECS melalui jaringan internal dan memulihkan data ke instans ApsaraDB RDS melalui jaringan internal, pastikan instans ECS, bucket, dan instans ApsaraDB RDS berada di wilayah yang sama.	China (Hangzhou)
        Storage Type	Pilih Standard. Operasi migrasi yang dijelaskan dalam topik ini tidak mendukung bucket dengan kelas penyimpanan lain.	Standard

2. Unggah file cadangan ke OSS.

   Setelah pencadangan database yang dikelola sendiri selesai, unggah file cadangan ke bucket OSS yang berada di wilayah yang sama dengan instans ApsaraDB RDS Anda. Jika bucket dan instans ApsaraDB RDS berada di wilayah yang sama, bucket dan instans dapat berkomunikasi melalui jaringan internal. Dalam hal ini, tidak ada biaya lalu lintas Internet yang dikenakan dan data diunggah dengan kecepatan lebih tinggi. Anda dapat menggunakan salah satu metode berikut:

   Unggah file menggunakan ossbrowser (direkomendasikan)

   1. Unduh ossbrowser.

   2. Dalam contoh ini, Windows x64 digunakan. Ekstrak paket oss-browser-win32-x64.zip yang diunduh, lalu klik ganda aplikasi oss-browser.exe.

   3. Pilih AK sebagai metode login, konfigurasi parameter Access Key ID dan Access Key Secret, gunakan nilai default untuk parameter lainnya, lalu klik Log On.

      Catatan

      AccessKey digunakan untuk otentikasi identitas guna memastikan keamanan data. Simpan AccessKey Anda secara rahasia.

      

   4. Klik bucket tujuan untuk membuka bucket tersebut.

   5. Klik , pilih file cadangan yang ingin Anda unggah, lalu klik Open. File lokal diunggah ke OSS.

   Unggah file menggunakan Konsol OSS

   Catatan

   Jika ukuran file cadangan kurang dari 5 GB, unggah file cadangan langsung di Konsol OSS.

   1. Login ke Konsol OSS.

   2. Klik Buckets, lalu klik nama bucket tujuan.

   3. Di bagian Files, klik Upload File.

   4. Seret file cadangan ke bagian Files to Upload, atau klik Select Files dan pilih file cadangan yang ingin Anda unggah.

   5. Klik Upload File di bagian bawah halaman. File cadangan lokal diunggah ke OSS.

   Unggah file menggunakan API OSS (contoh proyek Python 3)

   Catatan

   Jika ukuran file cadangan lebih dari 5 GB, panggil operasi API OSS untuk mengunggah file cadangan ke bucket OSS menggunakan unggah multi-bagian.

   # -*- coding: utf-8 -*-
   """
   Alibaba Cloud OSS Python SDK v2
   Dependency: 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:
       """
       Create a v2 client from environment variables.
       - Prioritize using Region (recommended), but also support custom Endpoints (optional).
       - Compatible with both AK and STS:
           * AK: Requires OSS_ACCESS_KEY_ID / OSS_ACCESS_KEY_SECRET
           * STS: Also requires OSS_SESSION_TOKEN (compatible with the old variable OSS_SECURITY_TOKEN)
       """
       # Compatibility: If the user uses the old variable OSS_SECURITY_TOKEN, map it to the v2 expected 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 Token (optional)
   
       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).")
   
       # Indicate the type of credential used
       if st:
           print("STS Token (OSS_SESSION_TOKEN) detected. Using STS credentials.")
       else:
           print("No STS Token detected. Using AccessKey (AK) credentials.")
   
       credentials_provider = oss.credentials.EnvironmentVariableCredentialsProvider()
       cfg = oss.config.load_default()
       cfg.credentials_provider = credentials_provider
   
       # Basic network configuration
       cfg.region = region  # Example: 'cn-hangzhou'
       if endpoint:
           # Optional: Custom Endpoint (e.g., internal network, accelerated, dedicated domain)
           cfg.endpoint = endpoint
   
       # You can also add other configurations here, such as: 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,
   ):
       """
       Implement concurrent multipart upload with resumable upload.
   
       :param client: Initialized oss.Client
       :param bucket_name: Destination bucket name
       :param object_key: Destination object key (without bucket name)
       :param file_path: Full path of the local file
       :param part_size: Part size in bytes, default is 1 MB
       :param parallel_num: Number of concurrent upload threads, default is 4
       :param checkpoint_dir: Directory to store breakpoint information; if None, resumable upload is disabled
       """
       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}")
   
       # Construct the Uploader; enable resumable upload based on whether checkpoint_dir is provided
       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"Starting to upload file: {file_path}")
       print(f"Destination Bucket: {bucket_name}")
       print(f"Destination Object: {object_key}")
       print(f"Part size: {part_size} bytes, Concurrency: {parallel_num}")
       if checkpoint_dir:
           print(f"Resumable upload: Enabled (checkpoint_dir={checkpoint_dir})")
       else:
           print("Resumable upload: Disabled (set checkpoint_dir to enable)")
   
       # Execute the upload (Uploader automatically chooses between multi/single part concurrent upload based on size)
       result = uploader.upload_file(
           oss.PutObjectRequest(bucket=bucket_name, key=object_key),
           filepath=file_path,
       )
   
       print("-" * 30)
       print("File uploaded successfully!")
       print(f"HTTP Status: {result.status_code}")
       print(f"ETag: {result.etag}")
       print(f"Request ID: {result.request_id}")
       # CRC-64 checksum; v2 enables data validation by default
       print(f"CRC64: {result.hash_crc64}")
       print("-" * 30)
   
   
   def main():
       # Before running the code example, make sure you have set the corresponding environment variables.
       # macOS/Linux:
       #   AK method:
       #     export OSS_ACCESS_KEY_ID=YOUR_AK_ID
       #     export OSS_ACCESS_KEY_SECRET=YOUR_AK_SECRET
       #   STS method:
       #     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
   
       # ===================== Parameters (modify as needed) =====================
       # Region example: 'cn-hangzhou'; we recommend using Region first
       region = "cn-hangzhou"
   
       # Optional: Custom Endpoint (for internal network, dedicated domain, accelerated domain name, etc.)
       # Example: 'https://oss-cn-hangzhou.aliyuncs.com'
       endpoint = 'https://oss-cn-hangzhou.aliyuncs.com'
   
       # Bucket and Object
       bucket_name = "examplebucket"
       object_key = "test.bak"
   
       # Full path of the local file to upload.
       # Windows example: r'D:\localpath\examplefile.txt'  (note the r at the beginning)
       # macOS/Linux example: '/Users/test/examplefile.txt'
       file_path = r"D:\oss\test.bak"
   
       # Sharding and concurrency
       part_size = 1 * 1024 * 1024  # Default is 1 MB; OSS requires a minimum part size of 100 KB
       parallel_num = 4
   
       # Resumable upload directory (pass None to disable; we recommend specifying a writable directory)
       checkpoint_dir = str(Path.cwd() / ".oss_checkpoints")
       # =================== End of parameters ===================
   
       print("Script execution starts...")
       try:
           client = get_client_from_env(region=region, endpoint=endpoint)
           # If resumable upload is enabled, make sure the directory exists
           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:
           # Error returned by the OSS server
           print("\nAn OSS server-side error occurred.")
           print(f"HTTP Status: {getattr(e, 'status_code', 'N/A')}")
           print(f"Error Code: {getattr(e, 'code', 'N/A')}")
           print(f"Message: {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 local/serialization/deserialization/credential errors
           print("\nAn OSS SDK client-side error occurred.")
           print(str(e))
       except Exception as e:
           print(f"\nAn unknown error occurred: {e}")
   
   
   if __name__ == "__main__":
       main()

3. Tentukan periode validitas URL file cadangan dan dapatkan URL file cadangan.

   1. Login ke Konsol OSS.

   2. Klik Buckets, lalu klik nama bucket tujuan.

   3. Di panel navigasi sebelah kiri, pilih File Management > Files.

   4. Klik Details di kolom Actions file cadangan database tujuan, lalu ubah Expiration (Seconds) menjadi 28800 detik, yaitu 8 jam, di panel yang muncul.

      Penting

      URL file cadangan diperlukan saat Anda memigrasikan file cadangan dari OSS ke ApsaraDB RDS. Jika URL kedaluwarsa sebelum migrasi selesai, migrasi data akan gagal.

   5. Klik Copy Object URL untuk mendapatkan URL file cadangan.

      

   6. Modifikasi URL file cadangan.

      URL yang Anda peroleh adalah URL publik file secara default. Untuk memigrasikan data melalui jaringan internal, ubah endpoint dalam URL file ke endpoint internal.

      Sebagai contoh, jika URL file cadangan adalah http://rdstest.oss-cn-shanghai.aliyuncs.com/testmigraterds_20170906143807_FULL.bak?Expires=15141****&OSSAccessKeyId=TMP****, ubah oss-cn-shanghai.aliyuncs.com dalam URL menjadi oss-cn-shanghai-internal.aliyuncs.com.

      Penting

      Endpoint internal berbeda-beda berdasarkan jenis jaringan dan wilayah. Untuk informasi lebih lanjut, lihat Wilayah dan endpoint.

SQL Server 2012 atau versi lebih baru, atau SQL Server 2008 R2 dengan cloud disk

1. Buka halaman Instances. Di bilah navigasi atas, pilih wilayah tempat instans RDS berada. Lalu, temukan instans RDS dan klik ID instans tersebut.

2. Di panel navigasi sebelah kiri, pilih Restoration.

3. Klik Restore Backup Data from OSS di bagian atas halaman.

4. Pada halaman Import Guide, klik Next dua kali untuk menuju langkah impor data.

   Catatan

   • Saat pertama kali menggunakan fitur migrasi data cadangan OSS, Anda harus memberikan otorisasi kepada akun layanan ApsaraDB RDS untuk mengakses OSS. Klik Authorization URL dan konfirmasi otorisasi. Jika tidak, daftar drop-down OSS Bucket akan kosong karena masalah izin.

   • Jika file tujuan tidak ditampilkan di halaman, periksa apakah ekstensi file cadangan di OSS memenuhi persyaratan (Anda dapat melihat persyaratan ekstensi di bagian Catatan dalam topik ini), dan pastikan instans ApsaraDB RDS dan bucket OSS berada di wilayah yang sama.

5. Konfigurasi parameter berikut.

   Parameter	Deskripsi
   Database Name	Nama database tempat data cadangan diimpor pada instans ApsaraDB RDS tujuan. Nama harus sesuai dengan aturan penamaan resmi SQL Server. Penting Sebelum memigrasikan data ke cloud, pastikan tidak ada database dengan nama yang sama dengan database yang akan dipulihkan dari file cadangan pada instans tujuan dan tidak ada file database yang tidak terpasang dengan nama yang sama. Jika keduanya tidak ada, Anda dapat memulihkan database menggunakan file database yang memiliki nama yang sama dengan nama database target dalam set cadangan. Jika database dengan nama yang sama dengan database yang akan dipulihkan dari file cadangan ada pada instans tujuan atau file database yang tidak terpasang dengan nama yang sama ada, migrasi akan gagal.
   OSS Bucket	Pilih bucket OSS tempat file cadangan disimpan.
   OSS File	Klik ikon di sebelah kanan untuk mencari file cadangan berdasarkan awalan nama file. Nama file, ukuran file, dan waktu pembaruan setiap file ditampilkan. Pilih file cadangan yang ingin Anda migrasikan.
   Cloud Migration Method	Immediate Access (Only One Full Backup): migrasi penuh. Opsi ini cocok untuk skenario di mana hanya satu file cadangan penuh digunakan untuk migrasi. Dalam contoh ini, Immediate Access (Only One Full Backup) dipilih. Dalam hal ini, BackupMode = FULL dan IsOnlineDB = True dalam operasi CreateMigrateTask. Access Pending (Incremental Backup or Log Files): migrasi inkremental. Opsi ini cocok untuk skenario di mana file cadangan penuh bersama dengan file cadangan log atau file backup diferensial digunakan untuk migrasi. Dalam hal ini, BackupMode = UPDF dan IsOnlineDB = False dalam operasi CreateMigrateTask.
   Consistency Check Mode	Asynchronous DBCC: Sistem tidak menjalankan DBCC CHECKDB saat database dibuka. Sebaliknya, sistem menjalankan DBCC CHECKDB secara asinkron setelah tugas pembukaan database selesai. Ini mengurangi overhead waktu pembukaan database (DBCC CHECKDB memakan waktu lama untuk database besar) dan mempersingkat waktu henti layanan. Jika layanan Anda sangat sensitif terhadap waktu henti dan Anda tidak peduli dengan hasil DBCC CHECKDB, gunakan DBCC asinkron. Dalam hal ini, CheckDBMode = AsyncExecuteDBCheck dalam operasi CreateMigrateTask. Synchronous DBCC: Dibandingkan dengan DBCC asinkron, DBCC sinkron cocok untuk pengguna yang peduli dengan hasil DBCC CHECKDB dan ingin mengidentifikasi kesalahan konsistensi data di database yang dikelola sendiri. Dalam hal ini, waktu yang dibutuhkan untuk membuka database meningkat. Dalam hal ini, CheckDBMode = SyncExecuteDBCheck dalam operasi CreateMigrateTask.

6. Klik OK.

   Tunggu hingga tugas migrasi selesai. Anda dapat mengklik Refresh untuk melihat status terbaru tugas. Jika tugas migrasi gagal, pecahkan masalah berdasarkan pesan dalam deskripsi tugas. Untuk informasi lebih lanjut, lihat bagian Kesalahan umum dalam topik ini.

   Catatan

   Setelah migrasi data selesai, sistem akan memulai pencadangan pada waktu cadangan yang ditentukan berdasarkan kebijakan pencadangan otomatis instans ApsaraDB RDS. Anda dapat mengubah waktu cadangan secara manual. Set cadangan yang dihasilkan berisi data yang dimigrasikan. Anda dapat melihat set cadangan di halaman Restoration instans ApsaraDB RDS.

   Jika waktu cadangan belum tiba tetapi Anda ingin menghasilkan cadangan di cloud sesegera mungkin, Anda dapat melakukan pencadangan manual.

SQL Server 2008 R2 dengan high-performance local disk

1. Login ke Konsol ApsaraDB RDS dan buka halaman Instances. Di bilah navigasi atas, pilih wilayah tempat instans RDS berada. Lalu, temukan instans RDS dan klik ID instans tersebut.

2. Di panel navigasi sebelah kiri, klik Databases.

3. Temukan database tujuan dan klik Migrate Backup Files from OSS di kolom Actions.

   

4. Di kotak dialog Import Guide, baca pesan tersebut, lalu klik Next.

5. Baca pesan tentang unggah OSS, lalu klik Next.

6. Di bidang OSS URL of the Backup File, masukkan URL OSS file cadangan, lalu klik OK.

   

   Catatan

   Instans ApsaraDB RDS untuk SQL Server yang menjalankan SQL Server 2008 R2 dengan high-performance local disk hanya mendukung solusi yang memigrasikan file cadangan penuh ke cloud sekaligus.

SQL Server 2012 atau versi lebih baru, atau SQL Server 2008 R2 dengan cloud disk

Buka halaman Restoration di panel navigasi sebelah kiri instans ApsaraDB RDS, lalu lihat catatan migrasi cadangan di tab Cloud Migration Records of Backup Data. Catatan tersebut mencakup status tugas, waktu mulai tugas, dan waktu selesai tugas. Secara default, catatan minggu lalu ditampilkan. Anda dapat mengubah rentang waktu sesuai kebutuhan.

SQL Server 2008 R2 dengan high-performance local disk

Buka halaman migrasi data di panel navigasi sebelah kiri instans ApsaraDB RDS, lalu temukan tugas migrasi tujuan untuk melihat progres migrasi data.