Azure Function EventGridTrigger使用SingletonAttribute报错问题

问题场景 #

尝试为带有EventGridTrigger的Azure Function配置SingletonAttribute，期望基于EventGridEvent.Subject实现单例运行，代码如下：

[Singleton("{Subject}")]
public void Run([EventGridTrigger] EventGridEvent eventGridEvent, ILogger logger)
{
    // 业务逻辑实现
}

运行时抛出错误：

[Error] Executed '[NameOfFunction]' System.InvalidOperationException :
No value for named parameter 'Subject'.

移除SingletonAttribute后，日志可确认eventGridEvent.Subject存在有效值；但将EventGrid事件转发到Azure存储队列，改用QueueTrigger结合Singleton("{Subject}")却能正常工作：

[Singleton("{Subject}")]
public void Run([QueueTrigger("evengrid-debug", Connection = "MessageQueueStorage")] HubEvent hubEvent, ILogger logger)
{
    // 业务逻辑实现
}

问题原因 #

1. 绑定时机差异：SingletonAttribute的占位符解析发生在触发器绑定的早期阶段，此时EventGridTrigger对应的EventGridEvent实例尚未完成初始化，无法读取到Subject属性值；而QueueTrigger是直接将队列消息反序列化为目标对象，解析阶段可直接从消息体中提取Subject字段。
2. 触发器元数据支持不同：EventGridTrigger的绑定元数据中未将Subject暴露为可用于占位符的参数，而QueueTrigger支持直接从消息体属性中提取占位符参数。

解决方案 #

方案1：手动控制分布式单例锁 #

放弃在SingletonAttribute中使用占位符，改为在函数内部通过IDistributedLockManager手动获取基于Subject的单例锁，示例代码：

public async Task Run([EventGridTrigger] EventGridEvent eventGridEvent, ILogger logger, IDistributedLockManager lockManager)
{
    if (string.IsNullOrWhiteSpace(eventGridEvent.Subject))
    {
        logger.LogWarning("Event Subject is empty, skipping singleton lock logic");
        return;
    }

    var lockKey = $"Singleton_Lock_{eventGridEvent.Subject}";
    using (var lockHandle = await lockManager.TryLockAsync(lockKey, TimeSpan.FromSeconds(30)))
    {
        if (lockHandle != null)
        {
            logger.LogInformation($"Processing event with Subject: {eventGridEvent.Subject} under singleton lock");
            // 执行需要单例运行的业务逻辑
        }
        else
        {
            logger.LogInformation($"Another instance is processing event with Subject: {eventGridEvent.Subject}, current execution skipped");
        }
    }
}

注意：消费计划下Azure Functions默认使用存储账户作为分布式锁存储，需确保函数配置了正确的存储连接字符串。

方案2：自定义输入绑定提前提取Subject #

通过自定义输入绑定将EventGridEvent.Subject提前提取为可用于SingletonAttribute的参数：

1. 实现自定义绑定转换器：

public class EventGridSubjectConverter : IAsyncConverter<EventGridTriggerAttribute, string>
{
    public async Task<string> ConvertAsync(EventGridTriggerAttribute input, CancellationToken cancellationToken)
    {
        var httpContext = HttpContext.Current;
        if (httpContext == null) return null;

        httpContext.Request.Body.Position = 0;
        var payload = await new StreamReader(httpContext.Request.Body).ReadToEndAsync();
        var events = JsonConvert.DeserializeObject<List<EventGridEvent>>(payload);
        return events?.FirstOrDefault()?.Subject;
    }
}

2. 注册自定义绑定并在函数中使用：

[Singleton("{Subject}")]
public void Run([EventGridTrigger] EventGridEvent eventGridEvent, [EventGridSubject] string Subject, ILogger logger)
{
    // 业务逻辑实现
}

此方案需完成自定义绑定的完整注册流程，适合需要复用该逻辑的场景。

方案3：转发到中间队列（已验证可行） #

采用你已经尝试过的方式：将EventGrid事件转发到Azure存储队列，通过QueueTrigger结合Singleton("{Subject}")处理。该方式无需复杂开发，利用QueueTrigger对消息体属性占位符的原生支持即可快速实现需求。

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