ApsaraDB RDS:Migrasikan cadangan penuh ke cloud

Opsi 1: ossbrowser (direkomendasikan untuk sebagian besar kasus)

1. Unduh ossbrowser.

2. Pada Windows x64: ekstrak oss-browser-win32-x64.zip dan jalankan oss-browser.exe.

3. Pilih Log On With AK, masukkan AccessKeyId dan AccessKeySecret Anda, lalu klik Log On.

   Pasangan AccessKey digunakan untuk verifikasi identitas. Simpan AccessKey Anda secara rahasia.

   

4. Klik bucket tujuan.

   

5. Klik , pilih file backup, lalu klik Open.

Opsi 2: Konsol OSS (untuk file berukuran kurang dari 5 GB)

1. Login ke konsol OSS.

2. Klik Buckets, lalu nama bucket Anda.

   

3. Di daftar Objects, klik Upload Object.

   

4. Seret file backup ke area Files to Upload, atau klik Select Files untuk menjelajahi.

   

5. Klik Upload Object.

Opsi 3: Unggah multi-bagian API OSS (untuk file berukuran lebih dari 5 GB)

Gunakan SDK Python alibabacloud-oss-v2 untuk unggah multi-bagian dengan dukungan unggah yang dapat dilanjutkan. Instal dependensi terlebih dahulu:

pip install alibabacloud-oss-v2

Atur variabel lingkungan berikut sebelum menjalankan skrip:

# -*- 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:
    """
    Buat klien v2 dari variabel lingkungan.
    - Utamakan penggunaan Region (direkomendasikan), tetapi juga mendukung Endpoint kustom (opsional).
    - Kompatibel dengan AK dan STS:
        * AK: Membutuhkan OSS_ACCESS_KEY_ID / OSS_ACCESS_KEY_SECRET
        * STS: Juga membutuhkan OSS_SESSION_TOKEN (kompatibel dengan variabel lama OSS_SECURITY_TOKEN)
    """
    # Kompatibilitas: Jika pengguna menggunakan variabel lama OSS_SECURITY_TOKEN, petakan ke OSS_SESSION_TOKEN yang diharapkan v2
    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")  # Token STS (opsional)

    if not (ak and sk):
        raise ValueError("Tidak ditemukan AK yang valid. Atur variabel lingkungan OSS_ACCESS_KEY_ID dan OSS_ACCESS_KEY_SECRET. "
                         "Jika menggunakan STS, atur juga OSS_SESSION_TOKEN (atau nama lama OSS_SECURITY_TOKEN).")

    # Tunjukkan jenis kredensial yang digunakan
    if st:
        print("Token STS (OSS_SESSION_TOKEN) terdeteksi. Menggunakan kredensial STS.")
    else:
        print("Token STS tidak terdeteksi. Menggunakan kredensial AccessKey (AK).")

    credentials_provider = oss.credentials.EnvironmentVariableCredentialsProvider()
    cfg = oss.config.load_default()
    cfg.credentials_provider = credentials_provider

    # Konfigurasi jaringan dasar
    cfg.region = region  # Contoh: 'cn-hangzhou'
    if endpoint:
        # Opsional: Endpoint Kustom (misalnya, jaringan internal, domain akselerasi, domain khusus)
        cfg.endpoint = endpoint

    # Anda juga dapat menambahkan konfigurasi lain di sini, seperti: 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,
):
    """
    Implementasikan unggah multi-bagian konkuren dengan dukungan unggah yang dapat dilanjutkan.

    :param client: oss.Client yang telah diinisialisasi
    :param bucket_name: Nama bucket tujuan
    :param object_key: Kunci objek tujuan (tanpa nama bucket)
    :param file_path: Jalur lengkap file lokal
    :param part_size: Ukuran bagian dalam byte, default 1 MB
    :param parallel_num: Jumlah thread unggah konkuren, default 4
    :param checkpoint_dir: Direktori untuk menyimpan informasi breakpoint; jika None, unggah yang dapat dilanjutkan dinonaktifkan
    """
    file_path = str(file_path)
    if not Path(file_path).exists():
        raise FileNotFoundError(f"Error: File lokal tidak ditemukan. Periksa konfigurasi file_path: {file_path}")

    # Bangun Uploader; aktifkan unggah yang dapat dilanjutkan berdasarkan apakah checkpoint_dir disediakan
    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"Mulai mengunggah file: {file_path}")
    print(f"Bucket Tujuan: {bucket_name}")
    print(f"Objek Tujuan: {object_key}")
    print(f"Ukuran bagian: {part_size} byte, Konkurensi: {parallel_num}")
    if checkpoint_dir:
        print(f"Unggah yang dapat dilanjutkan: Diaktifkan (checkpoint_dir={checkpoint_dir})")
    else:
        print("Unggah yang dapat dilanjutkan: Dinonaktifkan (atur checkpoint_dir untuk mengaktifkan)")

    # Jalankan unggah (Uploader secara otomatis memilih antara unggah multi-bagian/konkuren tunggal berdasarkan ukuran)
    result = uploader.upload_file(
        oss.PutObjectRequest(bucket=bucket_name, key=object_key),
        filepath=file_path,
    )

    print("-" * 30)
    print("File berhasil diunggah!")
    print(f"Status HTTP: {result.status_code}")
    print(f"ETag: {result.etag}")
    print(f"ID Permintaan: {result.request_id}")
    # Checksum CRC-64; v2 mengaktifkan validasi data secara default
    print(f"CRC64: {result.hash_crc64}")
    print("-" * 30)


