You need to enable JavaScript to run this app.
导航
对象存储
  • 文档首页
    • /
  • 对象存储

分片拷贝（Browser.js SDK）

最近更新时间：2024.02.04 18:31:06

首次发布时间：2023.07.08 17:33:01

我的收藏

对象大于 5GiB 时，需要进行分片拷贝。

注意事项

  • 为了避免在浏览器环境中暴露您的火山引擎账号密钥信息（即 AccessKey ID 和 AccessKey Secret），强烈建议您使用临时访问凭证的方式执行 TOS 相关操作，详细说明，请参见使用 STS 临时 AK/SK+Token 访问火山引擎 TOS。
  • Endpoint 为 TOS 对外服务的访问域名。TOS 支持的 Endpoint 信息，请参见访问域名 Endpoint。
  • 拷贝对象不支持跨区域的桶间拷贝。
  • 拷贝对象时，账号必须具备源对象的读取权限和目标桶的写入权限。
  • 拷贝对象时，可以保留所有元数据（默认值）或指定新的元数据。但 ACL 并未被保留，而是设置为私有。

分片拷贝步骤

  1. 通过 createMultipartUpload 初始化分片拷贝任务。
  2. 通过 uploadPartCopy 进行分片拷贝。
  3. 通过 completeMultipartUpload 合并分片。

示例代码

以下代码用于分片拷贝对象。

<!DOCTYPE html>
<html lang="en">
  <head>
    <meta charset="UTF-8" />
    <title>Document</title>
  </head>
  <body>
    <button id="upload">上传</button>
    <button id="copy">复制</button>
    <input id="file" type="file" />
    <!-- 导入 SDK 文件 -->
    <script src="https://tos-public.volccdn.com/obj/volc-tos-public/@volcengine/tos-sdk@latest/browser/tos.umd.production.min.js"></script>
    <script type="text/javascript">
      const client = new TOS({
        // yourRegion 填写Bucket 所在地域。以华北2（北京)为例，yourRegion 填写为 cn-beijing。
        region: yourRegion,
        // 填写 endpoint 名称。
        endpoint: yourEndpoint,
        // 从 STS 服务获取的临时访问密钥（AccessKey ID 和 AccessKey Secret）。
        accessKeyId: yourAccessKey,
        accessKeySecret: yourSecretKey,
        // 从 STS 服务获取的安全令牌（SecurityToken）。
        stsToken: yourSecurityToken,
        // 填写 Bucket 名称。
        bucket: examplebucket,
      });

      const srcBucket = yourSrcBucket; // 源桶
      const srcObject = 'exampledir/putObject-test'; // 源对象
      const dstBucket = yourDstBucket; // 目标桶
      const dstObject = 'exampledir/part-copy-test'; // 目标对象

      // 上传文件
      const upload = document.getElementById('upload');
      upload.addEventListener('click', async () => {
        // 从输入框获取 file 对象，例如 <input type="file" id="file" />。
        const data = document.getElementById('file').files[0];
        try {
          await client.uploadFile({
            bucket: srcBucket,
            key: srcObject,
            file: data,
          });
        } catch (e) {
          console.log(e);
        }
      });

      // 复制文件
      const copy = document.getElementById('copy');
      copy.addEventListener('click', async () => {
        try {
          // 获取上传任务 ID
          const {
            data: { UploadId },
          } = await client.createMultipartUpload({
            bucket: dstBucket,
            key: dstObject,
          });
          console.log('UploadId', UploadId);

          // 获取桶源桶中已存在对象的大小
          const {
            data: { 'content-length': contentLength },
          } = await client.headObject({
            bucket: srcBucket,
            key: srcObject,
          });
          console.log('srcObject content-length', contentLength);

          // 文件总大小
          const totalSize = contentLength;
          const partSize = 5 * 1024 * 1024;

          let offset = 0;
          let partNumber = 1;
          const partsInfo = [];

          while (offset < totalSize) {
            // 上传分片拷贝
            const uploadResult = await client.uploadPartCopy({
              bucket: dstBucket,
              key: dstObject,
              partNumber,
              uploadId: UploadId,
              headers: {
                'x-tos-copy-source': `/${srcBucket}/${srcObject}`,
                'x-tos-copy-source-range': `bytes=${offset}-${offset + partSize}`,
              },
            });
            const eTag = uploadResult.data.ETag;
            console.log(`partNumber${partNumber} Etag:`, eTag);
            partsInfo.push({
              partNumber,
              eTag,
            });
            partNumber++;
            offset += partSize;
          }
          console.log('parts information', partsInfo);

          // 完成分片上传
          const { data } = await client.completeMultipartUpload({
            bucket: dstBucket,
            key: dstObject,
            uploadId: UploadId,
            parts: partsInfo,
          });

          console.log('result data:', data);
        } catch (e) {
          console.log(e);
        }
      });
    </script>
  </body>
</html>