このトピックでは、バケット内または同じリージョン内のバケット間でオブジェクトをコピーする方法について説明します。
使用上の注意
このトピックでは、中国 (杭州) リージョンのパブリックエンドポイントを使用します。 OSSと同じリージョンにある他のAlibaba CloudサービスからOSSにアクセスする場合は、内部エンドポイントを使用します。 OSSリージョンとエンドポイントの詳細については、「リージョン、エンドポイント、オープンポート」をご参照ください。
このトピックでは、アクセス資格情報は環境変数から取得します。 アクセス資格情報の設定方法の詳細については、「アクセス資格情報の設定」をご参照ください。
このトピックでは、OSSエンドポイントを使用してOSSClientインスタンスを作成します。 カスタムドメイン名またはSTS (Security Token Service) を使用してOSSClientインスタンスを作成する場合は、「初期化」をご参照ください。
オブジェクトをコピーするには、ソースオブジェクトに対する読み取り権限と、宛先バケットに対する読み取りおよび書き込み権限が必要です。
ソースバケットとターゲットバケットに保持ポリシーが設定されていないことを確認します。 それ以外の場合、エラーメッセージ指定したオブジェクトは不変です。 が返されます。
ソースバケットと宛先バケットは同じリージョンにある必要があります。 たとえば、中国 (杭州) リージョンにあるバケットから中国 (青島) リージョンにある別のバケットにオブジェクトをコピーすることはできません。
サンプルコード
小さなオブジェクトをコピーする
CopyObjectを呼び出して、バケット内または同じリージョン内のバケット間でオブジェクトをコピーできます。 1 GB未満のサイズのオブジェクトをコピーするには、CopyObjectを呼び出すことを推奨します。
同じバケット内のオブジェクトのコピー
package main
import (
"log"
"time"
"github.com/aliyun/aliyun-oss-go-sdk/oss"
)
func main() {
// Obtain access credentials from environment variables. Before you run the sample code, make sure that the OSS_ACCESS_KEY_ID and OSS_ACCESS_KEY_SECRET environment variables are configured.
provider, err := oss.NewEnvironmentVariableCredentialsProvider()
if err != nil {
log.Fatalf("Failed to create credentials provider: %v", err)
}
// Create an OSSClient instance.
// Specify the endpoint of the region in which the bucket is located. For example, if the bucket is located in the China (Hangzhou) region, set the endpoint to https://oss-cn-hangzhou.aliyuncs.com. Specify your actual endpoint.
// Specify the region in which the bucket is located. For example, if the bucket is located in the China (Hangzhou) region, set the region to cn-hangzhou. Specify the actual region.
clientOptions := []oss.ClientOption{oss.SetCredentialsProvider(&provider)}
clientOptions = append(clientOptions, oss.Region("yourRegion"))
// Specify the version of the signature algorithm.
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)
}
// Specify the name of the bucket. Example: examplebucket.
bucketName := "examplebucket"
// Specify the full path of the source object. Example: srcdir/srcobject.jpg.
objectName := "srcdir/srcobject.jpg"
// Specify the full path of the destination object. Example: destdir/destobject.jpg.
destObjectName := "destdir/destobject.jpg"
// Obtain the bucket information.
bucket, err := client.Bucket(bucketName)
if err != nil {
log.Fatalf("Failed to get bucket '%s': %v", bucketName, err)
}
// Specify the metadata of the destination object.
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),
// Copy the tags of the source object to the destination object.
// oss.TaggingDirective(oss.TaggingCopy),
// Set the access control list (ACL) of the destination object to private when OSS creates the destination object.
// oss.ObjectACL(oss.ACLPrivate),
// Specify the customer master key (CMK) that is managed by Key Management Service (KMS). This parameter takes effect only when x-oss-server-side-encryption is set to KMS.
// oss.ServerSideEncryptionKeyID("9468da86-3509-4f8d-a61e-6eab1eac****"),
// Specify the server-side encryption algorithm that is used to encrypt the destination object when OSS creates the object.
// oss.ServerSideEncryption("AES256"),
// Copy the metadata of the source object to the destination object.
// oss.MetadataDirective(oss.MetaCopy),
// Specify whether the CopyObject operation overwrites an object that has the same name as the source bucket. In this example, this parameter is set to true. The value true indicates that the operation does not overwrite an object that has the same name as the source bucket.
// oss.ForbidOverWrite(true),
// If the ETag value that you specify in the request is the same as the ETag value of the source object, OSS copies the object and returns 200 OK.
// oss.CopySourceIfMatch("5B3C1A2E053D763E1B002CC607C5****"),
// If the ETag value that you specify in the request is different from the ETag value of the source object, OSS copies the object and returns 200 OK.
// oss.CopySourceIfNoneMatch("5B3C1A2E053D763E1B002CC607C5****"),
// If the time specified in the request is earlier than the actual time when the object is modified, OSS copies the object and returns 200 OK.
// oss.CopySourceIfModifiedSince(time.Date(2021, time.December, 9, 7, 1, 56, 0, time.UTC)),
// If the time specified in the request is the same as or later than the modification time of the object, OSS copies the object and returns 200 OK.
// oss.CopySourceIfUnmodifiedSince(time.Date(2021, time.December, 9, 7, 1, 56, 0, time.UTC)),
// Specify the storage class of the destination object. In this example, the storage class is set to Standard.
// oss.StorageClass("Standard"),
}
// Overwrite the metadata of the source object by using the metadata that you specify in the request.
_, 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() {
// Obtain access credentials from environment variables. Before you run the sample code, make sure that the OSS_ACCESS_KEY_ID and OSS_ACCESS_KEY_SECRET environment variables are configured.
provider, err := oss.NewEnvironmentVariableCredentialsProvider()
if err != nil {
log.Fatalf("Failed to create credentials provider: %v", err)
}
// Create an OSSClient instance.
// Specify the endpoint of the region in which the bucket is located. For example, if the bucket is located in the China (Hangzhou) region, set the endpoint to https://oss-cn-hangzhou.aliyuncs.com. Specify your actual endpoint.
// Specify the region in which the bucket is located. For example, if the bucket is located in the China (Hangzhou) region, set the region to cn-hangzhou. Specify the actual region.
clientOptions := []oss.ClientOption{oss.SetCredentialsProvider(&provider)}
clientOptions = append(clientOptions, oss.Region("yourRegion"))
// Specify the version of the signature algorithm.
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)
}
// Specify the name of the source bucket. Example: srcbucket.
srcBucketName := "srcbucket"
// Specify the full path of the source object. Example: srcobject.jpg.
srcObjectName := "srcobject.jpg"
// Specify the full path of the destination object. Example: destobject.jpg.
dstObjectName := "destobject.jpg"
// Specify the name of the destination bucket. Example: destbucket.
destBucketName := "destbucket"
// Create the destination bucket.
bucket, err := client.Bucket(destBucketName)
if err != nil {
log.Fatalf("Failed to get bucket '%s': %v", destBucketName, err)
}
// Copy the srcobject.jpg object from srcbucket to the destobject.jpg object in destbucket.
_, 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() {
// Obtain access credentials from environment variables. Before you run the sample code, make sure that the OSS_ACCESS_KEY_ID and OSS_ACCESS_KEY_SECRET environment variables are configured.
provider, err := oss.NewEnvironmentVariableCredentialsProvider()
if err != nil {
log.Fatalf("Failed to create credentials provider: %v", err)
}
// Create an OSSClient instance.
// Specify the endpoint of the region in which the bucket is located. For example, if the bucket is located in the China (Hangzhou) region, set the endpoint to https://oss-cn-hangzhou.aliyuncs.com. Specify your actual endpoint.
// Specify the region in which the bucket is located. For example, if the bucket is located in the China (Hangzhou) region, set the region to cn-hangzhou. Specify the actual region.
clientOptions := []oss.ClientOption{oss.SetCredentialsProvider(&provider)}
clientOptions = append(clientOptions, oss.Region("yourRegion"))
// Specify the version of the signature algorithm.
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)
}
// Specify the name of the bucket. Example: examplebucket.
bucketName := "examplebucket"
// Obtain the bucket information.
bucket, err := client.Bucket(bucketName)
if err != nil {
log.Fatalf("Failed to get bucket '%s': %v", bucketName, err)
}
// Specify the full path of the source object. Example: srcobject.txt.
objectSrc := "srcobject.txt"
// Specify the full path of the destination object. Example: destobject.txt.
objectDest := "destobject.txt"
// Specify the full path of the local file.
fileName := "D:\\localpath\\examplefile.txt"
// Splits the object into multiple chunks.
chunks, err := oss.SplitFileByPartNum(fileName, 3)
if err != nil {
log.Fatalf("Failed to split file: %v", err)
}
// Upload the file to OSS.
err = bucket.PutObjectFromFile(objectSrc, fileName)
if err != nil {
log.Fatalf("Failed to upload object '%s' from file '%s': %v", objectSrc, fileName, err)
}
// Initiate Multipart Upload.
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 {
// Specify options for Multipart Upload.
options := []oss.Option{}
// Copy the uploaded parts.
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)
}
// Complete Multipart Upload.
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)
}
関連ドキュメント
オブジェクトのコピーに使用される完全なサンプルコードについては、『GitHub』をご参照ください。
小さなオブジェクトをコピーするために呼び出すことができるAPI操作の詳細については、「CopyObject」をご参照ください。
ラージオブジェクトをコピーするために呼び出すことができるAPI操作の詳細については、「UploadPartCopy」をご参照ください。