如何知道 AWS 运动事件已通过 lambda 函数成功发送到客户端？

Question

我有一个架构，其中 lambda 函数将运动流中的事件传递给客户端。如果事件成功传递，则该事件应该从运动流中的队列中弹出。如果事件未成功传递，则它将在 x 分钟后重试。

1. 如何判断事件是否发送成功？
2. 如何从数据流队列中手动弹出一个事件？
3. 如果不成功，如何安排重新运行？

Answer 1

我认为您将 SQS 与 Kinesis 混淆了。 Kinesis 没有任何“队列”，您也不能“弹出”来自 Kinesis 的任何消息。你必须等到它们自己过期。

此外，您无法控制客户端从 Kinesis 流读取消息的内容和是否读取消息。管理它的是客户责任，而不是作为生产者的你。