是否可以在Apache Nifi中删除与UpdateRecord处理器的JSON键值对?

Question

是否可以删除与UpdateRecord处理器的键/值对?例如

{
"id": 5,
"name": "John",
"age": 26
}

{
"id": 5,
"name": "John"
}

我必须把处理器配置作为属性和值吗?

感谢

Answer 1

您可以使用QueryRecord过滤掉不需要的字段。

1. 添加QueryRecordProcessor
2. 设置Record Reader为JSONTreeReader
3. 设置Record Writer为JSONRecordSetWriter
4. 添加属性filter_id_name和值字段设置到SQLSELECT id, name FROM FLOWFILE
5. filter_id_name关系现在包含修改的内容。使用该关系进行进一步处理。

Answer 2

可以将jsonrecordsetwwriter控制器设置更改为:模式访问策略=使用'Schema Text'属性

UpdateRecord集合属性avro之前。模式=

{
"type": "record",
"name": "TestObject",
"namespace": "ca.dataedu",
"fields": [{
"name": "id",
"type": ["int"]
}, {
"name": "name",
"type": ["null", "string"],
"default": null
}]
}