Activity.current.addtag（）问题..... Singleton相关吗？

Question

我希望我能够很好地解释这个问题，以提示解决我的问题。

我有一个使用C＃编写的CosMoSDBTRIGGER的Azure函数（V4）。我们在其他功能类型中也看到了同样的问题。

为了在应用程序见解中添加自定义属性请求telemetry，我们使用了一个活动标记器。它是在函数启动中作为单身人士构建的。

在该功能中，我在我阅读的文档中添加了一个带有salestransactionnumber的标签，然后在代码I日志中进一步添加了交易编号已写入服务总线的代码。

问题在于，看来该活动标记器首次调用，它具有正确的交易号。之后，它可能是正确的，或者可能具有与上一个文档相同的交易号。记录的信息消息始终具有正确的交易号。

此问题是在下面显示的函数中使用的代码行。它将错误的交易号添加到定制限制中：

_activityTagger.AddTag("SaleTransactionNumber", sale.Header.TransactionNumber);

这是Activity Tagger的代码：

void AddTag(string key, string value)
{
    Activity.Current?.AddTag(key, value);
}

这是该函数的摘要（ChangeFeed）：

    public class ServiceBusNotifier
    {
        private readonly IActivityTagger _activityTagger;

        public ServiceBusNotifier(
            IActivityTagger activityTagger
            )
        {
            _activityTagger = activityTagger;
        }

        [FunctionName("ServiceBusNotifier")]
        public async Task RunAsync([CosmosDBTrigger(
            databaseName: "%CosmosDb:DatabaseId%",
            collectionName: "%masterCollectionName%",
            ConnectionStringSetting = "cosmosdb-connection",
            LeaseCollectionName = "%leasesCollectionName%",
            LeaseCollectionPrefix = "ServiceBusNotifier")] IReadOnlyList<Document> documents, ILogger logger)
        {
            try
            {
                if (documents != null && documents.Any())
                {
                    var callbackBasePath = _configuration.CallbackBaseUrl;

                    await Task.WhenAll(documents.Select(async document =>
                    {
                        var sale = JsonConvert.DeserializeObject<Sale>(document.ToString());

                        _activityTagger.AddTag("SaleTransactionNumber", sale.Header.TransactionNumber);
                        logger.LogInformation($"Sending Service Bus Message for Sales change for TransactionNumber {sale.Header.TransactionNumber}");

                        Message build logic...
                        
                        await _serviceBusClient.SendJsonMessageAsync(message, userProperties, messageId);
                        logger.LogInformation($"Sent Service Bus Message: {messageId}  TransactionNumber: {sale.Header.TransactionNumber}");
                    }));
                }
            }
            catch (Exception ex)
            {
                logger.LogError(ex, ex.Message);
                throw;
            }
        }
    }
}

我不确定它是否与ActivityTagger作为单身人士有关，或者也许必须这样做循环处理所有文档？任何帮助将不胜感激！