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

restoreObject(input: RestoreObjectInput): Response<BaseResponseOutput>

// 引入依赖包
import ObsClient, { RestoreObjectInput, RestoreTierType } from '@obs/esdk-obs-harmony';
import { process } from '@kit.ArkTS';
import { BusinessError } from '@kit.BasicServicesKit';
import { hilog } from '@kit.PerformanceAnalysisKit';

const processManager = new process.ProcessManager();

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

// 需要恢复的归档对象Key列表
const archiveObjectKeys: string[] = [
  "archive-object1.txt",
  "archive-object2.txt",
  "archive-object3.txt",
  "archive-object4.txt",
  "archive-object5.txt",
];

interface RestoreResult {
  key: string;
  success: boolean;
  error?: string;
}

async function batchRestore() {
  const bucket = "examplebucket";
  const days = 7;
  const tier = RestoreTierType.STANDARD;
  const concurrentCount = 3;
  const results: RestoreResult[] = [];

  for (let i = 0; i < archiveObjectKeys.length; i += concurrentCount) {
    const batch = archiveObjectKeys.slice(i, i + concurrentCount);
    const batchResults = await Promise.all(
      batch.map(async (objectKey) => {
        try {
          const params: RestoreObjectInput = {
            Bucket: bucket,
            Key: objectKey,
            Days: days,
            Tier: tier,
          };
          const result = await obsClient.restoreObject(params);
          if (result.CommonMsg.Status < 300) {
            hilog.info(0x0001, 'OBS-Harmony', "Restore request submitted: %s, Status: %d", objectKey, result.CommonMsg.Status);
            return { key: objectKey, success: true } as RestoreResult;
          } else {
            hilog.error(0x0001, 'OBS-Harmony', "Restore failed: %s, Status: %d, Code: %s", objectKey, result.CommonMsg.Status, result.CommonMsg.Code);
            return { key: objectKey, success: false, error: result.CommonMsg.Message } as RestoreResult;
          }
        } catch (error) {
          const err = error as BusinessError;
          hilog.error(0x0001, 'OBS-Harmony', 'Restore exception: %s, code=%d, message: %s', objectKey, err.code, err.message);
          return { key: objectKey, success: false, error: err.message } as RestoreResult;
        }
      })
    );
    results.push(...batchResults);
  }

  const successCount = results.filter(r => r.success).length;
  const failedCount = results.length - successCount;
  hilog.info(0x0001, 'OBS-Harmony', "Batch restore complete: %d/%d success, %d failed", successCount, results.length, failedCount);
}

batchRestore();