ekuiper 可以实现根据action处理的结果分流到不同的数据sink吗?

从数据源中接收到数据,经过数据格式判断,如果格式没问题流向数据目的A,否则流向数据目的B

某些 sink 是由动态属性的,比如发送的 MQTT topic 可以根据你的数据设置从而达到发送到不同目的的作用。你可以看看你的场景是否可以支持 Sink | eKuiper 文档

不是相同目的地的主题不同这样的,是完全不同的数据目的,比如如果格式校验错误,发送到mqtt,格式校验成功,发送kafka这样的

那可以用图规则里的 switch 节点 图规则 | eKuiper 文档。用 SQL 的话,可以用规则流水线,第一个规则判断目的地,然后接上两个规则分别处理两种目的地。 规则管道 | eKuiper 文档

好的,谢谢

像上图这样在switch里怎么拿数据源source里数据?

@huangjy

Manager 不更新了,建议用 API

用api也需要知道怎么获取mqtt数据源里的字段啊:joy:

跟你用 SQL 语句一样啊。。贴的文档有例子啊,你的数据源的数据结构里有 temperature 就直接用呗。


我用api创建规则,这么做switch还是不行

没有实现分流

看图里还有id, name什么的,应该是界面生成的。这个界面适配可能是有问题的。可以试试看手写。如果还有问题麻烦到 Github 上开个issue,谢谢