Azure Functions v4 .NET 6独立进程Event Hub Trigger如何获取EnqueuedTimeUTC？

在.NET 6独立进程模式的Azure Functions（Runtime 4 + Worker 1.10）中，Event Hub触发器无法通过BindingContext或直接添加enqueuedTimeUtcArray这类参数获取入队时间，正确的方式是直接绑定到EventData[]类型，从事件对象本身获取元数据。

步骤1：确认依赖包 #

确保你的项目已安装兼容版本的Microsoft.Azure.Functions.Worker.Extensions.EventHubs NuGet包（建议使用1.1.0及以上版本，以支持独立进程模式下的EventData绑定）。

步骤2：修改函数签名与实现 #

将原有的string[] messages替换为EventData[] events，通过遍历每个EventData实例获取EnqueuedTime属性：

using Azure.Messaging.EventHubs;
using Microsoft.Azure.Functions.Worker;
using Microsoft.Extensions.Logging;

public class MyFunction
{
    private readonly ILogger<MyFunction> _logger;

    public MyFunction(ILogger<MyFunction> logger)
    {
        _logger = logger;
    }

    [Function("MyFunction")]
    public async Task Run([EventHubTrigger("my-eventhub",
        ConsumerGroup = "a-consumer-group",
        Connection = "EventHub.ConnectionString")] EventData[] events)
    {
        foreach (var eventData in events)
        {
            // 获取消息体
            string messageContent = System.Text.Encoding.UTF8.GetString(eventData.Body);
            // 获取入队时间（UTC）
            DateTime enqueuedTimeUtc = eventData.EnqueuedTime.UtcDateTime;
            
            _logger.LogInformation($"消息内容：{messageContent}");
            _logger.LogInformation("入队时间（UTC）：{EnqueuedTime}", enqueuedTimeUtc);

            // 执行你的业务操作
        }
    }
}

为什么之前的方法无效？ #

• BindingContext方式：独立进程模式下，BindingContext.BindingData中并不包含enqueuedTimeUtcArray这类键，该逻辑仅适用于旧版进程内模式。
• 拆分字段参数方式：DateTime[] enqueuedTimeUtcArray这类参数绑定是进程内模式的特性，独立进程模式不支持这种元数据的直接拆分绑定。
• 独立进程模式的Event Hub触发器原生支持绑定到EventData[]类型，可直接访问事件的所有元数据（包括入队时间、序列号、偏移量等）。

额外说明 #

如果需要将消息体反序列化为自定义类型，可以在获取eventData.Body后自行处理，或通过eventData.Body.ToObjectFromJson<T>()（需引用Azure.Core.Serialization）进行反序列化，同时保留对元数据的访问能力。

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