.NET 8独立工作者Durable Function ActivityTrigger对象转换问题修复

问题根源 #

.NET 8的**孤立工作者模型（Isolated Worker Model）与.NET 6的进程内模型（In-Process Model）**在Durable Functions参数序列化机制上存在核心差异：

• 进程内模型默认用Newtonsoft.Json，可自动完成复杂类型的绑定与转换
• 孤立模型默认用System.Text.Json，ActivityTrigger输入默认以JSON字符串形式传递，若未匹配正确类型或配置序列化规则，会触发复杂类型转换失败

无需额外手动序列化的解决方案 #

方案1：直接绑定强类型参数 #

跳过字符串中转，在Orchestrator中先将输入反序列化为强类型对象，再传递给Activity，Activity直接接收强类型参数：

修改Orchestrator代码

var jobTypeName = "OrderImport";

[Function($"{jobTypeName}-Trigger")]
public async Task Trigger([OrchestrationTrigger] TaskOrchestrationContext context)
{   
    var functionName = $"{jobTypeName}-Trigger";
    var content = context.GetInput<string>();
    // 替换YourRequestType为实际请求模型类型
    var request = JsonConvert.DeserializeObject<YourRequestType>(content);
    var traceBundle = InitFunctionName(functionName, context);

    try
    {
        // 直接传递强类型request给Activity
        var processingGroups = await context.CallActivityAsync<List<OrderRequestModel>>($"{jobTypeName}-InitActivity", request);
        
        var itemCount = processingGroups.Count();
        var parallelTasks = new Task[itemCount];

        for (int i = 0; i < itemCount; i++)
        {
            processingGroups[i].Iterator = i + 1;
            parallelTasks[i] = context.CallActivityAsync($"{jobTypeName}-Activity", processingGroups[i]);
        }

        await Task.WhenAll(parallelTasks);
        
        await FinalizeDurableOrchestration(context, request, true);
        logger.LogInformation($"{functionName} completed");
    }
    catch (Exception ex)
    {
        logger.LogError($"{functionName} Error: [{ex.Message}]");
        await FinalizeDurableOrchestration(context, request, false, ex.Message);
        throw;
    }
}

修改Activity代码

[Function($"{jobTypeName}-InitActivity")]
public async Task<List<OrderRequestModel>> InitActivity([ActivityTrigger] YourRequestType request)
{
    var functionName = $"{jobTypeName}-InitActivity";
    // 直接使用强类型request，跳过原content初始化逻辑
    var traceBundle = ...; // 根据实际业务初始化traceBundle
    return myService.ParseOrder(request);
}

方案2：配置序列化器兼容原有行为 #

如果依赖Newtonsoft.Json的特性（如JsonProperty属性、自定义转换器），可将Durable Functions序列化器切换回Newtonsoft.Json，保持与.NET 6一致的行为：

在Program.cs中配置

var host = new HostBuilder()
    .ConfigureFunctionsWorkerDefaults()
    .ConfigureServices(services =>
    {
        services.AddDurableTask(options =>
        {
            // 切换为Newtonsoft.Json序列化器
            options.UseNewtonsoftJson();
            // 可添加自定义Newtonsoft配置，如契约解析器
            options.NewtonsoftJsonSerializerSettings.ContractResolver = new DefaultContractResolver();
        });
    })
    .Build();

host.Run();

若继续使用System.Text.Json，可配置对齐Newtonsoft的行为：

services.AddDurableTask(options =>
{
    options.JsonSerializerOptions.PropertyNameCaseInsensitive = true;
    options.JsonSerializerOptions.Converters.Add(new JsonStringEnumConverter());
    options.JsonSerializerOptions.ReferenceHandler = ReferenceHandler.IgnoreCycles;
    // 按需添加其他适配配置
});

方案3：ActivityTrigger自动完成JSON转复杂类型 #

若必须保留字符串输入，可在ActivityTrigger上显式指定目标类型，让框架自动完成反序列化：

// Activity直接接收目标类型，框架自动处理JSON字符串转换
[Function($"{jobTypeName}-InitActivity")]
public async Task<List<OrderRequestModel>> InitActivity([ActivityTrigger] List<OrderRequestModel> processingGroups)
{
    // 直接使用processingGroups，若需原content可调整为包含content的复合模型
    // ...
}

注意：此方式要求传递的JSON字符串结构与List<OrderRequestModel>完全匹配，否则仍会转换失败。

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