如何通过HTTP Post在单个Durable Function编排器中启动多并行实例？

要实现同一编排器下多次启动同一方法并获取所有子任务状态，你需要调整编排器逻辑、正确触发事件，并利用Durable的状态查询能力，具体步骤如下：

1. 修改编排器函数，支持多次启动子任务 #

原编排器可能仅处理一次外部事件就结束，你需要让它持续监听事件，直到启动足够数量的子任务。以下是C#示例（其他语言逻辑类似）：

[FunctionName("MyOrchestrator")]
public static async Task<List<string>> RunOrchestrator(
    [OrchestrationTrigger] IDurableOrchestrationContext context)
{
    var taskList = new List<Task<string>>();
    var taskStatus = new Dictionary<int, string>();
    // 设置最多启动3个子任务
    const int maxTasks = 3;

    for (int i = 0; i < maxTasks; i++)
    {
        // 等待名为"StartTimer"的外部事件，接收计时器时长（分钟）
        int timerMinutes = await context.WaitForExternalEvent<int>("StartTimer");
        
        // 启动子任务（你的InitiateDurableFunction活动函数）
        int taskId = i;
        var task = context.CallActivityAsync<string>("InitiateDurableFunction", timerMinutes)
            .ContinueWith(t => 
            {
                // 更新子任务状态，并同步到编排器自定义状态
                if (t.IsCompletedSuccessfully)
                    taskStatus[taskId] = $"已完成，时长：{timerMinutes}分钟";
                else if (t.IsFaulted)
                    taskStatus[taskId] = $"执行失败：{t.Exception.InnerException.Message}";
                else
                    taskStatus[taskId] = "已取消";
                
                context.SetCustomStatus(taskStatus);
                return t.Result;
            });
        
        taskList.Add(task);
    }

    // 等待所有子任务完成
    await Task.WhenAll(taskList);
    // 返回所有子任务的结果
    return taskList.Select(t => t.Result).ToList();
}

对应的活动函数（即你原有的InitiateDurableFunction）示例：

[FunctionName("InitiateDurableFunction")]
public static async Task<string> ExecuteTimerTask(
    [ActivityTrigger] int durationMinutes,
    ILogger log)
{
    log.LogInformation($"启动时长为{durationMinutes}分钟的计时器");
    await Task.Delay(TimeSpan.FromMinutes(durationMinutes));
    return $"计时器执行完成";
}

2. 正确触发同一编排实例的多次事件 #

你之前的问题是因为误用了不同的instanceId，导致创建新的编排实例。正确的操作是：

• 先通过客户端函数启动一个编排实例，记录返回的instanceId
• 三次调用raiseEvent接口时，使用同一个instanceId，请求示例：

  POST http://localhost:7228/runtime/webhooks/durabletask/instances/{你的instanceId}/raiseEvent/StartTimer?code={你的code}
  Content-Type: application/json
  
  60  # 第一次发送60，第二次可以发45，第三次发30，实现交错启动
  

3. 获取同一编排下的所有子任务状态 #

你可以通过以下两种方式获取状态集合：

方式1：HTTP API查询 #

调用编排实例状态查询接口，使用同一个instanceId：

GET http://localhost:7228/runtime/webhooks/durabletask/instances/{你的instanceId}?code={你的code}

返回的JSON响应中：

• output字段会包含所有子任务的执行结果列表
• customStatus字段会实时展示每个子任务的状态（如已启动、已完成、失败）
• history字段可以查看每个子任务的详细执行日志和时间线

方式2：在代码中获取 #

如果你需要在函数内部获取状态，可以使用IDurableOrchestrationClient的GetStatusAsync方法：

var instanceStatus = await starter.GetStatusAsync(instanceId);
// 从instanceStatus.CustomStatus或instanceStatus.Output提取子任务状态

关键注意事项 #

• 确保所有raiseEvent请求指向同一个编排实例ID，不要每次生成新的instanceId
• 编排器需要保持运行状态直到所有子任务完成，因此循环监听事件的逻辑要覆盖你需要的任务数量
• 如果需要动态添加任务（而非固定3个），可以修改编排器逻辑，监听终止事件来结束循环

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