解析json 中的属性值,并更新到flowfile 属性中。

用法场景:

 

1、从kafka 中读取flowfile content 中的json数据,传入EvaluateJsonPath

Nifi Processor | EvaluateJsonPath

 

2、B列是json 数据中的数据, A 列是需要设置到flowfile 的属性名。

Nifi Processor | EvaluateJsonPath

 

 

Return type 的选择:

如果json 为单层字符串,则scalar或者auto-detect, 如果为多层或者值中存在列表或者对象类的值选择json

注意:

Nifi Processor | EvaluateJsonPath

 

相关文章: