摘要：在日常 IT 运维、数据中心管理及工业边缘节点监控中，传统的邮件与 IM 消息通知极易引发“告警疲劳”。本文分享一种基于“软硬协同”的轻量化告警方案，通过标准 HTTP API、Modbus 协议驱动嵌入式声光终端，实现全彩 LED 视觉定位与本地 TTS 文本转语音的现场告警。
一、 传统告警链路的现场痛点
在分布式系统与边缘计算节点运维中，纯软件告警链常面临以下问题：
信息淹没：高频的日志与通知充斥在群聊和邮箱中，重要告警易被忽略。
物理隔离限制：在局域网或工业内网（Air-Gapped Network）环境中，无法调用公有云的微信/短信 API 推送通知。
定位效率低：面对整排机柜或长流水线，纯文本 IP 无法让巡检人员瞬间锁定故障源。
二、 系统架构与协议设计
告警系统分为三层：上游监控源、告警逻辑适配层、硬件声光执行终端。
+————————————————————-+
| 监控源 / 业务系统 |
| (Prometheus / Zabbix / 业务系统 Webhook / 自研 MIS / 邮箱告警) |
+——————————+——————————+
| (HTTP RESTful / Modbus TCP)
v
+————————————————————-+
| 边缘硬件告警终端 |
| – 轻量主动监控 (Ping/HTTP/SNMP) |
| – RGB 全彩 LED 状态显示 |
| – 本地离线 TTS 语音合成引擎 |
+————————————————————-+
核心接口协议设计（REST API）
告警终端暴露标准的 RESTful 接口，接收上游系统推送的结构化 JSON 报文：
-
请求方式：POST /api/v1/send_msg
-
Content-Type：application/json
报文结构定义：
JSON
{
"text": "警告，3号机柜 PDU 过载，当前电流 32 安培",
"color": "#FF0000",
"light_mode": "flash",
"audio_mode": "cycle",
"repeat_times": 3
}
三、 对接与代码实现
1. 基于 Python 的 HMAC 签名鉴权与推送
为防止局域网内恶意伪造请求，接口采用 HMAC-SHA256 签名鉴权与时间戳防重放机制：
Python
import requests
import json
import time
import hashlib
import hmac
class AlarmTerminalClient:
def __init__(self, host, api_key, secret_key):
self.base_url = f"http://{host}/api/v1"
self.api_key = api_key
self.secret_key = secret_key
def _calc_signature(self, timestamp, payload_str):
message = f"{timestamp}\\n{payload_str}".encode('utf-8')
return hmac.new(self.secret_key.encode('utf-8'), message, hashlib.sha256).hexdigest()
def send_alarm(self, message, level="CRITICAL"):
timestamp = str(int(time.time()))
payload = {
"text": message,
"color": "#FF0000" if level == "CRITICAL" else "#FFA500",
"light_mode": "flash" if level == "CRITICAL" else "steady",
"audio_mode": "cycle" if level == "CRITICAL" else "once",
"repeat_times": 3 if level == "CRITICAL" else 1
}
payload_str = json.dumps(payload, separators=(',', ':'))
signature = self._calc_signature(timestamp, payload_str)
headers = {
"Content-Type": "application/json",
"X-API-Key": self.api_key,
"X-Timestamp": timestamp,
"X-Signature": signature
}
try:
resp = requests.post(f"{self.base_url}/send_msg", data=payload_str, headers=headers, timeout=3)
return resp.status_code == 200
except Exception as e:
print(f"告警推送超时: {e}")
return False
# 调用示例
client = AlarmTerminalClient(host="192.168.1.200", api_key="admin", secret_key="SecretKey123")
client.send_alarm("核心网关 10.0.0.1 丢包率超过 15%，请立即排查", level="CRITICAL")
四、 避坑与调优策略
告警风暴抑制（Debounce）：在发送端增加滑动窗口机制（例如：同一错误 300 秒内仅驱动一次语音播报），防止频繁报错造成声光干扰。
优先级抢占队列：硬件端需设计抢占逻辑，当 P0 级告警触发时，中断当前正在播报的 P2 级语音并优先渲染 P0 视觉状态。
分时段音量策略：结合 Cron 任务在 night 模式下自动调低 TTS 播报音量或切至纯灯光闪烁模式，实现“高效告知、低度扰民”。
3. 重新提交小贴士
修改文章标题：确保标题中不含品牌或具体型号名称，使用如“基于 REST API/Modbus 的硬件告警实践”等通用标题。
分类与标签：标签选择 运维、架构、Python、API、工业互联网，避开“产品”、“推荐”类标签。
检查结尾：确保文章结尾没有“如果对博灵 Q 系列感兴趣…”、“欢迎购买/联系”等引导性语句，保持纯技术总结落脚。
