Azure Durable Functions中Activity Function运行数分钟后自动重启如何解决？

问题根因 #

1. Durable Functions底层依赖Azure存储队列实现Activity任务调度，队列消息的默认可见性超时为10分钟。当Activity运行时长超过该阈值时，还没被标记为处理完成的消息会重新变为可见状态，被Durable Task框架再次拉取执行，这就是你观察到断点二次触发的核心原因。
2. 你在host.json中配置的1小时超时是函数运行时层面的单次执行最大时长，不会影响Durable底层存储队列的消息可见性配置，因此无法解决该问题。
3. 短时间运行的任务可以正常执行，是因为执行速度快于队列可见性超时阈值，消息会被正常标记为已处理，不会触发重投逻辑。

解决方案 #

调整Durable Functions存储队列配置 #

在host.json的durableTask配置节中修改存储相关参数，将队列消息可见性超时调整为大于你的任务最大运行时长，比如最长任务需要运行1小时的话，可设置为2小时预留冗余：

{
  "version": "2.0",
  "functionTimeout": "01:00:00",
  "extensions": {
    "durableTask": {
      "storageProvider": {
        "messageVisibilityTimeout": "02:00:00",
        "extendedSessionsEnabled": true,
        "extendedSessionIdleTimeoutInSeconds": 7200
      }
    }
  }
}

其中messageVisibilityTimeout就是队列消息被拉取后的不可见时长，确保该值大于你业务逻辑的最长运行时间即可。

显式配置Activity重试策略（可选） #

如果你的业务逻辑不允许重复执行，可以在编排器调用Activity时显式指定不重试策略，避免异常场景下的不必要重复调用：

[FunctionName("StoreContent_RunOrchestrator")]
public async Task<StoreContentResult> RunOrchestrator(
    [OrchestrationTrigger] IDurableOrchestrationContext context)
{
    var input = context.GetInput<StoreContentInputArgs>();
    var callOptions = new CallActivityOptions
    {
        RetryOptions = RetryOptions.None
    };
    return await context.CallActivityAsync<StoreContentResult>("StoreContent_WriteFamilyData", input, callOptions);
}

额外注意事项 #

如果调整配置后仍然出现重复触发的情况，可以检查函数运行的高级计划是否配置了自动缩放，多实例场景下如果任务运行时长超过消息可见性阈值，也可能出现不同实例拉取同一条消息的情况，确保messageVisibilityTimeout足够覆盖最长运行时间即可解决。

内容的提问来源于stack exchange，提问作者System.Cats.Lol