Apache Nifi 转换流文件属性

Question

在我的 Nifi 1.3.0 数据流中，FetchElasticsearchHttp 处理器将文件名属性更改为其在数据库中的相应 ID。我想知道是否有办法使用 Nifi 的一些内部处理器将其改回原来的状态。

我考虑过简单地编写我自己的脚本来纠正这个问题，但似乎无法知道它是什么文件，所以我不能只获取它的名字。

Answer 1

如果我没理解错的话，您可以使用 UpdateAttribute 将文件名属性复制到另一个 属性。没有办法阻止处理器写入它的属性，但你肯定可以自己把它藏起来。诀窍是在调用获取处理器之前 copy/rename。