.NET Core中AWS DynamoDb集成Polly重试策略实现方法咨询

Polly完全可以和AWS DynamoDB集成，这是处理DynamoDB限流、网络波动等临时异常的常用方案。以下是具体的集成步骤、代码示例，以及给AWS新手的实用建议：

一、前置准备 #

首先安装所需的NuGet包：

• AWSSDK.DynamoDBv2：AWS DynamoDB的.NET SDK
• Polly：重试策略库
• （可选）AWSSDK.Extensions.NETCore.Setup：如果是.NET Core/.NET 5+项目，用于依赖注入配置DynamoDB客户端

二、定义Polly重试策略 #

针对DynamoDB常见的可恢复异常，创建指数退避的重试策略：

using Polly;
using Amazon.DynamoDBv2.Model;
using System.Net.Http;

// 定义重试策略：针对限流、网络异常进行指数退避重试
var retryPolicy = Policy
    .Handle<ProvisionedThroughputExceededException>() // 读写容量超出异常
    .Handle<ThrottlingException>() // AWS通用限流异常
    .Handle<HttpRequestException>() // 网络请求异常
    .WaitAndRetryAsync(
        retryCount: 3, // 最多重试3次
        sleepDurationProvider: retryAttempt => TimeSpan.FromSeconds(Math.Pow(2, retryAttempt)), // 指数退避：2^1, 2^2, 2^3秒
        onRetryAsync: (exception, timespan, retryCount, context) =>
        {
            // 重试时记录日志，方便排查
            Console.WriteLine($"[重试] 第 {retryCount} 次，等待 {timespan.TotalSeconds:F1} 秒，原因：{exception.Message}");
            return Task.CompletedTask;
        });

三、结合DynamoDB客户端执行请求 #

将DynamoDB的API调用包裹在Polly策略中执行，以PutItemAsync为例：

using Amazon.DynamoDBv2;
using Amazon.DynamoDBv2.Model;

// 初始化DynamoDB客户端（生产环境建议通过依赖注入配置）
var dynamoDbClient = new AmazonDynamoDBClient();

// 构造DynamoDB请求
var putItemRequest = new PutItemRequest
{
    TableName = "YourTargetTable",
    Item = new Dictionary<string, AttributeValue>
    {
        { "UserId", new AttributeValue { S = "user_12345" } },
        { "UserName", new AttributeValue { S = "John Doe" } }
    }
};

// 使用Polly策略执行DynamoDB操作
try
{
    var response = await retryPolicy.ExecuteAsync(async () =>
    {
        return await dynamoDbClient.PutItemAsync(putItemRequest);
    });

    // 处理成功响应
    if (response.HttpStatusCode == System.Net.HttpStatusCode.OK)
    {
        Console.WriteLine("数据写入成功");
    }
}
catch (Exception ex)
{
    // 所有重试失败后处理异常
    Console.WriteLine($"所有重试失败，最终异常：{ex.Message}");
    throw;
}

四、给AWS新手的实用建议 #

• 只重试可恢复异常：不要对ResourceNotFoundException（表不存在）、ValidationException（请求参数错误）这类永久错误重试，避免无效消耗。
• 优先指数退避：AWS官方推荐指数退避作为重试策略，Polly的WaitAndRetryAsync天然支持，能有效避免短时间内大量请求加重DynamoDB负载。
• 注意AWS SDK内置重试：AWS SDK本身自带默认重试机制，若使用Polly，建议调整两者的重试次数总和，避免过度重试（比如SDK默认重试3次，Polly就设置2次，总重试次数控制在5次以内）。
• 监控重试行为：通过Polly的onRetry回调记录日志，能帮你了解系统的限流频率，及时调整DynamoDB的读写容量或优化请求逻辑。
• 组合断路器模式：如果DynamoDB持续报错，可搭配Polly的断路器策略（CircuitBreaker），暂时停止请求，防止服务雪崩。

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