Node.js版Azure Functions使用Event Hub输出绑定写入ADX问题咨询

问题背景 #

基于Node.js构建HTTP触发的Azure Functions应用，数据流链路为：Azure Function（HTTP Trigger）→ Azure Event Hub → Azure ADX 数据摄取。
此前使用@azure/event-hubs包的EventHubProducerClient手动发消息时全链路正常，改用Extension Bundle提供的内置Event Hub输出绑定后，消息无法被ADX正常摄取。
已完成的基础配置：

• function.json中配置了HTTP触发器、HTTP响应输出、Event Hub输出绑定，通过应用配置项读取Event Hub名称与连接字符串
• 函数代码中直接将处理后的JSON数据赋值给context.bindings.outputEventHub

核心失效原因 #

• 未在Event Hub输出绑定中显式指定dataType属性，Node.js场景下绑定层自动类型推断会将JS对象按.NET POCO规则序列化，消息体附加额外类型元数据，ADX无法识别这类包装后的消息，直接丢弃。
• 直接给绑定赋值未序列化的JS对象时，不同版本Extension Bundle的序列化逻辑存在差异，部分版本生成的消息体不符合ADX Event Hub摄取要求的标准UTF-8 JSON字符串格式。

Event Hub输出绑定官方标注支持的String、Byte数组、EventData、POCO四类数据类型中，仅String类型在Node.js运行时下无跨运行时序列化兼容问题，其余三类均为.NET原生类型，JS侧传值易出现格式异常。

落地配置步骤 #

1. 修正function.json绑定配置 #

在Event Hub输出绑定节点中增加"dataType": "string"配置，强制绑定层将传入值作为UTF-8纯字符串处理，不做额外的.NET类型包装。
完整配置示例：

{
  "bindings": [
    {
      "authLevel": "function",
      "type": "httpTrigger",
      "direction": "in",
      "name": "req",
      "methods": ["post"],
      "route": "upload"
    },
    {
      "type": "http",
      "direction": "out",
      "name": "res"
    },    
    {
      "type": "eventHub",
      "name": "outputEventHub",
      "eventHubName": "%AZEH_EVENTHUB_NAME%",
      "connection": "AZEH_CONNECTION_STRING",
      "direction": "out",
      "dataType": "string"
    }
  ]
}

2. 调整函数代码赋值逻辑 #

给Event Hub输出绑定赋值前，必须通过JSON.stringify()将处理完成的JS对象序列化为标准JSON字符串，禁止直接传入JS对象。

• 单条消息发送：直接赋值序列化后的字符串
• 批量消息发送：赋值为序列化后字符串组成的数组
  代码示例：

module.exports = async function (context, req) {
    // 原有业务数据处理逻辑，得到结构化的处理结果对象
    const processedRecord = {
        ingestTime: new Date().toISOString(),
        // 其余业务字段与ADX表结构、列映射一一对应
        ...req.body
    };

    // 关键操作：序列化为标准JSON字符串再赋值给绑定
    context.bindings.outputEventHub = JSON.stringify(processedRecord);

    // 批量发送场景替换为以下写法
    // const recordList = req.body.list.map(item => JSON.stringify(item));
    // context.bindings.outputEventHub = recordList;

    context.res = {
        status: 200,
        body: {
            success: true,
            message: "data sent to event hub"
        }
    };
}

3. 链路校验要点 #

• Event Hub侧校验：通过Azure门户的Event Hub消息浏览功能查看Function发送的消息，确认消息体为纯JSON格式，无$type等.NET序列化附加字段。
• ADX侧校验：确认Event Hub数据连接配置的消费组、Event Hub实例与Function使用的配置一致，表结构、列映射与发送的JSON字段名、类型完全匹配，可先通过ADX inline ingest命令测试单条JSON数据可正常写入。

补充说明 #

• 若使用Node.js v4 编程模型（无需function.json配置），使用eventHubOutput装饰器定义输出绑定时，同样需要保证传入输出绑定的值为JSON.stringify()序列化后的字符串，不要直接传入JS对象。
• Node.js场景下不推荐使用Byte数组、EventData、POCO类型输出，这三类为.NET运行时原生类型，跨语言传值存在序列化兼容风险，String类型是对接ADX摄取最稳定的选择。

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