n8n + 텔레그램으로 만드는 Docker 시스템 상태 자동 모니터링 (호스트 cron 연동)

① 서버(호스트)의 cron이 5분마다 깨어남
        ↓
② 점검 스크립트(.sh) 실행 → Docker 컨테이너 상태 확인
        ↓
③ 결과를 JSON 형태로 만들어서
        ↓
④ curl 명령으로 n8n의 Webhook 주소에 전송 (POST)
        ↓
⑤ n8n이 받아서 "문제가 있는지" 판단
        ↓
⑥ 문제 있으면 → 텔레그램으로 메시지 발송
   문제 없으면 → 그냥 조용히 끝남

services:
  example-web:
    image: nginx:alpine
    container_name: example-web
    restart: always
    ports:
      - "8081:80"

  example-db:
    image: postgres:16-alpine
    container_name: example-db
    restart: always
    environment:
      POSTGRES_PASSWORD: examplepass
    volumes:
      - example-db-data:/var/lib/postgresql/data

  example-cache:
    image: redis:alpine
    container_name: example-cache
    restart: always

volumes:
  example-db-data:

# 폴더 만들고 위 내용을 docker-compose.yml로 저장한 뒤
mkdir -p ~/example-stack && cd ~/example-stack
# (nano나 vi로 docker-compose.yml 파일 작성)

# 실행
docker compose up -d

# 3개 컨테이너가 모두 Up 상태인지 확인
docker ps --filter "name=example-"

#!/bin/bash
# 점검할 컨테이너 이름을 여기에 나열 (본인 환경에 맞게 수정)
CONTAINERS=("example-web" "example-db" "example-cache")

OK_COUNT=0
FAIL_COUNT=0
CHECKS_JSON=()

for name in "${CONTAINERS[@]}"; do
  # docker inspect로 해당 컨테이너의 실행 상태를 가져옴
  # 컨테이너가 없으면 빈 값이 나옴
  state=$(docker inspect -f '{{.State.Status}}' "$name" 2>/dev/null)

  if [[ "$state" == "running" ]]; then
    echo "✓ $name : 정상 실행 중"
    status="OK"
    OK_COUNT=$((OK_COUNT+1))
  elif [[ -z "$state" ]]; then
    echo "✗ $name : 컨테이너를 찾을 수 없음 (이름 확인 필요)"
    status="FAIL"
    state="not_found"
    FAIL_COUNT=$((FAIL_COUNT+1))
  else
    echo "✗ $name : 비정상 상태 ($state)"
    status="FAIL"
    FAIL_COUNT=$((FAIL_COUNT+1))
  fi

  # JSON 한 조각을 만들어 배열에 추가
  CHECKS_JSON+=("{\"check\":\"$name\",\"status\":\"$status\",\"detail\":\"$state\"}")
done

echo ""
echo "정상 $OK_COUNT개 / 실패 $FAIL_COUNT개"

# 전체 결과를 하나의 JSON으로 합치기
JSON_OUTPUT=$(printf '{"timestamp":"%s","hostname":"%s","summary":{"ok":%d,"fail":%d},"checks":[%s]}' \
  "$(date -Iseconds)" "$(hostname)" "$OK_COUNT" "$FAIL_COUNT" \
  "$(IFS=,; echo "${CHECKS_JSON[*]}")")

# --json 옵션을 주면 사람용 출력 대신 JSON만 한 줄 출력 (n8n 연동용)
if [[ "$1" == "--json" ]]; then
  echo "$JSON_OUTPUT"
fi

# 스크립트 파일로 저장 (예: 홈 디렉토리에)
nano ~/check_containers.sh
# 위 전체 스크립트 내용 붙여넣기 후 저장 (Ctrl+O → Enter → Ctrl+X)

# 실행 권한 부여 — 이게 없으면 "Permission denied"
chmod +x ~/check_containers.sh

# 사람이 보는 일반 출력으로 먼저 테스트
~/check_containers.sh

# JSON 출력 테스트
~/check_containers.sh --json

*    *    *    *    *   명령어
│    │    │    │    │
│    │    │    │    └── 요일 (0=일요일 ~ 6=토요일, *는 매일)
│    │    │    └─────── 월 (1~12, *는 매월)
│    │    └──────────── 일 (1~31, *는 매일)
│    └───────────────── 시 (0~23, *는 매시간)
└────────────────────── 분 (0~59, */5는 5분마다)

