配置为消费Kinesis流的Lambda函数如何感知新记录推送?
Lambda消费Kinesis流的触发机制
1. 是否会定期轮询Kinesis流?
- Lambda服务会主动定期轮询Kinesis流,默认轮询间隔为200毫秒,这个底层轮询间隔无法直接修改,但你可以通过事件源映射的配置项(比如
BatchSize、MaximumBatchingWindowInSeconds)来调整触发的批量逻辑。轮询过程中,Lambda会针对流的每个分片,检查上次消费的检查点之后是否有新记录,一旦发现可读取的记录,就会拉取并触发函数执行。
2. 是否存在仅在新增记录时触发的机制?
- 不存在被动的“新增记录即推送通知”的机制,Lambda对Kinesis的消费依赖主动轮询模式,但轮询是智能判断的:当流中没有新记录时,Lambda不会触发函数执行;只有当轮询到有可用记录(且满足你设置的批量条件)时,才会调用Lambda处理。实际使用中,基本只有Kinesis有新增记录时,Lambda才会被触发,不会出现无意义的空触发。
内容的提问来源于stack exchange,提问作者Bear Bile Farming is Torture
相关产品推荐
相关产品推荐

