Hi @ep_gunner , You can use the QueryNiFiReportingTask reporting task to report on the status of any processors, connections, process groups, etc. This reporting task allow you to use a SQL query NiFi status. For example, if you're interested in any stopped processor, you can use the query: select *
from PROCESSOR_STATUS
where runStatus = 'Stopped' You could also filter that by processor name or id if you need to be more specific: select *
from PROCESSOR_STATUS
where runStatus = 'Stopped'
and <YOUR_FILTER>
where YOUR_FILTER could be any of the below:
id = '<YOUR_PROCESSOR_ID>'
groupId = '<YOUR_PROCESSOR_GROUP_ID>'
name = '<YOUR_PROCESSOR_NAME>'
processorType = '<YOUR_PROCESSOR_TYPE>'
or any combination of the above The results of this reporting task can be forwarded to any available ReportSink in NiFi (Database, Kafka, Email, etc). You can also send the results to a NiFi Input Port using the SiteToSiteReportingRecordSink and them you can process those reports with NiFi itself and take any other action you want. Cheers, André
... View more
