# 批量上传(HarmonyOS SDK)
#### 功能说明
本示例用于将多个本地文件批量上传到 OBS 桶。通过指定并发数控制同时上传的任务数量，并利用 Promise.all 分批并发执行 putObject 请求，每个文件上传完成后实时记录结果，便于统计成功与失败情况。
#### 接口约束
- 您必须是桶拥有者或拥有上传对象的权限，才能上传对象。建议使用IAM或桶策略进行授权，如果使用IAM则需授予obs:object:PutObject权限，如果使用桶策略则需授予PutObject权限。相关授权方式介绍可参见[OBS权限控制概述](https://support.huaweicloud.com/perms-cfg-obs/obs_40_0001.html)，配置方式详见[使用IAM自定义策略](https://support.huaweicloud.com/usermanual-obs/obs_03_0121.html)、[配置对象策略](https://support.huaweicloud.com/usermanual-obs/obs_03_0075.html)。
- OBS支持的Region与Endpoint的对应关系，详细信息请参见[地区与终端节点](https://developer.huaweicloud.com/endpoint?OBS)。
- 批量上传本质是循环调用 putObject 接口，单次上传对象大小不超过 5GB。如需上传大文件，建议使用断点续传上传接口。
- 并发数不宜过大，避免占用过多内存与带宽，建议根据设备性能和网络情况设置。
 
#### 方法定义
本接口为组合调用示例，基于 putObject 接口实现批量上传。
```
putObject(input: PutObjectInput): Response<PutObjectOutput>
```
#### 请求参数
批量上传基于 putObject 接口，请求参数与 putObject 接口一致，详细参数说明请参见[PutObjectInput](https://support.huaweicloud.com/sdk-harmony-devg-obs/obs_34_0623.html#obs_34_0623__table14455523)参数表。
#### 代码示例
本示例用于将本地文件列表批量上传到 examplebucket 桶，开启 CRC64 计算用于完整性校验，并发数设置为 3。
```
// 引入依赖包
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();
```
#### 相关链接
- 关于批量上传所调用的上传对象-PUT上传的API说明，请参见[PUT上传](https://support.huaweicloud.com/api-obs/obs_04_0080.html)。
- 上传对象过程中返回的错误码含义、问题原因及处理措施可参考[OBS错误码](https://support.huaweicloud.com/api-obs/obs_04_0115.html#section1)。