如何在AWS Kinesis Analytics中获取未输出数据并实时展示聚合中数据？

数据老陈

2026-5-20

解答：无服务器实时展示流聚合数据 + Kinesis Analytics翻滚窗口中间数据访问

首先，你的需求完全可以用AWS无服务生态实现，而且Kinesis相关服务完全适配这个场景，下面分模块拆解具体方案：

一、无服务器方案实现按需实时展示（含未完成聚合的数据）

要做到无需维护任何服务器，同时能按需查看包括仍在聚合中的数据，推荐以下组合方案：

调整Kinesis Analytics的窗口策略，输出中间聚合结果
默认的翻滚窗口（Tumbling Window）只会在窗口结束时输出最终聚合值，但你可以改用滑动窗口（Sliding Window），设置一个极小的滑动步长（比如1秒），同时保留原有的时间块长度（比如5分钟）。这样Kinesis Analytics会每隔1秒输出当前窗口内的实时聚合结果——相当于把未完成的中间状态持续暴露出来。
举个SQL示例（假设你在聚合某指标的总和）：
```
CREATE OR REPLACE STREAM "OUTPUT_STREAM" (
    window_start TIMESTAMP,
    window_end TIMESTAMP,
    total_value DOUBLE
);

CREATE OR REPLACE PUMP "STREAM_PUMP" AS INSERT INTO "OUTPUT_STREAM"
SELECT
    STEP(ROWTIME BY INTERVAL '5' MINUTE) AS window_start,
    STEP(ROWTIME BY INTERVAL '5' MINUTE) + INTERVAL '5' MINUTE AS window_end,
    SUM(value) AS total_value
FROM "INPUT_STREAM"
GROUP BY STEP(ROWTIME BY INTERVAL '5' MINUTE), SLIDING_WINDOW(ROWTIME, INTERVAL '1' SECOND);
```
用无服务存储+API层做按需查询
把Kinesis Analytics输出的中间结果写入DynamoDB（设置窗口起始时间为分区键，确保每个窗口的最新聚合值覆盖旧的），然后通过API Gateway + Lambda搭建一个轻量查询接口：
- 用户前端按需调用API，传入要查看的窗口时间范围
- Lambda从DynamoDB中读取对应窗口的最新聚合值返回
  全程都是无服务器组件，不需要维护任何EC2实例。

默认情况下，Kinesis Analytics的翻滚窗口状态（未完成聚合的数据）是存储在其内部状态存储中的，无法直接访问。但你可以通过两种方式间接获取：

滑动窗口模拟翻滚窗口的实时状态：如上面第一部分所说，用滑动窗口以小步长输出中间结果，相当于把翻滚窗口的实时状态持续暴露出来。这种方式最直接，完全基于Kinesis Analytics的原生SQL能力实现。
自定义状态持久化：如果你一定要用纯翻滚窗口，可以在Kinesis Analytics的应用中，通过Lambda集成（或输出到Kinesis Data Streams后触发Lambda），把每次数据进入窗口后的聚合状态写入外部存储（比如DynamoDB）。不过这种方式需要额外处理状态更新逻辑，不如滑动窗口简洁。

绝对属于！Kinesis生态的核心就是处理实时流数据的聚合、分析，你的需求（时间块聚合+实时查看中间状态）是典型的流分析场景，只是需要调整窗口策略或者结合其他无服务组件，就能实现默认行为之外的需求。

内容的提问来源于stack exchange，提问作者Teun D