在Node.js中列出Azure Blob存储和Readstream中的Blob

问题描述

这是我列出代码的代码。

已编辑！！！

------------------------------------编辑---------- --------------------------------

我编辑了代码，并在此TypeScript中进行了重写：

    const blobServiceClient = new BlobServiceClient(`https://${accountName}.blob.core.windows.net?${sasToken}`,pipeline)
    const containerClient = blobServiceClient.getContainerClient(containerName)
    console.log(containerClient)
    if (!containerClient.exists()) {
      console.log("the container does not exit")
      await containerClient.create()

    }
    const client = containerClient.getBlockBlobClient(this.currentFile.name)

    //name of uploded blob
    console.log(this.currentFile.name)
    //Metaata from the blob
    console.log(client)

    //List each blobs in the container
    for await (const blob of containerClient.listBlobsFlat()) {
      console.log('\t',blob.name);
      const blockBlobClient = containerClient.getBlockBlobClient(blob.name);
      const downloadBlockBlobResponse = await blockBlobClient.download(0);
      console.log('\nDownloaded blob content...');
      console.log('\t',await streamToString(downloadBlockBlobResponse.readableStreamBody));
      //end of loop
  }



  async function streamToString(readableStream) {
    return new Promise((resolve,reject) => {
      const chunks = [];
      readableStream.on("data",(data) => {
        chunks.push(data.toString());
      });
      readableStream.on("end",() => {
        resolve(chunks.join(""));
      });
      readableStream.on("error",reject);
    });
  }

但是随后我在浏览器中收到一个错误：

错误错误：未捕获（承诺）：TypeError：无法读取属性 未定义TypeError的“ on”：无法读取未定义的属性“ on”

解决方法

通过调用download方法来下载Blob。该示例代码包括一个名为streamToString的帮助程序函数，该函数用于将Node.js 可读流读取为字符串。

将此代码添加到主要功能的末尾：

const blockBlobClient = containerClient.getBlockBlobClient(blob.name);
const downloadBlockBlobResponse = await blockBlobClient.download(0);
console.log('\nDownloaded blob content...');
console.log('\t',await streamToString(downloadBlockBlobResponse.readableStreamBody));

在主要功能之后添加此辅助功能：

// A helper function used to read a Node.js readable stream into a string
async function streamToString(readableStream) {
  return new Promise((resolve,reject) => {
    const chunks = [];
    readableStream.on("data",(data) => {
      chunks.push(data.toString());
    });
    readableStream.on("end",() => {
      resolve(chunks.join(""));
    });
    readableStream.on("error",reject);
  });
}

有关更多详细信息，请参阅此article。