如何使用Go SDK在对象存储中分段上传并列举已上传的段？

Go SDK提供了对象存储分段上传的功能，允许开发者在上传大文件时将其分割成多个小段。该功能支持列举已上传的段，以便进行后续操作如续传或合并。这提高了文件上传的效率和可靠性。

对象存储分段上传列举已上传的段

分段上传是一种将大文件分解为多个小段，然后分别上传这些小段的方法，这种方法可以提高上传效率，减少失败的风险，并允许并行上传，在Go语言中，我们可以使用SDK来实现分段上传和列举已上传的段。

创建分段上传

我们需要创建一个分段上传，这可以通过调用SDK中的CreateMultipartUpload方法来实现，这个方法需要一个PutObjectOptions对象作为参数，其中包含了我们要上传的对象的信息，如桶名、对象键、元数据等。

import (
    "github.com/minio/miniogo/v7"
    "github.com/minio/miniogo/v7/pkg/credentials"
)
func main() {
    endpoint := "https://play.min.io:9000"
    accessKey := "Q3AM3UQ867SPQQAEXAMPLE"
    secretKey := "zuf+tfteSlswRu7BJ86wekitnwXbITMpJTO5y1火车"
    useSSL := true
    client, err := minio.New(endpoint, &minio.Options{
        Creds:  credentials.NewStaticV4(accessKey, secretKey, ""),
        Secure: useSSL,
    })
    if err != nil {
        log.Fatalln(err)
    }
    bucketName := "mybucket"
    objectName := "myobject"
    contentType := "application/octetstream"
    // 创建分段上传
    uploadID, err := client.InitiateMultipartUpload(context.Background(), bucketName, objectName, minio.InitiateMultipartUploadParameters{
        ContentType:  contentType,
        ContentLength: int64(totalSize), // 总大小
    })
    if err != nil {
        log.Fatalln(err)
    }
}

上传分段

我们可以开始上传分段，每个分段都是一个独立的上传请求，需要指定分段的索引和数据，我们可以使用UploadPart方法来上传分段。

import (
    "github.com/minio/miniogo/v7"
    "github.com/minio/miniogo/v7/pkg/credentials"
)
func main() {
    endpoint := "https://play.min.io:9000"
    accessKey := "Q3AM3UQ867SPQQAEXAMPLE"
    secretKey := "zuf+tfteSlswRu7BJ86wekitnwXbITMpJTO5y1火车"
    useSSL := true
    client, err := minio.New(endpoint, &minio.Options{
        Creds:  credentials.NewStaticV4(accessKey, secretKey, ""),
        Secure: useSSL,
    })
    if err != nil {
        log.Fatalln(err)
    }
    bucketName := "mybucket"
    objectName := "myobject"
    uploadID := "myuploadID"
    // 上传第i个分段
    partNumber := i // 分段索引，从1开始
    data := []byte("some data") // 分段数据
    _, err = client.UploadPart(context.Background(), bucketName, objectName, uploadID, partNumber, data, minio.PutObjectOptions{ContentType: "application/octetstream"})
    if err != nil {
        log.Fatalln(err)
    }
}

列举已上传的段

在分段上传过程中，我们可能需要查看已经上传了哪些分段，这可以通过调用ListParts方法来实现。

import (
    "github.com/minio/miniogo/v7"
    "github.com/minio/miniogo/v7/pkg/credentials"
)
func main() {
    endpoint := "https://play.min.io:9000"
    accessKey := "Q3AM3UQ867SPQQAEXAMPLE"
    secretKey := "zuf+tfteSlswRu7BJ86wekitnwXbITMpJTO5y1火车"
    useSSL := true
    client, err := minio.New(endpoint, &minio.Options{
        Creds:  credentials.NewStaticV4(accessKey, secretKey, ""),
        Secure: useSSL,
    })
    if err != nil {
        log.Fatalln(err)
    }
    bucketName := "mybucket"
    objectName := "myobject"
    uploadID := "myuploadID"
    // 列举已上传的段
    parts, err := client.ListParts(context.Background(), bucketName, objectName, uploadID)
    if err != nil {
        log.Fatalln(err)
    }
    for _, part := range parts {
        fmt.Printf("Part #%d, ETag: %s
", part.PartNumber, part.ETag)
    }
}

这段代码会输出已上传的每个分段的索引和ETag，ETag是服务器为每个分段生成的唯一标识符，用于验证分段的完整性。