使用sqlSink插件对mysql进行更新、删除,文档提示sink配置中需指定rowkindField属性为action。但设备等发送的数据并不含action字段,如何解决?还是规则中可以配置?
更新删除必须有action字段(可以用别的名字,配置rowkindField),否则不知道你是要更新还是删除还是插入啊。
应该可以通过类似EMQX内置的规则里去把数据加工后(加action字段)再传给ekuiper
好的。其次数据库插入操作,插入的数据是createTime:“2024-03-15T19:04:21.013”,对应的表中字段是create_time。在sqlSink中应该如何配置?是需要同时配置tableDataField和fields吗???
Select createTime as create_time