question Re: Apache NiFi: Put relationship name as attribute on flowfile in Archives of Support Questions (Read Only)

Apache NiFi: Put relationship name as attribute on flowfile

bas_vdl — Fri, 28 Jul 2017 18:44:36 GMT

In our case we have 5 different TailFile processors as inputs and we use 5 UpdateAttribute processors to tag the flowfile comming off the TailFile processors. But this results in a crazy looking data flow with an UpdateAttribute processor for each TailFile processor.

So my idea was, to link each TailFile processors to one and the same UpdateAttribute processor, with each a different relationship name. Within the UpdateAttribute I wanted to grep the relationship name and put this as an attrbute on the flow file.

But the question is, how to get the relationship name? If this is not possible is there a more simple and manageble way to tag flow files based on the input processor (TailFile)?

Thank you.

Re: Apache NiFi: Put relationship name as attribute on flowfile

Wynner — Tue, 01 Aug 2017 00:14:38 GMT

@Bas van de Lustgraaf

The TailFile processor adds the following attribute to each flow file it creates, tailfile.original.path = Path of the original file the flow file comes from. You could use the value of this attribute to add any additional attributes or for routing.

Re: Apache NiFi: Put relationship name as attribute on flowfile

bas_vdl — Tue, 01 Aug 2017 19:00:41 GMT

@Wynner

This will work, thank you! I've linked all TailFile inputs to a single UpdateAttribute. Using the Advanced option I've created per TailFile a rule.

For TailFileSuricata:

Conditions

${tailfile.original.path:find('/var/log/suricata/.*')}

Action

Attribute: log.source
Value: suricata