2

我对运动和运动分析的工作方式感到非常困惑。

我需要向 kenisis analytic 发送一些数据,然后每 5 分钟将前十个故事(数据)发送到 lambda 函数。我有 Kinesis 流和 Kinesis 分析设置如下:

在此处输入图像描述

现在的问题是,每当数据进入分析时,Kinesis 分析将故事正确地发送到 lambda,这不是我想要的。我需要每 5 分钟发送一次数据。有什么方法可以设置在运动分析中发送数据的时间?任何想法?

4

1 回答 1

0

这是我修复它的方法:

FLOOR(("TRENDING_STORIES_001".ROWTIME - TIMESTAMP  '1970-01-01 00:00:00') SECOND / 40 TO SECOND)
于 2018-01-16T17:15:45.193 回答