Willin: Azure Node.js Blob文件上传

对官方文档一些需要额外注意的细节整理

azure-storage官方文档: http://azure.github.io/azure-storage-node/

建立连接

有3种方式(文档中未提及):

1. 通过环境变量

1
AZURE_STORAGE_CONNECTION_STRING="valid storage connection string" node app.js

应用程序内:

1
2
3
const azure = require('azure-storage');
const blobService = azure.createBlobService();
// code here

2.连接字符串

1
2
3
const azure = require('azure-storage');
const blobService = azure.createBlobService('connectionString'); // 类似: DefaultEndpointsProtocol=https;AccountName=*****;AccountKey=*****;EndpointSuffix=*****.core.chinacloudapi.cn
// code here

3.账号+密钥

1
2
3
const azure = require('azure-storage');
const blobService = azure.createBlobService('storageAccount', 'storageAccessKey', 'storageHost');
// code here

上传示例

因为POST请求接收到的大部分是Stream.所以采用Sream的方式上传.

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
// azure.js
const azure = require('azure-storage');
const { getDefer } = require('@dwing/common');

const blobService = azure.createBlobService('accountName', 'accessKey', 'host');

exports.createBlockBlobFromStream = (container, filename, blob) => {
const deferred = getDefer();
blob.on('error', (err) => {
deferred.reject(err);
});
blob.pipe(blobService.createWriteStreamToBlockBlob(container, filename));
blob.on('end', () => {
deferred.resolve(1);
});
return deferred.promise;
};

测试代码:

1
2
3
4
5
6
7
8
9
10
11
// demo.js
const { createBlockBlobFromStream } = require('./azure');
const fs = require('fs');
const path = require('path');

const stream = fs.createReadStream(path.join(__dirname, '/testfile'));

(async () => {
const result = await createBlockBlobFromStream('container', 'filename', stream);
console.log(result);
})();

在 AirX 项目中的实际使用:

https://github.com/AirDwing/node-airx-sdk

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
const SDK = require('@airx/sdk');
const fs = require('fs');

const sdk = new SDK({
SecretId: 'xxxx',
SecretKey: 'xxxx'
});

(async () => {
const result = await sdk.upload({
auth: 'xxxx',
type: 'orgverify',
file: fs.createReadStream('PATH/TO/xxx.jpg') // 注意这里, 本地文件可以用 path.join 拼装地址,或者直接用Stream
});
console.log(result);
})();