Azure Durable Functions中如何实现无异常触发的重试机制？

首先明确：CallActivityWithRetryAsync的重试机制仅会在活动函数抛出异常时触发，无法通过返回特定值来触发重试。这是因为该API的设计逻辑就是将异常作为"需要重试"的信号。

如果你不想通过抛出异常来实现轮询，可以在编排器函数中手动实现轮询逻辑，替代内置的重试机制。具体做法是用循环结合CreateTimer控制轮询间隔，同时让活动函数返回状态而非抛出异常：

修改后的活动函数FetchResult #

public async Task<(bool IsReady, string Result)> FetchResult([ActivityTrigger] string input, ILogger log, CancellationToken cancellationToken)
{
    // 调用外部API检查状态并获取结果
    bool resultIsReady = ...;
    string result = ...;

    return (resultIsReady, result);
}

修改后的编排器函数轮询逻辑 #

public static async Task RunOrchestrator([OrchestrationTrigger] IDurableOrchestrationContext context)
{
    // 初始化请求部分保持不变
    var resume = await context.CallActivityAsync<bool>(nameof(Requester.InitiateRequest), input);
    if (!resume) return;

    var nowIn5Minutes = context.CurrentUtcDateTime.AddMinutes(5);
    await context.CreateTimer(nowIn5Minutes, CancellationToken.None);

    int maxRetries = 10;
    TimeSpan retryInterval = TimeSpan.FromMinutes(1);
    string finalResult = null;

    for (int i = 0; i < maxRetries; i++)
    {
        var status = await context.CallActivityAsync<(bool IsReady, string Result)>(nameof(Requester.FetchResult), input);
        
        if (status.IsReady)
        {
            finalResult = status.Result;
            break;
        }

        // 未就绪则等待指定间隔后重试
        var nextRetryTime = context.CurrentUtcDateTime.Add(retryInterval);
        await context.CreateTimer(nextRetryTime, CancellationToken.None);
    }

    if (finalResult == null)
    {
        // 处理超过最大重试次数的情况
        throw new ApplicationException("轮询超时，未获取到结果");
    }

    // 后续处理结果（原逻辑保留）
}

这种方式的优势：

• 活动函数无需抛出异常，逻辑更直观，避免用异常控制正常业务流程的反模式
• 轮询逻辑完全由编排器掌控，灵活性更高（比如可根据不同状态动态调整重试间隔）

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