nifi将json格式数据进行分片操作(3)

nifi将json格式数据进行分片操作

上一篇我们对从数据库里面提取出来的数据转化成了json格式,但是json不是一行一行展示的,这篇我们就要将他们进行一行一行的显示,大家可以想想,如果一行一行显示的话,我们是不是就可以一行一行的插入到数据库了呢,对的,我们就是要实现这种效果的

更改SplitJson处理器的name

在这里插入图片描述
在这里插入图片描述

配置SplitJson处理器的属性

【双击处理器打开属性配置】
在这里插入图片描述

创建下游EvaluateJsonPath t处理器

这个处理器的作用就是将接收到的数据可以经过取值的方法,巧妙的变成一个sql语句,那怎么生成取值呢,就需要EvaluateJsonPath 处理器,把值进行定义一下,下一篇我们再详细的介绍

在这里插入图片描述

连接两个处理器

在这里插入图片描述

设置SplitJson处理器的自连接方式

我们上面不是设置了只接收分片的吗,那我们失败的,或者是原来的怎么办,让他自连接进行接收

【双击处理器进行属性配置】

在这里插入图片描述

开启看看转化的效果

在这里插入图片描述
在这里插入图片描述

查看转化后的数据

在这里插入图片描述
每条的样式
在这里插入图片描述

结束语

接下来我们就需要将这些数据进行拼接,组成sql语句,然后再重新写入到数据中


版权声明:本文为guijianchouxyz原创文章,遵循CC 4.0 BY-SA版权协议,转载请附上原文出处链接和本声明。