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



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

我有多个lambda函数(CREATE/UPDATE/DELETE(订阅了驱动蛋白流,现在我只想根据数据/事件类型触发特定的lambda函数。

有可能吗?如果没有,处理这个问题的更好的体系结构/方法是什么?

遗憾的是,您无法做到这一点。通常有两种方法可以克服这一问题:

  1. 将流连接到一个lambda函数。函数将接收流中的所有记录,并将它们分派给其他函数。调度可以是直接的,也可以通过专用的SQS队列进行
/-----> SQS 1 ---> CREATE lambda
Kinesis---->Lambda ------> SQS 2 ---> UPDATE lambda
-----> SQS 3 ---> DELETE lambda
  1. 也使用一个函数,但这次UPDATE、CREATE和DELETE代码将在单个函数中。因此,在lambda处理程序函数中,您将使用基本的if-then-else条件来调用UPDATE、CREATE和DELETE功能的不同代码

最新更新