Object Storage Service：Manajer Unggah File (Python SDK V2)

Gunakan kode berikut untuk mengaktifkan unggah yang dapat dilanjutkan.

import argparse
import alibabacloud_oss_v2 as oss

# Buat parser argumen baris perintah dan jelaskan tujuan skrip: contoh unggah file
parser = argparse.ArgumentParser(description="contoh unggah file")

# Tambahkan argumen baris perintah --region, yang menentukan wilayah tempat bucket berada. Ini adalah parameter yang diperlukan.
parser.add_argument('--region', help='Wilayah tempat bucket berada.', required=True)
# Tambahkan argumen baris perintah --bucket, yang menentukan nama bucket tempat file diunggah. Ini adalah parameter yang diperlukan.
parser.add_argument('--bucket', help='Nama bucket.', required=True)
# Tambahkan argumen baris perintah --endpoint, yang menentukan nama domain yang dapat digunakan layanan lain untuk mengakses OSS. Ini adalah parameter opsional.
parser.add_argument('--endpoint', help='Nama domain yang dapat digunakan layanan lain untuk mengakses OSS')
# Tambahkan argumen baris perintah --key, yang menentukan kunci objek (file) di OSS. Ini adalah parameter yang diperlukan.
parser.add_argument('--key', help='Nama objek.', required=True)
# Tambahkan argumen baris perintah --file_path, yang menentukan path file lokal yang akan diunggah. Ini adalah parameter yang diperlukan, misalnya, "/Users/yourLocalPath/yourFileName".
parser.add_argument('--file_path', help='Path file unggahan.', required=True)

def main():
    # Parse argumen baris perintah untuk mendapatkan nilai yang diberikan pengguna.
    args = parser.parse_args()

    # Muat informasi otentikasi yang diperlukan untuk mengakses OSS dari variabel lingkungan untuk verifikasi identitas.
    credentials_provider = oss.credentials.EnvironmentVariableCredentialsProvider()

    # Buat objek konfigurasi menggunakan konfigurasi default SDK dan atur penyedia kredensial.
    cfg = oss.config.load_default()
    cfg.credentials_provider = credentials_provider
    
    # Atur properti region objek konfigurasi berdasarkan argumen baris perintah yang diberikan pengguna.
    cfg.region = args.region

    # Jika titik akhir kustom diberikan, perbarui properti endpoint dalam objek konfigurasi.
    if args.endpoint is not None:
        cfg.endpoint = args.endpoint

    # Inisialisasi klien OSS menggunakan konfigurasi di atas untuk mempersiapkan interaksi dengan OSS.
    client = oss.Client(cfg)

    # Buat objek untuk mengunggah file, aktifkan unggah yang dapat dilanjutkan, dan tentukan path untuk menyimpan file rekaman titik pemberhentian.
    uploader = client.uploader(enable_checkpoint=True, checkpoint_dir="/Users/yourLocalPath/checkpoint/")

    # Panggil metode untuk melakukan operasi unggah file.
    result = uploader.upload_file(
        oss.PutObjectRequest(
            bucket=args.bucket,  # Tentukan bucket tujuan.
            key=args.key,        # Tentukan nama file di OSS.
        ),
        filepath=args.file_path  # Tentukan lokasi file lokal.
    )

    # Cetak informasi tentang hasil unggahan, termasuk kode status, ID permintaan, dan Content-MD5.
    print(f'kode status: {result.status_code},'
          f' ID permintaan: {result.request_id},'
          f' content md5: {result.headers.get("Content-MD5")},'
          f' etag: {result.etag},'
          f' hash crc64: {result.hash_crc64},'
          f' ID versi: {result.version_id},'
          f' waktu server: {result.headers.get("x-oss-server-time")},'
          )

# Saat skrip ini dieksekusi langsung, panggil fungsi utama untuk memulai logika pemrosesan.
if __name__ == "__main__":
    main()  # Titik masuk skrip. Alur program dimulai dari sini.

Gunakan kode berikut untuk mengunggah aliran file lokal menggunakan manajer unggah.

