本文介绍如何将源Bucket中的文件(Object)复制到同一地域下相同或不同目标Bucket中。

注意事项

  • 拷贝文件时,您必须拥有源文件的读权限及目标Bucket的读写权限。
  • 拷贝文件时,您需要确保源Bucket和目标Bucket均未设置合规保留策略,否则报错The object you specified is immutable.
  • 不支持跨地域拷贝。例如不能将华东1(杭州)地域存储空间中的文件拷贝到华北1(青岛)地域。

拷贝小文件

您可以通过CopyObject方法在同一个Bucket或者同一个Region下的不同Bucket之间拷贝文件,文件大小建议小于1 GB。

同一个Bucket中拷贝文件

以下代码用于在同一个Bucket中拷贝文件。

package main

import (
    "fmt"
    "github.com/aliyun/aliyun-oss-go-sdk/oss"
    "os"
    "time"
)

func main() {
    // 创建OSSClient实例。
    // yourEndpoint填写Bucket对应的Endpoint,以华东1(杭州)为例,填写为https://oss-cn-hangzhou.aliyuncs.com。其它Region请按实际情况填写。
    // 阿里云账号AccessKey拥有所有API的访问权限,风险很高。强烈建议您创建并使用RAM用户进行API访问或日常运维,请登录RAM控制台创建RAM用户。
    client, err := oss.New("yourEndpoint", "yourAccessKeyId", "yourAccessKeySecret")
    if err != nil {
        fmt.Println("Error:", err)
        os.Exit(-1)
    }
    // 填写Bucket名称,例如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 {
        fmt.Println("Error:", err)

        os.Exit(-1)
    }

    //指定目标文件的元信息。
    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),
        // 指定复制源Object的对象标签到目标 Object。
        // oss.TaggingDirective(oss.TaggingCopy),
        // 指定创建目标Object时的访问权限ACL为私有。    
        // oss.ObjectACL(oss.ACLPrivate),
        // 指定KMS托管的用户主密钥,该参数仅在x-oss-server-side-encryption为KMS时有效。
        //oss.ServerSideEncryptionKeyID("9468da86-3509-4f8d-a61e-6eab1eac****"),
        // 指定OSS创建目标Object时使用的服务器端加密算法。
        // oss.ServerSideEncryption("AES256"),
        // 指定复制源Object的元数据到目标Object。
        //oss.MetadataDirective(oss.MetaCopy),
        // 指定CopyObject操作时是否覆盖同名目标Object。此处设置为true,表示禁止覆盖同名Object。
        // oss.ForbidOverWrite(true),
        // 如果源Object的ETag值和您提供的ETag相等,则执行拷贝操作,并返回200 OK。
        //oss.CopySourceIfMatch("5B3C1A2E053D763E1B002CC607C5****"),
        // 如果源Object的ETag值和您提供的ETag不相等,则执行拷贝操作,并返回200 OK。
        //oss.CopySourceIfNoneMatch("5B3C1A2E053D763E1B002CC607C5****"),
        // 如果指定的时间早于文件实际修改时间,则正常拷贝文件,并返回200 OK。
        //oss.CopySourceIfModifiedSince(2021-12-09T07:01:56.000Z),
        // 如果指定的时间等于或者晚于文件实际修改时间,则正常拷贝文件,并返回200 OK。
        //oss.CopySourceIfUnmodifiedSince(2021-12-09T07:01:56.000Z),
        // 指定Object的存储类型。此处设置为Standard,表示标准存储类型。
        //oss.StorageClass("Standard"),
        }

    // 使用指定的元信息覆盖源文件的元信息。
    _, err = bucket.CopyObject(objectName, destObjectName, options...)
    if err != nil {
        fmt.Println("Error:", err)
        os.Exit(-1)
    }
}

同一Region下不同Bucket之间拷贝文件

以下代码用于在同一个Region下不同Bucket之间拷贝文件。

package main

import (
  "fmt"
  "os"
  "github.com/aliyun/aliyun-oss-go-sdk/oss"
)

