Azure：尝试获取 blob 内容时函数停止工作

Question

我正在使用 nodeJS 和 Azure 函数。我正在尝试获取 blob（pptx）的内容，然后进一步使用该 pptx（使用 admzip 解压缩）。

但是，每当我尝试获取内容时，该功能都会停止而没有任何错误，并且在一段时间后会超时。我尝试首先获取 blob 的属性（以检查 blob 是否存在）并且有效。

这是我的功能：

const storage = require('azure-storage');
const STORAGE_ACCOUNT_NAME = 'storage-account';
const ACCOUNT_ACCESS_KEY = 'storage-key';
let AdmZip = require('adm-zip');
let fs = require('file-system');

const blobService = storage.createBlobService(STORAGE_ACCOUNT_NAME, ACCOUNT_ACCESS_KEY);

module.exports = function (context, req) {
    context.log('JavaScript HTTP trigger function processed a request.');
    getBlobProperties('default-powerpoint', 'download.pptx').then((properties) => {
        context.log('Properties: ', properties);
        getBlobContent('default-powerpoint', 'download.pptx').then((content) => {
            context.log('Blob Content: ', content);
        })
    });
};

function getBlobProperties(containerName, fileName) {
    return new Promise((resolve, reject) => {
        blobService.getBlobProperties(
            containerName,
            fileName,
            function (err, properties, status) {
                if (err) {
                    reject(err);
                } else {
                    resolve(properties);
                }
            });
    })
}

function getBlobContentAsStream(containerName, fileName, res) {
    return new Promise((resolve, reject) => {
        blobService.getBlobToStream(containerName, fileName, res, function (err, results) {
            if (err) {
                reject(err);
            } else {
                resolve(JSON.stringify(results, null, 2));
            }
        });
    })
}

function getBlobContent(containerName, blobName) {
    return new Promise((resolve, reject) => {
        blobService.getBlobToText(
            containerName,
            blobName,
            function (err, blobContent, blob) {
                if (err) {
                    reject(err);
                } else {
                    resolve({
                        'content': blobContent,
                        'blob': blob
                    });
                }
            });
    })
}

如您所见，我尝试了getBlobToStream 和getBlobToText，但结果相同。 getBlobProperties 工作正常，我得到了关于 blob 的所有信息，只是没有内容。

谁能帮我获取 blob 的内容。

编辑：

如果有人感兴趣，这是属性的输出：

BlobResult {
  container: 'default-powerpoint',
  name: 'download.pptx',
  metadata: {},
  lastModified: 'Wed, 14 Aug 2019 08:28:16 GMT',
  creationTime: 'Wed, 14 Aug 2019 08:28:16 GMT',
  etag: '"something"',
  blobType: 'BlockBlob',
  contentLength: '4658',
  serverEncrypted: 'true',
  requestId: 'someID',
  contentSettings: { contentType: 'image/jpeg' },
  lease: { status: 'unlocked', state: 'available' },
  copy: 
   { id: 'id123',
     status: 'success',
     source: 'sourceURL',
     progress: '4658/4658',
     bytesCopied: 4658,
     totalBytes: 4658,
     completionTime: 'Wed, 14 Aug 2019 08:28:16 GMT' } }

Answer 1

这是我在应用中使用的工作代码

  return new Promise(async r => {
            bst.getBlobToText(containername, name, (err, text) => r(err ? null : text));
  })

Full SourceCode

Answer 2

我能够使用代码解决这个问题

const storage = require('azure-storage');
const fs = require('fs');

const STORAGE_ACCOUNT_NAME = '<account_name>';
const ACCOUNT_ACCESS_KEY = '<access_key>';

const blobService = storage.createBlobService(STORAGE_ACCOUNT_NAME, ACCOUNT_ACCESS_KEY);

function getBlobContentAsStream(containerName, fileName, res) {
    return new Promise((resolve, reject) => {
        blobService.getBlobToStream(containerName, fileName, fs.createWriteStream('task1-download.txt'), function(error, serverBlob) {
            if(!error) {
                resolve(serverBlob);
            } else { 
                reject(err); 
            }
        });
    })
}

module.exports = function (context, req) {
    context.log('JavaScript HTTP trigger function processed a request.');

    context.log('Starting...');

    getBlobContentAsStream('default-powerpoint', 'download.pptx').then((content) => {
        context.log('Blob Content: ', content);
        context.done();
    }, function(err) {
        console.log.error(err);
        context.done();
    });

};

并跟踪输出

如果您将函数连接到代码中，您实际上可以在 Application Insights 跟踪中看到代码中发生的问题。您没有收到任何错误，因为您没有为 then 回调执行程序添加错误处理。

getBlobContent('default-powerpoint', 'download.pptx').then((content) => {
    context.log('Blob Content: ', content);
    context.done();
})

使用

getBlobContent('default-powerpoint', 'download.pptx').then((content) => {
    context.log('Blob Content: ', content);
    context.done();
}, function(err) {
    console.log(err);
    context.done();
}))

你会看到

详细说明

Error: An incorrect number of bytes was read from the connection. 
The connection may have been closed.

所以getBlobToText 遇到的问题是它试图将 Buffer 对象作为字符串返回，但无法验证 MD5。我在某处读到可以使用 write to stream 函数写入缓冲区而不是文件，但我现在找不到它。

我可能会抓取一些 NodeJS 内存流库并尝试在那里输出它，因为我假设您不想直接保存到文件中。但也许你愿意，自己决定。

如果您最终要使用“fs”库，请记住使用推荐的安全非阻塞模式，例如

const fs = require('fs');
const util = require('util');
const readFileAsync = util.promisify(fs.readFile);

module.exports = async function (context) {
    try {
        const data = await readFileAsync('./hello.txt');
    } catch (err) {
        context.log.error('ERROR', err);
        // This rethrown exception will be handled by the Functions Runtime and will only fail the individual invocation
        throw err;
    }
    context.log(`Data from file: ${data}`);
}

Answer 3

问题可能是 api 已更改。我刚刚在下面检查过，回调函数在getBlobToText 中只接受两个参数：

https://github.com/Azure-Samples/storage-blobs-node-quickstart/blob/master/index.js

const downloadBlob = async (containerName, blobName) => {
    const dowloadFilePath = path.resolve('./' + blobName.replace('.txt', '.downloaded.txt'));
    return new Promise((resolve, reject) => {
        blobService.getBlobToText(containerName, blobName, (err, data) => {
            if (err) {
                reject(err);
            } else {
                resolve({ message: `Blob downloaded "${data}"`, text: data });
            }
        });
    });
};