ApsaraDB RDS:Migrate full backups to the cloud

SQL Server 2012 veya sonrası ya da cloud diskli SQL Server 2008 R2

1. Kaynak veritabanının mevcut kurtarma modelini kontrol etmek için aşağıdaki komutu çalıştırın:

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

   ApsaraDB RDS'e geçiş için üretim yedeklemesi oluşturmadan önce veritabanının kurtarma modelini FULL olarak değiştirin:

   ALTER DATABASE [db_simple] SET RECOVERY FULL WITH NO_WAIT;

2. yedekleme betiğini indirin ve ardından yedekleme betiğini SQL Server Management Studio (SSMS) içinde açın.

3. Betiğin SELECT ifadesindeki aşağıdaki parametreleri değiştirin. Parametreler, betikte YOU HAVE TO INIT PUBLIC VARIABLES HERE satırının altında yer alır.

   Parametre	Açıklama
   @backup_databases_list	Yedeklemek istediğiniz veritabanları. Birden çok veritabanını noktalı virgül (;) veya virgül (,) ile ayırın.
   @backup_type	Yedekleme türü. Geçerli değerler: FULL: tam yedekleme. DIFF: artımlı yedekleme. LOG: günlük yedekleme.
   @backup_folder	Yedekleme dosyalarının depolandığı yerel dizin. Dizin yoksa otomatik olarak oluşturulur.
   @is_run	Yedeklemenin yapılıp yapılmayacağını belirtir. Geçerli değerler: 1: yedeklemeyi gerçekleştirir. 0: yalnızca kontrol gerçekleştirir ve yedekleme yapmaz.

4. Yedekleme betiğini çalıştırın.

Yüksek performanslı yerel diskli SQL Server 2008 R2

1. Microsoft SQL Server Management Studio (SSMS) uygulamasını açın.

2. Geçirmek istediğiniz veritabanında oturum açın.

3. Kaynak veritabanının mevcut kurtarma modelini kontrol etmek için aşağıdaki komutu çalıştırın:

   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

   • Sorgu sonucundaki model değeri FULL değilse 4. Adımı uygulayın.

   • Sorgu sonucundaki model değeri FULL ise 5. Adımı uygulayın.

4. Kaynak veritabanının kurtarma modelini FULL olarak ayarlamak için aşağıdaki komutu çalıştırın:

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

   Önemli

   Kurtarma modeli FULL olarak ayarlandıktan sonra daha fazla SQL Server günlüğü oluşturulur. Yeterli disk alanı bulunduğundan emin olun.

5. Kaynak veritabanını yedeklemek için aşağıdaki komutu çalıştırın.

   Bu örnekte dbtest veritabanı backup.bak dosyasına yedeklenmektedir.

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

6. Yedekleme dosyasının bütünlüğünü doğrulamak için aşağıdaki komutu çalıştırın:

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

   Önemli

   • Bir sonuç kümesi döndürülürse yedekleme dosyası geçerlidir.

   • Bir hata bildirilirse yedeklemeyi tekrar gerçekleştirin.

7. İsteğe bağlı: Veritabanının kurtarma modelini geri yüklemek için aşağıdaki komutu çalıştırın:

   Önemli

   Veritabanının kurtarma modeli zaten FULL ise bu adımı atlayın.

   ALTER DATABASE [dbname] SET RECOVERY SIMPLE;
   GO

SQL Server 2012 veya sonrası ya da cloud diskli SQL Server 2008 R2

1. Yedekleme dosyalarını OSS'e yüklemeden önce OSS'te bir paket oluşturmanız gerekir.

   • OSS'te zaten bir paket varsa paketin aşağıdaki gereksinimleri karşıladığından emin olun:

     • Paketin depolama sınıfı Standard olmalıdır. IA, Archive, Cold Archive ve Deep Cold Archive depolama sınıfları desteklenmez.

     • Paket için sunucu tarafı şifreleme etkinleştirilmemiştir.

   • OSS'te paket yoksa önce bir paket oluşturun. (OSS'in etkinleştirildiğinden emin olun.)

     1. OSS konsolunda oturum açın, Buckets seçeneğine tıklayın ve ardından Create bucket seçeneğine tıklayın.

     2. Aşağıdaki anahtar parametreleri yapılandırın ve diğer parametreler için varsayılan değerleri koruyun.

        Önemli

        • Bu paket yalnızca bu veri geçişi , bu nedenle yalnızca anahtar parametreleri yapılandırmanız gerekir. Geçiş tamamlandıktan sonra veri sızıntılarını ve ek ücretleri önlemek için paketi zamanında silin.

        • Paketi oluştururken sunucu tarafı şifrelemeyi etkinleştirmeyin.

        Parametre	Açıklama	Örnek
        Bucket Name	Paketin adı. Ad globally benzersiz olmalı ve paket oluşturulduktan sonra değiştirilememelidir. Adlandırma kuralları: Ad yalnızca küçük harfler, rakamlar ve tire (-) içerebilir. Ad küçük harf veya rakamla başlamalı ve bitmelidir. Ad 3 ila 63 karakter uzunluğunda olmalıdır.	migratetest
        Region	Paketin bulunduğu bölge. Verileri bir ECS örneğinden dahili ağ üzerinden pakete yükler ve verileri ApsaraDB RDS örneğine dahili ağ üzerinden geri yüklerseniz ECS örneğinin, paketin ve ApsaraDB RDS örneğinin aynı bölgede bulunduğundan emin olun.	China (Hangzhou)
        Storage Type	Standard seçeneğini seçin. Bu konuda açıklanan geçiş işlemi diğer depolama sınıflarındaki paketleri desteklemez.	Standard