func main() {
  // 创建OSSClient实例。
  // yourEndpoint填写Bucket对应的Endpoint,以华东1(杭州)为例,填写为https://oss-cn-hangzhou.aliyuncs.com。其它Region请按实际情况填写。
  // 阿里云账号AccessKey拥有所有API的访问权限,风险很高。强烈建议您创建并使用RAM用户进行API访问或日常运维,请登录RAM控制台创建RAM用户。
  client, err := oss.New("yourEndpoint", "yourAccessKeyId", "yourAccessKeySecret")
  if err != nil {
    fmt.Println("Error:", err)
    os.Exit(-1)
  }

  // 填写源Bucket名称,例如srcbucket。
  srcBucketName := "srcbucket"
  // 填写拷贝前文件的完整路径,例如srcobject.jpg。
  srcObjectName := "srcobject.jpg"
  // 填写拷贝后文件的完整路径,例如destobject.jpg。
  dstObjectName := "destobject.jpg"
  // 填写目标Bucket名称,例如destbucket。
  destBucketName := "destbucket"
  
  bucket, err := client.Bucket(destBucketName)
  if err != nil {
    fmt.Println("Error:", err)
    os.Exit(-1)
  }

  // 将srcbucket中的srcobject.jpg文件拷贝至destbucket内的destobject.jpg文件。
  _, err = bucket.CopyObjectFrom(srcBucketName, srcObjectName, dstObjectName)
  if err != nil {
    fmt.Println("CopyObjectFrom Error:", err)
    os.Exit(-1)
  }
}

拷贝大文件

以下代码用于拷贝大文件:

package main

import (
    "fmt"
    "os"
    "github.com/aliyun/aliyun-oss-go-sdk/oss"
)

func main() {
    // 创建OSSClient实例。
    // yourEndpoint填写Bucket对应的Endpoint,以华东1(杭州)为例,填写为https://oss-cn-hangzhou.aliyuncs.com。其它Region请按实际情况填写。
    // 阿里云账号AccessKey拥有所有API的访问权限,风险很高。强烈建议您创建并使用RAM用户进行API访问或日常运维,请登录RAM控制台创建RAM用户。
    client, err := oss.New("yourEndpoint", "yourAccessKeyId", "yourAccessKeySecret")
    if err != nil {
        fmt.Println("Error:", err)
        os.Exit(-1)
    }
    // 填写Bucket名称,例如examplebucket。
    bucketName := "examplebucket"

    // 获取存储空间。
    bucket, err := client.Bucket(bucketName)
    if err != nil {
        fmt.Println("Error:", err)
        os.Exit(-1)
    }

    // 指定拷贝前文件的完整路径,例如srcobject.txt。
    objectSrc := "srcobject.txt"
    // 指定拷贝后文件的完整路径,例如destobject.txt。
    objectDest := "destobject.txt"
    // 填写本地文件完整路径。
    var fileName = "D:\\localpath\\examplefile.txt"

    chunks, err := oss.SplitFileByPartNum(fileName, 3)
    if err != nil {
        fmt.Println("Error:", err)
        os.Exit(-1)
    }


    err = bucket.PutObjectFromFile(objectSrc, fileName)
    if err != nil {
        fmt.Println("Error:", err)
        os.Exit(-1)
    }

    imur, err := bucket.InitiateMultipartUpload(objectDest)

    var parts []oss.UploadPart
    for _, chunk := range chunks {
        // 使用指定的元信息覆盖源文件的元信息。
        options := []oss.Option{
            // 指定源Object的拷贝范围,例如设置bytes=0~1023,表示拷贝1~1024字节的内容。
            // oss.CopySourceRange(0,1023),
            // 如果源Object的ETag值和您提供的ETag相等,则执行拷贝操作,并返回200 OK。
            // oss.CopySourceIfMatch("5B3C1A2E053D763E1B002CC607C5****"),
            // 如果源Object的ETag值和您提供的ETag不相等,则执行拷贝操作,并返回200 OK。
            // oss.CopySourceIfNoneMatch("5B3C1A2E053D763E1B002CC607C5****"),
            // 如果指定的时间等于或者晚于文件实际修改时间,则正常拷贝文件,并返回200 OK。
            // oss.CopySourceIfModifiedSince(2021-12-09T07:01:56.000Z),
            // 如果指定的时间早于文件实际修改时间,则正常拷贝文件,并返回200 OK。
            // oss.CopySourceIfUnmodifiedSince(2021-12-09T07:01:56.000Z),
        }

        part, err := bucket.UploadPartCopy(imur, bucketName, objectSrc, chunk.Offset, chunk.Size, chunk.Number ,options...)
        if err != nil {
            fmt.Println("Error:", err)
            os.Exit(-1)
        }
        parts = append(parts, part)
    }

    cmur, err := bucket.CompleteMultipartUpload(imur, parts)

    fmt.Println("cmur:", cmur)

    if err != nil {
        fmt.Println("Error:", err)
        os.Exit(-1)
    }
}

相关文档

  • 关于拷贝文件的完整示例代码,请参见GitHub示例
  • 关于拷贝小文件的API接口说明,请参见CopyObject
  • 关于拷贝大文件的API接口说明,请参见UploadPartCopy