批量复制对象(HarmonyOS SDK)

copyObject(input: CopyObjectInput): Response<CopyObjectOutput>

// 引入依赖包
import ObsClient, { CopyObjectInput } 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 → 目标对象Key 映射
const copyMap: Record<string, string> = {
  "src-object1.txt": "dst-object1.txt",
  "src-object2.txt": "dst-object2.txt",
  "src-object3.txt": "dst-object3.txt",
  "src-object4.txt": "dst-object4.txt",
};

interface CopyResult {
  key: string;
  success: boolean;
  etag?: string;
  error?: string;
}

async function batchCopy() {
  const sourceBucket = "sourcebucket";
  const destBucket = "examplebucket";
  const entries = Object.entries(copyMap);
  const concurrentCount = 3;
  const results: CopyResult[] = [];

  for (let i = 0; i < entries.length; i += concurrentCount) {
    const batch = entries.slice(i, i + concurrentCount);
    const batchResults = await Promise.all(
      batch.map(async (entry) => {
        const srcKey = entry[0];
        const dstKey = entry[1];
        try {
          const result = await obsClient.copyObject({
            Bucket: destBucket,
            Key: dstKey,
            CopySource: sourceBucket + "/" + srcKey,
          });
          if (result.CommonMsg.Status < 300) {
            hilog.info(0x0001, 'OBS-Harmony', "Copy success: %s -> %s", srcKey, dstKey);
            return { key: dstKey, success: true, etag: result.InterfaceResult?.ETag } as CopyResult;
          } else {
            hilog.error(0x0001, 'OBS-Harmony', "Copy failed: %s, Status: %d, Code: %s", srcKey, result.CommonMsg.Status, result.CommonMsg.Code);
            return { key: dstKey, success: false, error: result.CommonMsg.Message } as CopyResult;
          }
        } catch (error) {
          const err = error as BusinessError;
          hilog.error(0x0001, 'OBS-Harmony', 'Copy exception: srcKey=%s, dstKey=%s, code=%d, message: %s', srcKey, dstKey, err.code, err.message);
          return { key: dstKey, success: false, error: err.message } as CopyResult;
        }
      })
    );
    results.push(...batchResults);
  }

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

batchCopy();