如何在AWS中基于表内特定数值触发告警并推送至SNS Topic

以下是3种AWS原生生态下的可落地方案，你可以根据校验结果表的存储类型选择：

方案1：校验结果表存储在DynamoDB（推荐，链路最稳定） #

• 开启目标DynamoDB表的DynamoDB Streams功能，设置仅捕获新写入条目即可，不需要同步全量历史数据
• 创建Lambda函数关联该DynamoDB Streams作为触发器，给触发器添加过滤规则：{"dynamodb": {"NewImage": {"unexpected values": {"N": [{"numeric": [">", 0]}]}}}，只有符合条件的异常条目才会触发Lambda运行，减少不必要的算力消耗
• Lambda函数内只需要实现简单逻辑：提取异常条目的validation run、validation name、checked column、unexpected values字段拼装成告警内容，调用SNS的publish接口推送到指定SNS Topic即可
• 可选优化：如果需要避免短时间内重复推送相同类型的告警，可以在Lambda内增加1-5分钟的去重缓存，或者给SNS添加消息过滤策略按列名/校验规则分组推送

方案2：校验结果表存储在数仓（Athena/Redshift/S3） #

• 每次校验任务跑完之后，新增一个步骤：把本轮所有校验条目的unexpected values数值作为自定义指标推送到CloudWatch，给指标添加validation name、checked column、数据集名称等维度标签，方便后续筛选
• 在CloudWatch控制台创建告警，告警阈值设置为指标值 > 0，告警触发动作绑定你预先创建好的SNS Topic即可
• 该方案额外优势是可以直接在CloudWatch面板查看历史异常趋势，不需要额外做可视化开发

方案3：轻量场景（校验任务本身是Lambda/Glue Job实现） #

不需要额外配置流或指标，直接在校验逻辑的末尾增加判断：只要本轮校验生成的结果里存在任意一条unexpected values > 0的条目，就直接调用SNS接口推送告警，链路最短、延迟最低，适合校验频率不高的场景

通用注意事项 #

• 推送告警的同时建议把异常条目同步写入单独的归档存储（DynamoDB表或者S3目录），方便后续排查问题
• 单个SNS Topic可绑定多类订阅端（邮件、企业办公机器人、短信、电话），不需要单独做多端适配
• 若校验频率很高（每分钟多次），可以给CloudWatch告警或者Lambda添加告警抑制规则，避免相同异常反复推送造成打扰

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