2. Yedekleme dosyasını OSS'e yükleyin.

   Kendi kendinize yönetilen veritabanının yedeklemesi tamamlandıktan sonra yedekleme dosyasını ApsaraDB RDS örneğinizle aynı bölgede bulunan bir OSS paketine yükleyin. Paket ve ApsaraDB RDS örneği aynı bölgedeyse paket ile örnek arasında dahili ağ üzerinden iletişim kurulabilir. Bu durumda İnternet trafiği ücreti alınmaz ve veriler daha hızlı bir hızda yüklenir. Aşağıdaki yöntemlerden birini kullanabilirsiniz:

   ossbrowser kullanarak dosya yükleme (önerilir)

   1. ossbrowser uygulamasını indirin.

   2. Bu örnekte Windows x64 kullanılmaktadır. İndirilen oss-browser-win32-x64.zip paketini ayıklayın ve ardından oss-browser.exe uygulamasına çift tıklayın.

   3. Oturum açma yöntemi olarak AK seçeneğini seçin, Access Key ID ve Access Key Secret parametrelerini yapılandırın, diğer parametreler için varsayılan değerleri koruyun ve ardından Log On seçeneğine tıklayın.

      Not

      Veri güvenliğini sağlamak amacıyla kimlik doğrulama için bir AccessKey kullanılır. AccessKey bilgilerinizi gizli tutun.

   4. Hedef pakete gitmek için ilgili pakete tıklayın.

   5. simgesine tıklayın, yüklemek istediğiniz yedekleme dosyasını seçin ve ardından Aç'a tıklayın. Yerel dosya OSS'e yüklenir.

   OSS konsolunu kullanarak dosya yükleme

   Not

   Yedekleme dosyasının boyutu 5 GB'den küçükse dosyayı doğrudan OSS konsolundan yükleyin.

   1. OSS konsolunda oturum açın.

   2. Buckets seçeneğine tıklayın ve ardından hedef paketin adına tıklayın.

   3. Files bölümünde Upload File seçeneğine tıklayın.

   4. Yedekleme dosyasını Files to Upload bölümüne sürükleyin veya Select Files seçeneğine tıklayıp yüklemek istediğiniz yedekleme dosyasını seçin.

   5. Sayfanın alt kısmındaki Upload File seçeneğine tıklayın. Yerel yedekleme dosyası OSS'e yüklenir.

   OSS API'sini kullanarak dosya yükleme (Python 3 projesi örneği)

   Not

   Yedekleme dosyasının boyutu 5 GB'den büyükse OSS API çağrıları yaparak yedekleme dosyasını çok parçalı yükleme yöntemiyle OSS paketine yükleyin.

   # -*- 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()

Yüksek performanslı yerel diskli SQL Server 2008 R2

