Azure函数 - NodeJS - 响应主体作为流

Question

当您点击给定的Azure功能端点时,我想从Blob存储中返回一个文件.该文件是二进制数据.

根据Azure存储Blob文档,最相关的调用似乎如下,因为它是唯一一个不需要将文件写入临时文件的调用: getBlobToStream

但是,此调用获取Blob并将其写入流.

有没有办法让Azure Functions使用Stream作为res.body的值,以便我可以从存储中获取Blob内容并立即将其写入响应？

要添加一些代码,尝试使用这样的代码:

'use strict';
const   azure = require('azure-storage'),
        stream = require('stream');
const BLOB_CONTAINER = 'DeContainer';

module.exports = function(context){
    var file = context.bindingData.file;
    var blobService = azure.createBlobService();
    var outputStream = new stream.Writable();

    blobService.getBlobToStream(BLOB_CONTAINER, file, outputStream, function(error, serverBlob) {
        if(error) {
            FileNotFound(context);
        } else {
            context.res = {
                status: 200,
                headers: {

                },
                isRaw: true,
                body : outputStream
            };
            context.done();


        }
    });
}

function FileNotFound(context){
    context.res =  {
        status: 404,
        headers: {
            "Content-Type" : "application/json"
        },
        body : { "Message" : "No esta aqui!."}
    };
    context.done();
}

Answer 1

不幸的是,我们还没有在NodeJS中实现流媒体支持 - 它位于积压工作中:https://github.com/Azure/azure-webjobs-sdk-script/issues/1361

如果您没有打开使用C#函数的NodeJ,则可以直接在输入绑定和流请求输出中使用存储sdk对象,而不是使用中间对象方法.

Answer 2

尽管根据我的提问方式，@ Matt Manson的答案绝对正确，但是以下代码段对于偶然发现此问题的人可能更有用。

虽然无法将Stream直接发送到响应主体，但可以使用自定义流将数据捕获到Uint8Array中，然后将其发送到响应主体。

注意：如果文件确实很大，将占用大量内存。

'use strict';
const   azure = require('azure-storage'),
        stream = require('stream');
const BLOB_CONTAINER = 'deContainer';

module.exports = function(context){
    var file = context.bindingData.file;
    var blobService = azure.createBlobService();
    var outputStream = new stream.Writable();
    outputStream.contents = new Uint8Array(0);//Initialize contents.

    //Override the write to store the value to our "contents"
    outputStream._write = function (chunk, encoding, done) {
        var curChunk = new Uint8Array(chunk);
        var tmp = new Uint8Array(this.contents.byteLength + curChunk.byteLength);
        tmp.set(this.contents, 0);
        tmp.set(curChunk, this.contents.byteLength);
        this.contents = tmp;
        done();
    };


    blobService.getBlobToStream(BLOB_CONTAINER, file, outputStream, function(error, serverBlob) {
        if(error) {
            FileNotFound(context);
        } else {
            context.res = {
                status: 200,
                headers: {

                },
                isRaw: true,
                body : outputStream.contents
            };
            context.done();
        }
    });//*/
}

function FileNotFound(context){
    context.res =  {
        status: 404,
        headers: {
            "Content-Type" : "application/json"
        },
        body : { "Message" : "No esta aqui!"}
    };
    context.done();
}