Kinesis Analytics直连与间接连Lambda的输出差异问题咨询

这其实不是AWS的Bug，而是不同服务集成的默认行为差异导致的，我来给你拆解清楚：

为什么两种集成方式的负载不一样？ #

1. 直接连接Kinesis Analytics到Lambda的逻辑 #

Kinesis Analytics的直接Lambda输出，会把同一计算窗口内生成的所有结果打包成一个数组，一次性发送给Lambda。这是它内置的批量投递机制，目的是减少Lambda的调用次数，提升整体效率。你看到的records数组包含两条数据，就是这个机制在起作用。

2. 经过Kinesis Stream中转的逻辑 #

当Kinesis Analytics把结果输出到Kinesis Stream时，它会将每条分析结果作为独立的Kinesis记录写入流中——也就是说你那两条数据会变成Stream里的两个单独记录，而不是一个包含数组的单条记录。

而Lambda消费Kinesis Stream时，默认的触发逻辑是根据你配置的**批量大小（Batch Size）和批量窗口（Batch Window）**来决定一次调用发送多少条记录。如果你的Stream里的记录是逐个到达的，或者你的批量配置比较小（比如默认Batch Size是1），Lambda就会每次只收到一条记录。

怎么让Lambda通过Stream中转后也收到批量记录？ #

你只需要调整Lambda的Kinesis触发器配置即可：

• 打开Lambda控制台，找到对应的函数，进入触发器标签页
• 找到关联的Kinesis Stream触发器，点击编辑
• 修改以下两个参数：
  • Batch Size：设置一个大于1的值（比如10，根据你每次生成的记录数调整）
  • Batch Window：设置为你的Kinesis Analytics窗口时长（比如40秒）
• 保存配置后，Lambda就会等待40秒或者攒够设置的批量大小的记录，再一次性调用，这样就能把同一窗口的多条记录打包到一个负载里了。

另外要注意：两种集成方式的负载格式本身就有差异——直接来自Kinesis Analytics的是它自定义的输出格式，而来自Kinesis Stream的是AWS Kinesis的标准事件格式，但两者data字段里的核心数据是完全一致的，解码后都是你Kinesis Analytics生成的结果。

内容的提问来源于stack exchange，提问作者Hamed Minaee