Azure函数（Service Bus Topic触发器）Blob存储输出绑定代码缺失问题

第一步：确认绑定配置（function.json） #

先确保你的function.json里的Blob输出绑定配置正确，以下是标准示例：

{
  "bindings": [
    {
      "name": "mySbMsg",
      "type": "serviceBusTrigger",
      "direction": "in",
      "topicName": "你的主题名称",
      "subscriptionName": "你的订阅名称",
      "connection": "ServiceBusConnection"
    },
    {
      "name": "outputBlob",
      "type": "blob",
      "direction": "out",
      "path": "目标容器名称/{rand-guid}.txt", // 支持动态路径，比如用时间戳{datetime:yyyy-MM-dd}.txt
      "connection": "AzureWebJobsStorage"
    }
  ]
}

第二步：核心代码实现 #

根据你使用的语言，添加对应的代码逻辑，关键是给输出绑定变量赋值，否则不会生成Blob：

C# 脚本（.csx）基础版 #

public static void Run(string mySbMsg, out string outputBlob, ILogger log)
{
    log.LogInformation($"收到Service Bus消息: {mySbMsg}");
    // 将消息内容直接写入Blob
    outputBlob = mySbMsg;
}

C# 脚本（.csx）进阶版（支持自定义路径或字节流） #

public static async Task Run(string mySbMsg, IBinder binder, ILogger log)
{
    log.LogInformation($"收到Service Bus消息: {mySbMsg}");
    // 自定义Blob路径和写入方式
    var blobAttr = new BlobAttribute("目标容器名称/自定义文件名.txt");
    using (var writer = await binder.BindAsync<TextWriter>(blobAttr))
    {
        await writer.WriteAsync(mySbMsg);
    }
}

Python 基础版 #

import azure.functions as func
import logging

def main(mySbMsg: func.ServiceBusMessage, outputBlob: func.Out[str]):
    logging.info('Service Bus消息已处理')
    # 解析消息内容
    msg_content = mySbMsg.get_body().decode('utf-8')
    # 将内容写入Blob输出绑定
    outputBlob.set(msg_content)

常见排查要点 #

• 连接字符串验证：确认AzureWebJobsStorage对应的应用设置是正确的存储账户连接字符串，且该账户拥有Blob写入权限。
• Blob路径检查：目标容器必须已存在，路径不能包含非法字符；若使用动态参数（如{rand-guid}），确保语法正确。
• 代码赋值检查：必须给输出绑定变量赋值（C#的out参数、Python的set()方法），未赋值则不会生成Blob。
• 日志排查：在Azure门户的函数监控页面查看执行日志，排查是否有权限错误、路径错误等异常信息。
• 触发验证：确认Service Bus消息确实触发了函数（日志中能看到消息接收记录），排除未触发的情况。

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