1. Yedekleme dosyalarını OSS'e yüklemeden önce OSS'te bir paket oluşturmanız gerekir.

   • OSS'te zaten bir paket varsa paketin aşağıdaki gereksinimleri karşıladığından emin olun:

     • Paketin depolama sınıfı Standard olmalıdır. IA, Archive, Cold Archive ve Deep Cold Archive depolama sınıfları desteklenmez.

     • Paket için sunucu tarafı şifreleme etkinleştirilmemiştir.

   • OSS'te paket yoksa önce bir paket oluşturun. (OSS'in etkinleştirildiğinden emin olun.)

     1. OSS konsolunda oturum açın, Buckets seçeneğine tıklayın ve ardından Create bucket seçeneğine tıklayın.

     2. Aşağıdaki anahtar parametreleri yapılandırın ve diğer parametreler için varsayılan değerleri koruyun.

        Önemli

        • Bu paket yalnızca bu veri geçişi , bu nedenle yalnızca anahtar parametreleri yapılandırmanız gerekir. Geçiş tamamlandıktan sonra veri sızıntılarını ve ek ücretleri önlemek için paketi zamanında silin.

        • Paketi oluştururken sunucu tarafı şifrelemeyi etkinleştirmeyin.

        Parametre	Açıklama	Örnek
        Bucket Name	Paketin adı. Ad globally benzersiz olmalı ve paket oluşturulduktan sonra değiştirilememelidir. Adlandırma kuralları: Ad yalnızca küçük harfler, rakamlar ve tire (-) içerebilir. Ad küçük harf veya rakamla başlamalı ve bitmelidir. Ad 3 ila 63 karakter uzunluğunda olmalıdır.	migratetest
        Region	Paketin bulunduğu bölge. Verileri bir ECS örneğinden dahili ağ üzerinden pakete yükler ve verileri ApsaraDB RDS örneğine dahili ağ üzerinden geri yüklerseniz ECS örneğinin, paketin ve ApsaraDB RDS örneğinin aynı bölgede bulunduğundan emin olun.	China (Hangzhou)
        Storage Type	Standard seçeneğini seçin. Bu konuda açıklanan geçiş işlemi diğer depolama sınıflarındaki paketleri desteklemez.	Standard

2. Yedekleme dosyasını OSS'e yükleyin.

   Kendi kendinize yönetilen veritabanının yedeklemesi tamamlandıktan sonra yedekleme dosyasını ApsaraDB RDS örneğinizle aynı bölgede bulunan bir OSS paketine yükleyin. Paket ve ApsaraDB RDS örneği aynı bölgedeyse paket ile örnek arasında dahili ağ üzerinden iletişim kurulabilir. Bu durumda İnternet trafiği ücreti alınmaz ve veriler daha hızlı bir hızda yüklenir. Aşağıdaki yöntemlerden birini kullanabilirsiniz:

   ossbrowser kullanarak dosya yükleme (önerilir)

   1. ossbrowser uygulamasını indirin.

   2. Bu örnekte Windows x64 kullanılmaktadır. İndirilen oss-browser-win32-x64.zip paketini ayıklayın ve ardından oss-browser.exe uygulamasına çift tıklayın.

   3. Oturum açma yöntemi olarak AK seçeneğini seçin, Access Key ID ve Access Key Secret parametrelerini yapılandırın, diğer parametreler için varsayılan değerleri koruyun ve ardından Log On seçeneğine tıklayın.

      Not

      Veri güvenliğini sağlamak amacıyla kimlik doğrulama için bir AccessKey kullanılır. AccessKey bilgilerinizi gizli tutun.

   4. Hedef pakete gitmek için ilgili pakete tıklayın.

   5. simgesine tıklayın, yüklemek istediğiniz yedekleme dosyasını seçin ve ardından Aç'a tıklayın. Yerel dosya OSS'e yüklenir.

   OSS konsolunu kullanarak dosya yükleme

   Not

   Yedekleme dosyasının boyutu 5 GB'den küçükse dosyayı doğrudan OSS konsolundan yükleyin.

   1. OSS konsolunda oturum açın.

   2. Buckets seçeneğine tıklayın ve ardından hedef paketin adına tıklayın.

   3. Files bölümünde Upload File seçeneğine tıklayın.

   4. Yedekleme dosyasını Files to Upload bölümüne sürükleyin veya Select Files seçeneğine tıklayıp yüklemek istediğiniz yedekleme dosyasını seçin.

   5. Sayfanın alt kısmındaki Upload File seçeneğine tıklayın. Yerel yedekleme dosyası OSS'e yüklenir.

   OSS API'sini kullanarak dosya yükleme (Python 3 projesi örneği)

   Not

   Yedekleme dosyasının boyutu 5 GB'den büyükse OSS API çağrıları yaparak yedekleme dosyasını çok parçalı yükleme yöntemiyle OSS paketine yükleyin.

   # -*- 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. Yedekleme dosyası URL'sinin geçerlilik süresini ayarlayın ve yedekleme dosyasının URL'sini edinin.

   1. OSS konsolunda oturum açın.

   2. Buckets seçeneğine tıklayın ve ardından hedef paketin adına tıklayın.

   3. Sol gezinme bölmesinde File Management > Files seçeneklerini seçin.

   4. Hedef veritabanı yedekleme dosyasının İşlemler sütununda Details seçeneğine tıklayın ve ardından açılan panelde Expiration (Seconds) değerini 28800 saniye (8 saat) olarak değiştirin.

      Önemli

      Yedekleme dosyasını OSS'ten ApsaraDB RDS'e geçirirken yedekleme dosyasının URL'si gerekir. Geçiş tamamlanmadan önce URL'nin süresi dolarsa veri geçişi başarısız olur.

   5. Yedekleme dosyasının URL'sini edinmek için Copy Object URL seçeneğine tıklayın.

   6. Yedekleme dosyasının URL'sini değiştirin.

      Edindiğiniz URL, varsayılan olarak dosyanın genel URL'sidir. Verileri dahili ağ üzerinden geçirmek için dosya URL'sindeki uç noktayı dahili uç nokta ile değiştirin.

      Örneğin, yedekleme dosyasının URL'si http://rdstest.oss-cn-shanghai.aliyuncs.com/testmigraterds_20170906143807_FULL.bak?Expires=15141****&OSSAccessKeyId=TMP**** ise URL'deki oss-cn-shanghai.aliyuncs.com ifadesini oss-cn-shanghai-internal.aliyuncs.com ile değiştirin.

      Önemli

      Dahili uç noktalar ağ türüne ve bölgeye göre değişir. Daha fazla bilgi için bkz. Bölgeler ve uç noktalarBölgeler ve uç noktalar.

