如何在Azure Functions的Activity函数中获取最顶层编排ID？

我有一个运行时版本为4.28.4.4、目标框架为.NET 6.0的Azure Functions应用。通过HTTP触发器启动一个包含多层子编排的流程，最终调用一个Activity函数。希望在该Activity函数中获取HTTP触发器启动的最顶层编排ID，且无需在所有函数中显式传递该ID，求可行方案。

场景代码示例：

[FunctionName("Test")]
public async Task<HttpResponseMessage> Run(
    [HttpTrigger(AuthorizationLevel.Function, "get", "post", Route = null)] HttpRequestMessage req,
    [DurableClient] IDurableOrchestrationClient starter,
    ILogger log)
{
    // 这个ID是后续需要获取的顶层编排ID
    var id = await starter.StartNewAsync(nameof(TestMainOrchestrator), "id-i-am-looking-for"); 
    return starter.CreateCheckStatusResponse(req, id);
}

[FunctionName(nameof(TestMainOrchestrator))]
public async Task TestMainOrchestrator([OrchestrationTrigger]IDurableOrchestrationContext context, ILogger log)
{
    await context.CallSubOrchestratorAsync(nameof(TestSubOrchestratorA), null);
}

[FunctionName(nameof(TestSubOrchestratorA))]
public async Task TestSubOrchestratorA([OrchestrationTrigger] IDurableOrchestrationContext context, ILogger log)
{
    await context.CallSubOrchestratorAsync(nameof(TestSubOrchestratorB), null);
}

[FunctionName(nameof(TestSubOrchestratorB))]
public async Task TestSubOrchestratorB([OrchestrationTrigger] IDurableOrchestrationContext context, ILogger log)
{
    await context.CallSubOrchestratorAsync(nameof(TestSubOrchestratorC), null);
}

[FunctionName(nameof(TestSubOrchestratorC))]
public async Task TestSubOrchestratorC([OrchestrationTrigger] IDurableOrchestrationContext context, ILogger log)
{
    await context.CallActivityAsync(nameof(TestActivity), null);
}

[FunctionName(nameof(TestActivity))]
public async Task TestActivity([ActivityTrigger]IDurableActivityContext context, ILogger log, CancellationToken token)
{
    log.LogWarning("当前Activity所属编排ID: '{0}'", context.InstanceId);
    // 此处需要获取最顶层的编排ID（即示例中的"id-i-am-looking-for"，也可能是自动生成的ID）
    // 但context.InstanceId仅返回TestSubOrchestratorC的ID，无法直接获取顶层ID
    await Task.Delay(100);
}

可行方案 #

方案1：递归查询父编排ID获取顶层ID #

利用Durable Functions的状态查询API，从当前Activity所属的子编排ID开始，递归向上查找父编排，直到找到没有父ID的顶层实例。该方案无需修改任何编排函数代码，仅需在Activity中实现查询逻辑。

代码实现：

[FunctionName(nameof(TestActivity))]
public async Task TestActivity(
    [ActivityTrigger]IDurableActivityContext context,
    [DurableClient] IDurableOrchestrationClient client,
    ILogger log, 
    CancellationToken token)
{
    var currentOrchestrationId = context.InstanceId;
    string topLevelId = currentOrchestrationId;

    while (true)
    {
        var status = await client.GetStatusAsync(topLevelId, token: token);
        if (string.IsNullOrEmpty(status.ParentInstanceId))
        {
            break;
        }
        topLevelId = status.ParentInstanceId;
    }

    log.LogWarning("顶层编排ID: '{0}'", topLevelId);
    await Task.Delay(100);
}

注意事项：

• 确保Activity函数拥有调用GetStatusAsync的权限（本地开发默认允许，生产环境需配置对应存储账户的读取权限）。
• 多层级编排场景下会产生多次状态查询请求，存在一定性能开销，适合层级较少的场景。

方案2：通过自定义属性传递顶层ID（性能更优） #

在顶层编排中设置包含自身ID的自定义状态属性，后续所有子编排继承该属性，Activity直接读取当前编排的自定义属性即可获取顶层ID。该方案避免了递归查询，性能更优。

步骤1：顶层编排设置自定义属性

[FunctionName(nameof(TestMainOrchestrator))]
public async Task TestMainOrchestrator([OrchestrationTrigger]IDurableOrchestrationContext context, ILogger log)
{
    // 将顶层ID存入自定义状态
    context.SetCustomStatus(new { TopLevelOrchestrationId = context.InstanceId });
    await context.CallSubOrchestratorAsync(nameof(TestSubOrchestratorA), null);
}

步骤2：子编排继承自定义属性
在每个子编排中读取父编排的自定义属性并设置到自身的自定义状态中：

[FunctionName(nameof(TestSubOrchestratorA))]
public async Task TestSubOrchestratorA([OrchestrationTrigger] IDurableOrchestrationContext context, ILogger log)
{
    var parentStatus = await context.GetStatusAsync(context.ParentInstanceId);
    var topLevelId = JsonConvert.DeserializeObject<dynamic>(parentStatus.CustomStatus.ToString()).TopLevelOrchestrationId;
    context.SetCustomStatus(new { TopLevelOrchestrationId = topLevelId });
    
    await context.CallSubOrchestratorAsync(nameof(TestSubOrchestratorB), null);
}

（TestSubOrchestratorB、TestSubOrchestratorC执行相同逻辑）

步骤3：Activity读取自定义属性

[FunctionName(nameof(TestActivity))]
public async Task TestActivity(
    [ActivityTrigger]IDurableActivityContext context,
    [DurableClient] IDurableOrchestrationClient client,
    ILogger log, 
    CancellationToken token)
{
    var currentOrchestrationId = context.InstanceId;
    var status = await client.GetStatusAsync(currentOrchestrationId, token: token);
    var topLevelId = JsonConvert.DeserializeObject<dynamic>(status.CustomStatus.ToString()).TopLevelOrchestrationId;

    log.LogWarning("顶层编排ID: '{0}'", topLevelId);
    await Task.Delay(100);
}

优势：仅需一次状态查询即可获取顶层ID，性能开销远低于方案1，适合多层级编排场景。

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