AWS Kinesis Lambda计划拉取调用

Question

似乎没有办法告诉lambdas以计划的方式拉取记录。

这意味着，除非记录的大小满足批处理规范，否则我的lambda函数永远不会被调用。

我想让我的lambda函数被急切地调用，这样它也可以在经过指定的时间后拉出记录。

假设您正在构建一个实时分析服务，该服务在非高峰期很长一段时间内不会填满指定的批处理大小。

有没有办法定期拉取记录？

Answer 1

这意味着，除非记录的大小满足批处理规范，否则我的lambda函数永远不会被调用。

据我所知，这是不正确的-你能提供这样说的文档吗？

据我所知

AWS使用守护进程轮询流并检查新记录。守护进程触发Lambda，它发生在以下两种情况中的一种：

批处理大小超过了指定的限制(在Lambda).

• Certain time中配置的限制已过(不知道确切数量)，当前的batch 不是empty.

我大量使用了Kinesis和Lambda，我将批量限制配置为500条记录(每次调用)。

我有不到500条记录的调用，有时甚至有大约20条记录-这是一个事实。