是否可以从 AWS Kinesis 流触发特定的 lambda 函数？

如何解决是否可以从 AWS Kinesis 流触发特定的 lambda 函数？

是否可以从 AWS Kinesis 流中触发特定的 lambda 函数？

我有多个订阅 kinesis 流的 lambda 函数（创建/更新/删除），现在我只想根据数据/事件类型触发特定的 lambda 函数。

有可能吗？如果不是，处理这个问题的更好的架构/方法是什么？

解决方法

遗憾的是，您不能这样做。通常有两种方法可以解决这个问题：

将您的流连接到一个 lambda 函数。该函数将从流中接收所有记录并将它们分派给其他函数。分派可以是直接的，也可以是通过专用的 SQS 队列进行分派。

                   /-----> SQS 1 ---> CREATE lambda
Kinesis---->Lambda ------> SQS 2 ---> UPDATE lambda
                   \-----> SQS 3 ---> DELETE lambda

也使用一个函数，但这次 UPDATE、CREATE 和 DELETE 代码将在单个函数中。因此，在 lambda 处理程序函数中，您将使用基本的if-then-else 条件来调用不同的代码以实现 UPDATE、CREATE 和 DELETE 功能。