如何使用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是服务器为每个分段生成的唯一标识符，用于验证分段的完整性。