从数据源中接收到数据,经过数据格式判断,如果格式没问题流向数据目的A,否则流向数据目的B
不是相同目的地的主题不同这样的,是完全不同的数据目的,比如如果格式校验错误,发送到mqtt,格式校验成功,发送kafka这样的
那可以用图规则里的 switch 节点 图规则 | eKuiper 文档。用 SQL 的话,可以用规则流水线,第一个规则判断目的地,然后接上两个规则分别处理两种目的地。 规则管道 | eKuiper 文档
好的,谢谢
像上图这样在switch里怎么拿数据源source里数据?
Manager 不更新了,建议用 API
用api也需要知道怎么获取mqtt数据源里的字段啊
跟你用 SQL 语句一样啊。。贴的文档有例子啊,你的数据源的数据结构里有 temperature 就直接用呗。
我用api创建规则,这么做switch还是不行
没有实现分流
看图里还有id, name什么的,应该是界面生成的。这个界面适配可能是有问题的。可以试试看手写。如果还有问题麻烦到 Github 上开个issue,谢谢