有个ekuiper流规则引擎的需求:有3台neuron设备采集数据,数据在同一个流里面,采集的字段是一样的,例如:tag1,tag2和node_name,其中node_name字段来标识不同的设备,我现在每隔3s对这3台设备,分别取最新的数据,然后对tag1求和。目前知道的取最新的数据,是使用latest函数,但是他是所有设备一起取最新,但是我要对3台设备分别取最新数据,请问怎么写sql?,
有个ekuiper流规则引擎的需求:有3台neuron设备采集数据,数据在同一个流里面,采集的字段是一样的,例如:tag1,tag2和node_name,其中node_name字段来标识不同的设备,我现在每隔3s对这3台设备,分别取最新的数据,然后对tag1求和。目前知道的取最新的数据,是使用latest函数,但是他是所有设备一起取最新,但是我要对3台设备分别取最新数据,请问怎么写sql?,