SQL Server 2012 veya sonrası ya da cloud diskli SQL Server 2008 R2

1. Instances sayfasına gidin. Üst gezinme çubuğunda RDS örneğinin bulunduğu bölgeyi seçin. Ardından RDS örneğini bulun ve örneğin Kimliğine tıklayın.

2. Sol gezinme bölmesinde Restoration seçeneğini belirleyin.

3. Sayfanın üst kısmındaki Restore Backup Data from OSS seçeneğine tıklayın.

4. Import Guide sayfasında, veri aktarma adımına gitmek için Next düğmesine iki kez tıklayın.

   Not

   • OSS yedekleme verisi geçiş özelliğini ilk kez kullanırken ApsaraDB RDS hizmet hesabının OSS'e erişmesine yetki vermeniz gerekir. Authorization URL seçeneğine tıklayarak yetkilendirmeyi onaylayın. Aksi takdirde izin sorunu nedeniyle OSS Bucket açılır listesi boş görünür.

   • Hedef dosya sayfada görüntülenmiyorsa OSS'teki yedekleme dosyasının dosya uzantısının gereksinimleri karşılayıp karşılamadığını kontrol edin (uzantı gereksinimlerini bu konudaki Notlar bölümünde görebilirsiniz) ve ApsaraDB RDS örneği ile OSS paketinin aynı bölgede bulunduğundan emin olun.

5. Aşağıdaki parametreleri yapılandırın.

   Parametre	Açıklama
   Database Name	Yedekleme verilerinin hedef ApsaraDB RDS örneğinde aktarılacağı veritabanının adı. Ad, resmi SQL Server adlandırma kurallarına uygun olmalıdır. Önemli Verileri buluta geçirmeden önce hedef örnekte yedekleme dosyasından geri yüklenecek veritabanıyla aynı ada sahip bir veritabanının ve aynı ada sahip eklenmemiş bir veritabanı dosyasının bulunmadığından emin olun. Her ikisi de yoksa yedekleme kümesindeki hedef veritabanı adıyla aynı ada sahip veritabanı dosyasını kullanarak veritabanını geri yükleyebilirsiniz. Hedef örnekte yedekleme dosyasından geri yüklenecek veritabanıyla aynı ada sahip bir veritabanı veya aynı ada sahip eklenmemiş bir veritabanı dosyası varsa geçiş başarısız olur.
   OSS Bucket	Yedekleme dosyasının depolandığı OSS paketini seçin.
   OSS File	Yedekleme dosyalarını dosya adı önekiyle aramak için sağ taraftaki simgesine tıklayın. Her dosyanın dosya adı, dosya boyutu ve güncelleme zamanı görüntülenir. Geçirmek istediğiniz yedekleme dosyasını seçin.
   Cloud Migration Method	Immediate Access (Only One Full Backup): tam geçiş. Bu seçenek yalnızca bir tam yedekleme dosyasının geçiş için kullanıldığı senaryolar için uygundur. Bu örnekte Immediate Access (Only One Full Backup) seçeneği seçilmiştir. Bu durumda CreateMigrateTask işlemi için BackupMode = FULL ve IsOnlineDB = True parametreleri kullanılır. Access Pending (Incremental Backup or Log Files): artımlı geçiş. Bu seçenek, bir tam yedekleme dosyasının günlük yedekleme dosyaları veya artımlı yedekleme dosyalarıyla birlikte geçiş için kullanıldığı senaryolar için uygundur. Bu durumda CreateMigrateTask işlemi için BackupMode = UPDF ve IsOnlineDB = False parametreleri kullanılır.
   Consistency Check Mode	Asynchronous DBCC: Sistem, veritabanı açıldığında DBCC CHECKDB çalıştırmaz. Bunun yerine sistem, veritabanı açma görevi tamamlandıktan sonra DBCC CHECKDB işlemini eşzamansız olarak çalıştırır. Bu sayede veritabanı açmanın zaman maliyeti azaltılır (büyük veritabanlarında DBCC CHECKDB zaman alıcıdır) ve hizmet kesinti süresi kısaltılır. Kesinti süresine karşı hassasiyetiniz yüksekse ve DBCC CHECKDB sonuçlarıyla ilgilenmiyorsanız eşzamansız DBCC kullanın. Bu durumda CreateMigrateTask işlemi için CheckDBMode = AsyncExecuteDBCheck parametresi kullanılır. Synchronous DBCC: Eşzamansız DBCC'ye kıyasla eşzamanlı DBCC, DBCC CHECKDB sonuçlarıyla ilgilenen ve kendi kendinize yönetilen veritabanlarında veri tutarlılığı hatalarını tespit etmek isteyen kullanıcılar için daha uygundur. Bu durumda veritabanının açılması için gereken süre artar. Bu durumda CreateMigrateTask işlemi için CheckDBMode = SyncExecuteDBCheck parametresi kullanılır.

