Azure Durable Functions编排器：如何避免活动间代码重复执行

核心思路：利用编排器的「确定性」和「状态持久化」特性 #

Durable Orchestrator的重放是为了保证状态一致性，所有非确定性操作（日志、计时等）必须放在仅执行一次的分支里，或者通过持久化状态避免重复计算。

1. 进度日志：基于已完成活动数的条件输出 #

编排器会自动持久化CallActivityAsync的返回结果，可通过统计已完成任务数判断是否输出进度，配合重放安全日志避免重复打印。

示例代码：

var totalActivities = 10000;
var completedCount = 0;

for (int i = 0; i < totalActivities; i++)
{
    await context.CallActivityAsync("YourActivityFunction", i);
    completedCount++;
    
    // 按间隔或最后一项输出进度，避免频繁日志
    if (completedCount % 100 == 0 || completedCount == totalActivities)
    {
        // 重放安全日志，仅首次执行时记录
        var logger = context.CreateReplaySafeLogger(log);
        logger.LogInformation($"Activity {completedCount} of {totalActivities} completed");
    }
}

2. 前几项性能计时：用持久化状态存储计时结果 #

直接在循环内计时会因重放重复计算，需用IDurableOrchestrationContext的状态存储功能保存已完成的计时数据。

示例代码：

var totalActivities = 10000;
var maxTimingCount = 10; // 仅统计前10项
var timingResults = context.GetState<List<long>>("activityTimings") ?? new List<long>();

for (int i = 0; i < totalActivities; i++)
{
    if (i < maxTimingCount && timingResults.Count <= i)
    {
        var stopwatch = Stopwatch.StartNew();
        await context.CallActivityAsync("YourActivityFunction", i);
        stopwatch.Stop();
        
        timingResults.Add(stopwatch.ElapsedMilliseconds);
        // 持久化计时结果，重放时直接读取
        await context.SetStateAsync("activityTimings", timingResults);
        
        var logger = context.CreateReplaySafeLogger(log);
        logger.LogInformation($"Activity {i+1} took {stopwatch.ElapsedMilliseconds}ms");
    }
    else
    {
        // 非计时项直接调用，重放时复用已有执行结果
        await context.CallActivityAsync("YourActivityFunction", i);
    }
}

// 仅在非重放状态且计时完成时计算平均值
if (timingResults.Count == maxTimingCount && !context.IsReplaying)
{
    var averageMs = timingResults.Average();
    var logger = context.CreateReplaySafeLogger(log);
    logger.LogInformation($"Average time for first {maxTimingCount} activities: {averageMs:F2}ms");
}

3. 通用控制代码处理原则 #

• 非确定性操作：日志、计时、随机数等必须放在!context.IsReplaying分支，或使用CreateReplaySafeLogger这类重放安全API
• 状态依赖逻辑：通过GetState/SetState持久化中间状态，重放时直接复用，避免重复计算
• 一次性逻辑：初始化、收尾等逻辑需判断IsReplaying，确保仅执行一次

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