问如何判断Lambdas何时完成SQS中所有消息的处理

EN

如果您不需要及时的信息，您可以查看SQS报价的SQS报价度量，例如：

ApproximateNumberOfMessagesVisible 可从队列中检索的消息数量。报告标准:如果队列处于活动状态，则报告非负值。

和

ApproximateNumberOfMessagesNotVisible 正在运行的消息数量。如果消息已发送到客户端，但尚未被删除或尚未到达其可见窗口的末尾，则视为正在运行。报告标准:如果队列处于活动状态，则报告非负值。

如果这两个指标之和为零，队列中就没有消息，应该进行处理。

如果您需要更及时的信息，消息的生产者可以在DynamoDB中增加一个计数器项，并添加消息的数量，并且每个Lambda都会减少计数器的数量。然后，可以使用过滤器将Lambda添加到该表的DynamoDB流中，并在值再次变为零时执行一些操作。然而，这要复杂得多。

第三种选择是将整个事件转换为一个逐步函数，并使用带有并行化因子的映射状态来执行任务。缺点是它可以处理的列表的长度是有限的。