完成分块上传

完成分块上传

功能说明

组装指定 UploadId 中所有的分块为一个完整的文件，文件最终大小必须大于1MB，否则会返回错误。

方法原型

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

请求示例

// 封装 UploadPart 接口返回 etag 信息
func uploadPart(c *cos.Client, name string, uploadID string, blockSize, n int) string {
    b := make([]byte, blockSize)
    if _, err := rand.Read(b); err != nil {
        panic(err)
    }
    s := fmt.Sprintf("%X", b)
    f := strings.NewReader(s)
    // 当传入参数f不是 bytes.Buffer/bytes.Reader/strings.Reader 时，必须指定 opt.ContentLength
    //opt := &cos.ObjectUploadPartOptions{
    //    ContentLength: size,
    //}
    resp, err := c.Object.UploadPart(
        context.Background(), name, uploadID, n, f, nil,
    )
    if err != nil {
        panic(err)
    }
    return resp.Header.Get("Etag")
}
// Init, UploadPart and Complete process
key := "test/test_complete_upload.go"
v, resp, err := client.Object.InitiateMultipartUpload(context.Background(), key, nil)
uploadID := v.UploadID
blockSize := 1024 * 1024 * 3
opt := &cos.CompleteMultipartUploadOptions{}
for i := 1; i < 5; i++ {
    // 调用上面封装的接口获取 etag 信息
    etag := uploadPart(c, key, uploadID, blockSize, i)
    opt.Parts = append(opt.Parts, cos.Object{
        PartNumber: i, ETag: etag},
    )
}
v, resp, err = client.Object.CompleteMultipartUpload(
    context.Background(), key, uploadID, opt,
)

参数说明

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

返回结果说明

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