计划读取DynamoDB流

Question

我正在寻找一种方法，以预定的时间间隔从DynamoDB批量读取更新。

例如，我希望每隔10分钟就能读取自上次读取以来发生的所有DynamoDB表更新。

我知道DynamoDB Streams可以设置为触发Lambda函数。无论如何Lambda会在特定的时间间隔内批量更新所有更新吗？一次处理全部？

Answer 1

是的。

您需要设置一个云值班报警（每10分钟，像一个cronjob，并将其配置为触发你的拉姆达。

但是（！），你将需要编写读取的代码dynamodb流，且其将是一个挑战的它

你需要坚持的地方（另一dynamodb表，S3或Redis的）的dynamodb流处理的最后位置 - 这样你就不会被处理相同的更新两次

我强烈建议你使用默认拓扑，并设置触发器为dynamodb，然后你的羊肉da将得到更新的记录作为输入。 AWS为您管理流上的位置，这是（与其他选项不同）是一种可扩展的解决方案。