.NET 6迁移至.NET 8隔离Azure函数后EventData序列化异常

核心问题 #

从.NET 6进程内模式迁移到.NET 8隔离模式后，使用EventData[]作为Event Hub输出绑定类型时，运行时会默认将EventData对象序列化为其类型信息或元数据JSON，而非实际的消息Payload。这是因为两种模式下的函数运行时对EventData的处理逻辑不同：

• .NET 6进程内模式对EventData有特殊内置处理，直接提取Payload发送
• .NET 8隔离模式默认使用System.Text.Json序列化整个对象，导致发送的不是预期的消息内容

另外，你的代码中存在属性名笔误：Timer函数里的outputBindings.EventHub2.Append应该改为outputBindings.OutEventHub2.Append，否则无法正确向目标输出绑定添加事件。

可行解决方案 #

方案1：使用EventDataBatch替代EventData[] #

隔离模式对EventDataBatch有原生支持，能直接识别并发送其中的EventData内容，避免序列化问题。

修改输出绑定模型

using System.Diagnostics.CodeAnalysis;
using Azure.Messaging.EventHubs;
using Azure.Messaging.EventHubs.Producer;
using Microsoft.Azure.Functions.Worker;

public class RetryFailedEventHubOutputBindings
{
    public RetryFailedEventHubOutputBindings()
    {
        // 使用默认选项初始化Batch，也可根据需求配置分区、大小等
        OutEventHub1 = new EventDataBatch(new EventHubProducerClientOptions());
        OutEventHub2 = new EventDataBatch(new EventHubProducerClientOptions());
    }

    [EventHubOutput("OutEventHub1", Connection = "EventHubConnection")]
    public EventDataBatch OutEventHub1 { get; set; }

    [EventHubOutput("OutEventHub2", Connection = "EventHubConnection")]
    public EventDataBatch OutEventHub2 { get; set; }
}

修改Timer触发函数

[Function(nameof(RetryFailedFunction))]
public async Task<RetryFailedEventHubOutputBindings> RunAsync([TimerTrigger("%ScheduleTriggerTime%")] TimerInfo myTimer)
{
    var outputBindings = new RetryFailedEventHubOutputBindings();
    var eventData = new EventData(Encoding.UTF8.GetBytes("{\"ErrorId\": 10}"));

    // 尝试将事件添加到Batch，处理Batch已满的情况
    if (!outputBindings.OutEventHub2.TryAdd(eventData))
    {
        // 可选：如果Batch已满，可创建新Batch或记录日志
        _logger.LogWarning("Event Hub batch is full, unable to add event");
    }

    return outputBindings;
}

方案2：通过FunctionContext手动发送EventData #

直接通过IAsyncCollector获取输出绑定的发送器，绕过自动序列化逻辑，手动发送EventData。

修改Timer触发函数

[Function(nameof(RetryFailedFunction))]
public async Task RunAsync([TimerTrigger("%ScheduleTriggerTime%")] TimerInfo myTimer, FunctionContext context)
{
    await Semaphore.WaitAsync();
    try
    {
        var eventData = new EventData(Encoding.UTF8.GetBytes("{\"ErrorId\": 10}"));
        // 获取OutEventHub2的输出绑定收集器
        var eventHubCollector = context.BindingContext.Bindings.GetValueOrDefault("OutEventHub2") as IAsyncCollector<EventData>;
        
        if (eventHubCollector != null)
        {
            await eventHubCollector.AddAsync(eventData);
            await eventHubCollector.FlushAsync();
        }
        else
        {
            _logger.LogError("Failed to get Event Hub output collector");
        }
    }
    finally
    {
        Semaphore.Release();
    }
}

注意：此方案无需返回RetryFailedEventHubOutputBindings，函数返回类型改为Task即可。

额外检查 #

1. 确保Microsoft.Azure.Functions.Worker.Extensions.EventHubs NuGet包升级到最新稳定版本，避免版本兼容问题
2. 接收端代码无需修改，只要发送端正确发送Payload，就能正常解析事件内容

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