本文介绍如何解冻归档文件。
归档类型(Archive)的文件需要解冻(Restore)之后才能读取。非归档类型的文件,无需调用restoreObject方法。
归档文件的状态变换过程如下:
- 归档类型的文件初始时处于冷冻状态。
- 提交解冻操作后,服务端执行解冻,文件处于解冻中的状态。
- 完成解冻后,可以读取文件。解冻状态默认持续1天,最多延长7天,之后文件又回到冷冻状态。
归档存储类型的详细说明请参见存储类型介绍。相关状态码的详细解释请参见API文档RestoreObject。解冻归档文件的完整代码请参见GitHub。
以下代码用于解冻归档文件:
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)
}
// 获取存储空间。
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) {
// 解冻归档类型文件,进入读就绪状态。
err = archiveBucket.RestoreObject(objectName)
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(1000 * 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")
}