在我的Nifi1.3.0数据流中,FetchElasticsearchHttp处理器将filename属性更改为其在数据库中的对应ID。我想知道有没有办法用一些Nifi的内部处理器把它改回来。
我想过简单地编写自己的脚本来纠正这个问题,但似乎没有办法知道它是什么文件,所以我不能只是获取它的名称。
发布于 2017-07-10 00:15:16
如果我没理解错的话,您可以使用UpdateAttribute将filename属性复制到另一个属性。没有办法阻止处理器写它的属性,但是你肯定可以自己把它藏起来。诀窍是在调用fetch处理器之前复制/重命名。
https://stackoverflow.com/questions/44995185
复制相似问题