https://community.cloudera.com/t5/Support-Questions/Count-number-of-incoming-flow-files/m-p/377887#M243370 <P><a href="https://community.cloudera.com/t5/user/viewprofilepage/user-id/105620">@Fanxxx</a>,<BR /><BR />How I would do the first POC:<BR />1) <STRONG>GetMongoRecord</STRONG>: execute the count on the first table. Using the property "<EM>Query Output Attribute</EM>" you save that value directly as an attribute.<BR />2) connected to the success queue another <STRONG>GetMongoRecord</STRONG>: execute the count on the second table. Using the property "<EM>Query Output Attribute</EM>" you save that value directly as an attribute.&nbsp;<BR />3) connected to the success queue an <STRONG>RouteOnAttribute</STRONG>: here you define a rules --&gt; if count1=count2, do what you want to do, otherwise call the logic for the insert, as you said. (using NiFi Expression language:<EM> ${attribute1:equals(${attribute2})}</EM> )</P> Thu, 19 Oct 2023 06:53:50 GMT cotopaul 2023-10-19T06:53:50Z