Durable Function中Activity偶发非确定性工作流错误排查求助

Durable Function 非确定性错误的核心触发逻辑是：编排器重放时的执行路径、调用的任务序列/参数，和首次执行时存储的历史事件不一致。结合你给出的代码，偶发错误的高概率原因如下：

• ContinueAsNew 逻辑缺陷：你在触发context.ContinueAsNew(setting)后没有终止当前编排器的执行流，调用ContinueAsNew仅告知Durable运行时下一次重放从新实例启动，当前线程仍会继续执行后续的foreach迭代逻辑，生成额外的Activity调用请求，和历史存储的事件序列不一致，直接触发校验失败。该错误仅在达到MAX_ACTIVITIES阈值时触发，因此表现为偶发。
• 编排器非确定性数据源：代码中folders集合的获取逻辑被省略，如果该集合是在编排器内直接通过查询数据库、调用外部接口、获取系统时间、使用随机数等非确定性方式获取，重放时集合的元素数量、顺序、属性值发生变化，会导致调用Activity的序列和历史记录不匹配，偶发报错。
• 值元组序列化不稳定：你给Activity_updatelogTransferDetailsStatus传递的输入是C#值元组，Durable Task默认序列化器对值元组的序列化存在偶发的不稳定问题，重放时校验输入参数和历史记录不一致时会触发错误。
• 计数器状态异常：如果activityCounter是静态变量或者未在编排器开头正确初始化，重放时计数结果会和首次执行不一致，导致提前/延迟触发ContinueAsNew逻辑，引发执行路径不匹配。

• 首先修复ContinueAsNew逻辑：在context.ContinueAsNew(setting);后立刻添加return;语句终止当前执行流，上线后观察错误是否复现，这是最高概率的修复点。
• 校验编排器内所有数据源：确认folders集合是否通过Activity/子编排器获取，编排器内禁止直接执行任何IO操作、非确定性API调用，所有外部数据必须通过Durable上下文提供的方法调用任务获取。
• 替换Activity输入参数类型：将值元组替换为显式定义的POCO类作为入参，避免值元组序列化不稳定的问题。
• 导出实例历史事件：通过Durable Function的监控面板导出报错实例的完整事件历史，对比首次执行和重放时的TaskScheduledEvent序列，确认是否存在多余的Activity调用，定位差异对应的代码位置。
• 开启重放日志：在host.json中开启Durable Task的重放日志，对比重放过程中执行的任务序列和历史记录的差异，快速定位非确定性代码位置。

你当前的数据库更新代码使用字符串拼接SQL语句，存在SQL注入风险，建议改为参数化查询，示例如下：

public static async Task updatelogTransferDetailsStatus(string Tablename, int DetailStatus, long TransferDetailId)
{
    string query = @"UPDATE dbo.bkp_logTransferDetails
                     SET DetailStatus = @DetailStatus
                     WHERE TransferDetailId = @TransferDetailId";
    using (SqlConnection connection = new SqlConnection(CONNECTIONSTRING))
    {
        await connection.OpenAsync();
        using (SqlCommand command = new SqlCommand(query, connection))
        {
            command.CommandType = CommandType.Text;
            command.Parameters.AddWithValue("@DetailStatus", DetailStatus);
            command.Parameters.AddWithValue("@TransferDetailId", TransferDetailId);
            await command.ExecuteNonQueryAsync();
        }
    }
}

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