According to my test, we can use the following code to upload and download
1. install sdk
my package.json
"dependencies": {
"@azure/abort-controller": "^1.0.1",
"@azure/storage-blob": "^12.0.2",
"fs": "0.0.1-security",
"stream": "0.0.2"
}
- code
const accountname ="blobstorage0516";
const key = "your account key";
const cerds = new storage.StorageSharedKeyCredential(accountname,key);
const containerName="test";
const pipeline = storage.newPipeline(cerds, {
retryOptions: { maxTries: 4 }, // Retry options
userAgentOptions: { userAgentPrefix: "AdvancedSample V1.0.0" }, // Customized telemetry string
keepAliveOptions: {
// Keep alive is enabled by default, disable keep alive by setting false
enable: false
}
});
const blobServiceClient =new storage.BlobServiceClient( `https://${accountname}.blob.core.windows.net`,pipeline)
var containerClient =blobServiceClient.getContainerClient(containerName)
if(!containerClient.exists()){
console.log("the container does not exit")
await containerClient.create()
}
const blobNmae="test.jpg";
const localFilePath="D:\\download\\test.jpg";
const blockBlobClient =containerClient.getBlockBlobClient(blobNmae)
// upload
await blockBlobClient.uploadStream(fs.createReadStream(localFilePath), 4 * 1024 * 1024, 20, {
abortSignal: AbortController.timeout(30 * 60 * 1000)})
// download
const downloadBlockBlobResponse = await blockBlobClient.download(0);
const datastream = new stream.PassThrough();
const readableStream = downloadBlockBlobResponse.readableStreamBody
readableStream.on("data", data => {
datastream.push(data);
});
readableStream.on("end" , () => {
fs.writeFileSync('D:\\test1.jpg', datastream.read())
console.log("download successfully")
datastream.destroy();
});
readableStream.on("error" , (error) => {
datastream.destroy();
throw error;
});
For more details, please refer to the document and the sample
