如何获取Azure Functions Event Hub Trigger接收事件的messageId或eventId

云上老周

2026-10-3

区分Event Hub重复事件与同负载独立事件的解决方案

核心判断逻辑

你可以直接使用 分区ID（PartitionId）+ 序列号（SequenceNumber）的组合 作为事件的全局唯一标识，该组合由Event Hub服务端强制保证全局唯一，不存在重复可能：

Event Hub会为每个分区内成功写入的消息分配单调递增、永不复用的SequenceNumber，同一分区内的不同消息SequenceNumber必然不同
结合PartitionContext中获取的PartitionId做跨分区区分，整个事件中心范围内不会出现两条不同消息拥有相同的组合值

注：你提到的MessageId/EventId属于生产者发送消息时可选填充的自定义属性，不是Event Hub的强制必填字段，生产者未设置时消费端自然无法获取，因此不适合作为通用的唯一标识。

代码实现示例

你在现有触发逻辑中新增一行即可生成事件唯一标识，用于去重判断：

[FunctionName("function-name")]
public async Task RunAsync(
[EventHubTrigger("az_eventhubname", 
    Connection = "connection-string-path", ConsumerGroup = "%AzureEventHubConsumerName%")] EventData ed, 
    ExecutionContext eCtx, PartitionContext PartitionContext)
{
    // 生成事件全局唯一标识
    string eventUniqueId = $"{PartitionContext.PartitionId}_{ed.SystemProperties.SequenceNumber}";
    
    // 可选去重逻辑：查询缓存/数据库中是否存在该ID，存在则直接跳过处理
    // if(CheckEventIdProcessed(eventUniqueId)) return;
    
    var messageBody = Encoding.UTF8.GetString(ed.Body);
    // 原有业务处理逻辑...
    
    // 处理完成后将该ID存入缓存/数据库，过期时间设置为Event Hub的消息保留时长即可
    // SaveProcessedEventId(eventUniqueId);
}