使用@azure/service-bus调度消息时Azure Functions触发器绑定变量为undefined

你遇到的问题其实是调用scheduleMessages方法时参数顺序搞反了，这才导致调度的消息没有正确携带内容，触发器里的mySbMsg变成undefined。

错误原因 #

查看@azure/service-bus库的API定义，scheduleMessages的正确参数顺序是：

1. 第一个参数：要调度的消息数组（SendableMessageInfo[]）
2. 第二个参数：预定的入队时间（Date）

而你的代码里把这两个参数顺序写反了：

// 错误写法：参数顺序颠倒
sender.scheduleMessages(scheduledEnqueueTimeUtc, [message]);

这种情况下，SDK会把时间对象当成消息来处理，自然没有body内容，触发器接收到的就是空消息，表现为mySbMsg是undefined。

修正后的代码 #

把参数顺序调整过来，同时别忘了await异步操作（你当前的代码没有awaitsend和scheduleMessages，可能导致函数提前退出，消息发送不完整），另外还要记得释放Service Bus客户端资源，避免内存泄漏：

import { AzureFunction, Context, HttpRequest } from "@azure/functions"
import * as sb from "@azure/service-bus"

const PublishToServiceBus: AzureFunction = async function (context: Context, req: HttpRequest): Promise<void> {
  const eventDoc = req.body;
  const serviceBusConnectionString = process.env["ServiceBusConnection"];
  const topicName = process.env["TopicName"];
  
  const sbClient = sb.ServiceBusClient.createFromConnectionString(serviceBusConnectionString);
  try {
    const topicClient = sbClient.createTopicClient(topicName);
    const sender = topicClient.createSender();

    const message: sb.SendableMessageInfo = { body: eventDoc };
    // await异步操作，确保消息发送完成
    await sender.send(message);

    // 修正参数顺序：消息数组在前，预定入队时间在后
    const scheduledEnqueueTimeUtc = new Date(Date.now() + 10000);
    await sender.scheduleMessages([message], scheduledEnqueueTimeUtc);
    
    context.log("即时消息和调度消息发送成功");
  } finally {
    // 释放客户端资源，避免内存泄漏
    await sbClient.close();
  }
};

export default PublishToServiceBus;

额外排查小技巧 #

如果再遇到类似绑定变量为空的情况，可以在触发器函数里打印所有绑定内容，帮助定位问题：

const serviceBusTopicTrigger: AzureFunction = async function (context: Context, mySbMsg: any): Promise<void> {
  // 打印所有绑定信息，确认消息是否真的为空
  context.log('所有绑定内容:', context.bindings);
  context.log('ServiceBus topic trigger function processed message', mySbMsg);
};

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