Object Storage Service:Copier (Go SDK V2)

Create a Copier

// Create a Copier with default options.
c := client.NewCopier()

// Create a Copier with custom options.
c := client.NewCopier(func(o *oss.CopierOptions) {
    o.PartSize = 128 * 1024 * 1024               // 128 MiB per part
    o.ParallelNum = 5                             // 5 concurrent parts
    o.MultipartCopyThreshold = 500 * 1024 * 1024 // switch to multipart above 500 MiB
})

Copy an object

The following example copies an object from a source bucket to a destination bucket, sets the storage class to Standard, and replaces the source metadata and tags with new values.

package main

import (
	"context"
	"flag"
	"log"

	"github.com/aliyun/alibabacloud-oss-go-sdk-v2/oss"
	"github.com/aliyun/alibabacloud-oss-go-sdk-v2/oss/credentials"
)

var (
	region         string
	srcBucketName  string
	srcObjectName  string
	destBucketName string
	destObjectName string
)

func init() {
	flag.StringVar(&region, "region", "", "The region where the bucket is located.")
	flag.StringVar(&srcBucketName, "src-bucket", "", "The name of the source bucket.")
	flag.StringVar(&srcObjectName, "src-object", "", "The name of the source object.")
	flag.StringVar(&destBucketName, "dest-bucket", "", "The name of the destination bucket.")
	flag.StringVar(&destObjectName, "dest-object", "", "The name of the destination object.")
}

func main() {
	flag.Parse()

	if len(srcBucketName) == 0 {
		flag.PrintDefaults()
		log.Fatalf("invalid parameters, bucket name required")
	}
	if len(region) == 0 {
		flag.PrintDefaults()
		log.Fatalf("invalid parameters, region required")
	}
	// If no destination bucket is specified, copy within the source bucket.
	if len(destBucketName) == 0 {
		destBucketName = srcBucketName
	}
	if len(srcObjectName) == 0 {
		flag.PrintDefaults()
		log.Fatalf("invalid parameters, source object name required")
	}
	if len(destObjectName) == 0 {
		flag.PrintDefaults()
		log.Fatalf("invalid parameters, destination object name required")
	}

	// Load credentials from environment variables.
	cfg := oss.LoadDefaultConfig().
		WithCredentialsProvider(credentials.NewEnvironmentVariableCredentialsProvider()).
		WithRegion(region)

	client := oss.NewClient(cfg)

	// Create a Copier.
	c := client.NewCopier()

	request := &oss.CopyObjectRequest{
		Bucket:            oss.Ptr(destBucketName),
		Key:               oss.Ptr(destObjectName),
		SourceBucket:      oss.Ptr(srcBucketName),
		SourceKey:         oss.Ptr(srcObjectName),
		StorageClass:      oss.StorageClassStandard, // Set the destination storage class to Standard.
		MetadataDirective: oss.Ptr("Replace"),        // Use new metadata instead of copying from the source.
		TaggingDirective:  oss.Ptr("Replace"),        // Use new tags instead of copying from the source.
	}

	result, err := c.Copy(context.TODO(), request)
	if err != nil {
		log.Fatalf("failed to copy object: %v", err)
	}

	log.Printf("copy result: %#v\n", result)
}

Access credentials are loaded from the OSS_ACCESS_KEY_ID and OSS_ACCESS_KEY_SECRET environment variables. For configuration details, see Configure access credentials.

NewCopier

func (c *Client) NewCopier(optFns ...func(*CopierOptions)) *Copier

Copy

func (c *Copier) Copy(ctx context.Context, request *CopyObjectRequest, optFns ...func(*CopierOptions)) (*CopyResult, error)

Parameters

Return values

CopyObjectRequest parameters

CopierOptions parameters