You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
The flow continuously monitors system and NiFi metrics (CPU, RAM, Threads, Disk usage, etc.), evaluates them against predefined thresholds, and triggers alerts via HTTP and Email when anomalies are detected.
3
+
3
4
The alerting pipeline is built around the following logical stages:
4
-
-**Flow Triggering**
5
-
-**Metrics Collection**
6
-
-**Metrics Extraction**
7
-
-**Threshold Evaluation**
8
-
-**Routing**
9
-
-**Notification**
5
+
6
+
-**Flow Triggering**
7
+
-**Metrics Collection**
8
+
-**Metrics Extraction**
9
+
-**Threshold Evaluation**
10
+
-**Routing**
11
+
-**Notification**
12
+
10
13
## Main Alerting Process Group
11
14

12
15
## Metrics System Alerting – Sub Process Group
@@ -15,32 +18,43 @@ The alerting pipeline is built around the following logical stages:
15
18

16
19

17
20
## Processors Description
18
-
-**GenerateFlowFile**
21
+
-**GenerateFlowFile**
22
+
19
23
Acts as a scheduler to trigger the monitoring flow periodically.
20
24

21
-
-**InvokeHTTP**
25
+
-**InvokeHTTP**
26
+
22
27
Metrics Collection
23
28

29
+
24
30
Calls a monitoring endpoint (NiFi API / system metrics API).
31
+
25
32
GET /nifi-api/system-diagnostics
33
+
26
34

27
-
-**EvaluateJsonPath**
35
+
-**EvaluateJsonPath**
36
+
28
37
Extracts metrics from the JSON response.
29
38

30
-
-**UpdateAttribute**
39
+
-**UpdateAttribute**
40
+
31
41
Normalizes metrics and defines the necessary attributes, such as metric thresholds for alerts.
32
42

33
-
-**RouteOnAttribute**
43
+
-**RouteOnAttribute**
44
+
34
45
Alert Detection : Compares metrics against thresholds and routes FlowFiles.
35
46

36
-
-**ReplaceText**
47
+
-**ReplaceText**
48
+
37
49
Alert Message Formatting : Builds a clean and readable alert message.
38
50

39
51
## Notification Processors
40
-
-**PutEmail**
52
+
-**PutEmail**
53
+
41
54
Sends alert notifications via email.
42
55

43
-
-**InvokeHTTP (Webhook / API)**
56
+
-**InvokeHTTP (Webhook / API)**
57
+
44
58
Sends alerts to external systems (Slack, Teams, Monitoring API, etc.).
0 commit comments