Apache Nifi - 从Avro中提取属性

Question

我正试图从Avro和JSON中提取属性.我可以使用EvaluateJsonPath处理器从JSON中提取属性.我试图在Avro上做同样的事,但我不确定它是否可以实现.

这是我的流程,ExecuteSQL- > SplitAvro- >UpdateAttribute

UpdateAttribute是我想要提取属性的处理器.请在下面找到UpdateAttribute处理器的快照,

所以,我的基本问题是,我们可以从Avro中提取属性吗？如果是,请为我提供正确的方法.或者ConvertAvroToJSON在提取属性之前是否必须始终使用？

Answer 1

目前,NiFi无法直接从Avro中提取属性(目前还没有类似于XPath for XML或JsonPath for JSON的AvroPath),因为您说在提取属性之前可以使用ConvertAvroToJSON.

或者,我编写了一个用于ExecuteScript处理器的Groovy脚本,它将"Avro path"值作为动态属性(每个以avro.path开头,其值实际上是JsonPath),将Avro转换为内存中的JSON,以及需要您下载并指向Avro JAR.如果你感兴趣,我可以在这里发布它,但它的唯一优势是保持Avro中的流文件内容,虽然它可能很烦人,你可以使用ConvertAvroToJson - > EvaluateJsonPath - > ConvertJsonToAvro作为解决方法.