Azure Function v4编程模型中Event Hub输出绑定如何设置Key/Headers

算力阿峰

2026-6-25

Azure Functions v4 Event Hub输出绑定：设置消息内容、分区键和自定义属性

在v3编程模型中，你可以通过构造包含Value、Headers等字段的对象来设置Event Hub消息的内容和属性，但这种方式在v4模型中不再生效——v4会直接将整个对象作为消息体发送，不会解析这些特殊字段。以下是v4模型中正确的实现方式：

正确的消息构造方式

在v4的JavaScript/TypeScript函数中，需要使用EventHubMessage类（或直接构造指定结构的对象）来定义消息内容、分区键和自定义属性：

代码示例

const { app, EventHubMessage } = require('@azure/functions');

app.eventHub('eventHubOutput', {
  connection: 'EventHubConnectionString', // 替换为你的连接字符串配置名
  eventHubName: 'kafkaeventhubtest1', // 替换为你的Event Hub名称
  handler: async (context) => {
    // 使用EventHubMessage类构造消息
    const message1 = new EventHubMessage('one', {
      partitionKey: 'your-partition-key', // 对应v3中的Key
      properties: { test: 'javascript' } // 对应v3中的Headers（键值对形式）
    });

    // 或者直接构造符合规范的消息对象（无需依赖EventHubMessage）
    const message2 = {
      body: 'two', // 对应v3中的Value，作为消息主体内容
      partitionKey: 'your-partition-key',
      properties: { test: 'javascript' }
    };

    // 批量发送消息
    context.extraOutputs.set('eventHubOutput', [message1, message2]);
  }
});