腾讯云对象存储复制与移动对象

简介

本文档提供关于对象的复制、移动操作相关的 API 概览以及 SDK 示例代码。简单操作

分块操作

简单操作

复制对象（修改属性）

PUT Object – Copy 请求创建一个已存在 COS 的对象的副本，即将一个对象从源路径（对象键）复制到目标路径（对象键）。在复制的过程中，对象元数据和访问控制列表（ACL）可以被修改。
用户可以通过该接口创建副本、修改对象元属性（源对象和目标文件的属性相同）、移动或重命名对象（先复制，再单独调用删除接口）。

方法原型

func (s *ObjectService) Copy(ctx context.Context, key, sourceURL string, opt *ObjectCopyOptions) (*ObjectCopyResult, *Response, error)

请求示例1：简单复制对象

package main
import (    "context"    "fmt"    "github.com/tencentyun/cos-go-sdk-v5"    "net/http"    "net/url"    "os"    "strings")
func main() {    // 存储桶名称，由 bucketname-appid 组成，appid 必须填入，可以在 COS 控制台查看存储桶名称。 https://console.cloud.tencent.com/cos5/bucket    // 替换为用户的 region，存储桶 region 可以在 COS 控制台“存储桶概览”查看 https://console.cloud.tencent.com/ ，关于地域的详情见 https://cloud.tencent.com/document/product/436/6224 。    u, _ := url.Parse("https://examplebucket-1250000000.cos.ap-guangzhou.myqcloud.com")    b := &cos.BaseURL{BucketURL: u}    client := cos.NewClient(b, &http.Client{        Transport: &cos.AuthorizationTransport{            // 通过环境变量获取密钥            // 环境变量 SECRETID 表示用户的 SecretId，登录访问管理控制台查看密钥，https://console.cloud.tencent.com/cam/capi            SecretID: os.Getenv("SECRETID"),  // 用户的 SecretId，建议使用子账号密钥，授权遵循最小权限指引，降低使用风险。子账号密钥获取可参见 https://cloud.tencent.com/document/product/598/37140            // 环境变量 SECRETKEY 表示用户的 SecretKey，登录访问管理控制台查看密钥，https://console.cloud.tencent.com/cam/capi            SecretKey: os.Getenv("SECRETKEY"),  // 用户的 SecretKey，建议使用子账号密钥，授权遵循最小权限指引，降低使用风险。子账号密钥获取可参见 https://cloud.tencent.com/document/product/598/37140        },    })    name := "exampleobject"    // 上传源对象    f := strings.NewReader("test")    _, err := client.Object.Put(context.Background(), name, f, nil)
    sourceURL := fmt.Sprintf("examplebucket-1250000000.cos.ap-guangzhou.myqcloud.com/%s", name)    dest := "example_dest"    // 如果不是必要操作，建议上传文件时不要给单个文件设置权限，避免达到限制。若不设置默认继承桶的权限。    // opt := &cos.ObjectCopyOptions{}    _, _, err = client.Object.Copy(context.Background(), dest, sourceURL, nil)    if err != nil {        panic(err)    }}

请求示例2：移动对象

package main
import (    "context"    "fmt"    "github.com/tencentyun/cos-go-sdk-v5"    "net/http"    "net/url"    "os"    "strings")
func main() {    // 存储桶名称，由 bucketname-appid 组成，appid 必须填入，可以在 COS 控制台查看存储桶名称。 https://console.cloud.tencent.com/cos5/bucket    // 替换为用户的 region，存储桶 region 可以在 COS 控制台“存储桶概览”查看 https://console.cloud.tencent.com/ ，关于地域的详情见 https://cloud.tencent.com/document/product/436/6224 。    u, _ := url.Parse("https://examplebucket-1250000000.cos.ap-guangzhou.myqcloud.com")    b := &cos.BaseURL{BucketURL: u}    client := cos.NewClient(b, &http.Client{        Transport: &cos.AuthorizationTransport{            // 通过环境变量获取密钥            // 环境变量 SECRETID 表示用户的 SecretId，登录访问管理控制台查看密钥，https://console.cloud.tencent.com/cam/capi            SecretID: os.Getenv("SECRETID"),  // 用户的 SecretId，建议使用子账号密钥，授权遵循最小权限指引，降低使用风险。子账号密钥获取可参见 https://cloud.tencent.com/document/product/598/37140            // 环境变量 SECRETKEY 表示用户的 SecretKey，登录访问管理控制台查看密钥，https://console.cloud.tencent.com/cam/capi            SecretKey: os.Getenv("SECRETKEY"),  // 用户的 SecretKey，建议使用子账号密钥，授权遵循最小权限指引，降低使用风险。子账号密钥获取可参见 https://cloud.tencent.com/document/product/598/37140        },    })    source := "test/oldfile"    f := strings.NewReader("test")    // 上传文件    _, err := client.Object.Put(context.Background(), source, f, nil)    if err != nil {        // Error    }
    // 移动对象    dest := "test/newfile"    sourceURL := fmt.Sprintf("examplebucket-1250000000.cos.ap-guangzhou.myqcloud.com/%s", source)    _, _, err = client.Object.Copy(context.Background(), dest, sourceURL, nil)    if err == nil {        _, err = client.Object.Delete(context.Background(), source, nil)        if err != nil {            // Error        }    }}

请求示例3：修改存储类型

注意标准存储可以修改为低频存储、智能分层存储、归档存储和深度归档存储等，如果希望将归档存储或深度归档存储的对象修改为其他存储类型，首先需要使用 PostRestore 将归档存储或深度归档存储的对象回热，才能使用该接口请求修改存储类型；关于存储类型的详细说明请参见 存储类型概述。

package main
import (    "context"    "fmt"    "github.com/tencentyun/cos-go-sdk-v5"    "net/http"    "net/url"    "os"    "strings")
func main() {    // 存储桶名称，由 bucketname-appid 组成，appid 必须填入，可以在 COS 控制台查看存储桶名称。 https://console.cloud.tencent.com/cos5/bucket    // 替换为用户的 region，存储桶 region 可以在 COS 控制台“存储桶概览”查看 https://console.cloud.tencent.com/ ，关于地域的详情见 https://cloud.tencent.com/document/product/436/6224 。    u, _ := url.Parse("https://examplebucket-1250000000.cos.ap-guangzhou.myqcloud.com")    b := &cos.BaseURL{BucketURL: u}    client := cos.NewClient(b, &http.Client{        Transport: &cos.AuthorizationTransport{            // 通过环境变量获取密钥            // 环境变量 SECRETID 表示用户的 SecretId，登录访问管理控制台查看密钥，https://console.cloud.tencent.com/cam/capi            SecretID: os.Getenv("SECRETID"),  // 用户的 SecretId，建议使用子账号密钥，授权遵循最小权限指引，降低使用风险。子账号密钥获取可参见 https://cloud.tencent.com/document/product/598/37140            // 环境变量 SECRETKEY 表示用户的 SecretKey，登录访问管理控制台查看密钥，https://console.cloud.tencent.com/cam/capi            SecretKey: os.Getenv("SECRETKEY"),  // 用户的 SecretKey，建议使用子账号密钥，授权遵循最小权限指引，降低使用风险。子账号密钥获取可参见 https://cloud.tencent.com/document/product/598/37140        },    })    name := "exampleobject"    // 上传源对象    f := strings.NewReader("test")    _, err := client.Object.Put(context.Background(), name, f, nil)
    sourceURL := fmt.Sprintf("%s/%s", client.BaseURL.BucketURL.Host, name)    opt := &cos.ObjectCopyOptions{        &cos.ObjectCopyHeaderOptions{            XCosMetadataDirective: "Replaced",            XCosStorageClass:      "Archive", // 修改成归档类型        },        nil,    }    _, _, err = client.Object.Copy(context.Background(), name, sourceURL, opt)    if err != nil {        panic(err)    }}

请求示例4：修改对象元数据

package main
import (    "context"    "fmt"    "github.com/tencentyun/cos-go-sdk-v5"    "net/http"    "net/url"    "os"    "strings")
func main() {    // 存储桶名称，由 bucketname-appid 组成，appid 必须填入，可以在 COS 控制台查看存储桶名称。 https://console.cloud.tencent.com/cos5/bucket    // 替换为用户的 region，存储桶 region 可以在 COS 控制台“存储桶概览”查看 https://console.cloud.tencent.com/ ，关于地域的详情见 https://cloud.tencent.com/document/product/436/6224 。    u, _ := url.Parse("https://examplebucket-1250000000.cos.ap-guangzhou.myqcloud.com")    b := &cos.BaseURL{BucketURL: u}    client := cos.NewClient(b, &http.Client{        Transport: &cos.AuthorizationTransport{            // 通过环境变量获取密钥            // 环境变量 SECRETID 表示用户的 SecretId，登录访问管理控制台查看密钥，https://console.cloud.tencent.com/cam/capi            SecretID: os.Getenv("SECRETID"),  // 用户的 SecretId，建议使用子账号密钥，授权遵循最小权限指引，降低使用风险。子账号密钥获取可参见 https://cloud.tencent.com/document/product/598/37140            // 环境变量 SECRETKEY 表示用户的 SecretKey，登录访问管理控制台查看密钥，https://console.cloud.tencent.com/cam/capi            SecretKey: os.Getenv("SECRETKEY"),  // 用户的 SecretKey，建议使用子账号密钥，授权遵循最小权限指引，降低使用风险。子账号密钥获取可参见 https://cloud.tencent.com/document/product/598/37140        },    })    name := "exampleobject"    // 上传源对象    f := strings.NewReader("test")    _, err := client.Object.Put(context.Background(), name, f, nil)
    sourceURL := fmt.Sprintf("%s/%s", client.BaseURL.BucketURL.Host, name)    opt := &cos.ObjectCopyOptions{        &cos.ObjectCopyHeaderOptions{            XCosMetadataDirective: "Replaced",            ContentType: "application/xml",  // 修改ContentType            XCosMetaXXX: &http.Header{		 // 覆盖自定义meta                "x-cos-meta-a": {"value_a"},                "x-cos-meta-b": {"value_b"},            },        },        nil,    }    _, _, err = client.Object.Copy(context.Background(), name, sourceURL, opt)    if err != nil {        panic(err)    }}

参数说明

type ObjectCopyOptions struct {    *ObjectCopyHeaderOptions     *ACLHeaderOptions        }type ACLHeaderOptions struct {    XCosACL              string     XCosGrantRead        string     XCosGrantWrite       string     XCosGrantFullControl string }type ObjectCopyHeaderOptions struct {    XCosMetadataDirective           string     XCosCopySourceIfModifiedSince   string     XCosCopySourceIfUnmodifiedSince string     XCosCopySourceIfMatch           string     XCosCopySourceIfNoneMatch       string     XCosStorageClass                string     // 自定义的 x-cos-meta-* header    XCosMetaXXX    				    *http.Header     XCosCopySource 					string      }

返回结果说明

上传文件的属性：

type ObjectCopyResult struct {    ETag         string     LastModified string}

移动对象

功能说明

移动对象主要包括两个操作：复制源对象到目标位置，删除源对象。由于 COS 通过存储桶名称（Bucket）和对象键（ObjectKey）来标识对象。移动对象也就意味着修改这个对象的标识，COS 目前没有提供修改对象唯一标识名的单独接口，但是可以通过组合复制对象加上删除对象的基本操作，来达到修改对象标识的目的，从而实现移动对象。例如将 mybucket-1250000000 这个存储桶中的 picture.jpg 这个对象移动到同个存储桶的 doc 路径下。首先可以复制 picture.jpg 对象到存储桶的 doc 路径下，即对象键设定为 doc/picture.jpg，复制完成后删除 picture.jpg 这个对象，来实现“移动”的效果。同样的，如果想将 mybucket-1250000000 这个存储桶里的 picture.jpg 这个对象移动到 myanothorbucket-1250000000 这个存储桶里，可以先将对象复制到 myanothorbucket-1250000000 存储桶，然后删除原来的对象。

请求示例

package main
import (    "context"    "fmt"    "github.com/tencentyun/cos-go-sdk-v5"    "net/http"    "net/url"    "os"    "strings")
func main() {    // 存储桶名称，由 bucketname-appid 组成，appid 必须填入，可以在 COS 控制台查看存储桶名称。 https://console.cloud.tencent.com/cos5/bucket    // 替换为用户的 region，存储桶 region 可以在 COS 控制台“存储桶概览”查看 https://console.cloud.tencent.com/ ，关于地域的详情见 https://cloud.tencent.com/document/product/436/6224 。    u, _ := url.Parse("https://examplebucket-1250000000.cos.ap-guangzhou.myqcloud.com")    b := &cos.BaseURL{BucketURL: u}    client := cos.NewClient(b, &http.Client{        Transport: &cos.AuthorizationTransport{            // 通过环境变量获取密钥            // 环境变量 SECRETID 表示用户的 SecretId，登录访问管理控制台查看密钥，https://console.cloud.tencent.com/cam/capi            SecretID: os.Getenv("SECRETID"),  // 用户的 SecretId，建议使用子账号密钥，授权遵循最小权限指引，降低使用风险。子账号密钥获取可参见 https://cloud.tencent.com/document/product/598/37140            // 环境变量 SECRETKEY 表示用户的 SecretKey，登录访问管理控制台查看密钥，https://console.cloud.tencent.com/cam/capi            SecretKey: os.Getenv("SECRETKEY"),  // 用户的 SecretKey，建议使用子账号密钥，授权遵循最小权限指引，降低使用风险。子账号密钥获取可参见 https://cloud.tencent.com/document/product/598/37140        },    })    source := "test/oldfile"    f := strings.NewReader("test")    // 上传文件    _, err := client.Object.Put(context.Background(), source, f, nil)    if err != nil {        // Error    }    // 移动对象    dest := "test/newfile"    sourceURL := fmt.Sprintf("%s/%s", u.Host, source)    _, _, err = client.Object.Copy(context.Background(), dest, sourceURL, nil)    if err == nil {        _, err = client.Object.Delete(context.Background(), source, nil)        if err != nil {            // Error        }    }}

分块操作

初始化分块复制

功能说明

Initiate Multipart Upload 请求实现初始化分块复制，成功执行此请求后会返回 Upload ID ，用于后续的 Upload Part – Copy 请求。

方法原型

func (s *ObjectService) InitiateMultipartUpload(ctx context.Context, name string, opt *InitiateMultipartUploadOptions) (*InitiateMultipartUploadResult, *Response, error)

请求示例

package main
import (    "context"    "fmt"    "github.com/tencentyun/cos-go-sdk-v5"    "net/http"    "net/url"    "os")
func main() {    // 存储桶名称，由 bucketname-appid 组成，appid 必须填入，可以在 COS 控制台查看存储桶名称。 https://console.cloud.tencent.com/cos5/bucket    // 替换为用户的 region，存储桶 region 可以在 COS 控制台“存储桶概览”查看 https://console.cloud.tencent.com/ ，关于地域的详情见 https://cloud.tencent.com/document/product/436/6224 。    u, _ := url.Parse("https://examplebucket-1250000000.cos.ap-guangzhou.myqcloud.com")    b := &cos.BaseURL{BucketURL: u}    client := cos.NewClient(b, &http.Client{        Transport: &cos.AuthorizationTransport{            // 通过环境变量获取密钥            // 环境变量 SECRETID 表示用户的 SecretId，登录访问管理控制台查看密钥，https://console.cloud.tencent.com/cam/capi            SecretID: os.Getenv("SECRETID"),  // 用户的 SecretId，建议使用子账号密钥，授权遵循最小权限指引，降低使用风险。子账号密钥获取可参见 https://cloud.tencent.com/document/product/598/37140            // 环境变量 SECRETKEY 表示用户的 SecretKey，登录访问管理控制台查看密钥，https://console.cloud.tencent.com/cam/capi            SecretKey: os.Getenv("SECRETKEY"),  // 用户的 SecretKey，建议使用子账号密钥，授权遵循最小权限指引，降低使用风险。子账号密钥获取可参见 https://cloud.tencent.com/document/product/598/37140        },    })    name := "exampleobject"    v, _, err := client.Object.InitiateMultipartUpload(context.Background(), name, nil)    if err != nil {        panic(err)    }    UploadID := v.UploadID    fmt.Println(UploadID)}

参数说明

type InitiateMultipartUploadOptions struct {    *ACLHeaderOptions           *ObjectPutHeaderOptions }type ACLHeaderOptions struct {    XCosACL              string                               XCosGrantRead        string    XCosGrantWrite       string     XCosGrantFullControl string                                           } type ObjectPutHeaderOptions struct {    CacheControl       string     ContentDisposition string     ContentEncoding    string     ContentType        string     ContentLength      int64       Expires            string     // 自定义的 x-cos-meta-* header    XCosMetaXXX        *http.Header     XCosStorageClass   string      }

返回结果说明

type InitiateMultipartUploadResult struct {    Bucket   string    Key      string    UploadID string} 

复制分块

功能说明

Upload Part – Copy 接口请求实现将一个对象的分块内容从源路径复制到目标路径。注意使用上传分块对象，必须先初始化分块上传。在初始化分块上传的响应中，会返回一个唯一的描述符（upload ID），您需要在分块上传请求中携带此 ID。

方法原型

func (s *ObjectService) CopyPart(ctx context.Context, key, uploadID string, partNumber int, sourceURL string, opt *ObjectCopyPartOptions) (*CopyPartResult, *Response, error)

请求示例

package main
import (    "context"    "github.com/tencentyun/cos-go-sdk-v5"    "net/http"    "net/url"    "os")
func main() {    // 存储桶名称，由 bucketname-appid 组成，appid 必须填入，可以在 COS 控制台查看存储桶名称。 https://console.cloud.tencent.com/cos5/bucket    // 替换为用户的 region，存储桶 region 可以在 COS 控制台“存储桶概览”查看 https://console.cloud.tencent.com/ ，关于地域的详情见 https://cloud.tencent.com/document/product/436/6224 。    u, _ := url.Parse("https://examplebucket-1250000000.cos.ap-guangzhou.myqcloud.com")    b := &cos.BaseURL{BucketURL: u}    client := cos.NewClient(b, &http.Client{        Transport: &cos.AuthorizationTransport{            // 通过环境变量获取密钥            // 环境变量 SECRETID 表示用户的 SecretId，登录访问管理控制台查看密钥，https://console.cloud.tencent.com/cam/capi            SecretID: os.Getenv("SECRETID"),  // 用户的 SecretId，建议使用子账号密钥，授权遵循最小权限指引，降低使用风险。子账号密钥获取可参见 https://cloud.tencent.com/document/product/598/37140            // 环境变量 SECRETKEY 表示用户的 SecretKey，登录访问管理控制台查看密钥，https://console.cloud.tencent.com/cam/capi            SecretKey: os.Getenv("SECRETKEY"),  // 用户的 SecretKey，建议使用子账号密钥，授权遵循最小权限指引，降低使用风险。子账号密钥获取可参见 https://cloud.tencent.com/document/product/598/37140        },    })    // 初始化分块    name := "exampleobject"    v, _, err := client.Object.InitiateMultipartUpload(context.Background(), name, nil)    if err != nil {        // ERROR    }    uploadID := v.UploadID
    // 复制分块    sourceUrl := "examplebucket-1250000000.cos.ap-guangzhou.myqcloud.com/sourceobject"    res, _, err := client.Object.CopyPart(context.Background(), name, uploadID, 1, sourceUrl, nil)    if err != nil {        // ERROR    }
    // 完成分块上传    completeOpt := &cos.CompleteMultipartUploadOptions{}    completeOpt.Parts = append(completeOpt.Parts, cos.Object{        PartNumber: 1,        ETag:       res.ETag,    })    _, _, err = client.Object.CompleteMultipartUpload(context.Background(), name, uploadID, completeOpt)    if err != nil {        // ERROR    }}

参数说明

type ObjectCopyPartOptions struct {    XCosCopySourceRange    XCosCopySourceIfModifiedSince    XCosCopySourceIfUnmodifiedSince    XCosCopySourceIfMatch    XCosCopySourceIfNoneMatch}

返回结果说明

type CopyPartResult struct {    ETag         string    LastModified string}

完成分块复制

功能说明

Complete Multipart Upload 接口请求用来实现完成整个分块复制。当使用 Copy Parts 复制完所有块以后，必须调用该 API 来完成整个文件的分块复制。在使用该 API 时，您必须在请求 Body 中给出每一个块的 PartNumber 和 ETag，用来校验块的准确性。
由于分块复制完后需要合并，而合并需要数分钟时间，因而当合并分块开始的时候，COS 就立即返回200的状态码，在合并的过程中，COS 会周期性的返回空格信息来保持连接活跃，直到合并完成，COS 会在 Body 中返回合并后块的内容。当上传块小于1MB的时候，在调用该 API 时，会返回400 EntityTooSmall。当上传块编号不连续的时候，在调用该 API 时，会返回400 InvalidPart。当请求 Body 中的块信息没有按序号从小到大排列的时候，在调用该 API 时，会返回400 InvalidPartOrder。当 UploadId 不存在的时候，在调用该 API 时，会返回404 NoSuchUpload。注意建议您及时完成分块复制或者舍弃分块复制，因为已上传但是未终止的块会占用存储空间进而产生存储费用。

方法原型

func (s *ObjectService) CompleteMultipartUpload(ctx context.Context, key, uploadID string, opt *CompleteMultipartUploadOptions) (*CompleteMultipartUploadResult, *Response, error)

请求示例

package main
import (    "context"    "github.com/tencentyun/cos-go-sdk-v5"    "net/http"    "net/url"    "os")
func main() {    // 存储桶名称，由 bucketname-appid 组成，appid 必须填入，可以在 COS 控制台查看存储桶名称。 https://console.cloud.tencent.com/cos5/bucket    // 替换为用户的 region，存储桶 region 可以在 COS 控制台“存储桶概览”查看 https://console.cloud.tencent.com/ ，关于地域的详情见 https://cloud.tencent.com/document/product/436/6224 。    u, _ := url.Parse("https://examplebucket-1250000000.cos.ap-guangzhou.myqcloud.com")    b := &cos.BaseURL{BucketURL: u}    client := cos.NewClient(b, &http.Client{        Transport: &cos.AuthorizationTransport{            // 通过环境变量获取密钥            // 环境变量 SECRETID 表示用户的 SecretId，登录访问管理控制台查看密钥，https://console.cloud.tencent.com/cam/capi            SecretID: os.Getenv("SECRETID"),  // 用户的 SecretId，建议使用子账号密钥，授权遵循最小权限指引，降低使用风险。子账号密钥获取可参见 https://cloud.tencent.com/document/product/598/37140            // 环境变量 SECRETKEY 表示用户的 SecretKey，登录访问管理控制台查看密钥，https://console.cloud.tencent.com/cam/capi            SecretKey: os.Getenv("SECRETKEY"),  // 用户的 SecretKey，建议使用子账号密钥，授权遵循最小权限指引，降低使用风险。子账号密钥获取可参见 https://cloud.tencent.com/document/product/598/37140        },    })    // 初始化分块    name := "exampleobject"    v, _, err := client.Object.InitiateMultipartUpload(context.Background(), name, nil)    if err != nil {        // ERROR    }    uploadID := v.UploadID
    // 复制分块    sourceUrl := "examplebucket-1250000000.cos.ap-guangzhou.myqcloud.com/sourceobject"    res, _, err := client.Object.CopyPart(context.Background(), name, uploadID, 1, sourceUrl, nil)    if err != nil {        // ERROR    }
    // 完成分块上传    completeOpt := &cos.CompleteMultipartUploadOptions{}    completeOpt.Parts = append(completeOpt.Parts, cos.Object{        PartNumber: 1,        ETag:       res.ETag,    })    _, _, err = client.Object.CompleteMultipartUpload(context.Background(), name, uploadID, completeOpt)    if err != nil {        // ERROR    }}

参数说明

type CompleteMultipartUploadOptions struct {    Parts   []Object }type Object struct {     ETag         string     PartNumber   int     }

返回结果说明

type CompleteMultipartUploadResult struct {    Location string    Bucket   string    Key      string    ETag     string}



对象存储官网1折活动，限时活动，即将结束，速速收藏
同尘科技为腾讯云授权服务中心。
购买腾讯云产品享受折上折，更有现金返利。同意关联立享优惠