首页 > 解决方案 > 具有初始状态的流

问题描述

我想公开订阅或“粘性查询”之类的内容:目标是查询 DynamoDB 并通过 API Gateway 中的 WebSockets API 返回结果。好吧,每当 DynamoDB 以某种方式发生更改时,查询都会受到影响(我想我可以为此使用 Streams),我想通知客户端。如何确保客户端获得初始列表和所有更新?我想确保客户端在创建订阅后和返回初始结果列表之前不会错过任何更新......

标签: amazon-dynamodbdynamodb-queriesamazon-dynamodb-streamsamazon-dynamodb-data-modeling

解决方案


要通知您的客户有关您的 DynamoDB 的更改,可以使用DynamoDB Streams 。但是,该信息仅在 24 小时内可用。即使您将更新写入Kinesis Stream,您的信息也最多可使用 7 天(根据常见问题解答

我建议将您的用例分成两部分:

  • 创建一个服务,您可以在其中返回“粘性查询”的初始状态
  • 创建一个流,它将通知您的客户有关“粘性查询”的更新

推荐阅读