批量恢复归档或深度归档存储对象(Node.js SDK)

开发过程中，您有任何问题可以在GitHub上提交issue，或者在华为云对象存储服务论坛中发帖求助。

代码示例

本示例用于批量恢复归档或深度归档存储的对象。归档或深度归档类型的对象处于冷冻状态无法直接访问，需要先提交恢复请求，等待恢复完成后才能访问。

     // 引入obs库
// 使用npm安装
const ObsClient = require("esdk-obs-nodejs");
// 使用源码安装
// var ObsClient = require('./lib/obs');

// 创建ObsClient实例
const obsClient = new ObsClient({
  // 推荐通过环境变量获取AKSK，这里也可以使用其他外部引入方式传入，如果使用硬编码可能会存在泄露风险
  // 您可以登录访问管理控制台获取访问密钥AK/SK，获取方式请参见https://support.huaweicloud.com/usermanual-ca/ca_01_0003.html
  access_key_id: process.env.ACCESS_KEY_ID,
  secret_access_key: process.env.SECRET_ACCESS_KEY,
  // 【可选】如果使用临时AK/SK和SecurityToken访问OBS，同样建议您尽量避免使用硬编码，以降低信息泄露风险。您可以通过环境变量获取访问密钥AK/SK，也可以使用其他外部引入方式传入
  // security_token: process.env.SECURITY_TOKEN,
  // endpoint填写Bucket对应的Endpoint, 这里以华北-北京四为例，其他地区请按实际情况填写
  server: "https://obs.cn-north-4.myhuaweicloud.com",
});

/**
 * 批量恢复归档存储对象
 * 归档存储类型的对象需要恢复后才能访问，恢复过程通常需要数分钟到数小时
 */
async function batchRestoreObjects() {
  try {
    const bucketName = "examplebucket";
    const prefix = "archive/";
    const params = {
      Bucket: bucketName,
      Prefix: prefix,
      EncodingType: "url",
    };
    // 需要恢复的存储类型：归档存储(COLD)和深度归档存储(DEEP_ARCHIVE)
    const restorableStorageClasses = ["COLD", "DEEP_ARCHIVE"];
    // 列举需要恢复的归档对象
    let objectsToRestore = [];
    let allListed = 0;
    while (true) {
      const listResult = await obsClient.listObjects(params);
      if (listResult.CommonMsg.Status > 300) {
        console.log("列举对象失败: Status=%d, Code=%s, Message=%s",
          listResult.CommonMsg.Status, listResult.CommonMsg.Code, listResult.CommonMsg.Message);
        return;
      }
      if (listResult.InterfaceResult.Contents && listResult.InterfaceResult.Contents.length > 0) {
        // 过滤出归档存储和深度归档存储类型的对象
        const restorable = listResult.InterfaceResult.Contents.filter(
          (obj) => restorableStorageClasses.includes(obj.StorageClass)
        );
        objectsToRestore = objectsToRestore.concat(restorable);
        // 统计非目标类型对象，便于日志展示
        const skipped = listResult.InterfaceResult.Contents.length - restorable.length;
        if (skipped > 0) {
          console.log(`本次列举中跳过 ${skipped} 个非归档存储对象（StorageClass: ${listResult.InterfaceResult.Contents[0]?.StorageClass || 'N/A'}）`);
        }
        allListed += listResult.InterfaceResult.Contents.length;
      }
      if (listResult.InterfaceResult.IsTruncated === "true") {
        params.Marker = listResult.InterfaceResult.NextMarker;
      } else {
        break;
      }
    }
    console.log(`共列举 ${allListed} 个对象，其中可恢复的归档/深度归档对象 ${objectsToRestore.length} 个，开始批量恢复...`);
    // 批量恢复对象
    const restoreDays = 1; // 恢复后保留天数
    const restoreTier = "Expedited"; // 恢复速度：Expedited(快速)、Standard(标准)、Bulk(批量)
    for (const obj of objectsToRestore) {
      const restoreParams = {
        Bucket: bucketName,
        Key: obj.Key,
        RestoreRequest: {
          Days: restoreDays,
          RestoreJobDefinition: {
            Tier: restoreTier,
          },
        },
      };
      const result = await obsClient.restoreObject(restoreParams);
      if (result.CommonMsg.Status <= 300) {
        console.log(`对象 [${obj.Key}] 恢复请求提交成功, RequestId: ${result.CommonMsg.RequestId}`);
      } else {
        console.log(`对象 [${obj.Key}] 恢复失败: Status=${result.CommonMsg.Status}, Code=${result.CommonMsg.Code}, Message=${result.CommonMsg.Message}`);
      }
    }
    console.log("批量恢复完成");
  } catch (error) {
    console.log("客户端异常:");
    console.log(error);
  }
}
batchRestoreObjects();
 
 
  