n8n Workflow: การตรวจสอบและแจ้งเตือนความผิดปกติของ AI API

การเรียกใช้ AI API ใน production environment นั้น ความน่าเชื่อถือเป็นสิ่งสำคัญมาก ในบทความนี้เราจะมาดูวิธีการตั้งค่า monitoring และ alerting สำหรับ n8n workflow ที่ใช้ AI API อย่างมีประสิทธิภาพ พร้อมทั้งแนะนำบริการ AI API ที่คุ้มค่าอย่าง HolySheep AI

ตารางเปรียบเทียบบริการ AI API

เกณฑ์	HolySheep AI	API อย่างเป็นทางการ	บริการ Relay อื่นๆ
ราคา (GPT-4)	$8/MTok	$60/MTok	$15-30/MTok
ราคา (Claude)	$15/MTok	$75/MTok	$20-40/MTok
ความหน่วง (Latency)	<50ms	100-300ms	80-200ms
การชำระเงิน	WeChat/Alipay	บัตรเครดิต	หลากหลาย
เครดิตฟรี	มีเมื่อลงทะเบียน	$5 ฟรี	แตกต่างกัน

ทำไมต้องตรวจสอบ AI API Call

จากประสบการณ์ในการ deploy n8n workflow หลายสิบตัวพบว่า ปัญหาที่พบบ่อยที่สุดคือ:

• API rate limit - เรียกใช้เกินโควต้าที่กำหนด
• Timeout - request ใช้เวลานานเกินไปจนหมดเวลา
• Invalid API key - key หมดอายุหรือไม่ถูกต้อง
• Response parsing error - รูปแบบข้อมูลตอบกลับไม่ตรงตามที่คาดหวัง
• Balance ไม่เพียงพอ - เครดิตในบัญชีหมด

การตั้งค่า n8n Workflow สำหรับ Monitoring

1. สร้าง Error Handler Workflow

{
  "name": "AI API Error Handler",
  "nodes": [
    {
      "parameters": {
        "rule": {
          "junctions": [
            {
              "conditions": {
                "options": {
                  "caseSensitive": true,
                  "leftValue": "",
                  "typeValidation": "strict"
                },
                "conditions": [
                  {
                    "id": "error-condition",
                    "leftValue": "={{ $json.error }}",
                    "rightValue": "",
                    "operator": {
                      "type": "string",
                      "operation": "isNotEmpty"
                    }
                  }
                ],
                "combinator": "and"
              },
              "output": "Error Detected"
            }
          ]
        }
      },
      "id": "error-detector",
      "name": "Error Check",
      "type": "n8n-nodes-base.if",
      "typeVersion": 1,
      "position": [250, 300]
    },
    {
      "parameters": {
        "webhookUrl": "https://notify.example.com/webhook"
      },
      "id": "discord-notifier",
      "name": "Discord Alert",
      "type": "n8n-nodes-base.httpRequest",
      "typeVersion": 3,
      "position": [450, 300]
    }
  ],
  "connections": {
    "Error Check": {
      "main": [
        [{
          "node": "Discord Alert",
          "type": "main",
          "index": 0
        }]
      ]
    }
  },
  "settings": {
    "executionOrder": "v1"
  }
}

2. ตัวอย่างการเรียก HolySheep API พร้อม Error Handling

// n8n Code Node - AI API Call with Monitoring
const axios = require('axios');

// Configuration
const BASE_URL = 'https://api.holysheep.ai/v1';
const API_KEY = $env.HOLYSHEEP_API_KEY; // ตั้งค่าใน n8n credentials

