.NET代理Lambda调用DynamoDB的Table.LoadTable方法超时求助

问题核心原因 #

1. 异步操作同步阻塞导致死锁：代码中使用.Result等待异步方法（GetItemAsync），在ASP.NET Core/Lambda的线程池环境下，这种同步阻塞会引发线程死锁，最终导致超时。
2. DynamoDB客户端管理不当：手动创建静态客户端可能无法正确读取Lambda环境的区域配置，且手动实例化不利于资源复用和依赖注入管理。

分步解决方案 #

1. 修复异步调用的死锁问题 #

将所有同步等待.Result的代码替换为await，并将方法改为异步签名：

修改QuoteController的GetRandomQuote方法为异步：

[HttpGet]
public async Task<ActionResult> GetRandomQuote()
{
    var quoteData = await _quoteRetriever.GetRandomQuoteAsync();
    return Ok(quoteData);
}

修改QuoteRetriever的方法为异步：

public async Task<QuoteData> GetRandomQuoteAsync()
{
    const string tableInfo = "TableInfo";
    Document tableInfoItem;
    Table table;

    _logger.LogInformation("Reached GetRandomQuote.");
    try
    {
        _logger.LogInformation("About to set table.");
        table = Table.LoadTable(_dynamoDbClient, "QuotesTable");
        _logger.LogInformation("Set table.");

        // 替换.Result为await
        tableInfoItem = await table.GetItemAsync(tableInfo);
        _logger.LogInformation("Retrieved tableInfoItem.");
    }
    catch (Exception e)
    {
        Console.WriteLine(e);
        _logger.LogInformation("Error Message: " + e.Message);
        _logger.LogInformation("Error Stacktrace: " + e.StackTrace);
        throw;
    }
    _logger.LogInformation("Successfully retrieved TableInfo!");

    var highestQuoteNr = tableInfoItem["HighestQuoteNumber"].AsInt();
    var missingQuoteNumbers = tableInfoItem["MissingQuoteNumbers"].AsListOfPrimitive();

    var random = new Random();
    var randomQuoteNumber = random.Next(0, highestQuoteNr);
    if (missingQuoteNumbers.Any())
    {
        while (missingQuoteNumbers.Contains(randomQuoteNumber))
        {
            randomQuoteNumber = random.Next(0, highestQuoteNr + 1);
        }
    }

    // 替换.Result为await
    var randomQuote = await table.GetItemAsync(randomQuoteNumber.ToString());

    var quoteData = new QuoteData
    {
        QuoteNumber = randomQuoteNumber,
        Quote = randomQuote["Quote"].AsString(),
        Quotee = randomQuote["Quotee"].AsString()
    };

    return quoteData;
}

2. 通过依赖注入管理DynamoDB客户端 #

避免手动创建静态客户端，利用AWS SDK的DI扩展自动配置客户端（自动读取Lambda环境的区域和凭证）：

在Program.cs中注册DynamoDB客户端和QuoteRetriever：

var builder = WebApplication.CreateBuilder(args);

// Add services to the container.
builder.Services.AddControllers();

// 注册DynamoDB客户端为单例（自动读取Lambda环境的区域和凭证）
builder.Services.AddAWSService<IAmazonDynamoDB>();

// 注册QuoteRetriever为Scoped服务，方便依赖注入
builder.Services.AddScoped<QuoteRetriever>();

// Add AWS Lambda support.
builder.Services.AddAWSLambdaHosting(LambdaEventSource.RestApi);

var app = builder.Build();

app.UseHttpsRedirection();
app.UseAuthorization();
app.MapControllers();

app.MapGet("/", () => "Welcome to running ASP.NET Core Minimal API on AWS Lambda");

app.Run();

修改QuoteRetriever的构造函数，注入IAmazonDynamoDB：

public class QuoteRetriever
{
    private readonly ILogger<QuoteController> _logger;
    private readonly IAmazonDynamoDB _dynamoDbClient;

    // 通过构造函数注入客户端
    public QuoteRetriever(ILogger<QuoteController> logger, IAmazonDynamoDB dynamoDbClient)
    {
        _logger = logger;
        _dynamoDbClient = dynamoDbClient;
    }

    // 异步方法GetRandomQuoteAsync...
}

修改QuoteController，注入QuoteRetriever：

[ApiController]
[Route("[controller]")]
public class QuoteController : ControllerBase
{
    private readonly ILogger<QuoteController> _logger;
    private readonly QuoteRetriever _quoteRetriever;

    public QuoteController(ILogger<QuoteController> logger, QuoteRetriever quoteRetriever)
    {
        _logger = logger;
        _quoteRetriever = quoteRetriever;
    }

    [HttpGet]
    public async Task<ActionResult> GetRandomQuote()
    {
        var quoteData = await _quoteRetriever.GetRandomQuoteAsync();
        return Ok(quoteData);
    }
}

3. 调整Lambda超时时间 #

当前Lambda超时设置为3秒，建议临时调整为10秒，验证修复后是否能正常执行，之后再根据实际耗时优化超时时间。

4. 验证IAM权限 #

确认Lambda的执行角色已通过CDK的quotesTable.grantFullAccess(handler)正确获取DynamoDB的读写权限，可以在IAM控制台查看角色的策略文档，确认包含QuotesTable的相关权限。

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