1

我有一个用例,其中 Kinesis 从视频流中提取事件(每个视频流都有一个唯一的 ID),但是数据被分解并且无序到达。

例如:

VideoId1 {}
VideoId2 {}
VideoId2 {}
VideoId1 {}
VideoId1 {}

我在这里尝试做的是使用翻转窗口将视频流事件编织成一个连续的、按时间顺序排列的片段。例如:

VideoId1-> [Event1, Event2, Event3, etc] (from the 1 minute window)
VideoId2-> [Event1, Event2, Event3, etc] (from the 1 minute window)

但是,我发现在 Kinesis Analytics 中很难做到这一点。似乎翻滚的窗户需要一个 group by 子句,我在这里不需要。这里的任何指示或建议都会非常有帮助。也许分析不是正确的工具。

4

0 回答 0