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

Question

在分布式数据库中，有一个名为publishTime的列，我正在寻找一种“扫描器”，它可以定期(例如，每5分钟)扫描表，如果publishTime早于当前时间，则将该行发送到SNS。我正在考虑开发一个使用Kinesis流检测器的轮询服务，但不确定是否有任何定期扫描的解决方案，Kinesis Firehose是否适用于此用例？谢谢

Answer 1

如果你想留在亚马逊网络服务中，我的建议是使用Cloudwatch Events每5分钟触发一次 lambda 函数-该函数将查询DDB并将条目发送到SNS。

Kinesis在这里似乎不是合适的工具。