Node.js Azure Function配置Blob输出绑定写入数据方法

你规划的「HTTP触发写队列 → 队列触发写Blob」架构完全可行，不需要额外引入Storage SDK，直接用Azure Function原生输出绑定就能完成Blob写入。不建议在HTTP触发器里直接挂载Blob输出绑定，把Blob写入逻辑放到独立的队列触发函数中，既能保证HTTP接口快速响应，也能利用队列的重试机制避免请求日志因瞬时存储故障丢失。

第一步：修正HTTP触发函数（仅负责写入队列） #

你之前想在HTTP触发器的function.json中添加Blob配置是多余的，这个函数只需要保留HTTP输入、HTTP响应输出、队列输出三个绑定即可。

function.json 配置 #

{
  "scriptFile": "./index.js",
  "bindings": [
    {
      "authLevel": "function",
      "type": "httpTrigger",
      "direction": "in",
      "name": "req",
      "methods": ["get", "post", "put", "delete"]
    },
    {
      "type": "http",
      "direction": "out",
      "name": "res"
    },
    {
      "type": "queue",
      "direction": "out",
      "name": "outputQueue",
      "queueName": "apirequests",
      "connection": "AzureWebJobsStorage"
    }
  ]
}

注意：connection字段填写Function应用配置中存储账号连接字符串对应的配置项名称，默认使用内置的AzureWebJobsStorage即可，不要直接把连接字符串硬编码在配置文件中。

index.js 逻辑 #

不要只往队列发送GUID，直接把完整的请求/响应对象发到队列，否则队列触发环节拿不到完整日志内容：

const { v4: genId } = require('uuid');
module.exports = async function (context, req) {
    context.log('HTTP trigger processed a request.');
    const reqBody = req.body ? JSON.stringify(req.body) : '';

    const wholeObj = {
        GUID: genId(),
        method: req.method,
        url: req.url,
        request: {
            headers: req.headers,
            body: reqBody
        },
        // 补充自定义响应字段逻辑
        response: {}
    }
    // 将完整日志对象发送到队列
    context.bindings.outputQueue = wholeObj;
    // 正常返回接口响应
    context.res = {
        status: 200,
        body: { code: 0, msg: "success", requestId: wholeObj.GUID }
    };
}

第二步：新建队列触发函数（负责写入Blob） #

这是实现Blob写入的核心环节，单独新建一个函数，以apirequests队列为触发器，输出绑定到目标Blob容器即可。

function.json 配置 #

{
  "scriptFile": "./index.js",
  "bindings": [
    {
      "name": "myQueueItem",
      "type": "queueTrigger",
      "direction": "in",
      "queueName": "apirequests",
      "connection": "AzureWebJobsStorage"
    },
    {
      "name": "outputBlob",
      "type": "blob",
      "direction": "out",
      "blobPath": "request-logs/{GUID}.json",
      "connection": "AzureWebJobsStorage"
    }
  ]
}

配置项说明：

• blobPath格式为容器名/Blob文件名，这里用request-logs作为存储请求日志的容器名，{GUID}是绑定表达式，会自动读取队列消息里的GUID字段作为Blob文件名，最终生成的Blob路径为request-logs/xxx-xxx-xxx.json
• connection字段规则和队列绑定一致，填写存储连接字符串对应的配置项名称即可

index.js 逻辑 #

逻辑非常简单，只需要把队列拿到的消息赋值给Blob输出绑定，运行时会自动完成序列化和写入操作：

module.exports = async function (context, myQueueItem) {
    context.log('Processing queue item, GUID:', myQueueItem.GUID);
    // 直接给输出绑定赋值即可完成Blob写入
    context.bindings.outputBlob = JSON.stringify(myQueueItem, null, 2);
};

注意事项 #

• 不需要额外安装azure-storage类SDK，绑定能力是Function运行时内置的，配置正确即可自动完成写入
• 如果一定要在同一个HTTP函数里直接写Blob（不推荐，会拖慢接口响应），只需要在HTTP函数的绑定数组中添加和队列函数一致的Blob输出配置，在代码中给context.bindings.outputBlob赋值即可，但强烈建议拆成两个函数实现解耦
• 存储账号中的目标容器不需要提前手动创建，Function运行时第一次写入时如果发现容器不存在会自动创建
• 如果本地调试时提示找不到Blob/Queue绑定，执行func extensions install安装对应Storage扩展即可

内容的提问来源于stack exchange，提问作者Hugobop