async function callAIWithRetry(messages, maxRetries = 3) {
  const startTime = Date.now();
  let lastError = null;
  
  for (let attempt = 1; attempt <= maxRetries; attempt++) {
    try {
      const response = await axios.post(
        ${BASE_URL}/chat/completions,
        {
          model: "gpt-4.1",
          messages: messages,
          temperature: 0.7,
          max_tokens: 1000
        },
        {
          headers: {
            'Authorization': Bearer ${API_KEY},
            'Content-Type': 'application/json'
          },
          timeout: 30000 // 30 วินาที timeout
        }
      );
      
      const latency = Date.now() - startTime;
      console.log(✅ API Call Success - Latency: ${latency}ms);
      
      return {
        success: true,
        data: response.data,
        latency: latency,
        attempt: attempt
      };
      
    } catch (error) {
      lastError = error;
      console.error(❌ Attempt ${attempt} failed:, error.message);
      
      // ตรวจสอบประเภทข้อผิดพลาด
      if (error.response) {
        const { status, data } = error.response;
        console.error(Status: ${status}, Error:, data);
        
        // Rate limit - รอแล้วลองใหม่
        if (status === 429) {
          const retryAfter = error.response.headers['retry-after'] || 60;
          console.log(Rate limited. Waiting ${retryAfter}s...);
          await sleep(retryAfter * 1000);
          continue;
        }
        
        // Authentication error - ไม่ต้องลองใหม่
        if (status === 401 || status === 403) {
          throw new Error('API Authentication Failed - Check your API key');
        }
      }
      
      // Timeout - ลองใหม่
      if (error.code === 'ECONNABORTED') {
        console.log('Request timeout. Retrying...');
        await sleep(2000 * attempt);
        continue;
      }
    }
  }
  
  throw new Error(All ${maxRetries} attempts failed: ${lastError.message});
}

function sleep(ms) {
  return new Promise(resolve => setTimeout(resolve, ms));
}

// Main execution
const messages = [
  { role: "system", content: "You are a helpful assistant." },
  { role: "user", content: $input.item.json.prompt }
];

const result = await callAIWithRetry(messages);

return [{
  json: {
    success: result.success,
    response: result.data.choices[0].message.content,
    latency_ms: result.latency,
    attempts: result.attempt,
    timestamp: new Date().toISOString()
  }
}];

3. Dashboard สำหรับติดตามสถานะ

{
  "nodes": [
    {
      "parameters": {
        "rule": {
          "interval": [
            {
              "field": "cronExpression",
              "expression": "*/5 * * * *"
            }
          ]
        }
      },
      "id": "schedule-trigger",
      "name": "Every 5 Minutes",
      "type": "n8n-nodes-base.scheduleTrigger",
      "typeVersion": 1.1,
      "position": [100, 300]
    },
    {
      "parameters": {
        "url": "https://api.holysheep.ai/v1/usage",
        "options": {
          "response": {
            "response": {
              "responseFormat": "json"
            }
          }
        },
        "method": "GET"
      },
      "id": "check-balance",
      "name": "Check Balance",
      "type": "n8n-nodes-base.httpRequest",
      "typeVersion": 4.1,
      "position": [300, 300]
    },
    {
      "parameters": {
        "conditions": {
          "options": {
            "caseSensitive": true,
            "leftValue": "",
            "typeValidation": "strict"
          },
          "conditions": [
            {
              "id": "low-balance",
              "leftValue": "={{ $json.remaining }}",
              "rightValue": 1000,
              "operator": {
                "type": "number",
                "operation": "less"
              }
            }
          ],
          "combinator": "and"
        },
        "options": {}
      },
      "id": "balance-check",
      "name": "Low Balance Check",
      "type": "n8n-nodes-base.if",
      "typeVersion": 2,
      "position": [500, 300]
    },
    {
      "parameters": {
        "webhookUrl": "={{ $env.SLACK_WEBHOOK }}",
        "method": "POST",
        "bodyParameters": {
          "parameters": [
            {
              "name": "text",
              "value": "⚠️ HolySheep AI Balance ต่ำกว่า 1,000 credits! กรุณาเติมเงิน"
            }
          ]
        }
      },
      "id": "slack-alert",
      "name": "Slack Alert",
      "type": "n8n-nodes-base.httpRequest",
      "typeVersion": 4.1,
      "position": [700, 250]
    }
  ]
}

การตั้งค่า Prometheus Metrics สำหรับ Production

# prometheus.yml configuration for n8n AI monitoring
global:
  scrape_interval: 15s
  evaluation_interval: 15s

