技能介绍

解决的工程问题

在AWS数据管道中，手动管理S3与SQS的交互常面临三个具体问题：一是S3对象生命周期（上传、读取、删除）需分散调用不同API，缺乏统一管理；二是SQS消息队列的处理逻辑（接收、确认、重试）需自行封装长轮询逻辑，易出现消息遗漏或重复消费；三是S3事件通知到SQS的事件驱动链路需要配置IAM权限、触发器等，流程繁琐且易出错。

技能如何工作

该技能通过封装@aws-sdk/client-s3与@aws-sdk/client-sqs的核心命令，提供三层核心能力：

S3对象生命周期管理：基于PutObjectCommand实现对象上传，GetObjectCommand完成读取，结合生命周期规则（如过期删除）自动化管理存储资源；
SQS消息处理：使用ReceiveMessageCommand开启长轮询（支持配置WaitTimeSeconds），实现消息的可靠接收，并自动处理消息确认与重试逻辑，避免消息丢失；
事件驱动管道配置：通过S3事件通知功能，将对象创建、删除等事件触发到SQS队列，实现「存储操作→消息队列→下游处理」的自动化链路。

关键步骤对应三个能力：初始化S3/SQS客户端→调用对应命令管理对象或处理消息→配置事件触发规则完成联动。

适用边界与注意点

需预先配置AWS凭证（如AWS_ACCESS_KEY_ID、AWS_SECRET_ACCESS_KEY），且S3存储桶、SQS队列需存在并正确配置权限；
仅适用于基于Node.js的环境（依赖@aws-sdk系列包），不支持其他语言运行时；
SQS消息处理需注意幂等性，技能虽封装了重试逻辑，但需在业务侧实现消息去重；
长轮询参数（如WaitTimeSeconds）需根据业务场景调整，避免过度占用资源。