From c2cc8ab2186cbffd9c2a8eeddbf0e6af2890d437 Mon Sep 17 00:00:00 2001
From: zhouzb <zhouzb@emqx.io>
Date: Fri, 21 Aug 2020 10:51:22 +0800
Subject: [PATCH] feature(resource-down-alarm): add resource down alarm

---
 src/emqx_alarm.erl | 9 +++++++--
 1 file changed, 7 insertions(+), 2 deletions(-)

diff --git a/src/emqx_alarm.erl b/src/emqx_alarm.erl
index 41553e79c..50dfb811f 100644
--- a/src/emqx_alarm.erl
+++ b/src/emqx_alarm.erl
@@ -289,10 +289,10 @@ delete_expired_deactivated_alarms(ActivatedAt, Checkpoint) ->
 do_actions(_, _, []) ->
     ok;
 do_actions(activate, Alarm = #activated_alarm{name = Name, message = Message}, [log | More]) ->
-    ?LOG(warning, "Alarm ~p is activated, ~s", [Name, Message]),
+    ?LOG(warning, "Alarm ~s is activated, ~s", [Name, Message]),
     do_actions(activate, Alarm, More);
 do_actions(deactivate, Alarm = #deactivated_alarm{name = Name}, [log | More]) ->
-    ?LOG(warning, "Alarm ~p is deactivated", [Name]),
+    ?LOG(warning, "Alarm ~s is deactivated", [Name]),
     do_actions(deactivate, Alarm, More);
 do_actions(Operation, Alarm, [publish | More]) ->
     Topic = topic(Operation),
@@ -342,6 +342,11 @@ normalize_message(too_many_processes, #{usage := Usage}) ->
     list_to_binary(io_lib:format("~p% process usage", [Usage]));
 normalize_message(partition, #{occurred := Node}) ->
     list_to_binary(io_lib:format("Partition occurs at node ~s", [Node]));
+normalize_message(partition, #{occurred := Node}) ->
+    list_to_binary(io_lib:format("Partition occurs at node ~s", [Node]));
+normalize_message(ResourceDown = <<"resource", _/binary>>, _) ->
+    [_, Type, ID, _] = binary:split(ResourceDown, <<"/">>, [global, trim_all]),
+    list_to_binary(io_lib:format("Resource ~s(~s) is down", [Type, ID]));
 normalize_message(_Name, _UnknownDetails) ->
     <<"Unknown alarm">>.