Created 01-03-2018 02:15 PM
Hi
I have a listDataBaseTables which gives be 256 flowfiles. In my flow there is a lot of processing going on and i need to process one at the time.
Is it possible to trigger a processor only to continue when the flowfile before reach a certain processor, otherwise is it possible
to get a processor to continue each flowfile on a period of time so there is a timespand between each flowfile.
I have tried with a process eait using routeOnAttribute but it don't work as i want it to do.
Best regards Simon
Created on 01-03-2018 02:59 PM - edited 08-18-2019 02:20 AM
If you know the time for 1 flowfile processing then
Try with Control Rate processor with below properties
Rate Control Criteria
flowfile count
Maximum Rate
1
Time Duration
1 min
Based on above property values Control Rate processor will release 1 flowfile per 1 minute.
Change the Time Duration value based on your one flowfile processing time.
Configs:-
(or)
You need to use Wait and Notify processors to release flowfiles if the flowfile reaches certain processor.
Refer the below link about how to use wait and notify processors
http://ijokarumawak.github.io/nifi/2017/02/02/nifi-notify-batch/
Created on 01-03-2018 02:59 PM - edited 08-18-2019 02:20 AM
If you know the time for 1 flowfile processing then
Try with Control Rate processor with below properties
Rate Control Criteria
flowfile count
Maximum Rate
1
Time Duration
1 min
Based on above property values Control Rate processor will release 1 flowfile per 1 minute.
Change the Time Duration value based on your one flowfile processing time.
Configs:-
(or)
You need to use Wait and Notify processors to release flowfiles if the flowfile reaches certain processor.
Refer the below link about how to use wait and notify processors
http://ijokarumawak.github.io/nifi/2017/02/02/nifi-notify-batch/
Created 01-16-2018 03:41 PM
Thank you this worked for me