上传对象-异步断点续传上传

package main
import (
    "fmt"
    "os"
    obs "github.com/huaweicloud/huaweicloud-sdk-go-obs/obs"
)
func main() {
    //推荐通过环境变量获取AKSK，这里也可以使用其他外部引入方式传入，如果使用硬编码可能会存在泄露风险。
    //您可以登录访问管理控制台获取访问密钥AK/SK，获取方式请参见https://support.huaweicloud.com/usermanual-ca/ca_01_0003.html。
    ak := os.Getenv("AccessKeyID")
    sk := os.Getenv("SecretAccessKey")
    // 【可选】如果使用临时AK/SK和SecurityToken访问OBS，同样建议您尽量避免使用硬编码，以降低信息泄露风险。您可以通过环境变量获取访问密钥AK/SK，也可以使用其他外部引入方式传入。
    // securityToken := os.Getenv("SecurityToken")
   // endpoint填写Bucket对应的Endpoint, 这里以华北-北京四为例，其他地区请按实际情况填写。
    endPoint := "https://obs.cn-north-4.myhuaweicloud.com"
    // 创建obsClient实例
    // 如果使用临时AKSK和SecurityToken访问OBS，需要在创建实例时通过obs.WithSecurityToken方法指定securityToken值。
    obsClient, err := obs.New(ak, sk, endPoint/*, obs.WithSecurityToken(securityToken)*/)
    if err != nil {
        fmt.Printf("Create obsClient error, errMsg: %s", err.Error())
    }
// 准备上传输入
    input := &obs.UploadFileInput{
        Bucket:     "examplebucket",
        Key:        "new-example",
        UploadFile: "/path/to/local/example",
        PartSize:   10 * 1024 * 1024, // 10MB
        TaskNum:    3,                // 3个并发任务
    }

    // 启动异步上传
    task, err := client.UploadFileAsync(input)
    if err != nil {
        log.Fatal(err)
    }

    // 等待上传完成
    <-task.Done()

    // 获取上传结果
    result, err := task.GetResult()
    if err != nil {
        fmt.Printf("上传失败: %v\n", err)
        return
    }

    output := result.(*obs.CompleteMultipartUploadOutput)
    fmt.Printf("上传成功!\nETag: %s\nVersionId: %s\n", output.ETag, output.VersionId)
}

package main
import (
    "fmt"
    "os"
    obs "github.com/huaweicloud/huaweicloud-sdk-go-obs/obs"
)

// 进度监听器
type ProgressListener struct{}

func (l *ProgressListener) ProgressChanged(event *obs.ProgressEvent) {
    switch event.EventType {
    case obs.TransferStartedEvent:
        fmt.Printf("开始上传: 总大小 %d 字节\n", event.TotalBytes)
    case obs.TransferDataEvent:
        percent := float64(event.ConsumedBytes) / float64(event.TotalBytes) * 100
        fmt.Printf("上传中: %.2f%% (%d/%d 字节)\n", percent, event.ConsumedBytes, event.TotalBytes)
    case obs.TransferCompletedEvent:
        fmt.Println("上传完成!")
    case obs.TransferFailedEvent:
        fmt.Printf("上传失败: 已传输 %d/%d 字节\n", event.ConsumedBytes, event.TotalBytes)
    }
}
func main() {
    //推荐通过环境变量获取AKSK，这里也可以使用其他外部引入方式传入，如果使用硬编码可能会存在泄露风险。
    //您可以登录访问管理控制台获取访问密钥AK/SK，获取方式请参见https://support.huaweicloud.com/usermanual-ca/ca_01_0003.html。
    ak := os.Getenv("AccessKeyID")
    sk := os.Getenv("SecretAccessKey")
    // 【可选】如果使用临时AK/SK和SecurityToken访问OBS，同样建议您尽量避免使用硬编码，以降低信息泄露风险。您可以通过环境变量获取访问密钥AK/SK，也可以使用其他外部引入方式传入。
    // securityToken := os.Getenv("SecurityToken")
   // endpoint填写Bucket对应的Endpoint, 这里以华北-北京四为例，其他地区请按实际情况填写。
    endPoint := "https://obs.cn-north-4.myhuaweicloud.com"
    // 创建obsClient实例
    // 如果使用临时AKSK和SecurityToken访问OBS，需要在创建实例时通过obs.WithSecurityToken方法指定securityToken值。
    obsClient, err := obs.New(ak, sk, endPoint/*, obs.WithSecurityToken(securityToken)*/)
    if err != nil {
        fmt.Printf("Create obsClient error, errMsg: %s", err.Error())
    }
input := &obs.UploadFileInput{
        Bucket:     "examplebucket",
        Key:        "new-example",
        UploadFile: "/path/to/local/example",
        PartSize:   10 * 1024 * 1024,
        TaskNum:    3,
    }

    // 添加进度监听器
    task, err := client.UploadFileAsync(input, obs.WithProgressListener(&ProgressListener{}))
    if err != nil {
        log.Fatal(err)
    }

    // 等待完成
    <-task.Done()

    result, err := task.GetResult()
    if err != nil {
        fmt.Printf("上传失败: %v\n", err)
        return
    }

    output := result.(*obs.CompleteMultipartUploadOutput)
    fmt.Printf("上传成功! ETag: %s\n", output.ETag)
}

