如何在Logic App中传递ServiceBus消息供Azure Function读取

你已经完成了Service Bus队列触发Logic App的配置，后续传参、串接流程直接按下面走就行：

• 第一步：先把要调用的首段Azure Function调整为HTTP触发模式
  授权级别选Function即可，请求方法允许POST，代码侧直接读取HTTP请求正文拿参数就行，不用提前绑定Service Bus相关触发器，举两个常见语言的最简接收逻辑：
  • C# 隔离式函数：直接用await req.ReadFromJsonAsync<dynamic>()读取请求体
  • Python函数：直接用req.get_json()获取传入的消息内容
    函数处理完业务逻辑后，把校验/处理结果序列化成JSON作为HTTP 200响应返回，Logic App会自动解析响应结构生成后续可调用的动态字段。
• 第二步：在Logic App工作流中配置函数调用与消息传递
  在已有的Service Bus触发器节点下点新增步骤，选择Azure Functions连接器下的「调用函数」操作，下拉选中你部署好的函数应用和对应函数名：
  • 普通文本/JSON格式的队列消息：直接在「请求正文」输入框的动态内容弹窗里，选Service Bus触发器输出的ContentData（也就是队列消息正文）字段，直接传递即可。
  • Base64编码的队列消息：不要直接选动态字段，在输入框里写表达式base64ToString(triggerBody()?['ContentData'])转码后再传，不然函数侧拿到的是乱码。
  • 如果需要同步传递消息ID、投递次数这类元数据，直接在请求正文里自定义JSON结构即可，示例：

    {
      "messageContent": "@{triggerBody()?['ContentData']}",
      "messageId": "@{triggerBody()?['MessageId']}",
      "deliveryCount": "@{triggerBody()?['DeliveryCount']}"
    }
    

• 第三步：串接后续流程
  首段函数调用成功后，你可以按业务需求继续新增多个调用Azure Function的动作，传参的时候直接从之前函数返回的动态内容里选对应字段就行；所有流程处理完成后，新增Service Bus连接器的「发送消息」动作，选中目标队列，把汇总后的最终结果填入消息内容字段，就完成整个闭环。

常见踩坑提示 #

• 调用函数返回403错误：先检查Logic App和Function之间的连接配置，刷新下Function访问密钥即可，POC阶段不用特意配托管标识，用密钥授权足够。
• 函数侧接收到空消息：检查Service Bus队列的消息锁定期配置，POC场景设为30秒即可，避免消息还没传递到函数就被队列回收。
• 后续步骤选不到函数返回的字段：手动在函数调用动作里跑一次测试触发，Logic App拿到实际响应结构后，会自动把所有返回字段加载到动态内容面板里。

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