Node.js Azure Functions同时发送消息至Service Bus与Event Hub问题排查

看起来你遇到了两个核心问题：Service Bus的连接字符串配置错误，以及Event Hub没有实际发送事件的代码问题。让我们一步步解决它们：

1. 修复Service Bus的"NamespaceConnectionString should not contain EntityPath"错误 #

这个错误的根源是你在Service Bus输出绑定中使用了**包含实体路径（队列/主题名称）**的连接字符串，但Azure Functions的Service Bus绑定有明确要求：

• 连接字符串只需要命名空间级别的（不带EntityPath参数）
• 队列/主题名称要单独在绑定的queueName或topicName属性中配置

举个例子，你的local.settings.json或者函数应用配置里的Service Bus连接字符串应该是这样的：

{
  "Values": {
    "ServiceBusConnection": "Endpoint=sb://your-namespace.servicebus.windows.net/;SharedAccessKeyName=RootManageSharedAccessKey;SharedAccessKey=your-key"
  }
}

而不是带EntityPath=your-queue的版本。然后在function.json的输出绑定里指定实体名称：

{
  "type": "serviceBus",
  "direction": "out",
  "name": "outputSbMsg",
  "queueName": "your-queue-name",
  "connection": "ServiceBusConnection"
}

2. 修复Event Hub无事件发送的问题 #

你的代码里有几个明显的问题导致Event Hub没有发送事件：

• 定义了output变量但最后给context.bindings.outputEventHubMessage赋值的是未定义的out变量，属于笔误
• axios.post的请求体键名data-json是无效的JavaScript对象键，需要用引号包裹或者改成合法的标识符（比如dataJson）
• 在async函数中不需要调用context.done()，async函数会自动处理完成状态
• axios的导入应该放在函数外部，避免每次函数调用都重新加载模块

修正后的完整代码 #

const axios = require('axios'); // 移到函数外部，提升性能

module.exports = async function (context, eventHubMessages) {
    context.log(`JavaScript eventhub trigger function called for message array ${eventHubMessages}`);
    
    // 注意：如果eventHubMessages有多个消息，这里只会保留最后一个，根据你的需求调整
    const completeData = eventHubMessages[eventHubMessages.length - 1];
    context.log(`Processed message ${completeData}`);

    try {
        // 修复请求体的键名，用合法的标识符或引号包裹
        const response = await axios.post('http://fake-endpoint', { dataJson: completeData });
        context.log(`statusCode: ${response.status}`); // axios里是response.status，不是statusCode
        context.log(response.data);
        
        const outputData = response.data;
        const time = new Date().toString();
        context.log('Event Hub message created at: ', time);

        // 修正变量名，用正确的outputData赋值
        context.bindings.outputEventHubMessage = outputData;
        context.bindings.outputSbMsg = outputData;

        return outputData;
    } catch (error) {
        context.log.error('Request failed:', error);
        throw error; // async函数中抛出错误会自动标记函数失败
    }
};

额外注意事项 #

• 如果你的Event Hub输出绑定需要发送多条消息，可以赋值为数组，比如context.bindings.outputEventHubMessage = [outputData, anotherData];
• 确认function.json中的Event Hub输出绑定配置正确，指定了正确的事件中心名称和连接字符串：

{
  "type": "eventHub",
  "direction": "out",
  "name": "outputEventHubMessage",
  "eventHubName": "your-eventhub-name",
  "connection": "EventHubConnection"
}

• 检查函数应用的配置中，Event Hub和Service Bus的连接字符串都没有包含额外的实体路径，且权限足够（比如Service Bus需要发送权限，Event Hub需要发送权限）

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