隔离模式下IDurableActivityContext的替代及InstanceId传递方式确认

你提出的元组参数传递方案是完全正确的，这是隔离模式下将编排InstanceId传递到活动函数的标准可行方案之一。

在隔离模式中，IDurableActivityContext已被移除，活动函数无法再通过上下文对象直接获取编排的InstanceId，因此必须从编排函数主动传递该值。

你的元组实现的合理性 #

你的代码逻辑完全符合隔离模式的设计要求：

1. 编排函数从TaskOrchestrationContext获取InstanceId
2. 将文件名和InstanceId打包为元组作为活动函数的输入参数
3. 活动函数通过[ActivityTrigger]直接接收元组参数并使用

其他可选实现方案 #

如果后续需要扩展更多参数，使用自定义DTO类会比元组更易维护，示例如下：

编排函数代码

public async Task<Result> ProcessFileAsync(
    [OrchestrationTrigger] TaskOrchestrationContext context)
{
    var fileName = context.GetInput<string>();
    var instanceId = context.InstanceId;

    try
    {   
        var input = new FileProcessingInput
        {
            FileName = fileName,
            OrchestrationInstanceId = instanceId
        };
        var readFileOperation = await context.CallActivityAsync<Result<List<SmsRecipientFileModel>>>(nameof(ReadRecordsFromFileActivityFunction), input);
        // 后续业务逻辑...
    }
}

// 自定义输入DTO类
public class FileProcessingInput
{
    public string FileName { get; set; }
    public string OrchestrationInstanceId { get; set; }
}

活动函数代码

[Function(nameof(ReadRecordsFromFileActivityFunction))]
public async Task<Result<List<SmsRecipientFileModel>>> ReadFileAsync([ActivityTrigger] FileProcessingInput input)
{
    var fileName = input.FileName;
    var instanceId = input.OrchestrationInstanceId;
    
    var operation = await _blobReaderService.GetRecordsAsync(fileName);
    if (!operation.Status)
    {
        return Result<List<SmsRecipientFileModel>>.Failure(operation.ErrorMessage);
    }

    var records = operation.Data;
    if (records == null || !records.Any())
    {
        _logger.Warning("There are no records.");
        return Result<List<SmsRecipientFileModel>>.Failure("There are no records.");
    }

    records.ForEach(x => x.MainOrchestrationId = instanceId);
    return Result<List<SmsRecipientFileModel>>.Success(records);
}

总结 #

• 元组方案简洁高效，适合参数数量少、结构简单的场景
• 自定义DTO方案扩展性更强，适合参数较多或未来可能新增参数的场景
  两种方案均符合Durable Functions隔离模式的规范，可根据实际需求选择。

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