def main():
    # Sebelum menjalankan contoh kode, pastikan Anda telah mengatur variabel lingkungan yang sesuai.
    # macOS/Linux:
    #   Metode AK:
    #     export OSS_ACCESS_KEY_ID=YOUR_AK_ID
    #     export OSS_ACCESS_KEY_SECRET=YOUR_AK_SECRET
    #   Metode 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

    # ===================== Parameter (sesuaikan sesuai kebutuhan) =====================
    # Contoh wilayah: 'cn-hangzhou'; kami merekomendasikan menggunakan Region terlebih dahulu
    region = "cn-hangzhou"

    # Opsional: Endpoint Kustom (untuk jaringan internal, domain khusus, nama domain yang dipercepat, dll.)
    # Contoh: 'https://oss-cn-hangzhou.aliyuncs.com'
    endpoint = 'https://oss-cn-hangzhou.aliyuncs.com'

    # Bucket dan Objek
    bucket_name = "examplebucket"
    object_key = "test.bak"

    # Jalur lengkap file lokal yang akan diunggah.
    # Contoh Windows: r'D:\localpath\examplefile.txt'  (perhatikan r di awal)
    # Contoh macOS/Linux: '/Users/test/examplefile.txt'
    file_path = r"D:\oss\test.bak"

    # Pembagian dan konkurensi
    part_size = 1 * 1024 * 1024  # Default 1 MB; OSS mensyaratkan ukuran bagian minimum 100 KB
    parallel_num = 4

    # Direktori unggah yang dapat dilanjutkan (berikan None untuk menonaktifkan; kami merekomendasikan menentukan direktori yang dapat ditulis)
    checkpoint_dir = str(Path.cwd() / ".oss_checkpoints")
    # =================== Akhir parameter ===================

    print("Eksekusi skrip dimulai...")
    try:
        client = get_client_from_env(region=region, endpoint=endpoint)
        # Jika unggah yang dapat dilanjutkan diaktifkan, pastikan direktori tersebut ada
        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 yang dikembalikan oleh server OSS
        print("\nTerjadi error sisi server OSS.")
        print(f"Status HTTP: {getattr(e, 'status_code', 'N/A')}")
        print(f"Kode Error: {getattr(e, 'code', 'N/A')}")
        print(f"Pesan: {getattr(e, 'message', 'N/A')}")
        print(f"ID Permintaan: {getattr(e, 'request_id', 'N/A')}")
        print(f"Endpoint: {getattr(e, 'request_target', 'N/A')}")
    except oss_ex.BaseError as e:
        # Error SDK sisi klien/serialisasi/deserialisasi/kredensial
        print("\nTerjadi error sisi klien SDK OSS.")
        print(str(e))
    except Exception as e:
        print(f"\nTerjadi error tak dikenal: {e}")


if __name__ == "__main__":
    main()