.NET 8分布式系统跨进程传递App Insights追踪上下文问题

核心思路：基于.NET Activity提取和传递追踪信息 #

你不需要从ILogger的Scope中提取追踪数据——.NET的Activity类才是承载TraceId、SpanId等追踪上下文的核心载体，Application Insights的日志Scope只是将Activity的信息同步展示出来而已。下面是具体实现步骤：

1. 定义包含追踪上下文的任务消息DTO #

首先创建一个用于Redis传输的消息类，把任务数据和追踪信息打包在一起：

public class RedisTaskMessage
{
    // 你的业务任务数据
    public string TaskPayload { get; set; }
    // 追踪核心字段
    public string TraceId { get; set; }
    public string ParentSpanId { get; set; }
    // 可选：传递自定义 baggage 数据
    public Dictionary<string, string> Baggage { get; set; } = new();
}

2. Manager端：提取追踪上下文并发送到Redis #

在Manager创建任务并发送到Redis时，直接从Activity.Current获取当前追踪上下文：

// 假设你已经注入了IDatabase（Redis连接）
private readonly IDatabase _redisDb;

public async Task EnqueueTaskAsync(string taskData)
{
    var currentActivity = Activity.Current;
    if (currentActivity == null)
    {
        // 如果当前无Activity，手动创建一个根追踪（比如后台定时任务触发的场景）
        using var rootActivity = new Activity("ManagerTaskInitiation").Start();
        currentActivity = rootActivity;
    }

    // 构建带追踪信息的消息
    var taskMessage = new RedisTaskMessage
    {
        TaskPayload = taskData,
        TraceId = currentActivity.TraceId.ToString(),
        ParentSpanId = currentActivity.SpanId.ToString(),
        Baggage = currentActivity.Baggage.ToDictionary(kv => kv.Key, kv => kv.Value)
    };

    // 序列化后发送到Redis List
    var json = JsonSerializer.Serialize(taskMessage);
    await _redisDb.ListLeftPushAsync("worker-task-queue", json);
}

3. Worker端：接收消息并恢复追踪上下文 #

Worker从Redis取出消息后，基于收到的追踪信息创建新的Activity，延续整个追踪链：

private readonly IDatabase _redisDb;
private readonly ITargetBlock<string> _taskProcessingBlock; // TPL Dataflow块

public async Task DequeueAndProcessTasksAsync(CancellationToken cancellationToken)
{
    while (!cancellationToken.IsCancellationRequested)
    {
        var json = await _redisDb.ListRightPopAsync("worker-task-queue", TimeSpan.FromSeconds(5));
        if (string.IsNullOrEmpty(json)) continue;

        var taskMessage = JsonSerializer.Deserialize<RedisTaskMessage>(json);
        
        // 恢复追踪上下文：创建子Activity关联到Manager的Span
        using var workerActivity = new Activity("WorkerTaskProcessing")
            .SetParentId(taskMessage.TraceId, taskMessage.ParentSpanId)
            .Start();

        // 将自定义baggage附加到当前Activity
        foreach (var (key, value) in taskMessage.Baggage)
        {
            workerActivity.AddBaggage(key, value);
        }

        // 发送到TPL Dataflow处理——上下文会自动传播到数据块中
        await _taskProcessingBlock.SendAsync(taskMessage.TaskPayload, cancellationToken);
    }
}

4. TPL Dataflow中确保上下文延续 #

TPL Dataflow默认会自动捕获并传播ExecutionContext（包含当前Activity），所以在数据块中处理任务时，日志会自动关联到正确的追踪链：

// 初始化TPL Dataflow处理块
private ITargetBlock<string> CreateTaskProcessingBlock()
{
    return new ActionBlock<string>(async taskData =>
    {
        // 这里的ILogger日志会自动带上当前Activity的TraceId/SpanId
        _logger.LogInformation("Processing task: {TaskData}", taskData);
        
        // 你的任务处理逻辑...
        await ProcessTaskAsync(taskData);
    }, new ExecutionDataflowBlockOptions
    {
        MaxDegreeOfParallelism = Environment.ProcessorCount
    });
}

关键注意事项 #

• 确保Manager端在发送任务时存在Activity.Current：如果是HTTP触发的Manager，ASP.NET Core会自动创建Activity；如果是后台定时任务，需要手动创建根Activity。
• 使用using包裹Activity：确保Activity在任务处理完成后正确结束，Application Insights会收到完整的Span数据。
• 无需从ILogger提取Scope：Activity.Current是追踪上下文的权威来源，在任何深层逻辑中直接调用即可获取TraceId、SpanId等信息。

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