scrape_configs:
  - job_name: 'n8n-ai-api'
    static_configs:
      - targets: ['n8n-server:5678']
    metrics_path: '/metrics'
    relabel_configs:
      - source_labels: [__address__]
        target_label: instance
        replacement: 'ai-api-monitor'

Alert rules for AI API monitoring
groups:
  - name: ai_api_alerts
    rules:
      - alert: HighAPILatency
        expr: ai_api_latency_seconds > 5
        for: 5m
        labels:
          severity: warning
        annotations:
          summary: "AI API Latency สูงกว่าปกติ"
          
      - alert: HighErrorRate
        expr: rate(ai_api_errors_total[5m]) > 0.1
        for: 2m
        labels:
          severity: critical
        annotations:
          summary: "อัตราข้อผิดพลาด AI API สูง"
          
      - alert: LowBalance
        expr: ai_api_balance_remaining < 1000
        for: 1m
        labels:
          severity: warning
        annotations:
          summary: "เครดิต AI API ใกล้หมด"

ข้อผิดพลาดที่พบบ่อยและวิธีแก้ไข

กรณีที่ 1: 401 Unauthorized - Invalid API Key

// ❌ ข้อผิดพลาดที่พบ
// Error: Request failed with status code 401
// {"error":{"message":"Invalid API key provided","type":"invalid_request_error"}}

// ✅ วิธีแก้ไข - ตรวจสอบและตั้งค่า API key อย่างถูกต้อง

// 1. ตรวจสอบว่าใช้ base_url ที่ถูกต้อง
const BASE_URL = 'https://api.holysheep.ai/v1'; // ต้องเป็น URL นี้เท่านั้น

// 2. สร้าง Credentials ใน n8n
// Settings > Credentials > New > API Key
// ตั้งชื่อ: HolySheep API
// กรอก API Key ที่ได้จาก https://www.holysheep.ai/register

// 3. ใช้ credentials ใน HTTP Request Node
// Headers > Authorization = Bearer {{ $credentials.holysheepApi.apiKey }}

// 4. หรือใน Code Node
const API_KEY = $credentials.holysheepApi.apiKey;

กรณีที่ 2: 429 Rate Limit Exceeded

// ❌ ข้อผิดพลาดที่พบ
// Error: Request failed with status code 429
// {"error":{"message":"Rate limit exceeded","type":"rate_limit_error"}}

// ✅ วิธีแก้ไข - ใช้ Exponential Backoff

async function callWithBackoff(apiCall, maxRetries = 5) {
  for (let i = 0; i < maxRetries; i++) {
    try {
      return await apiCall();
    } catch (error) {
      if (error.response?.status === 429) {
        // คำนวณเวลารอแบบ exponential
        const retryDelay = Math.min(1000 * Math.pow(2, i), 32000);
        const jitter = Math.random() * 1000;
        
        console.log(⏳ Rate limited. Retrying in ${retryDelay + jitter}ms...);
        await sleep(retryDelay + jitter);
        
        // ลองเรียก balance API เพื่อตรวจสอบสถานะ
        await checkAPIBalance();
      } else {
        throw error;
      }
    }
  }
  throw new Error('Max retries exceeded');
}

// ใช้งาน
const result = await callWithBackoff(() => 
  axios.post(${BASE_URL}/chat/completions, payload, config)
);

กรณีที่ 3: Timeout และ Connection Error

// ❌ ข้อผิดพลาดที่พบ
// Error: connect ECONNREFUSED
// Error: Request timeout of 30000ms exceeded

// ✅ วิธีแก้ไข - เพิ่ม retry logic และ timeout ที่เหมาะสม

const axios = require('axios');

// สร้าง axios instance ที่ตั้งค่า timeout อย่างถูกต้อง
const apiClient = axios.create({
  baseURL: 'https://api.holysheep.ai/v1',
  timeout: 45000, // 45 วินาที - เผื่อเวลา network latency
  headers: {
    'Content-Type': 'application/json',
    'Authorization': Bearer ${API_KEY}
  }
});