package main
import (
    "fmt"
    "os"
    obs "github.com/huaweicloud/huaweicloud-sdk-go-obs/obs"
)
func main() {
    //推荐通过环境变量获取AKSK，这里也可以使用其他外部引入方式传入，如果使用硬编码可能会存在泄露风险。
    //您可以登录访问管理控制台获取访问密钥AK/SK，获取方式请参见https://support.huaweicloud.com/usermanual-ca/ca_01_0003.html。
    ak := os.Getenv("AccessKeyID")
    sk := os.Getenv("SecretAccessKey")
    // 【可选】如果使用临时AK/SK和SecurityToken访问OBS，同样建议您尽量避免使用硬编码，以降低信息泄露风险。您可以通过环境变量获取访问密钥AK/SK，也可以使用其他外部引入方式传入。
    // securityToken := os.Getenv("SecurityToken")
   // endpoint填写Bucket对应的Endpoint, 这里以华北-北京四为例，其他地区请按实际情况填写。
    endPoint := "https://obs.cn-north-4.myhuaweicloud.com"
    // 创建obsClient实例
    // 如果使用临时AKSK和SecurityToken访问OBS，需要在创建实例时通过obs.WithSecurityToken方法指定securityToken值。
    obsClient, err := obs.New(ak, sk, endPoint/*, obs.WithSecurityToken(securityToken)*/)
    if err != nil {
        fmt.Printf("Create obsClient error, errMsg: %s", err.Error())
    }
    input := &obs.UploadFileInput{
        Bucket:     "examplebucket",
        Key:        "new-example",
        UploadFile: "/path/to/local/example",
        PartSize:   10 * 1024 * 1024,
        TaskNum:    3,
    }

    task, err := client.UploadFileAsync(input)
    if err != nil {
        log.Fatal(err)
    }

    // 运行 5 秒后暂停
    go func() {
        time.Sleep(5 * time.Second)
        fmt.Println("暂停上传...")
        err := task.Pause()
        if err != nil {
            fmt.Printf("暂停失败: %v\n", err)
        } else {
            fmt.Println("上传已暂停")
        }
    }()

    // 等待暂停
    for task.Status() != obs.TransferStatusPaused {
        time.Sleep(100 * time.Millisecond)
    }

    fmt.Println("当前状态: 已暂停")

    // 暂停 3 秒后恢复
    time.Sleep(3 * time.Second)
    fmt.Println("恢复上传...")
    err = task.Resume()
    if err != nil {
        fmt.Printf("恢复失败: %v\n", err)
    } else {
        fmt.Println("上传已恢复")
    }

    // 等待完成
    <-task.Done()

    result, err := task.GetResult()
    if err != nil {
        fmt.Printf("上传失败: %v\n", err)
        return
    }

    output := result.(*obs.CompleteMultipartUploadOutput)
    fmt.Printf("上传成功! ETag: %s\n", output.ETag)
}

package main
import (
    "fmt"
    "os"
    obs "github.com/huaweicloud/huaweicloud-sdk-go-obs/obs"
)
func main() {
    //推荐通过环境变量获取AKSK，这里也可以使用其他外部引入方式传入，如果使用硬编码可能会存在泄露风险。
    //您可以登录访问管理控制台获取访问密钥AK/SK，获取方式请参见https://support.huaweicloud.com/usermanual-ca/ca_01_0003.html。
    ak := os.Getenv("AccessKeyID")
    sk := os.Getenv("SecretAccessKey")
    // 【可选】如果使用临时AK/SK和SecurityToken访问OBS，同样建议您尽量避免使用硬编码，以降低信息泄露风险。您可以通过环境变量获取访问密钥AK/SK，也可以使用其他外部引入方式传入。
    // securityToken := os.Getenv("SecurityToken")
   // endpoint填写Bucket对应的Endpoint, 这里以华北-北京四为例，其他地区请按实际情况填写。
    endPoint := "https://obs.cn-north-4.myhuaweicloud.com"
    // 创建obsClient实例
    // 如果使用临时AKSK和SecurityToken访问OBS，需要在创建实例时通过obs.WithSecurityToken方法指定securityToken值。
    obsClient, err := obs.New(ak, sk, endPoint/*, obs.WithSecurityToken(securityToken)*/)
    if err != nil {
        fmt.Printf("Create obsClient error, errMsg: %s", err.Error())
    }
    input := &obs.UploadFileInput{
        Bucket:     "examplebucket",
        Key:        "new-example",
        UploadFile: "/path/to/local/example",
        PartSize:   10 * 1024 * 1024,
        TaskNum:    3,
    }

    task, err := client.UploadFileAsync(input)
    if err != nil {
        log.Fatal(err)
    }

    // 运行 5 秒后取消
    go func() {
        time.Sleep(5 * time.Second)
        fmt.Println("取消上传...")
        err := task.Cancel()
        if err != nil {
            fmt.Printf("取消失败: %v\n", err)
        } else {
            fmt.Println("上传已取消")
        }
    }()

    // 等待完成/取消
    <-task.Done()

    // 检查结果
    result, err := task.GetResult()
    if err != nil {
        if err.Error() == "upload task cancelled" {
            fmt.Println("上传已被用户取消")
        } else {
            fmt.Printf("上传失败: %v\n", err)
        }
        return
    }

    output := result.(*obs.CompleteMultipartUploadOutput)
    fmt.Printf("上传成功! ETag: %s\n", output.ETag)

}