当流中没有数据时,有什么方法可以触发运动分析?尽管有数据还是没有数据,但还是像定期运行一样?
我有一个来自传感器的数据流,如下所示:
[
{
"timestamp": "2011/09/01 22:30",
"reading": 1
},
{
"timestamp": "2011/10/01 22:31",
"reading": 0
}
]
reading
我的用例是在 1 分钟的桶中实时计算 a 为 1 的秒数。
拜托,我打算只使用 Kinesis Analytics SQL 或 AWS 工具,而不是像 drools 或任何其他初创公司这样的第三方服务。