归档或冷归档类型的文件需要解冻(Restore)之后才能读取。本文介绍如何解冻归档和冷归档文件。

注意 非归档或非冷归档类型的文件,请勿调用RestoreObject方法。

解冻归档文件

以下代码用于解冻归档文件:

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实例。
    // yourEndpoint填写Bucket对应的Endpoint,以华东1(杭州)为例,填写为https://oss-cn-hangzhou.aliyuncs.com。其它Region请按实际情况填写。
    // 阿里云账号AccessKey拥有所有API的访问权限,风险很高。强烈建议您创建并使用RAM用户进行API访问或日常运维,请登录RAM控制台创建RAM用户。
    client, err := oss.New("yourEndpoint", "yourAccessKeyId", "yourAccessKeySecret")
    if err != nil {
        HandleError(err)
    }
    // 填写存储空间名称,例如examplebucket。
    bucketName := "examplebucket"
    // 填写不包含Bucket名称在内的Object的完整路径,例如exampledir/exampleobject.txt。
    objectName := "exampledir/exampleobject.txt"
    // 填写本地文件的完整路径,例如D:\\localpath\\examplefile.txt。
    localFilename := "D:\\localpath\\examplefile.txt"

    // 创建存储空间。
    err = client.CreateBucket(bucketName, oss.StorageClass(oss.StorageArchive))
    if err != nil {
        HandleError(err)
    }

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

    // 上传归档文件。
    var val = "More than just cloud."
    err = archiveBucket.PutObject(objectName, strings.NewReader(val))
    if err != nil {
        HandleError(err)
    }

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

    fmt.Println("X-Oss-Storage-Class : ", meta.Get("X-Oss-Storage-Class"))
    if meta.Get("X-Oss-Storage-Class") == string(oss.StorageArchive) {
        // 解冻归档类型文件。
        var restoreConfig oss.RestoreConfiguration
        // 设置解冻的天数,取值范围为1~7天。
        restoreConfig.Days = 1
        err = archiveBucket.RestoreObject(objectName,restoreConfig)
        if err != nil {
            HandleError(err)
        }

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

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

    // 再次解冻文件。
    err = archiveBucket.RestoreObject(objectName)

    fmt.Println("ArchiveSample completed")
}            

解冻冷归档文件

以下代码用于解冻冷归档文件:

package main

import (
    "fmt"
    "os"

    "github.com/aliyun/aliyun-oss-go-sdk/oss"
)

func main() {
    // 创建OSSClient实例。
    // yourEndpoint填写Bucket对应的Endpoint,以华东1(杭州)为例,填写为https://oss-cn-hangzhou.aliyuncs.com。其它Region请按实际情况填写。
    // 阿里云账号AccessKey拥有所有API的访问权限,风险很高。强烈建议您创建并使用RAM用户进行API访问或日常运维,请登录RAM控制台创建RAM用户。
    client, err := oss.New("yourEndpoint", "yourAccessKeyId", "yourAccessKeySecret")
    if err != nil {
        fmt.Println("Error:", err)
        os.Exit(-1)
    }

    // 填写存储空间名称,例如examplebucket。
    bucket, err := client.Bucket("examplebucket")
    if err != nil {
        fmt.Println("Error:", err)
        os.Exit(-1)
    }

    var restoreConfig oss.RestoreConfiguration

    // 表示1小时内完成解冻。
    // restoreConfig.Tier = string(oss.RestoreExpedited)
    // 表示2~5小时内完成解冻。
    // restoreConfig.Tier = string(oss.RestoreStandard)
    // 表示5~12小时内完成解冻。
    // restoreConfig.Tier = string(oss.RestoreBulk)

    // 设置解冻的天数,取值范围为1~7天。
    restoreConfig.Days = 1
    // 填写不包含Bucket名称在内的Object的完整路径,例如exampledir/exampleobject.txt。
    err = bucket.RestoreObjectDetail("exampledir/exampleobject.txt", restoreConfig)
    if err != nil {
        fmt.Println("Error:", err)
        os.Exit(-1)
    }
}

相关文档

关于解冻归档及冷归档类型文件的API接口说明,请参见RestoreObject