Object Storage Service:Go SDK を使用したオブジェクトのコピー

CopyObject を呼び出して、同じリージョン内のバケット内またはバケット間でオブジェクトをコピーできます。 サイズが 1 GB 未満のオブジェクトをコピーするには、CopyObject を呼び出すことをお勧めします。

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 インスタンスを作成します。
	// バケットが配置されているリージョンのエンドポイントを指定します。 たとえば、バケットが中国 (杭州) リージョンにある場合は、エンドポイントを https://oss-cn-hangzhou.aliyuncs.com に設定します。 実際のエンドポイントを指定してください。
	// バケットが配置されているリージョンを指定します。 たとえば、バケットが中国 (杭州) リージョンにある場合は、リージョンを 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)
	}

	// バケットの名前を指定します。 例: examplebucket。
	bucketName := "examplebucket"
	// ソースオブジェクトの完全なパスを指定します。 例: srcdir/srcobject.jpg。
	objectName := "srcdir/srcobject.jpg"
	// デスティネーションオブジェクトの完全なパスを指定します。 例: destdir/destobject.jpg。
	destObjectName := "destdir/destobject.jpg"

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

	// デスティネーションオブジェクトのメタデータを指定します。
	expires := time.Date(2049, time.January, 10, 23, 0, 0, 0, time.UTC)
	tag1 := oss.Tag{
		Key:   "a",
		Value: "1",
	}

	taggingInfo := oss.Tagging{
		Tags: []oss.Tag{tag1},
	}

	options := []oss.Option{
		oss.MetadataDirective(oss.MetaReplace),
		oss.Expires(expires),
		oss.SetTagging(taggingInfo),
		// ソースオブジェクトのタグをデスティネーションオブジェクトにコピーします。
		// oss.TaggingDirective(oss.TaggingCopy),
		// OSS がデスティネーションオブジェクトを作成するときに、デスティネーションオブジェクトのアクセス制御リスト (ACL) を非公開に設定します。
		// oss.ObjectACL(oss.ACLPrivate),
		// Key Management Service (KMS) によって管理されるカスタマーマスターキー (CMK) を指定します。 このパラメーターは、x-oss-server-side-encryption が KMS に設定されている場合にのみ有効になります。
		// oss.ServerSideEncryptionKeyID("9468da86-3509-4f8d-a61e-6eab1eac****"),
		// OSS がオブジェクトを作成するときに、デスティネーションオブジェクトの暗号化に使用するサーバー側暗号化アルゴリズムを指定します。
		// oss.ServerSideEncryption("AES256"),
		// ソースオブジェクトのメタデータをデスティネーションオブジェクトにコピーします。
		// oss.MetadataDirective(oss.MetaCopy),
		// CopyObject 操作で、ソースバケットと同じ名前のオブジェクトを上書きするかどうかを指定します。 この例では、このパラメーターは true に設定されています。 値 true は、操作がソースバケットと同じ名前のオブジェクトを上書きしないことを示します。
		// oss.ForbidOverWrite(true),
		// リクエストで指定した ETag 値がソースオブジェクトの ETag 値と同じである場合、OSS はオブジェクトをコピーし、200 OK を返します。
		// oss.CopySourceIfMatch("5B3C1A2E053D763E1B002CC607C5****"),
		// リクエストで指定した ETag 値がソースオブジェクトの ETag 値と異なる場合、OSS はオブジェクトをコピーし、200 OK を返します。
		// oss.CopySourceIfNoneMatch("5B3C1A2E053D763E1B002CC607C5****"),
		// リクエストで指定された時間がオブジェクトが変更された実際の時間よりも早い場合、OSS はオブジェクトをコピーし、200 OK を返します。
		// oss.CopySourceIfModifiedSince(time.Date(2021, time.December, 9, 7, 1, 56, 0, time.UTC)),
		// リクエストで指定された時間がオブジェクトの変更時刻と同じかそれ以降の場合、OSS はオブジェクトをコピーし、200 OK を返します。
		// oss.CopySourceIfUnmodifiedSince(time.Date(2021, time.December, 9, 7, 1, 56, 0, time.UTC)),
		// デスティネーションオブジェクトのストレージクラスを指定します。 この例では、ストレージクラスは標準に設定されています。
		// oss.StorageClass("Standard"),
	}

	// リクエストで指定したメタデータを使用して、ソースオブジェクトのメタデータを上書きします。
	_, err = bucket.CopyObject(objectName, destObjectName, options...)
	if err != nil {
		log.Fatalf("Failed to copy object from '%s' to '%s': %v", objectName, destObjectName, err)
	}

	log.Printf("Successfully copied object from '%s' to '%s'", objectName, destObjectName)
}

