Azure Function V4 单例ActivityTagger调用AddTag标签值串扰问题

该问题和单例注册的IActivityTagger服务无关，核心原因是：

1. Activity.Current基于AsyncLocal实现，是绑定到Azure Function单次触发请求根链路的共享上下文实例，一次触发内启动的所有并行Task默认都会继承、操作同一个Activity对象
2. 你使用Task.WhenAll并行处理多个Cosmos变更文档时，所有并发的文档处理任务都在往同一个共享Activity上写入SaleTransactionNumber标签，同键标签的写入时序完全由线程调度决定，必然会出现标签值被其他任务覆盖、和当前处理文档不匹配的问题
3. 业务日志输出的交易号始终正确，是因为日志里引用的sale.Header.TransactionNumber是每个并行任务lambda闭包内的独立变量，每个任务持有自己反序列化得到的Sale对象值，不存在共享覆盖。

• 临时将Task.WhenAll并行处理逻辑改为串行foreach逐个处理文档，如果标签值完全匹配不再错乱，即可100%确认是并行操作共享Activity上下文导致的问题
• 在AddTag调用位置打印Activity.Current?.ActivityId，会发现所有并行任务拿到的ActivityId完全一致，不存在独立的上下文实例
• 即使将IActivityTagger注册为瞬态、作用域服务，问题依然会复现——因为问题根源不在服务实例生命周期，而在服务操作的Activity.Current是全局共享的上下文对象

方案1：为每个文档创建独立子Activity（推荐，符合链路追踪规范） #

单请求级别的根Activity只适合存本次函数触发的公共属性，单文档维度的标签应该打在每个文档处理流程对应的独立子Activity上，既可以彻底避免标签串扰，还能在Application Insights中看到每个文档处理的单独耗时、错误、独立链路：

await Task.WhenAll(documents.Select(async document =>
{
    // 基于根Activity创建当前文档处理的独立子Activity
    using var documentActivity = Activity.Current?.Source.StartActivity("ProcessSingleSaleDocument");
    var sale = JsonConvert.DeserializeObject<Sale>(document.ToString());

    // 标签打在当前文档自己的子Activity上，完全隔离
    documentActivity?.AddTag("SaleTransactionNumber", sale.Header.TransactionNumber);
    logger.LogInformation($"Sending Service Bus Message for Sales change for TransactionNumber {sale.Header.TransactionNumber}");

    // 原有消息构建逻辑
    // ...
    
    await _serviceBusClient.SendJsonMessageAsync(message, userProperties, messageId);
    logger.LogInformation($"Sent Service Bus Message: {messageId}  TransactionNumber: {sale.Header.TransactionNumber}");
    // using代码块结束时自动释放、结束子Activity，不会污染其他任务的上下文
}));

方案2：串行处理（临时规避，不推荐） #

如果暂时不需要拆分单文档链路，可以放弃并行处理，改用串行foreach循环逐个处理文档，确保同一时间只有一个任务操作根Activity的标签，但是会明显降低批量文档的处理吞吐量。

方案3：手动维护遥测属性（适合不需要细粒度链路的场景） #

如果不需要子Activity链路，不要依赖Activity.Current自动收集标签，可以在函数执行时拿到当前请求的RequestTelemetry实例手动维护属性，但注意单次函数触发只对应一个RequestTelemetry，批量处理多文档时不适合在RequestTelemetry上存单文档维度的属性，否则依然会出现覆盖问题。

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