我现在有个stream流,会监控所有的设备,现在有个业务场景,怎么同时判断两个设备同时满足各各自条件
场景不太一样把,我这个就是每个光强探测器(id 区分)都会上传光照强度,我要判断id=1的light>10并且id=2的light>10
你的提问没有内容啊,只能按照那样理解 不过这个场景仍然只是链接的变种。分析函数支持 WHEN 条件去拿到特定 id 的light值 Analytic Functions | eKuiper Documentation
可以 通过 latest(light) OVER (WHEN id = 1) 拿到 id 1的最新light值,同理可得 id 2
哦哦,明白了,这样的话,就可以同时判断id 1和2了,,我之前一直想的是where后边加条件id=1 and id=2
之前的不就是最新的吗
最新可能就是本条数据啊,lag一定不是当条数据
cast 那个部分需要吗,原本的数据类型不对是吗
对,,原本都是string类型的
有好的思路吗
在我看来,这已经足够简单了。要不就先分个预处理规则在前面,把类型,中间变量先算好,看起来更清晰
好的,问下,我这个地方用latest是速度小于10的最新一条数据,用lag是不是代表速度小于10的最新的一条数据再往前的一条数据
上一次小于10的数据。如果本条数据不小于10,那跟latest没区别
我两个and 分开执行都可以触发,,用and连接一起触发不了了,,头疼,语法应该没问题吧,就是用and连接
and 需要两个同时成立啊,确定数据能触发这个条件吗
想问下,如果对字段进行算术或关系运算符操作,sql能自动将字符串类型转换吗