如题,谢谢
问题不是很明白,麻烦详细说明一下。请问是想把数据写入数据库?
谢谢回复。我的意思是ekuiper如何将接收到的设备数据(json格式的id,电流,电压等)按照字段id去更新数据库里对应的电流和电压数据,通过manager的界面如何操作。
假设你的设备数据通过MQTT传输,那么主要有几个步骤
- 安装 SQL sink 插件
- 创建 MQTT 数据流
- 编写规则,输出数据中包含动作字段(可固定为SELECT ‘update’ as action),类似https://ekuiper.org/docs/zh/latest/guide/sinks/plugin/sql.html#更新示例
Manager 版本较老,不确定是否有适配这个功能。可以直接 REST API 发布,或者使用 NeuronEX
我更新规则这样写,但是数据字段uname没有更新,想知道问题出在哪里,谢谢
问题找到了,是sql设置中没有设置标签字段