Azure Durable Entity单例是否可行？重启后调用挂起问题求助

问题背景 #

我在使用Azure Durable编排函数搭配Durable Entity，该实体用于向编排函数返回工作流所需的数据，封装了基于数据状态定位合适数据的逻辑，因此采用单例模式（使用固定Entity Key）。正常运行无问题，但编排函数重启后，调用该实体的GetData方法时，编排会无限进入等待状态。

代码片段 #

public static async Task RunOrchestrator(
    [OrchestrationTrigger] IDurableOrchestrationContext context, ILogger logger)
{
    try
    {
        var sourceEntity = new EntityId(nameof(UploadDispenser), "UploadDispenserInstance");
        var dispenser = context.CreateEntityProxy<IUploadDispenser>(sourceEntity);
        var data = await dispenser.GetData();
        // 处理数据逻辑
        // 函数重启后，此处会无限等待
        var next = context.CurrentUtcDateTime.AddMinutes(1);
        await context.CreateTimer(next, CancellationToken.None);
        context.ContinueAsNew(null);
    }
    catch (Exception ex)
    {
        logger.LogError($"Error in RunOrchestrator: {ex}");
        throw;
    }
}

核心疑问 #

• 跨编排运行能否使用固定Entity Key？
• 为何实体调用会挂起？

目前仅能通过重置持久化状态解决，但这并非良策。已尝试终止重启实例、清除历史、暂停恢复编排函数，均无效。

解答 #

1. 跨编排运行可以使用固定Entity Key #

Durable Entity原生支持单例模式，固定Entity Key是完全合法的用法，这类场景正是单例实体的典型适用场景（比如共享状态、全局数据提供器），所以该用法本身没有问题。

2. 调用挂起的原因分析 #

无限等待的核心原因是编排重启后，实体请求的消息出现死锁或未被正确处理，常见触发场景：

• 旧编排实例的未完成请求阻塞新实例：当编排通过ContinueAsNew重启后，旧实例进入完成状态，但如果之前的实体调用请求未处理完成，或者消息队列中存在针对该实体的旧请求，新实例的请求可能被阻塞。
• 实体方法异常未处理：如果UploadDispenser的GetData方法出现未捕获异常，会导致消息进入死信队列，或实体处于故障状态，后续调用会一直等待响应。
• 持久化存储状态不一致：Durable Task Framework的持久化存储（如Azure Storage）中，编排与实体的状态记录出现不一致，导致新编排实例无法正确跟踪实体请求状态，持续等待。

3. 可行解决方案 #

• 给实体调用添加超时：使用CallEntityAsync的重载版本设置超时，避免无限等待：

  var data = await context.CallEntityAsync<DataModel>(sourceEntity, "GetData", null, TimeSpan.FromSeconds(30));
  

• 完善实体的异常处理：在实体方法中添加完整的异常捕获逻辑，确保即使出错也能返回响应，避免实体挂起：

  [FunctionName(nameof(UploadDispenser))]
  public static void Run([EntityTrigger] IDurableEntityContext context)
  {
      try
      {
          switch (context.OperationName)
          {
              case "GetData":
                  var data = // 数据获取逻辑
                  context.Return(data);
                  break;
              // 其他操作分支
          }
      }
      catch (Exception ex)
      {
          // 记录日志并返回错误响应
          context.Return(new { Error = ex.Message });
      }
  }
  

• 清理实体未处理消息：通过Azure Portal或Azure CLI查看Durable Entity的消息队列，清理死信队列中的滞留消息。
• 优化ContinueAsNew时机：调用ContinueAsNew前，确保所有实体调用已完成，避免在未完成请求的状态下重启编排。

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