使用 DDB、Kinesis 和 SNS 的高级解决方案



说在DDB中,有一个名为publishTime的列,我正在寻找一个"扫描仪",它可以定期(例如,每5分钟(扫描表,如果publishTime在当前时间之前,则将该行发送到SNS。我正在考虑为此开发带有 Kinesis 流检测器的轮询服务,但不确定是否有任何定期扫描的解决方案,Kinesis Firehose 是否可用于此用例?谢谢

如果您想留在 AWS 中,我的建议是使用 Cloudwatch Events 每 5 分钟触发一次 lambda 函数 - lambda 函数将查询 DDB 并将条目发送到 SNS。

Kinesis在这里似乎不是正确的工具。

最新更新