6. OK seçeneğine tıklayın.

   Geçiş görevinin tamamlanmasını bekleyin. Görevin en son durumunu görüntülemek için Refresh seçeneğine tıklayabilirsiniz. Geçiş görevi başarısız olursa görev açıklamasındaki mesaja göre sorunu giderin. Daha fazla bilgi için bu konudaki Yaygın hatalar bölümüne bakın.

   Not

   Veri geçişi tamamlandıktan sonra sistem, ApsaraDB RDS örneğinin otomatik yedekleme ilkesine göre belirtilen yedekleme saatinde bir yedekleme başlatır. Yedekleme saatini manuel olarak değiştirebilirsiniz. Oluşturulan yedekleme kümesi geçirilen verileri içerir. Yedekleme kümesini ApsaraDB RDS örneğinin Restoration sayfasında görüntüleyebilirsiniz.

   Yedekleme saati gelmediyse ancak bulutta mümkün olan en kısa sürede bir yedekleme oluşturmak istiyorsanız manuel yedekleme gerçekleştirebilirsiniz.

Yüksek performanslı yerel diskli SQL Server 2008 R2

1. ApsaraDB RDS konsolunda oturum açın ve Instances sayfasına gidin. Üst gezinme çubuğunda RDS örneğinin bulunduğu bölgeyi seçin. Ardından RDS örneğini bulun ve örneğin Kimliğine tıklayın.

2. Sol gezinme bölmesinde Databases seçeneğine tıklayın.

3. Hedef veritabanını bulun ve Actions sütununda Migrate Backup Files from OSS seçeneğine tıklayın.

4. Import Guide iletişim kutusunda mesajı okuyun ve ardından Next seçeneğine tıklayın.

5. OSS yükleme hakkındaki mesajı okuyun ve ardından Next seçeneğine tıklayın.

6. OSS URL of the Backup File alanına yedekleme dosyasının OSS URL'sini girin ve ardından OK seçeneğine tıklayın.

   Not

   Yüksek performanslı yerel diskli SQL Server 2008 R2 çalışan ApsaraDB RDS for SQL Server örnekleri yalnızca tam yedekleme dosyalarını tek seferde buluta geçiren çözümü destekler.

SQL Server 2012 veya sonrası ya da cloud diskli SQL Server 2008 R2

ApsaraDB RDS örneğinin sol gezinme bölmesindeki Restoration sayfasına gidin ve ardından Cloud Migration Records of Backup Data sekmesindeki yedekleme geçiş kayıtlarını görüntüleyin. Kayıtlar görev durumu, görev başlangıç saati ve görev bitiş saati bilgilerini içerir. Varsayılan olarak son haftanın kayıtları görüntülenir. Zaman aralığını gerektiği şekilde değiştirebilirsiniz.

Yüksek performanslı yerel diskli SQL Server 2008 R2

ApsaraDB RDS örneğinin sol gezinme bölmesindeki veri geçiş sayfasına gidin ve ardından veri geçişinin ilerlemesini görüntülemek için hedef geçiş görevini bulun.