Is there a mechanism or technique for communicating the results of a flow file 
to its "sister" flow files?

Here is a high-level description of what I am doing:

Input to my flow is a JSON array of documents that get split (SplitJson) into 
individual documents and each document becomes a distinct flow file.  Each 
document (flow file) gets validated against a JSON schema (ValidateJson) then 
gets updated into a Mongo collection (PutMongoUpdate).  At the end of all this, 
I want to do some post processing but only if all documents processed 
successfully.  

When a failure occurs (either in the validation or the Mongo update) is there a 
way to communicate that to the success branch of the flow process so a decision 
can be made about whether to proceed to post processing or not.

I am using NiFi 1.1.2

Thank you for any guidance you can offer,

Steve



  • Communication betwee... Byers, Steven K (Steve) CTR USARMY MEDCOM JMLFDC (US)

Reply via email to