Object Storage Service:オブジェクトをローカルファイルにダウンロードする (Go SDK V1)

バケットからオブジェクトをダウンロードする際に、条件を指定できます。これらの条件は、オブジェクトの最終更新時刻または ETag に基づいて設定できます。ETag は、オブジェクトのコンテンツの識別子です。オブジェクトは、指定された条件が満たされた場合にのみダウンロードされます。それ以外の場合は、エラーが返されます。条件付きダウンロードにより、ネットワークトラフィックが削減され、効率が向上します。

OSS は次の条件をサポートしています：

次のコードは、条件付きダウンロードを実行する方法の例です。

package main

import (
	"log"
	"time"

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

func main() {
	// 環境変数からアクセス認証情報を取得します。サンプルコードを実行する前に、OSS_ACCESS_KEY_ID および OSS_ACCESS_KEY_SECRET 環境変数が設定されていることを確認してください。
	provider, err := oss.NewEnvironmentVariableCredentialsProvider()
	if err != nil {
		log.Fatalf("Failed to create credentials provider: %v", err)
	}

	// OSSClient インスタンスを作成します。
	// yourEndpoint をバケットのエンドポイントに設定します。たとえば、中国 (杭州) リージョンのバケットの場合、エンドポイントを https://oss-cn-hangzhou.aliyuncs.com に設定します。他のリージョンのバケットの場合は、実際のエンドポイントに設定します。
	// yourRegion をバケットが配置されているリージョンに設定します。たとえば、中国 (杭州) リージョンのバケットの場合、リージョンを cn-hangzhou に設定します。他のリージョンのバケットの場合は、実際のリージョンに設定します。
	clientOptions := []oss.ClientOption{oss.SetCredentialsProvider(&provider)}
	clientOptions = append(clientOptions, oss.Region("yourRegion"))
	// 署名バージョンを設定します。
	clientOptions = append(clientOptions, oss.AuthVersion(oss.AuthV4))
	client, err := oss.New("yourEndpoint", "", "", clientOptions...)
	if err != nil {
		log.Fatalf("Failed to create OSS client: %v", err)
	}

	// バケット名を指定します。
	bucketName := "yourBucketName" // 実際のバケット名に置き換えてください。
	bucket, err := client.Bucket(bucketName)
	if err != nil {
		log.Fatalf("Failed to get bucket: %v", err)
	}

	// オブジェクトが 2023年11月21日 18:43:02 に最終更新されたと仮定します。この時刻より前の UTC 時刻を指定すると、IfModifiedSince 条件が満たされ、ダウンロードがトリガーされます。
	date := time.Date(2023, time.November, 21, 18, 43, 2, 0, time.UTC)

	// オブジェクトの完全なパスを指定します。完全なパスにバケット名を含めることはできません。
	objectName := "yourObjectName" // 実際のオブジェクト名に置き換えてください。
	localFilePath := "LocalFile"   // ローカルファイルのパス。

	// 条件が満たされないため、オブジェクトはダウンロードされません。
	err = bucket.GetObjectToFile(objectName, localFilePath, oss.IfUnmodifiedSince(date))
	if err == nil {
		log.Fatal("Expected an error when the condition is not met, but got nil")
	}

	// 条件が満たされたため、オブジェクトはダウンロードされます。
	err = bucket.GetObjectToFile(objectName, localFilePath, oss.IfModifiedSince(date))
	if err != nil {
		log.Fatalf("Failed to download file: %v", err)
	}

	log.Println("File has been downloaded successfully.")
}

オブジェクトをダウンロードする際に、プログレスバーを使用してリアルタイムのダウンロード進行状況を確認できます。これにより、タスクをモニターし、長時間の待機中にダウンロードが停止したのではないかという懸念を回避できます。

次のコードは、examplebucket バケットから exampleobject.txt オブジェクトをダウンロードする際にプログレスバーを表示する方法の例です。

package main

import (
	"log"
	"sync/atomic"

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

// プログレスリスナーを定義します。
type OssProgressListener struct {
	lastProgress int64
}

// 進行状況変更イベントのハンドラを定義します。
func (listener *OssProgressListener) ProgressChanged(event *oss.ProgressEvent) {
	switch event.EventType {
	case oss.TransferStartedEvent:
		log.Printf("Transfer Started, 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 Completed, ConsumedBytes: %d, TotalBytes %d.\n",
			event.ConsumedBytes, event.TotalBytes)
	case oss.TransferFailedEvent:
		log.Printf("\nTransfer Failed, ConsumedBytes: %d, TotalBytes %d.\n",
			event.ConsumedBytes, event.TotalBytes)
	default:
	}
}

func main() {
	// 環境変数からアクセス認証情報を取得します。サンプルコードを実行する前に、OSS_ACCESS_KEY_ID および OSS_ACCESS_KEY_SECRET 環境変数が設定されていることを確認してください。
	provider, err := oss.NewEnvironmentVariableCredentialsProvider()
	if err != nil {
		log.Fatalf("Error: %v", err)
	}

	// OSSClient インスタンスを作成します。
	// yourEndpoint をバケットのエンドポイントに設定します。たとえば、中国 (杭州) リージョンのバケットの場合、エンドポイントを https://oss-cn-hangzhou.aliyuncs.com に設定します。他のリージョンのバケットの場合は、実際のエンドポイントに設定します。
	// yourRegion をバケットが配置されているリージョンに設定します。たとえば、中国 (杭州) リージョンのバケットの場合、リージョンを cn-hangzhou に設定します。他のリージョンのバケットの場合は、実際のリージョンに設定します。
	clientOptions := []oss.ClientOption{oss.SetCredentialsProvider(&provider)}
	clientOptions = append(clientOptions, oss.Region("yourRegion"))
	// 署名バージョンを設定します。
	clientOptions = append(clientOptions, oss.AuthVersion(oss.AuthV4))
	client, err := oss.New("yourEndpoint", "", "", clientOptions...)
	if err != nil {
		log.Fatalf("Error: %v", err)
	}

	// バケット名を指定します。
	bucketName := "examplebucket"
	// オブジェクトの完全なパスを指定します。完全なパスにバケット名を含めることはできません。
	objectName := "exampleobject.txt"
	// ローカルファイルの完全なパスを指定します。指定されたローカルファイルが存在する場合、上書きされます。指定されたローカルファイルが存在しない場合は、作成されます。
	// ローカルパスを指定しない場合、ダウンロードされたファイルはサンプルプログラムが存在するプロジェクトのローカルパスに保存されます。
	localFile := "D:\\localpath\\examplefile.txt"

	// バケットを取得します。
	bucket, err := client.Bucket(bucketName)
	if err != nil {
		log.Fatalf("Error: %v", err)
	}

	// プログレスバー付きでオブジェクトをダウンロードします。
	err = bucket.GetObjectToFile(objectName, localFile, oss.Progress(&OssProgressListener{}))
	if err != nil {
		log.Fatalf("Error: %v", err)
	}
	log.Println("Transfer Completed.")
}