问题描述
尝试设计用于错误处理的解决方案。我们有一个lambda，它接收来自sns主题的数据，并将数据发送到已知有时不可用的旧服务。
当旧版服务关闭时，我想将消息发送到dyanmodb表进行重播。
我想使用断路器模式。因此，在此刻，我正在考虑启动一项服务，该服务将不断轮询旧版服务，然后再提供一些伪代码，如下所示：
If (legacy service changes from dead to alive){
Send all entries from dynamo to sns topic;
//This will trigger the lambda again which will hit legacy service which we kNow is Now up
}
问题是，我们喜欢使用无服务器技术，并且不确定我是否可以拥有不断轮询的无服务器服务，因此可以在服务器上运行它是有意义的。
我正在寻找一种执行此操作的好方法，因此我想知道是否可以配置dynamodb来轮询旧版服务，并在条件从无效变为活动的情况下填充sns主题。或任何其他使用无服务器技术的解决方案。
P.s我不喜欢间隔运行lambda来检查dB的想法，因为我们可能会错过一些停机时间，而且从dB读取数据并发送到sns可能是一个漫长的操作。
更新：正在深入研究电路模式，意识到我不需要不断地轮询，所以我可以在dynamodb表中检查最近XX秒内失败的呼叫数量，因此出现了一个新问题，我可以发送吗从dynamodb到sns的消息，取决于其条目之一的条件。例如。 FailsInLastMinute从3变为3以下，我们将dynamo中一列中的所有消息发送到sns，或者我需要此部分的服务
解决方法
我认为DynamoDB无法做到这一点，毕竟它是一个数据库，而不是集成平台。
也就是说，一种可能的解决方案是使用DynamoDB streams将DynamoDB用作SNS和旧版应用程序之间的队列。来自SNS的任何消息都使用Lambda插入DynamoDB中。然后，DynamoDB流将触发另一个Lambda，该Lambda会将消息发送到旧版应用程序。
如果旧版应用程序关闭，Lambda函数将无法连接，从而产生故障。然后DynamoDB将重试Lambda，直到成功为止。
请注意，最好使用启用了fifo的SQS队列。这样做是一样的，但是没有DynomoDB的开销。