import argparse
import alibabacloud_oss_v2 as oss

# Buat parser argumen baris perintah dan jelaskan tujuan skrip: contoh unggah dari file
parser = argparse.ArgumentParser(description="contoh unggah dari file")

# Tambahkan argumen baris perintah --region, yang menentukan wilayah tempat bucket berada. Ini adalah parameter yang diperlukan.
parser.add_argument('--region', help='Wilayah tempat bucket berada.', required=True)
# Tambahkan argumen baris perintah --bucket, yang menentukan nama bucket tempat file diunggah. Ini adalah parameter yang diperlukan.
parser.add_argument('--bucket', help='Nama bucket.', required=True)
# Tambahkan argumen baris perintah --endpoint, yang menentukan nama domain yang dapat digunakan layanan lain untuk mengakses OSS. Ini adalah parameter opsional.
parser.add_argument('--endpoint', help='Nama domain yang dapat digunakan layanan lain untuk mengakses OSS')
# Tambahkan argumen baris perintah --key, yang menentukan kunci objek (file) di OSS. Ini adalah parameter yang diperlukan.
parser.add_argument('--key', help='Nama objek.', required=True)
# Tambahkan argumen baris perintah --file_path, yang menentukan path file lokal yang akan diunggah. Ini adalah parameter yang diperlukan, misalnya, "/Users/yourLocalPath/yourFileName".
parser.add_argument('--file_path', help='Path file unggahan.', required=True)

def main():
    # Parse argumen baris perintah untuk mendapatkan nilai yang diberikan pengguna.
    args = parser.parse_args()

    # Muat informasi otentikasi yang diperlukan untuk mengakses OSS dari variabel lingkungan untuk verifikasi identitas.
    credentials_provider = oss.credentials.EnvironmentVariableCredentialsProvider()

    # Buat objek konfigurasi menggunakan konfigurasi default SDK dan atur penyedia kredensial.
    cfg = oss.config.load_default()
    cfg.credentials_provider = credentials_provider
    
    # Atur properti region objek konfigurasi berdasarkan argumen baris perintah yang diberikan pengguna.
    cfg.region = args.region

    # Jika titik akhir kustom diberikan, perbarui properti endpoint dalam objek konfigurasi.
    if args.endpoint is not None:
        cfg.endpoint = args.endpoint

    # Inisialisasi klien OSS menggunakan konfigurasi di atas untuk mempersiapkan interaksi dengan OSS.
    client = oss.Client(cfg)

    # Buat objek untuk mengunggah file.
    uploader = client.uploader()

    # Buka file lokal untuk dibaca dalam mode biner.
    with open(file=args.file_path, mode='rb') as f:
        # Panggil metode untuk melakukan operasi unggah file.
        result = uploader.upload_from(
            oss.PutObjectRequest(
                bucket=args.bucket,  # Tentukan bucket tujuan.
                key=args.key,        # Tentukan nama file di OSS.
            ),
            reader=f  # Masukkan pembaca file.
        )

        # Cetak informasi tentang hasil unggahan, termasuk kode status, ID permintaan, dan Content-MD5.
        print(f'kode status: {result.status_code},'
              f' ID permintaan: {result.request_id},'
              f' content md5: {result.headers.get("Content-MD5")},'
              f' etag: {result.etag},'
              f' hash crc64: {result.hash_crc64},'
              f' ID versi: {result.version_id},'
              f' waktu server: {result.headers.get("x-oss-server-time")},'
              )

# Saat skrip ini dieksekusi langsung, panggil fungsi utama untuk memulai logika pemrosesan.
if __name__ == "__main__":
    main()  # Titik masuk skrip. Alur program dimulai dari sini.

Gunakan kode berikut untuk menentukan ukuran bagian dan konkurensi.

import argparse
import alibabacloud_oss_v2 as oss

# Buat parser argumen baris perintah dan jelaskan tujuan skrip: contoh unggah file
parser = argparse.ArgumentParser(description="contoh unggah file")

# Tambahkan argumen baris perintah --region, yang menentukan wilayah tempat bucket berada. Ini adalah parameter yang diperlukan.
parser.add_argument('--region', help='Wilayah tempat bucket berada.', required=True)
# Tambahkan argumen baris perintah --bucket, yang menentukan nama bucket tempat file diunggah. Ini adalah parameter yang diperlukan.
parser.add_argument('--bucket', help='Nama bucket.', required=True)
# Tambahkan argumen baris perintah --endpoint, yang menentukan nama domain yang dapat digunakan layanan lain untuk mengakses OSS. Ini adalah parameter opsional.
parser.add_argument('--endpoint', help='Nama domain yang dapat digunakan layanan lain untuk mengakses OSS')
# Tambahkan argumen baris perintah --key, yang menentukan kunci objek (file) di OSS. Ini adalah parameter yang diperlukan.
parser.add_argument('--key', help='Nama objek.', required=True)
# Tambahkan argumen baris perintah --file_path, yang menentukan path file lokal yang akan diunggah. Ini adalah parameter yang diperlukan, misalnya, "/Users/yourLocalPath/yourFileName".
parser.add_argument('--file_path', help='Path file unggahan.', required=True)

def main():
    # Parse argumen baris perintah untuk mendapatkan nilai yang diberikan pengguna.
    args = parser.parse_args()

    # Muat informasi otentikasi yang diperlukan untuk mengakses OSS dari variabel lingkungan untuk verifikasi identitas.
    credentials_provider = oss.credentials.EnvironmentVariableCredentialsProvider()

    # Buat objek konfigurasi menggunakan konfigurasi default SDK dan atur penyedia kredensial.
    cfg = oss.config.load_default()
    cfg.credentials_provider = credentials_provider
    
    # Atur properti region objek konfigurasi berdasarkan argumen baris perintah yang diberikan pengguna.
    cfg.region = args.region

    # Jika titik akhir kustom diberikan, perbarui properti endpoint dalam objek konfigurasi.
    if args.endpoint is not None:
        cfg.endpoint = args.endpoint

    # Inisialisasi klien OSS menggunakan konfigurasi di atas untuk mempersiapkan interaksi dengan OSS.
    client = oss.Client(cfg)

    # Buat objek untuk mengunggah file dan tetapkan ukuran bagian dan konkurensi.
    uploader = client.uploader(
        part_size=100 * 1024,  # Tetapkan ukuran bagian menjadi 100 KB.
        parallel_num=5,        # Tetapkan konkurensi menjadi 5.
        leave_parts_on_error=True  # Pertahankan bagian yang diunggah jika terjadi kesalahan.
    )

    # Panggil metode untuk melakukan operasi unggah file.
    result = uploader.upload_file(
        oss.PutObjectRequest(
            bucket=args.bucket,  # Tentukan bucket tujuan.
            key=args.key,        # Tentukan nama file di OSS.
        ),
        filepath=args.file_path  # Tentukan lokasi file lokal.
    )

    # Cetak informasi tentang hasil unggahan, termasuk kode status, ID permintaan, dan Content-MD5.
    print(f'kode status: {result.status_code},'
          f' ID permintaan: {result.request_id},'
          f' content md5: {result.headers.get("Content-MD5")},'
          f' etag: {result.etag},'
          f' hash crc64: {result.hash_crc64},'
          f' ID versi: {result.version_id},'
          f' waktu server: {result.headers.get("x-oss-server-time")},'
          )

# Saat skrip ini dieksekusi langsung, panggil fungsi utama untuk memulai logika pemrosesan.
if __name__ == "__main__":
    main()  # Titik masuk skrip. Alur program dimulai dari sini.

Jika Anda ingin memberi tahu server aplikasi setelah file diunggah, gunakan kode contoh berikut.

import argparse
import base64
import alibabacloud_oss_v2 as oss

# Buat parser argumen baris perintah dan jelaskan tujuan skrip: contoh unggah file
parser = argparse.ArgumentParser(description="contoh unggah file")