// เพิ่ม retry interceptor
apiClient.interceptors.response.use(
  response => response,
  async error => {
    const config = error.config;
    
    // ตรวจสอบว่าเป็น timeout หรือไม่
    if (error.code === 'ECONNABORTED' || error.code === 'ETIMEDOUT') {
      if (!config._retryCount) {
        config._retryCount = 0;
      }
      config._retryCount++;
      
      if (config._retryCount <= 3) {
        console.log(🔄 Retrying request (attempt ${config._retryCount})...);
        return apiClient(config);
      }
    }
    
    return Promise.reject(error);
  }
);

// กรณีที่ API ล่ม - fallback ไปใช้ model อื่น
async function callAIFallback(prompt) {
  const models = [
    { name: 'gpt-4.1', fallback: 'gpt-3.5-turbo' },
    { name: 'claude-sonnet-4.5', fallback: 'claude-3-haiku' }
  ];
  
  for (const model of models) {
    try {
      const response = await apiClient.post('/chat/completions', {
        model: model.name,
        messages: [{ role: 'user', content: prompt }]
      });
      return response.data;
    } catch (error) {
      console.error(${model.name} failed, trying ${model.fallback}...);
      continue;
    }
  }
  
  throw new Error('All AI models unavailable');
}

กรณีที่ 4: Response Parsing Error

// ❌ ข้อผิดพลาดที่พบ
// TypeError: Cannot read properties of undefined (reading 'content')
// หรือ response ที่ได้มีโครงสร้างไม่ตรงตาม expected

// ✅ วิธีแก้ไข - ตรวจสอบ response structure อย่างปลอดภัย

function extractMessageContent(response) {
  // ตรวจสอบว่า response มีโครงสร้างที่ถูกต้อง
  if (!response) {
    throw new Error('Empty response received');
  }
  
  if (!response.data) {
    throw new Error('Invalid response format - missing data field');
  }
  
  const data = response.data;
  
  // ตรวจสอบ choices array
  if (!Array.isArray(data.choices) || data.choices.length === 0) {
    throw new Error('No choices in response');
  }
  
  const choice = data.choices[0];
  
  // ตรวจสอบ message object
  if (!choice.message) {
    throw new Error('No message in choice');
  }
  
  if (!choice.message.content) {
    throw new Error('Empty message content');
  }
  
  return choice.message.content.trim();
}

// ใช้ optional chaining สำหรับ safe access
function safeParseResponse(response) {
  try {
    const content = response?.data?.choices?.[0]?.message?.content;
    
    if (!content) {
      return {
        success: false,
        error: 'Invalid response structure',
        raw: response
      };
    }
    
    return {
      success: true,
      content: content,
      model: response?.data?.model,
      usage: response?.data?.usage
    };
  } catch (error) {
    return {
      success: false,
      error: error.message,
      raw: response
    };
  }
}

สรุป

การตรวจสอบและแจ้งเตือนความผิดปกติของ AI API ใน n8n workflow นั้น เป็นสิ่งจำเป็นอย่างยิ่งสำหรับ production environment โดยหลักการสำคัญคือ:

• Retry with Backoff - ลองใหม่อัตโนมัติเมื่อเกิดข้อผิดพลาดชั่วคราว
• Timeout ที่เหมาะสม - ตั้งค่า timeout ให้เพียงพอสำหรับ network latency
• Error Classification - แยกประเภทข้อผิดพลาดเพื่อจัดการที่ถูกต้อง
• Monitoring Dashboard - ติดตามสถานะและ balance อย่างสม่ำเสมอ
• Fallback Strategy - เตรียม model สำรองเมื่อ model หลักไม่พร้อมใช้งาน

การใช้ HolySheep AI ช่วยลดต้นทุนได้มากกว่า 85% เมื่อเทียบกับการใช้ API อย่างเป็นทางการ พร้อมทั้งความหน่วงต่ำกว่า 50ms และรองรับการชำระเงินผ่าน WeChat/Alipay ทำให้เหมาะสำหรับผู้ใช้ในเอเชีย

👉 สมัคร HolySheep AI — รับเครดิตฟรีเมื่อลงทะเบียน