AWS SDK Rust 升级至 1.23.0 版本后出现的 SQS 超时问题分析

近期 AWS SDK Rust 项目在升级到 1.23.0 版本后，用户报告了大量 SQS 服务调用超时的问题。本文将深入分析该问题的成因、影响范围以及解决方案。

问题现象

当用户将 aws-sdk-sqs 升级到 1.23.0 版本后，绝大多数 SQS 调用都会出现超时错误。错误日志显示如下信息：

DispatchFailure(DispatchFailure { source: ConnectorError { kind: Timeout, source: ThroughputBelowMinimum { expected: Throughput { bytes_read: 1, per_time_elapsed: 1s }, actual: Throughput { bytes_read: 0, per_time_elapsed: 1s } }, connection: Unknown } })

问题根源

该问题源于 AWS SDK Rust 在 2024_03_28 行为版本中引入的"停滞流保护"机制。该机制默认会对上传和下载操作设置最低吞吐量要求（默认为1字节/秒）。当实际吞吐量低于此阈值时，系统会主动终止连接以防止资源浪费。

对于 SQS 这类消息服务，由于其消息体通常较小且处理速度快，很容易触发这个保护机制，导致系统误判为连接停滞而主动终止。

影响范围

该问题主要影响：

1. 使用 aws-sdk-sqs 1.23.0 及以上版本的项目
2. 使用默认 BehaviorVersion::v2024_03_28() 配置的项目
3. 处理小消息体或高频短请求的场景

解决方案

AWS SDK Rust 团队提供了多种解决方案：

1. 临时解决方案

方案A：仅禁用上传保护

let config = aws_config::defaults(aws_config::BehaviorVersion::latest())
    .stalled_stream_protection(
        StalledStreamProtectionConfig::enabled()
            .upload_enabled(false)
            .build(),
    )
    .load()
    .await;

方案B：完全禁用停滞流保护

let config = aws_config::defaults(aws_config::BehaviorVersion::latest())
    .stalled_stream_protection(StalledStreamProtectionConfig::disabled())
    .load()
    .await;

方案C：回退到旧版本行为

BehaviorVersion::v2023_11_09()

2. 官方修复

AWS SDK Rust 团队在后续版本中修复了此问题：

1. 首先在 2024-05-21 发布运行时库更新
2. 随后在 SDK 发布中包含了完整修复

用户只需升级到最新版本即可解决该问题。

经验教训

1. 新特性风险评估：引入类似"停滞流保护"这样的底层网络特性时，需要充分考虑各种服务的使用场景差异。

2. 版本兼容性测试：在升级 SDK 版本时，特别是涉及行为版本变更时，应进行充分的兼容性测试。

3. 渐进式部署：生产环境中建议采用渐进式部署策略，先在小范围验证新版本稳定性。

总结

AWS SDK Rust 在 1.23.0 版本引入的停滞流保护机制虽然本意是优化资源使用，但由于未充分考虑 SQS 等服务的特殊使用场景，导致了广泛的超时问题。开发团队通过快速响应和发布修复版本展现了良好的维护能力。作为用户，在遇到类似问题时，既可以使用临时解决方案快速恢复服务，也应关注官方修复并及时升级。