我有一个 Lambda,其事件源指向 Kinesis Stream Consumer(具有任意数量的分片)
我想确保流中具有相同“分区键”的项目由 Lambda 按顺序处理,而不是同时处理。(这被用作对象的标识,我不希望多个 Lambda 同时对同一个对象执行逻辑。)
例如,如果流中的项目具有分区键:
1,2,1,3,4,1,2,1
如果我们按照从左到右的处理顺序,Lambda 将同时处理分区键为 1,2,3 和 4 的项目。然后,当它完成具有特定分区键的一项时,它可以开始处理具有该键的另一项。
这是否可以通过某种方式实现,而不使用会导致 Lambda 使用效率低下的分布式锁?
谢谢