nifi将json格式数据进行分片操作
上一篇我们对从数据库里面提取出来的数据转化成了json格式,但是json不是一行一行展示的,这篇我们就要将他们进行一行一行的显示,大家可以想想,如果一行一行显示的话,我们是不是就可以一行一行的插入到数据库了呢,对的,我们就是要实现这种效果的
更改SplitJson处理器的name
配置SplitJson处理器的属性
【双击处理器打开属性配置】
创建下游EvaluateJsonPath t处理器
这个处理器的作用就是将接收到的数据可以经过取值的方法,巧妙的变成一个sql语句,那怎么生成取值呢,就需要EvaluateJsonPath 处理器,把值进行定义一下,下一篇我们再详细的介绍
连接两个处理器
设置SplitJson处理器的自连接方式
我们上面不是设置了只接收分片的吗,那我们失败的,或者是原来的怎么办,让他自连接进行接收
【双击处理器进行属性配置】
开启看看转化的效果
查看转化后的数据
每条的样式
结束语
接下来我们就需要将这些数据进行拼接,组成sql语句,然后再重新写入到数据中