Hi all, I have a file transfer system set up where files transit several NiFi instances before getting to their destination. I need to tie the provenance events together across these NiFi instances using the name of the file. Depending on the provenance event, this filename may be in previousAttributes.filename or updatedAttributes.filename. I want to add a processor that updates the record by adding a single attribute 'filename' to the record (the provenance data is in a regular flow as json at this point). In pseudo code something like...
filename = (previousAttributes.filename if not null) or updatedAttributes.filename Has anyone done this before? What would you recommend for the processor? UpdateRecord? Thanks Tim
