本文介绍如何拷贝文件。

拷贝文件的完整代码请参见GitHub。

同一存储空间内拷贝文件

以下代码用于在同一个存储空间内拷贝文件：

  1. package main
  3. import (
  4.     "fmt"
  5.     "os"
  6.     "github.com/aliyun/aliyun-oss-go-sdk/oss"
  7. )
  9. func main() {
  10.     // 创建OSSClient实例。
  11.     client, err := oss.New("<yourEndpoint>", "<yourAccessKeyId>", "<yourAccessKeySecret>")
  12.     if err != nil {
  13.         fmt.Println("Error:", err)
  14.         os.Exit(-1)
  15.     }
  17.     bucketName := "<yourBucketName>"
  18.     objectName := "<yourObjectName>"
  19.     destObjectName := "<yourDestObjectName>"
  21.     // 获取存储空间。
  22.     bucket, err := client.Bucket(bucketName)
  23.     if err != nil {
  24.         fmt.Println("Error:", err)
  25.         os.Exit(-1)
  26.     }
  28.     // 拷贝文件到同一个存储空间的另一个文件。
  29.     _, err = bucket.CopyObject(objectName, destObjectName)
  30.     if err != nil {
  31.         fmt.Println("Error:", err)
  32.         os.Exit(-1)
  33.     }
  34. }

跨存储空间拷贝文件

您可以将其它存储空间的文件拷贝到当前存储空间，也可以将当前存储空间的文件拷贝到其它存储空间。代码如下：

  1. package main
  3. import (
  4.     "fmt"
  5.     "os"
  6.     "github.com/aliyun/aliyun-oss-go-sdk/oss"
  7. )
  9. func main() {
  10.     // 创建OSSClient实例。
  11.     client, err := oss.New("<yourEndpoint>", "<yourAccessKeyId>", "<yourAccessKeySecret>")
  12.     if err != nil {
  13.         fmt.Println("Error:", err)
  14.         os.Exit(-1)
  15.     }
  17.     bucketName := "<yourBucketName>"
  18.     srcBucketName := "<yourSrcBucketName>"
  19.     dstBucketName := "<yourDstBucketName>"
  20.     srcObjectName := "<yourSrcObjectName>"
  21.     dstObjectName := "<yourDstObjectName>"
  23.     // 获取存储空间。
  24.     bucket, err := client.Bucket(bucketName)
  25.     if err != nil {
  26.         fmt.Println("Error:", err)
  27.         os.Exit(-1)
  28.     }
  30.     // 从其它存储空间（srcBucketName）拷贝源文件（srcObjectName）到本存储空间。
  31.     bucket.CopyObjectFrom(srcBucketName, srcObjectName, dstObjectName)
  32.     if err != nil {
  33.         fmt.Println("CopyObjectFrom Error:", err)
  34.         os.Exit(-1)
  35.     }
  37.     // 从本存储空间拷贝源文件（srcObjectName）到其它存储空间（dstBucketName）。
  38.     bucket.CopyObjectTo(dstBucketName, dstObjectName, srcObjectName)
  39.     if err != nil {
  40.         fmt.Println("CopyObjectTo Error:", err)
  41.         os.Exit(-1)
  42.     }
  43. }

拷贝时处理文件元信息

您可以在拷贝文件时通过MetadataDirective参数来处理文件元信息。MetadataDirective的取值如下：

  • oss.MetaCopy：默认值。目标文件的元信息与源文件的元信息相同，即拷贝源文件的元信息。
  • oss.MetaReplace：使用指定的元信息覆盖源文件的元信息。

注意 oss.MetaReplace将覆盖源文件的全部元信息，且无法恢复，请谨慎操作。

MetadataDirective取值为oss.MetaReplace时，可以指定的元信息如下：

参数说明
CacheControl指定目标文件被下载时的网页的缓存行为。
ContentDisposition指定目标文件被下载时的名称。
ContentEncoding指定目标文件被下载时的内容编码格式。
Expires设置缓存过期时间，格式是格林威治时间（GMT）。
ServerSideEncryption指定OSS创建目标文件时的服务器端加密编码算法。有效值：AES256。
ObjectACL指定OSS创建的目标文件的访问权限。
Meta自定义元信息，以X-Oss-Meta-为前缀的参数。

