node.js - Azure Functions - NodeJS - 响应正文作为流

标签 node.js azure azure-functions

当您到达给定的 Azure Function 端点时,我想从 Blob 存储返回一个文件。该文件是二进制数据。

根据 Azure 存储 Blob 文档,最相关的调用如下所示,因为它是唯一不需要将文件写入临时文件的调用: 获取Blob到Stream

但是,此调用获取 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();
}

最佳答案

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

如果您不依赖于使用 C# 函数的 NodeJ,则可以直接在输入绑定(bind)和流请求输出中使用存储 sdk 对象,而不是使用中间对象方法。

关于node.js - Azure Functions - NodeJS - 响应正文作为流,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/43810082/

相关文章:

javascript - 如何在妥协中创造一个兑现的 promise

node.js - graphenedb 中的自动索引

azure - 将 Azure 应用服务 (Web) 功能与 IIS 进行比较

Azure 函数与 EntityFramework + DI

azure - 如何在没有 setx AZURE_STORAGE_CONNECTION_STRING 的情况下为 azure 函数提供存储连接字符串

node.js - 尝试将 mongoose 与 webpack 结合使用时出现大量神秘错误和警告

mysql - Sequelize findAll 不是一个函数

azure - 无法加载文件或程序集“Microsoft.WindowsAzure.ServiceRuntime,版本=2.0.0.0”

Azure AD - 将应用程序主体添加到组

azure - Microsoft.Azure.Storage.Common : No connection could be made because t he target machine actively refused it