package main

import (
	"log"

	"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 インスタンスを作成します。
	// バケットが配置されているリージョンのエンドポイントを指定します。 たとえば、バケットが中国 (杭州) リージョンにある場合は、エンドポイントを https://oss-cn-hangzhou.aliyuncs.com に設定します。 実際のエンドポイントを指定してください。
	// バケットが配置されているリージョンを指定します。 たとえば、バケットが中国 (杭州) リージョンにある場合は、リージョンを 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)
	}

	// ソースバケットの名前を指定します。 例: srcbucket。
	srcBucketName := "srcbucket"
	// ソースオブジェクトの完全なパスを指定します。 例: srcobject.jpg。
	srcObjectName := "srcobject.jpg"
	// デスティネーションオブジェクトの完全なパスを指定します。 例: destobject.jpg。
	dstObjectName := "destobject.jpg"
	// デスティネーションバケットの名前を指定します。 例: destbucket。
	destBucketName := "destbucket"

	// デスティネーションバケットを作成します。
	bucket, err := client.Bucket(destBucketName)
	if err != nil {
		log.Fatalf("Failed to get bucket '%s': %v", destBucketName, err)
	}

	// srcbucket から srcobject.jpg オブジェクトを destbucket の destobject.jpg オブジェクトにコピーします。
	_, err = bucket.CopyObjectFrom(srcBucketName, srcObjectName, dstObjectName)
	if err != nil {
		log.Fatalf("Failed to copy object from '%s/%s' to '%s/%s': %v", srcBucketName, srcObjectName, destBucketName, dstObjectName, err)
	}

	log.Printf("Successfully copied object from '%s/%s' to '%s/%s'", srcBucketName, srcObjectName, destBucketName, dstObjectName)
}

次のコードは、大きなオブジェクトをコピーする方法の例を示しています。

package main

import (
	"log"

	"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 インスタンスを作成します。
	// バケットが配置されているリージョンのエンドポイントを指定します。 たとえば、バケットが中国 (杭州) リージョンにある場合は、エンドポイントを https://oss-cn-hangzhou.aliyuncs.com に設定します。 実際のエンドポイントを指定してください。
	// バケットが配置されているリージョンを指定します。 たとえば、バケットが中国 (杭州) リージョンにある場合は、リージョンを 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)
	}

	// バケットの名前を指定します。 例: examplebucket。
	bucketName := "examplebucket"

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

	// ソースオブジェクトの完全なパスを指定します。 例: srcobject.txt。
	objectSrc := "srcobject.txt"
	// デスティネーションオブジェクトの完全なパスを指定します。 例: destobject.txt。
	objectDest := "destobject.txt"
	// ローカルファイルの完全なパスを指定します。
	fileName := "D:\\localpath\\examplefile.txt"

	// オブジェクトを複数のチャンクに分割します。
	chunks, err := oss.SplitFileByPartNum(fileName, 3)
	if err != nil {
		log.Fatalf("Failed to split file: %v", err)
	}

	// ファイルを OSS にアップロードします。
	err = bucket.PutObjectFromFile(objectSrc, fileName)
	if err != nil {
		log.Fatalf("Failed to upload object '%s' from file '%s': %v", objectSrc, fileName, err)
	}

	// マルチパートアップロードを開始します。
	imur, err := bucket.InitiateMultipartUpload(objectDest)
	if err != nil {
		log.Fatalf("Failed to initiate multipart upload for '%s': %v", objectDest, err)
	}

	var parts []oss.UploadPart
	for _, chunk := range chunks {
		// マルチパートアップロードのオプションを指定します。
		options := []oss.Option{}

		// アップロードされたパーツをコピーします。
		part, err := bucket.UploadPartCopy(imur, bucketName, objectSrc, chunk.Offset, chunk.Size, chunk.Number, options...)
		if err != nil {
			log.Fatalf("Failed to upload part %d of '%s': %v", chunk.Number, objectSrc, err)
		}
		parts = append(parts, part)
	}

	// マルチパートアップロードを完了します。
	cmur, err := bucket.CompleteMultipartUpload(imur, parts)
	if err != nil {
		log.Fatalf("Failed to complete multipart upload for '%s': %v", objectDest, err)
	}

	log.Printf("Multipart upload completed successfully for '%s'. cmur: %v", objectDest, cmur)
}