使用n8n搭建服务器监控系统：从Webhook到Telegram告警的完整实现

https://your-n8n-domain.com/webhook-test/server-monitor

const CONFIG = {
  // 监控系统认证Token（使用openssl rand -hex 32生成）
  MONITOR_AUTH_TOKEN: 'YOUR_SECURE_TOKEN_HERE',

  // Telegram Chat ID（接收通知的Chat）
  TELEGRAM_CHAT_ID: 'YOUR_TELEGRAM_CHAT_ID',

  // 允许使用机器人的用户ID列表
  ALLOWED_USER_IDS: ['YOUR_TELEGRAM_USER_ID'],

  // 告警阈值配置
  THRESHOLDS: {
    cpu: 80,      // CPU使用率阈值（%）
    memory: 85,   // 内存使用率阈值（%）
    disk: 90      // 磁盘使用率阈值（%）
  }
};

// 验证Token
const requestToken = $input.item.json.body.auth_token;
const authorized = requestToken === CONFIG.MONITOR_AUTH_TOKEN;

// 返回验证结果和配置
return {
  authorized: authorized,
  body: $input.item.json.body,
  config: CONFIG
};

{{$json.authorized}} === true

const data = $input.item.json.body;
const config = $input.item.json.config;
const thresholds = config.THRESHOLDS;

// 解析监控数据
const serverName = data.server_name || 'Unknown';
const cpu = parseFloat(data.cpu_usage || 0);
const memory = parseFloat(data.memory_usage || 0);
const disk = parseFloat(data.disk_usage || 0);
const networkIn = parseFloat(data.network_in || 0);
const networkOut = parseFloat(data.network_out || 0);
const loadAvg = data.load_average || 'N/A';
const uptime = data.uptime || 'N/A';

// 检查告警
let alerts = [];
let status = '正常';
let alertLevel = 'info';

if (cpu > thresholds.cpu) {
  alerts.push(`CPU使用率过高: ${cpu.toFixed(2)}%`);
  alertLevel = 'warning';
  status = '警告';
}

if (memory > thresholds.memory) {
  alerts.push(`内存使用率过高: ${memory.toFixed(2)}%`);
  alertLevel = 'warning';
  status = '警告';
}

if (disk > thresholds.disk) {
  alerts.push(`磁盘使用率过高: ${disk.toFixed(2)}%`);
  alertLevel = 'critical';
  status = '严重';
}

// 生成告警消息
const message = `
## 服务器监控报告

## 服务器: ${serverName}
## 时间: ${new Date(data.timestamp).toLocaleString('zh-CN')}

## 系统资源
————————————
CPU: ${cpu.toFixed(2)}%
内存: ${memory.toFixed(2)}%
磁盘: ${disk.toFixed(2)}%
负载: ${loadAvg}
运行: ${uptime}

## 网络流量
————————————
入站: ${(networkIn / 1024).toFixed(2)} KB/s
出站: ${(networkOut / 1024).toFixed(2)} KB/s

## 状态: ${status}

${alerts.join('\n')}
`;

return {
  message: message,
  hasAlert: alerts.length > 0,
  alertLevel: alertLevel,
  serverName: serverName,
  chatId: config.TELEGRAM_CHAT_ID,
  timestamp: new Date().toISOString(),
  metrics: {
    cpu: cpu,
    memory: memory,
    disk: disk,
    networkIn: networkIn,
    networkOut: networkOut,
    loadAvg: loadAvg,
    uptime: uptime
  }
};

{{$json.hasAlert}} === true

curl -X POST https://your-n8n-domain.com/webhook/server-monitor \
-H "Content-Type: application/json" \
-d '{
  "auth_token": "YOUR_SECURE_TOKEN_HERE",
  "server_name": "test-server",
  "cpu_usage": 85.5,
  "memory_usage": 70.3,
  "disk_usage": 50.9,
  "network_in": 1024000,
  "network_out": 512000,
  "load_average": "1.5",
  "uptime": "5 days",
  "timestamp": "'$(date -u +%Y-%m-%dT%H:%M:%SZ)'"
}'

#!/bin/bash

# n8n Webhook地址
WEBHOOK_URL="https://your-n8n-domain.com/webhook/server-monitor"

# 认证Token（与n8n中配置保持一致）
AUTH_TOKEN="YOUR_SECURE_TOKEN_HERE"

# 服务器名称
SERVER_NAME=$(hostname)

# 采集系统指标
CPU_USAGE=$(top -bn1 | grep "Cpu(s)" | sed "s/.*, *\([0-9.]*\)%* id.*/\1/" | awk '{print 100 - $1}')
MEMORY_USAGE=$(free | grep Mem | awk '{printf("%.2f", ($3/$2) * 100.0)}')
DISK_USAGE=$(df -h / | awk 'NR==2 {print $5}' | sed 's/%//')
NETWORK_IN=$(cat /sys/class/net/eth0/statistics/rx_bytes)
NETWORK_OUT=$(cat /sys/class/net/eth0/statistics/tx_bytes)
LOAD_AVERAGE=$(uptime | awk -F'load average:' '{print $2}' | awk -F',' '{print $1}' | xargs)
UPTIME=$(uptime -p | sed 's/up //')
TIMESTAMP=$(date -u +%Y-%m-%dT%H:%M:%SZ)

# 发送数据到n8n
curl -X POST "$WEBHOOK_URL" \
  -H "Content-Type: application/json" \
  -d "{
    \"auth_token\": \"$AUTH_TOKEN\",
    \"server_name\": \"$SERVER_NAME\",
    \"cpu_usage\": $CPU_USAGE,
    \"memory_usage\": $MEMORY_USAGE,
    \"disk_usage\": $DISK_USAGE,
    \"network_in\": $NETWORK_IN,
    \"network_out\": $NETWORK_OUT,
    \"load_average\": \"$LOAD_AVERAGE\",
    \"uptime\": \"$UPTIME\",
    \"timestamp\": \"$TIMESTAMP\"
  }"

   */5 * * * * /usr/local/bin/server-monitor.sh >> /var/log/server-monitor.log 2>&1