Durable Functions中如何传递Dictionary<string, object>给编排与活动触发器？

问题根源 #

Durable Functions 默认使用 Newtonsoft.Json 做序列化/反序列化，当传递 Dictionary<string, object> 时，object 类型的子项若包含复杂结构（嵌套对象、数组等），序列化过程会丢失类型信息，反序列化时无法正确还原，进而导致活动绑定失败、编排无法被识别的问题。

可行解决方案 #

方案1：用JObject替代Dictionary<string, object>（推荐）

直接将模型中的动态字段替换为 Newtonsoft.Json.Linq.JObject，它本身就是JSON的动态表示，Durable的序列化器能完美兼容，无需额外配置。

修改模型示例：

// 原模型
public class WorkflowInput
{
    public string FlowType { get; set; }
    public Dictionary<string, object> DynamicData { get; set; }
}

// 修改后模型
public class WorkflowInput
{
    public string FlowType { get; set; }
    public JObject DynamicData { get; set; }
}

编排器与活动中的使用示例：

// 编排器中传递JObject
[FunctionName("MainOrchestrator")]
public static async Task RunOrchestrator(
    [OrchestrationTrigger] IDurableOrchestrationContext context)
{
    var input = context.GetInput<WorkflowInput>();
    await context.CallActivityAsync<string>("ProcessDynamicData", input.DynamicData);
}

// 活动函数中处理动态数据
[FunctionName("ProcessDynamicData")]
public static string ProcessDynamicData([ActivityTrigger] JObject dynamicData)
{
    // 直接通过键取值
    var basicValue = dynamicData["StaticKey"].ToString();
    // 用dynamic处理嵌套结构
    dynamic dynData = dynamicData;
    var nestedValue = dynData.NestedObject.SubValue;
    
    return "Processed";
}

方案2：配置序列化器保留类型信息

如果必须保留 Dictionary<string, object> 类型，可以修改Durable的序列化配置，让Newtonsoft.Json在序列化时保留类型标识，反序列化时据此还原对象类型。

在项目的Startup.cs（.NET 5及更早）或Program.cs（.NET 6+）中添加配置：

using Microsoft.Azure.Functions.Extensions.DependencyInjection;
using Microsoft.Azure.WebJobs.Extensions.DurableTask;
using Newtonsoft.Json;

[assembly: FunctionsStartup(typeof(YourProjectNamespace.Startup))]
namespace YourProjectNamespace
{
    public class Startup : FunctionsStartup
    {
        public override void Configure(IFunctionsHostBuilder builder)
        {
            builder.Services.Configure<DurableTaskOptions>(options =>
            {
                // 自动为需要的对象添加类型标识
                options.JsonSerializerSettings.TypeNameHandling = TypeNameHandling.Auto;
            });
        }
    }
}

注意：该方案会在JSON中插入$type字段记录类型信息，若输入不可信，存在反序列化安全风险，仅适用于可控的内部场景。

方案3：将动态结构序列化为JSON字符串传递

如果不想修改模型或序列化配置，可以先把动态字段序列化为JSON字符串，在活动函数中再反序列化处理。

模型修改示例：

public class WorkflowInput
{
    public string FlowType { get; set; }
    public string DynamicDataJson { get; set; }
}

编排器与活动中的使用示例：

// 编排器中传递JSON字符串
[FunctionName("MainOrchestrator")]
public static async Task RunOrchestrator(
    [OrchestrationTrigger] IDurableOrchestrationContext context)
{
    var input = context.GetInput<WorkflowInput>();
    await context.CallActivityAsync<string>("ProcessDynamicData", input.DynamicDataJson);
}

// 活动函数中反序列化处理
[FunctionName("ProcessDynamicData")]
public static string ProcessDynamicData([ActivityTrigger] string dynamicDataJson)
{
    var dynamicData = JsonConvert.DeserializeObject<Dictionary<string, object>>(dynamicDataJson);
    // 处理数据逻辑
    return "Processed";
}

方案选择建议 #

• 优先选方案1：完全适配JSON动态结构场景，Durable原生支持，无额外配置，也规避了类型安全风险。
• 必须用Dictionary<string, object>时选方案2，但要严格控制输入来源的安全性。
• 方案3适合临时兼容场景，代码稍繁琐，但无需调整序列化配置。

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