NIFI的处理器:SplitJson 2.4.0
该处理器将JSON文件拆分为由JsonPath表达式指定的数组元素的多个单独的FlowFiles。每个生成的FlowFile都由指定数组的一个元素组成,并传输到关系“split”,原始文件传输到“original”关系。如果找不到指定的JsonPath或其计算结果不是数组元素,则原始文件将被路由到“failure”,并且不会生成任何文件。
该处理器默认有3个属性:
JsonPath Expression:一个JsonPath表达式,指示要拆分为JSON/标量片段的数组元素。值为$.*时,表示按各个元素进行拆分。
Max String Length:支持的最大长度。
Null Value Representation:指示产生空值的JSON Path表达式的所需表示形式。
需要知道的是,该处理器支持添加自定义的属性,这样就可以进行一些扩展。比如,当不同类型的设备采集数据通过不同的数据流汇入时,可以对各类型的设备采集数据定义不同的属性值,以在数据流的下游业务系统进行区分。