Object Storage Service:Unduh objek ke file lokal (Go SDK V1)

Anda dapat menentukan kondisi saat mengunduh objek dari bucket. Kondisi tersebut dapat didasarkan pada waktu modifikasi terakhir objek atau ETag-nya. ETag adalah pengidentifikasi untuk konten objek. Objek hanya akan diunduh jika kondisi yang ditentukan terpenuhi; jika tidak, error akan dikembalikan. Unduhan bersyarat membantu mengurangi lalu lintas jaringan dan meningkatkan efisiensi.

OSS mendukung kondisi berikut:

Kode berikut menunjukkan cara melakukan unduhan bersyarat.

package main

import (
	"log"
	"time"

	"github.com/aliyun/aliyun-oss-go-sdk/oss"
)

func main() {
	// Peroleh kredensial akses dari variabel lingkungan. Sebelum menjalankan kode contoh, pastikan variabel lingkungan OSS_ACCESS_KEY_ID dan OSS_ACCESS_KEY_SECRET telah dikonfigurasi.
	provider, err := oss.NewEnvironmentVariableCredentialsProvider()
	if err != nil {
		log.Fatalf("Gagal membuat penyedia kredensial: %v", err)
	}

	// Buat instans OSSClient.
	// Setel yourEndpoint ke titik akhir bucket. Misalnya, untuk bucket di wilayah China (Hangzhou), setel titik akhir ke https://oss-cn-hangzhou.aliyuncs.com. Untuk bucket di wilayah lain, setel titik akhir ke titik akhir aktual.
	// Setel yourRegion ke wilayah tempat bucket berada. Misalnya, untuk bucket di wilayah China (Hangzhou), setel wilayah ke cn-hangzhou. Untuk bucket di wilayah lain, setel wilayah ke wilayah aktual.
	clientOptions := []oss.ClientOption{oss.SetCredentialsProvider(&provider)}
	clientOptions = append(clientOptions, oss.Region("yourRegion"))
	// Setel versi signature.
	clientOptions = append(clientOptions, oss.AuthVersion(oss.AuthV4))
	client, err := oss.New("yourEndpoint", "", "", clientOptions...)
	if err != nil {
		log.Fatalf("Gagal membuat client OSS: %v", err)
	}

	// Tentukan nama bucket.
	bucketName := "yourBucketName" // Ganti dengan nama bucket yang sebenarnya.
	bucket, err := client.Bucket(bucketName)
	if err != nil {
		log.Fatalf("Gagal mendapatkan bucket: %v", err)
	}

	// Asumsikan objek terakhir dimodifikasi pada pukul 18:43:02, 21 November 2023. Jika Anda menentukan waktu UTC yang lebih awal dari waktu ini, kondisi IfModifiedSince terpenuhi dan unduhan dipicu.
	date := time.Date(2023, time.November, 21, 18, 43, 2, 0, time.UTC)

	// Tentukan path lengkap objek. Path lengkap tidak boleh mengandung nama bucket.
	objectName := "yourObjectName" // Ganti dengan nama objek yang sebenarnya.
	localFilePath := "LocalFile"   // Path file lokal.

	// Kondisi tidak terpenuhi. Objek tidak diunduh.
	err = bucket.GetObjectToFile(objectName, localFilePath, oss.IfUnmodifiedSince(date))
	if err == nil {
		log.Fatal("Mengharapkan error ketika kondisi tidak terpenuhi, tetapi mendapatkan nil")
	}

	// Kondisi terpenuhi. Objek diunduh.
	err = bucket.GetObjectToFile(objectName, localFilePath, oss.IfModifiedSince(date))
	if err != nil {
		log.Fatalf("Gagal mengunduh file: %v", err)
	}

	log.Println("File berhasil diunduh.")
}

Saat mengunduh objek, Anda dapat menggunakan progress bar untuk memantau progres unduhan secara real-time. Fitur ini membantu Anda melacak status tugas dan menghindari kekhawatiran bahwa unduhan macet selama waktu tunggu yang lama.

