C# Async函数调用未正常执行 S3批量文件复制仅处理单文件问题

• Lambda运行时生命周期机制：入口方法FunctionHandler执行完成后，会立刻回收执行资源，不会等待入口方法触发的、未被await的异步操作。你当前实现中RenameFilesAsync使用async void签名，触发后不会被任何上层逻辑跟踪等待，方法内部一旦执行到第一个await s3client.CopyObjectAsync(...)，执行权会立刻返回给外层的同步调用链。
  外层的CreateAndExecuteSpawn方法没有任何等待逻辑，会快速完成所有批次的方法触发，进而走完整个FunctionHandler的执行流程，Lambda直接判定任务完成、销毁运行上下文。此时所有挂起的S3复制请求被中断，没有机会回到RenameFilesAsync的foreach循环处理后续文件，表现为每个批次仅处理1个文件。
• 委托类型选择错误：使用List<Action>存储异步方法，Action是同步无返回值的委托，无法捕获异步方法返回的Task对象，自然没有办法统一等待所有批次的执行完成。

• 将所有业务异步方法的返回值从async void调整为async Task，这是.NET异步编程的规范，仅事件处理器场景才允许使用async void。
• 调整委托存储类型，从List<Action>改为List<Func<Task>>，确保每个异步方法触发后可以返回对应的Task对象。
• 改造整条调用链的异步逻辑：CreateAndExecuteSpawn收集所有批次对应的Task对象，使用Task.WhenAll()等待所有任务全部执行完成后再返回；入口方法FunctionHandler同样改为异步签名，awaitCreateAndExecuteSpawn的执行结果，确保Lambda运行时可以正确跟踪所有异步操作的完成状态，不会提前回收资源。
• （可选优化）循环内每次创建独立的CopyObjectRequest实例，避免后续调整并发逻辑时出现请求状态污染的问题。

public async Task CreateAndExecuteSpawn(string srcBucket, List<List<string>> pdfFileList, IAmazonS3 s3client)
{
    int i = 0;
    // 用Func<Task>存储异步委托，可获取返回的Task对象
    List<Func<Task>> taskFactoryList = new List<Func<Task>>();
    LambdaLogger.Log("PDF Set count: " + pdfFileList.Count.ToString());
    foreach (var list in pdfFileList)
    {
        taskFactoryList.Add(() => RenameFilesAsync(srcBucket, list, s3client));
    }

    // 触发所有任务，并收集返回的Task
    List<Task> runningTasks = new List<Task>();
    foreach (var taskFactory in taskFactoryList)
    {
        runningTasks.Add(taskFactory.Invoke());
        LambdaLogger.Log("Method invoked: "+ i++.ToString());
    }

    // 等待所有批次的任务全部执行完成
    await Task.WhenAll(runningTasks);
}
            
// 从async void改为async Task
public async Task RenameFilesAsync(string srcBucket, List<string> pdfFiles, IAmazonS3 s3client)
{
    LambdaLogger.Log("In RenameFileAsync method");
    CopyObjectRequest copyRequest = null;
    try
    {
        foreach (var file in pdfFiles)
        {
            if (!file.Contains("index.xml"))
            {
                string[] newFilename = file.Split('{');
                string[] destKey = file.Split('/');
                // 每次循环创建独立的请求对象，避免状态污染
                copyRequest = new CopyObjectRequest
                {
                    SourceBucket = srcBucket,
                    DestinationBucket = srcBucket,
                    SourceKey = file,
                    DestinationKey = destKey[0] + "/" + destKey[1] + "/Renamed/" + newFilename[1]
                };
                LambdaLogger.Log("About to rename File: " + file);
                CopyObjectResponse response = await s3client.CopyObjectAsync(copyRequest);
                LambdaLogger.Log("Rename done: ");
            }
        }
    }
    catch(Exception ex)
    {
        LambdaLogger.Log(ex.Message);
        if(copyRequest != null)
        {
            LambdaLogger.Log(copyRequest.DestinationKey);
        }
    }
}
        
// 入口方法改为async Task，适配异步等待逻辑
public async Task FunctionHandler(S3Event evnt, ILambdaContext context)
{
    // 原有业务逻辑
    await CreateAndExecuteSpawn(bucket, pdfFileSet, s3client);
}

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