能否通过中间件向Azure Function传递解析后的对象？

Azure Functions（Isolated Worker模型）支持自定义参数绑定逻辑，完全可以实现你需要的——让中间件解析XML得到的ComplexObject自动注入到Function的参数中，类似MVC的值提供器机制。

实现步骤 #

1. 完善中间件逻辑，存入解析后的对象

首先确保中间件正确获取HTTP请求的XML数据并解析，然后将对象存入FunctionContext.Items（你的思路是对的，这一步没问题）：

public class MyMiddleware : IFunctionsWorkerMiddleware
{
    public async Task Invoke(FunctionContext context, FunctionExecutionDelegate next)
    {
        // 从HTTP上下文获取XML数据
        var req = await context.GetHttpRequestDataAsync();
        using var reader = new StreamReader(req.Body);
        var xmlContent = await reader.ReadToEndAsync();
        
        // 解析XML到ComplexObject
        var myComplexObject = ParseXMLToObject(xmlContent);
        
        // 将对象存入FunctionContext.Items
        context.Items["ComplexObjectInstance"] = myComplexObject;

        await next(context);
    }

    private ComplexObject ParseXMLToObject(string xml)
    {
        // 这里实现你的XML反序列化逻辑，示例：
        var serializer = new XmlSerializer(typeof(ComplexObject));
        using var stringReader = new StringReader(xml);
        return (ComplexObject)serializer.Deserialize(stringReader);
    }
}

2. 自定义参数绑定提供器

要让Function参数自动获取FunctionContext.Items中的对象，需要实现IParameterBindingProvider和IInputBinding：

// 自定义绑定特性（可选，用于标记需要注入的参数）
[AttributeUsage(AttributeTargets.Parameter)]
public class FromMiddlewareAttribute : Attribute
{
}

// 参数绑定提供器
public class ComplexObjectBindingProvider : IParameterBindingProvider
{
    public bool TryCreateParameterBinding(ParameterInfo parameter, IInputBindingProvider inputBindingProvider, out IParameterBinding parameterBinding)
    {
        // 检查参数类型是否是ComplexObject，且标记了FromMiddleware特性（可选）
        if (parameter.ParameterType == typeof(ComplexObject) && parameter.GetCustomAttribute<FromMiddlewareAttribute>() != null)
        {
            parameterBinding = new ComplexObjectInputBinding();
            return true;
        }

        parameterBinding = null;
        return false;
    }
}

// 输入绑定实现
public class ComplexObjectInputBinding : IInputBinding
{
    public Type Type => typeof(ComplexObject);

    public Task<object> BindAsync(FunctionContext context, BindingContext bindingContext)
    {
        // 从FunctionContext.Items中获取对象
        if (context.Items.TryGetValue("ComplexObjectInstance", out var instance) && instance is ComplexObject obj)
        {
            return Task.FromResult<object>(obj);
        }

        throw new InvalidOperationException("ComplexObject未从中间件注入");
    }
}

3. 在Program.cs注册中间件和绑定提供器

var host = new HostBuilder()
    .ConfigureFunctionsWorkerDefaults(builder =>
    {
        // 注册自定义中间件
        builder.UseMiddleware<MyMiddleware>();
        
        // 注册自定义参数绑定提供器
        builder.Services.AddSingleton<IParameterBindingProvider, ComplexObjectBindingProvider>();
    })
    .Build();

host.Run();

4. 在Function中使用自动注入

[Function("Function1")]
public HttpResponseData Run(
    [HttpTrigger(AuthorizationLevel.Function, "get", "post")] HttpRequestData req,
    [FromMiddleware] ComplexObject someObject) // 自动从中间件注入
{
    // 直接使用someObject
    var response = req.CreateResponse(HttpStatusCode.OK);
    response.WriteAsJsonAsync(someObject);
    return response;
}

关键说明 #

• 如果你不需要特性标记，也可以简化绑定提供器的逻辑，直接判断参数类型是ComplexObject就进行绑定。
• FunctionContext.Items是中间件和Function之间传递数据的标准方式，配合自定义绑定提供器就能实现自动注入，这就是Azure Functions中类似MVC值提供器的实现方案。

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