本文介绍如何将源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文件。
      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 = "/Users/liuzekun/Desktop/go1.11.8.darwin-amd64.pkg"

    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