feat: store messages in DAQJobHealthcheck

src/daq/jobs/healthcheck.py

@@ -10,7 +10,8 @@
 from daq.base import DAQJob
 from daq.jobs.handle_stats import DAQJobMessageStats, DAQJobStatsDict
 from daq.models import DAQJobStats
-from daq.store.models import StorableDAQJobConfig
+from daq.store.models import DAQJobMessageStore, StorableDAQJobConfig
+from utils.time import get_now_unix_timestamp_ms
 
 
 class AlertCondition(str, Enum):
@@ -150,3 +151,18 @@ def send_alert(self, item: HealthcheckItem):
                 alert_info=item.alert_info,
             )
         )
+        if len(self.config.store_config) > 0:
+            self.message_out.put(
+                DAQJobMessageStore(
+                    store_config=self.config.store_config,
+                    daq_job=self,
+                    keys=["timestamp", "severity", "message"],
+                    data=[
+                        [
+                            get_now_unix_timestamp_ms(),
+                            item.alert_info.severity,
+                            item.alert_info.message,
+                        ]
+                    ],
+                )
+            )

src/utils/time.py

@@ -0,0 +1,5 @@
+from datetime import datetime
+
+
+def get_now_unix_timestamp_ms() -> int:
+    return int(datetime.now().timestamp() * 1000)