AWS Redshift行插入通知实现：自定义错误日志表新增行触发SNS通知方法

以下方案均需要提前配置对应服务的IAM访问权限，比如Redshift调用Lambda的权限、Lambda调用SNS的权限等 #

方案1：存储过程内直接触发（改造成本最低） #

因为错误日志本身就是存储过程出错时主动写入的，直接修改存储过程的错误捕获逻辑即可：

• 预先创建一个支持调用Lambda的Redshift UDF，Lambda内部实现SNS通知发送逻辑
• 在存储过程的EXCEPTION错误捕获块中，完成错误日志写入操作后，直接调用上述UDF，传入错误类型、错误内容等参数即可触发通知

优势：无额外监听/轮询成本，通知延迟最低，适合所有可修改现有存储过程的场景

方案2：基于审计日志的无侵入事件驱动方案 #

如果无法修改现有存储过程，可采用全托管的事件流方案：

• 开启Redshift的用户活动审计日志功能，将所有INSERT操作日志投递到CloudWatch Logs
• 在CloudWatch Logs中创建日志过滤器，匹配针对自定义错误日志表的INSERT操作记录
• 配置过滤器触发EventBridge规则，绑定触发Lambda函数
• Lambda函数解析日志中新增的错误记录内容，调用SNS主题发送通知

优势：完全不需要修改现有业务代码，适合存储过程不可修改的生产场景

方案3：轻量定时轮询方案（适合低错误频率场景） #

如果对通知延迟要求不高，可采用实现最简单的轮询方案：

• 配置EventBridge定时规则，按你需要的频率（比如1分钟/5分钟一次）触发Lambda函数
• Lambda连接Redshift，查询上次轮询时间节点之后新增的错误日志记录
• 如果查询到新记录，调用SNS发送通知，同时记录当前时间作为下次轮询的起始时间

优势：实现逻辑最简单，运行成本极低，适合错误发生频率不高、允许分钟级延迟的场景

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