如何将单个Node.js Azure Function Event Hub触发器连接到同一命名空间下的多个事件中心？

首先明确：可以让单个Azure函数监听同一命名空间下的多个Event Hub，但不能直接在function.json里添加多个Event Hub触发器绑定——因为Azure Functions不支持单个函数绑定多个同类型的触发型绑定，你之前的配置违反了这个规则，所以函数停止工作。

下面是两种可行的实现方案：

方案1：使用Event Hub多主题监听（扩展v5+支持） #

Azure Functions Event Hub触发器扩展v5及以上版本支持在单个触发器里指定多个Event Hub名称，或监听整个命名空间。

配置步骤： #

1. 确保Event Hub相关扩展版本≥5.x。对于Node.js项目，检查package.json中@azure/functions和@azure/event-hubs的版本，若版本过低，执行npm install @azure/functions@latest @azure/event-hubs@latest更新。
2. 修改function.json，将eventHubName设置为多个Event Hub名称的逗号分隔值：

{
  "bindings": [
    {
      "type": "eventHubTrigger",
      "name": "eventHubMessages",
      "direction": "in",
      "eventHubName": "general,insights-logs-auditevent",
      "connection": "EVENTHUB_CONN_STR",
      "cardinality": "many",
      "consumerGroup": "$Default"
    }
  ],
  "disabled": false
}

3. 在Node.js函数代码中，通过消息的systemProperties.eventHubName字段区分来源Event Hub，统一处理后推送到Datadog：

module.exports = async function (context, eventHubMessages) {
    for (const msg of eventHubMessages) {
        const sourceHub = msg.systemProperties.eventHubName;
        context.log(`处理来自${sourceHub}的日志: ${JSON.stringify(msg)}`);
        
        // 加入推送Datadog的逻辑，比如调用Datadog REST API
        await pushToDatadog(msg, sourceHub);
    }
};

// 抽离公共推送逻辑
async function pushToDatadog(message, sourceHub) {
    // 你的Datadog推送代码
}

方案2：多个函数共用业务逻辑 #

如果不想升级扩展版本，可以创建多个函数，每个函数绑定一个Event Hub触发器，但共用同一份推送Datadog的业务代码，避免重复开发。

实现步骤： #

1. 创建两个函数，比如EventHubGeneralTrigger和EventHubAuditTrigger
2. 分别配置它们的function.json：
   • 第一个函数的eventHubName设为general
   • 第二个函数的eventHubName设为insights-logs-auditevent
3. 把推送Datadog的逻辑抽成独立模块（比如datadogClient.js），两个函数都引入该模块处理事件：

// datadogClient.js
module.exports = async function pushToDatadog(message) {
    // 你的Datadog推送代码
};

// EventHubGeneralTrigger/index.js
const pushToDatadog = require('../datadogClient');
module.exports = async function (context, eventHubMessages) {
    for (const msg of eventHubMessages) {
        await pushToDatadog(msg);
    }
};

// EventHubAuditTrigger/index.js
const pushToDatadog = require('../datadogClient');
module.exports = async function (context, eventHubMessages) {
    for (const msg of eventHubMessages) {
        await pushToDatadog(msg);
    }
};

为什么原配置失效？ #

Azure Functions的核心规则是：单个函数只能拥有一个触发型绑定。触发型绑定是用来触发函数执行的（比如Event Hub触发器、Timer触发器），一个函数不能同时被多个触发器触发，所以你添加第二个Event Hub触发器后，配置被视为无效，函数无法启动。

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