nifi之将一行一行数据进行值的定义
EvaluateJsonPath:主要作用就是把数据里面的配置成“键值对”的方式。方便下游处理器进行取值
创建EvaluateJsonPath处理器
接上一篇长,已经成功创建了出来
给处理器name
对上游数据进行分析
我们通过分析上游数据来对如何进行“键值对”配置来进行了解,这边涉及到jsonpath的语法。感兴趣的大家可以去百度了解一下
上游的数据长这个样子
分析:通过取前面的id或者age可以得到后面的值,这个还是一层的,比较好取值,好的,开搞
对处理器进行配置
定义id
定义age
其他的类似
创建下游ReplaceText处理器
上面我们不是定义了吗,也就是下游处理器在接收到这组数据的时候,取id的值就是数据中$id的值,其他的类推,然后再加上inster字符传的拼接,是不是可以组成一个完整的sql语句
连接上下游关系
创建自连接
出现报错
原因:指示JsonPath的计算结果是写入FlowFile内容还是写入FlowFile属性;如果使用attribute,必须指定attribute Name属性。如果设置为flowfile-content,则只能指定一个JsonPath,并且忽略属性名。所以我们还需要重新配置下处理器属性
启动查看效果
查看数据效果
可以看到我们已经成功的将属性进行了定义
结束语
下一篇我们将要使用repletext处理器拼接sql语句