以下代码用于在拷贝时处理文件元信息：

  1. package main
  3. import (
  4.     "fmt"
  5.     "os"
  6.     "time"
  7.     "github.com/aliyun/aliyun-oss-go-sdk/oss"
  8. )
  10. func main() {
  11.     // 创建OSSClient实例。
  12.     client, err := oss.New("<yourEndpoint>", "<yourAccessKeyId>", "<yourAccessKeySecret>")
  13.     if err != nil {
  14.         fmt.Println("Error:", err)
  15.         os.Exit(-1)
  16.     }
  18.     bucketName := "<yourBucketName>"
  19.     objectName := "<yourObjectName>"
  20.     destObjectName := "<yourDestObjectName>"
  22.     // 获取存储空间。
  23.     bucket, err := client.Bucket(bucketName)
  24.     if err != nil {
  25.         fmt.Println("Error:", err)
  26.         os.Exit(-1)
  27.     }
  29.     // 指定目标文件的元信息。
  30.     expires := time.Date(2049, time.January, 10, 23, 0, 0, 0, time.UTC)
  31.     options := []oss.Option{
  32.         oss.MetadataDirective(oss.MetaReplace),
  33.         oss.Expires(expires),
  34.         oss.ObjectACL(oss.ACLPublicRead),
  35.         oss.Meta("MyMeta", "MyMetaValue")}
  37.     // 使用指定的元信息覆盖源文件的元信息。
  38.     _, err = bucket.CopyObject(objectName, destObjectName, options...)
  39.     if err != nil {
  40.         fmt.Println("Error:", err)
  41.         os.Exit(-1)
  42.     }
  43. }

限定条件拷贝

拷贝文件时，可以指定一个或多个限定条件。满足限定条件则拷贝，不满足则返回错误，不拷贝。可以使用的限定条件如下：

参数说明
CopySourceIfMatch如果源文件的ETag和指定的ETag匹配，则执行拷贝操作；否则返回错误。
CopySourceIfNoneMatch如果源文件的ETag和指定的ETag不匹配，则执行拷贝操作；否则返回错误。
CopySourceIfModifiedSince如果指定的时间早于实际修改时间，则执行拷贝操作；否则返回错误。
CopySourceIfUnmodifiedSince如果指定的时间等于或者晚于文件实际修改时间，则执行拷贝操作；否则返回错误。

CopySourceIfMatch和CopySourceIfNoneMatch可以同时存在。CopySourceIfModifiedSince和CopySourceIfUnmodifiedSince可以同时存在。

以下代码用于限定条件拷贝：

  1. package main
  3. import (
  4.     "fmt"
  5.     "os"
  6.     "time"
  7.     "github.com/aliyun/aliyun-oss-go-sdk/oss"
  8. )
  10. func main() {
  11.     // 创建OSSClient实例。
  12.     client, err := oss.New("<yourEndpoint>", "<yourAccessKeyId>", "<yourAccessKeySecret>")
  13.     if err != nil {
  14.         fmt.Println("Error:", err)
  15.         os.Exit(-1)
  16.     }
  18.     // bucketName := "<yourBucketName>"
  19.     // objectName := "<yourObjectName>"
  20.     bucketName := "<yourBucketName>"
  21.     objectName := "<yourObjectName>"
  22.     destMatchObjectName := "<yourMatchDestObjectName>"
  23.     destUnMatchObjectName := "<yourUnmatchDestObjectName>"
  25.     // 获取存储空间。
  26.     bucket, err := client.Bucket(bucketName)
  27.     if err != nil {
  28.         fmt.Println("Error:", err)
  29.         os.Exit(-1)
  30.     }
  32.     date := time.Date(2011, time.November, 10, 23, 0, 0, 0, time.UTC)
  34.     // 满足限定条件，执行拷贝。
  35.     _, err = bucket.CopyObject(objectName, destMatchObjectName, oss.CopySourceIfModifiedSince(date))
  36.     if err != nil {
  37.         fmt.Println("CopyObject CopySourceIfModifiedSince Error:", err)
  38.     }
  40.     // 不满足限定条件，不执行拷贝。
  41.     _, err = bucket.CopyObject(objectName, destUnMatchObjectName, oss.CopySourceIfUnmodifiedSince(date))
  42.     if err != nil {
  43.         fmt.Println("CopyObject CopySourceIfUnmodifiedSince Error:", err)
  44.     }
  45. }