# Tambahkan argumen baris perintah --region, yang menentukan wilayah tempat bucket berada. Ini adalah parameter yang diperlukan.
parser.add_argument('--region', help='Wilayah tempat bucket berada.', required=True)
# Tambahkan argumen baris perintah --bucket, yang menentukan nama bucket tempat file diunggah. Ini adalah parameter yang diperlukan.
parser.add_argument('--bucket', help='Nama bucket.', required=True)
# Tambahkan argumen baris perintah --endpoint, yang menentukan nama domain yang dapat digunakan layanan lain untuk mengakses OSS. Ini adalah parameter opsional.
parser.add_argument('--endpoint', help='Nama domain yang dapat digunakan layanan lain untuk mengakses OSS')
# Tambahkan argumen baris perintah --key, yang menentukan kunci objek (file) di OSS. Ini adalah parameter yang diperlukan.
parser.add_argument('--key', help='Nama objek.', required=True)
# Tambahkan argumen baris perintah --file_path, yang menentukan path file lokal yang akan diunggah. Ini adalah parameter yang diperlukan.
parser.add_argument('--file_path', help='Path file unggahan.', required=True)

def main():
    # Parse argumen baris perintah untuk mendapatkan nilai yang diberikan pengguna.
    args = parser.parse_args()

    # Muat informasi otentikasi yang diperlukan untuk mengakses OSS dari variabel lingkungan untuk verifikasi identitas.
    credentials_provider = oss.credentials.EnvironmentVariableCredentialsProvider()

    # Buat objek konfigurasi menggunakan konfigurasi default SDK dan atur penyedia kredensial.
    cfg = oss.config.load_default()
    cfg.credentials_provider = credentials_provider

    # Atur properti region objek konfigurasi berdasarkan argumen baris perintah yang diberikan pengguna.
    cfg.region = args.region

    # Jika titik akhir kustom diberikan, perbarui properti endpoint dalam objek konfigurasi.
    if args.endpoint is not None:
        cfg.endpoint = args.endpoint

    # Inisialisasi klien OSS menggunakan konfigurasi di atas untuk mempersiapkan interaksi dengan OSS.
    client = oss.Client(cfg)

    # Buat objek uploader untuk mengunggah file.
    uploader = client.uploader()

    # Tentukan alamat webhook.
    call_back_url = "http://www.example.com/callback"
    # Konstruksi parameter callback: tentukan alamat webhook dan badan permintaan untuk callback, dan enkode dalam Base64.
    callback=base64.b64encode(str('{\"callbackUrl\":\"' + call_back_url + '\",\"callbackBody\":\"bucket=${bucket}&object=${object}&my_var_1=${x:var1}&my_var_2=${x:var2}\"}').encode()).decode()
    # Konstruksi variabel kustom (callback-var) dan enkode dalam Base64.
    callback_var=base64.b64encode('{\"x:var1\":\"value1\",\"x:var2\":\"value2\"}'.encode()).decode()

    # Panggil metode untuk melakukan operasi unggah file.
    result = uploader.upload_file(
        oss.PutObjectRequest(
            bucket=args.bucket,  # Tentukan bucket tujuan.
            key=args.key,        # Tentukan nama file di OSS.
            callback=callback,
            callback_var=callback_var,
        ),
        filepath=args.file_path,  # Tentukan lokasi file lokal.
    )

    # Cetak informasi tentang hasil unggahan, termasuk kode status, ID permintaan, dan Content-MD5.
    print(f'kode status: {result.status_code},'
          f' ID permintaan: {result.request_id},'
          f' content md5: {result.headers.get("Content-MD5")},'
          f' etag: {result.etag},'
          f' hash crc64: {result.hash_crc64},'
          f' ID versi: {result.version_id},'
          f' waktu server: {result.headers.get("x-oss-server-time")},'
          )

# Saat skrip ini dieksekusi langsung, panggil fungsi utama untuk memulai logika pemrosesan.
if __name__ == "__main__":
    main()  # Titik masuk skrip. Alur program dimulai dari sini.