apache-nifi - Nifi - 属性为 json - 无法从属性生成所需的 json

Question

流文件内容是

{ "resourceType": "Patient", "myArray": [1, 2, 3, 4] }

我使用 EvaluateJsonPath 处理器将“myArray”加载到属性 myArray。


然后我使用处理器 AttributesToJSON 从 myArray 创建一个 json。


但在流文件内容中，我得到的是

{"myArray":"[1,2,3,4]"}

我希望流文件具有以下内容。

{"myArray":[1,2,3,4]}

这是流文件属性

如何在内容中再次将“myArray”作为数组？

Answer 1

使用面向记录的处理器，如 转换记录处理器 而不是使用 EvaluateJsonPath,AttributesToJSON 处理器。

RecordReader 作为 JsonPathReader

JsonPathReader 配置:


AvroSchemaRegistry:

{
    "namespace": "nifi",
    "name": "person",
    "type": "record",
    "fields": [     
        { "name": "myArray", "type": {
            "type": "array",
            "items": "int"
        }}
    ]
}

JsonSetWriter:
使用相同的 AvroSchemaRegistry Controller 服务来访问架构。
访问 AvroSchema 您需要设置 架构名称流文件的属性。

输出流文件 内容将是

[{"myArray":[1,2,3,4]}]

请引用 this链接如何配置 ConvertRecord 处理器

(或)

如果您应得的输出是 {"myArray":[1,2,3,4]}没有 [](array)然后使用
替换文本 处理器而不是 AttributesToJson 处理器。

替换文本配置: