批量上传(HarmonyOS SDK)

putObject(input: PutObjectInput): Response<PutObjectOutput>

// 引入依赖包
import ObsClient, { PutObjectInput } 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 fileMap: Record<string, string> = {
  "/path/to/file1.txt": "object1.txt",
  "/path/to/file2.txt": "object2.txt",
  "/path/to/file3.txt": "object3.txt",
  "/path/to/file4.txt": "object4.txt",
  "/path/to/file5.txt": "object5.txt",
};

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

async function batchUpload() {
  const entries = Object.entries(fileMap);
  const concurrentCount = 3;
  const results: UploadResult[] = [];

  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 filePath = entry[0];
        const objectKey = entry[1];
        try {
          const result = await obsClient.putObject({
            Bucket: "examplebucket",
            Key: objectKey,
            SourceFile: filePath,
            NeedCalculateCrc64: true,
          });
          if (result.CommonMsg.Status < 300) {
            hilog.info(0x0001, 'OBS-Harmony', "Upload success: %s, ETag: %s", objectKey, result.InterfaceResult?.ETag ?? "");
            return { key: objectKey, success: true, etag: result.InterfaceResult?.ETag } as UploadResult;
          } else {
            hilog.error(0x0001, 'OBS-Harmony', "Upload failed: %s, Status: %d, Code: %s", objectKey, result.CommonMsg.Status, result.CommonMsg.Code);
            return { key: objectKey, success: false, error: result.CommonMsg.Message } as UploadResult;
          }
        } catch (error) {
          const err = error as BusinessError;
          hilog.error(0x0001, 'OBS-Harmony', 'Upload exception: %s, code=%d, message: %s', objectKey, err.code, err.message);
          return { key: objectKey, success: false, error: err.message } as UploadResult;
        }
      })
    );
    results.push(...batchResults);
  }

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

batchUpload();