SuperAPI AI 工具集

aws-messaging-and-streaming

部署与运维

查看项目

更新于 10-15 23:46

技能介绍

用途:为在 AWS 上移动数据的工作负载提供领域知识,帮助判断该用消息模式还是流式模式,并选择合适的服务与集成方式。

主要能力:区分消息(消费后删除、无重放、竞争消费者)与流式(保留可重放、分区内严格有序、多消费者按位点读取)两种模式,并给出数据生命周期、顺序、吞吐、延迟、扩展单位等维度对比;覆盖消息类服务 SQS、SNS、EventBridge、Amazon MQ 与流式类服务 Kinesis Data Streams、Data Firehose、Managed Service for Apache Flink、MSK 的适用场景与差异点。

使用方式:回答具体数字、版本、限制与行为细节时,应查阅服务专属技能或官方文档,不确定时不要猜测;涉及推荐配置(如 CloudWatch 告警阈值、缺失数据处理)时同样查文档而非套用通用最佳实践。

常见集成陷阱:SQS 系统属性与用户消息属性需分别用 AttributeNames 与 MessageAttributeNames 显式请求;SNS→Firehose→S3 默认已是 NDJSON,不要开启 AppendDelimiterToRecord;EventBridge 规则目标 DLQ 与 SNS 订阅 DLQ 都需为 DLQ 队列配置允许对应服务主体的队列策略;生产队列建议开启长轮询(ReceiveMessageWaitTimeSeconds=20)并使用客户托管密钥加密;Amazon MQ、MSK 的凭据应存入 Secrets Manager(MSK SASL/SCRAM 密钥需以 AmazonMSK_ 前缀命名并用客户托管 KMS 密钥加密);服务主体资源策略需加 aws:SourceArn / aws:SourceAccount 条件以防混淆代理。

限制:资料未提供具体价格、配额数值与完整配置示例,需以官方文档为准。