调用子编排器时Azure Orchestrator Function的问题求助

关于主编排器“重启”的说明 #

这是Durable Orchestrator的正常重放机制，并非异常。Durable编排器基于检查点和重放执行：

• 调用CallSubOrchestratorAsync时，主编排会暂停执行，将当前状态保存到存储中；
• 子编排完成后，主编排会从最近的检查点位置重新执行（重放），直到处理完子编排的返回结果。
  这种设计是为了保证编排的可靠性，即使进程崩溃也能从断点恢复。

await未等待子编排完成的解决方法 #

针对你的代码，优先排查以下几点：

1. 子编排器名称传递错误 #

你的代码中CallSubOrchestratorAsync<string>(GetID, data)存在问题：第一个参数需要传入子编排器的FunctionName字符串，而非方法引用。正确写法：

var id = await context.CallSubOrchestratorAsync<string>(nameof(GetID), data);
var name = await context.CallSubOrchestratorAsync<string>(nameof(GetName), id);

Durable框架通过FunctionName定位子编排器，直接传方法引用会导致无法找到对应子编排，进而引发流程异常。

2. 子编排器定义不符合规范 #

确保子编排器的代码结构正确，必须包含[OrchestrationTrigger]属性，示例如下：

[FunctionName(nameof(GetID))]
public static async Task<string> GetID(
    [OrchestrationTrigger] IDurableOrchestrationContext context,
    ILogger log)
{
    var input = context.GetInput<YourDataType>(); // 替换为实际输入类型
    // 子编排逻辑处理
    return await Task.FromResult("generated-id");
}

3. 避免编排器中的非确定性操作 #

编排器代码必须是确定性的，如果使用DateTime.Now、Guid.NewGuid()、直接调用外部API等非确定性操作，会导致重放时行为不一致，让流程看起来像是await未生效。外部操作必须通过CallActivityAsync调用Activity函数执行。

4. 检查子编排器是否抛出异常 #

如果子编排器执行中抛出未捕获的异常，主编排的await会直接捕获异常，导致流程中断。可通过try-catch块排查：

try
{
    var id = await context.CallSubOrchestratorAsync<string>(nameof(GetID), data);
}
catch (Exception ex)
{
    log.LogError(ex, "调用GetID子编排失败");
    // 异常处理逻辑
}

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