JavaScript Azure Blob存储移动Blob

0s7z1bwu  于 2022-10-30  发布在  Java
关注(0)|答案(2)|浏览(245)

我有一个NodeJS后端,它使用微软的官方blob存储库(@azure/storage-blob)来管理我的Blob存储:
https://www.npmjs.com/package/@azure/storage-blob
将一个blob从一个文件夹移动到另一个文件夹是必要的。不幸的是,我找不到任何相关文档。
到目前为止,我所做的是:

const { BlobServiceClient } = require("@azure/storage-blob");

const blobServiceClient = BlobServiceClient.fromConnectionString(process.env.storageconnection);
const containerClient = blobServiceClient.getContainerClient('import');
const blobClient = containerClient.getBlobClient('toImport/' + req.body.file);
const downloadBlockBlobResponse = await blobClient.download();
... do some stuff with the value of the files

就像你在代码中看到的那样,我从文件夹“toImport”中读取了一个文件。然后我想把这个文件移到另一个文件夹“finished”中。这可能吗?也许我需要创建一个文件的副本,然后删除旧的文件?

h43kikqp

h43kikqp1#

因此,Azure Blob存储中不支持此类移动操作。你必须做的是将Blob从源复制到目标,监视复制进度(因为复制操作是异步的),并在复制完成后删除Blob。
对于复制,您要使用的方法是beginCopyFromURL(string, BlobBeginCopyFromURLOptions)
请参阅以下代码:

const { BlobServiceClient } = require("@azure/storage-blob");

const connectionString = "DefaultEndpointsProtocol=https;AccountName=account-name;AccountKey=account-key;EndpointSuffix=core.windows.net";
const container = "container-name";
const sourceFolder = "source";
const targetFolder = "target";
const blobName = "blob.png";

async function moveBlob() {
  const blobServiceClient = BlobServiceClient.fromConnectionString(connectionString);
  const containerClient = blobServiceClient.getContainerClient(container);
  const sourceBlobClient = containerClient.getBlobClient(`${sourceFolder}/${blobName}`);
  const targetBlobClient = containerClient.getBlobClient(`${targetFolder}/${blobName}`);
  console.log('Copying source blob to target blob...');
  const copyResult = await targetBlobClient.beginCopyFromURL(sourceBlobClient.url);
  console.log('Blob copy operation started successfully...');
  console.log(copyResult);
  do {
    console.log('Checking copy status...')
    const blobCopiedSuccessfully = await checkIfBlobCopiedSuccessfully(targetBlobClient);
    if (blobCopiedSuccessfully) {
      break;
    }
  } while (true);
  console.log('Now deleting source blob...');
  await sourceBlobClient.delete();
  console.log('Source blob deleted successfully....');
  console.log('Move operation complete.');
}

async function checkIfBlobCopiedSuccessfully(targetBlobClient) {
  const blobPropertiesResult = await targetBlobClient.getProperties();
  const copyStatus = blobPropertiesResult.copyStatus;
  return copyStatus === 'success';
}

moveBlob();
v6ylcynt

v6ylcynt2#

前面的最佳解决方案似乎工作,但我不喜欢使用无限循环。
这是移动blob文件的另一种方法

const move = async (
    fileName: string,
    src: string,
    dest: string
  ) => {

    try {
      const = blobServiceClient = BlobServiceClient.fromConnectionString();
      logger.info(`Move storage file [ ${src} -> ${dest} | ${fileName} ]`);
      const srcContainerClient = blobServiceClient.getContainerClient(src);
      const destContainerClient =
        blobServiceClient.getContainerClient(dest);
      const blobClient = srcContainerClient.getBlobClient(fileName);
      const downloadBlockBlobResponse = await blobClient.download();
      const buffer = await streamToBuffer(
        downloadBlockBlobResponse.readableStreamBody!
      );
      blobClient.delete();
      const blockBlobClient = containerClient.getBlockBlobClient(fileName);
      await blockBlobClient.upload(buffer, buffer.length);
      return `${this.storageUrl}/${containerClient.containerName}/${fileName}`;
    } catch (e) {
      throw new Error(
        `Fail to move storage file [ ${src} -> ${dest} | ${fileName} ]`
      );
    }
  };

const streamToBuffer = async (readableStream: NodeJS.ReadableStream): Promise<Buffer> => {
  return new Promise((resolve, reject) => {
    const chunks: Buffer[] = [];
    readableStream.on("data", (data) => {
      chunks.push(data instanceof Buffer ? data : Buffer.from(data));
    });
    readableStream.on("end", () => {
      resolve(Buffer.concat(chunks));
    });
    readableStream.on("error", reject);
  });
};

相关问题