# crontab 편집 화면 열기 (처음이면 편집기 선택하라고 나올 수 있음 — nano 추천)
crontab -e

*/5 * * * * /root/check_containers.sh --json | curl -s -X POST -H "Content-Type: application/json" -d @- "YOUR_N8N_URL" > /dev/null 2>&1

#!/bin/bash
# cron 환경에서도 docker, curl 명령어를 찾을 수 있도록 PATH 명시
export PATH=/usr/local/sbin:/usr/local/bin:/usr/sbin:/usr/bin:/sbin:/bin

# 등록된 crontab 목록 확인
crontab -l

# cron이 제대로 도는지 확인하고 싶으면, 결과를 파일로도 남기게 바꿔서 테스트
*/5 * * * * /root/check_containers.sh --json >> /var/log/check_containers.log 2>&1

# 잠시 후 로그 확인
tail -20 /var/log/check_containers.log

// cron이 보낸 데이터 꺼내기 (Webhook은 보통 .body 안에 실제 내용이 들어있음)
const input = $input.first().json;
const data = input.body || input;

const summary = data.summary || { ok: 0, fail: 0 };
const checks = data.checks || [];
const hostname = data.hostname || 'unknown';

// status가 FAIL인 항목만 골라내기
const fails = checks.filter(c => c.status === 'FAIL');
const shouldAlert = fails.length > 0;

let message = `🚨 *컨테이너 상태 알림*\n\`${hostname}\`\n정상 ${summary.ok} / 실패 ${summary.fail}\n\n`;
for (const f of fails) {
  message += `• ${f.check} — ${f.detail}\n`;
}

return [{ json: { shouldAlert, message } }];

{
  "name": "컨테이너 상태 모니터링",
  "nodes": [
    {
      "parameters": { "httpMethod": "POST", "path": "container-status",
        "responseMode": "onReceived", "responseData": "success", "options": {} },
      "id": "n1", "name": "Webhook",
      "type": "n8n-nodes-base.webhook", "typeVersion": 2, "position": [-440, 0]
    },
    {
      "parameters": { "jsCode": "/* STEP 05의 Code 노드 본문과 동일 */" },
      "id": "n2", "name": "메시지 생성",
      "type": "n8n-nodes-base.code", "typeVersion": 2, "position": [-220, 0]
    },
    {
      "parameters": { "conditions": { "options": { "caseSensitive": true,
        "leftValue": "", "typeValidation": "loose" },
        "conditions": [{ "id": "c1", "leftValue": "={{ $json.shouldAlert }}",
          "rightValue": true, "operator": { "type": "boolean", "operation": "true" } }],
        "combinator": "and" }, "options": {} },
      "id": "n3", "name": "IF",
      "type": "n8n-nodes-base.if", "typeVersion": 2, "position": [0, 0]
    },
    {
      "parameters": { "resource": "message", "operation": "sendMessage",
        "chatId": "YOUR_CHAT_ID", "text": "={{ $json.message }}",
        "additionalFields": { "parse_mode": "Markdown" } },
      "id": "n4", "name": "텔레그램 발송",
      "type": "n8n-nodes-base.telegram", "typeVersion": 1.2, "position": [220, -50],
      "credentials": { "telegramApi": { "id": "YOUR_CRED_ID", "name": "Telegram account" } }
    }
  ],
  "connections": {
    "Webhook": { "main": [[{ "node": "메시지 생성", "type": "main", "index": 0 }]] },
    "메시지 생성": { "main": [[{ "node": "IF", "type": "main", "index": 0 }]] },
    "IF": { "main": [[{ "node": "텔레그램 발송", "type": "main", "index": 0 }], []] }
  },
  "active": false,
  "settings": { "executionOrder": "v1" }
}

# 1. 정상 상태에서 한 번 전송 — 텔레그램 조용해야 정상 (FAIL 없으니까)
~/check_containers.sh --json | curl -s -X POST -H "Content-Type: application/json" -d @- "여기에_n8n_Production_URL"

# 2. 의도적으로 하나 정지시켜서 알림이 오는지 확인
docker stop example-cache

# 3. 다시 전송 — 이번엔 텔레그램이 와야 함
~/check_containers.sh --json | curl -s -X POST -H "Content-Type: application/json" -d @- "여기에_n8n_Production_URL"

# 4. 확인 후 복구
docker start example-cache