如何解决在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。
版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。