Kode berikut menunjukkan cara menampilkan progress bar saat mengunduh objek exampleobject.txt dari bucket examplebucket.

package main

import (
	"log"
	"sync/atomic"

	"github.com/aliyun/aliyun-oss-go-sdk/oss"
)

// Definisikan pendengar progres.
type OssProgressListener struct {
	lastProgress int64
}

// Definisikan penanganan untuk event perubahan progres.
func (listener *OssProgressListener) ProgressChanged(event *oss.ProgressEvent) {
	switch event.EventType {
	case oss.TransferStartedEvent:
		log.Printf("Transfer Dimulai, ConsumedBytes: %d, TotalBytes %d.\n",
			event.ConsumedBytes, event.TotalBytes)
	case oss.TransferDataEvent:
		if event.TotalBytes != 0 {
			progress := int64(event.ConsumedBytes * 100 / event.TotalBytes)
			if progress > atomic.LoadInt64(&listener.lastProgress) {
				atomic.StoreInt64(&listener.lastProgress, progress)
				log.Printf("\rTransfer Data, ConsumedBytes: %d, TotalBytes %d, %d%%.",
					event.ConsumedBytes, event.TotalBytes, progress)
			}
		}
	case oss.TransferCompletedEvent:
		log.Printf("\nTransfer Selesai, ConsumedBytes: %d, TotalBytes %d.\n",
			event.ConsumedBytes, event.TotalBytes)
	case oss.TransferFailedEvent:
		log.Printf("\nTransfer Gagal, ConsumedBytes: %d, TotalBytes %d.\n",
			event.ConsumedBytes, event.TotalBytes)
	default:
	}
}

func main() {
	// Peroleh kredensial akses dari variabel lingkungan. Sebelum menjalankan kode contoh, pastikan variabel lingkungan OSS_ACCESS_KEY_ID dan OSS_ACCESS_KEY_SECRET telah dikonfigurasi.
	provider, err := oss.NewEnvironmentVariableCredentialsProvider()
	if err != nil {
		log.Fatalf("Error: %v", err)
	}

	// Buat instans OSSClient.
	// Setel yourEndpoint ke titik akhir bucket. Misalnya, untuk bucket di wilayah China (Hangzhou), setel titik akhir ke https://oss-cn-hangzhou.aliyuncs.com. Untuk bucket di wilayah lain, setel titik akhir ke titik akhir aktual.
	// Setel yourRegion ke wilayah tempat bucket berada. Misalnya, untuk bucket di wilayah China (Hangzhou), setel wilayah ke cn-hangzhou. Untuk bucket di wilayah lain, setel wilayah ke wilayah aktual.
	clientOptions := []oss.ClientOption{oss.SetCredentialsProvider(&provider)}
	clientOptions = append(clientOptions, oss.Region("yourRegion"))
	// Setel versi signature.
	clientOptions = append(clientOptions, oss.AuthVersion(oss.AuthV4))
	client, err := oss.New("yourEndpoint", "", "", clientOptions...)
	if err != nil {
		log.Fatalf("Error: %v", err)
	}

	// Tentukan nama bucket.
	bucketName := "examplebucket"
	// Tentukan path lengkap objek. Path lengkap tidak boleh mengandung nama bucket.
	objectName := "exampleobject.txt"
	// Tentukan path lengkap file lokal. Jika file lokal yang ditentukan sudah ada, file tersebut akan ditimpa. Jika file lokal yang ditentukan belum ada, file tersebut akan dibuat.
	// Jika Anda tidak menentukan path lokal, file yang diunduh akan disimpan ke path lokal proyek tempat program contoh berada.
	localFile := "D:\\localpath\\examplefile.txt"

	// Dapatkan bucket.
	bucket, err := client.Bucket(bucketName)
	if err != nil {
		log.Fatalf("Error: %v", err)
	}

	// Unduh objek dengan progress bar.
	err = bucket.GetObjectToFile(objectName, localFile, oss.Progress(&OssProgressListener{}))
	if err != nil {
		log.Fatalf("Error: %v", err)
	}
	log.Println("Transfer Selesai.")
}