解冻文件

package main

import (
  "fmt"
  "os"
  "time"
  "strings"
  "github.com/aliyun/aliyun-oss-go-sdk/oss"
)

func HandleError(err error) {
  fmt.Println("Error:", err)
  os.Exit(-1)
}

func main() {
  // 创建OSSClient实例。
  client, err := oss.New("<yourEndpoint>", "<yourAccessKeyId>", "<yourAccessKeySecret>")
  if err != nil {
    HandleError(err)
  }

  bucketName := "<yourBucketName>"
  objectName := "<yourObjectName>"
  localFilename := "<yourLocalFilename>"

  // 创建归档类型的存储空间。
  err = client.CreateBucket(bucketName, oss.StorageClass(oss.StorageArchive))
  if err != nil {
    HandleError(err)
  }
  // 设置存储空间为开启版本控制状态。
  config := oss.VersioningConfig{Status: "Enabled"}
  err = client.SetBucketVersioning(bucketName, config)
  if err != nil {
    fmt.Println("Error:", err)
    os.Exit(-1)
  }

  // 获取存储空间。
  archiveBucket, err := client.Bucket(bucketName)
  if err != nil {
    HandleError(err)
  }

  var retHeader http.Header
  // 上传字符串。用oss.GetResponseHeader获取返回header。
  err = archiveBucket.PutObject("<yourObjectName>", strings.NewReader("yourObjectValue"), oss.GetResponseHeader(&retHeader))
  if err != nil {
    fmt.Println("Error:", err)
    os.Exit(-1)
  }
  // 获取上传解冻文件的versionId。
  versionId := oss.GetVersionId(retHeader)

  // 检查是否为归档类型文件。
  meta, err := archiveBucket.GetObjectDetailedMeta(objectName, oss.VersionId(versionId))
  if err != nil {
    HandleError(err)
  }

  if meta.Get("X-Oss-Storage-Class") == string(oss.StorageArchive) {
    err = archiveBucket.RestoreObject(objectName, oss.VersionId(versionId))
    if err != nil {
      HandleError(err)
    }

    // 等待解冻结束。
    meta, err = archiveBucket.GetObjectDetailedMeta(objectName, oss.VersionId(versionId))
    for meta.Get("X-Oss-Restore") == "ongoing-request=\"true\"" {
      fmt.Println("x-oss-restore:" + meta.Get("X-Oss-Restore"))
      time.Sleep(1000 * time.Second)
      meta, err = archiveBucket.GetObjectDetailedMeta(objectName, oss.VersionId(versionId))
    }
  }

  // 下载已解冻的文件。
  err = archiveBucket.GetObjectToFile(objectName, localFilename, oss.VersionId(versionId))
  if err != nil {
    HandleError(err)
  }
}