You need to enable JavaScript to run this app.
优惠活动
大模型
产品
解决方案
定价
更多

配置为消费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

相关产品推荐
方舟 Agent Plan

超全模态模型 × Harness 升级,最新支持 Deepseek-V4.1-Flash、GLM-5.3 系列、Doubao-Seedream-5.0-pro、Kimi-K3 (部分), 限时 9.9 元起

最近更新时间:2026.06.29 19:08:08