Apach Nifi Rücksetzen Flowfile Attribut

Question

In meinem Nifi 1.3.0 Datenfluss ändert der FetchElasticsearchHttp Prozessor das Dateiname Attribut zu seiner entsprechenden ID in der Datenbank. Ich habe mich gefragt, ob es eine Möglichkeit gibt, es mit einigen Nifis in Hausprozessoren zu ändern.

Ich habe darüber nachgedacht, einfach mein eigenes Skript zu schreiben, um das zu korrigieren, aber es scheint keine Möglichkeit zu geben, zu wissen, um welche Datei es sich handelt, so dass ich nicht einfach seinen Namen holen kann.

Answer 1

Wenn ich Sie richtig verstanden habe, können Sie UpdateAttribute verwenden, um das Dateiname-Attribut in eine andere Eigenschaft zu kopieren. Es gibt keine Möglichkeit, den Prozessor daran zu hindern, seine Eigenschaften zu schreiben, aber Sie können ihn sicher selbst beiseite legen. Der Trick besteht darin, vor dem Aufruf des Abrufprozessors zu kopieren/umzubenennen.