การปฏิวัติ n8n MCP: เชื่อมต่อ AI Agents เข้ากับ Production Workflows ในปี 2026

{
  "jsonrpc": "2.0",
  "id": 1,
  "method": "tools/call",
  "params": {
    "name": "n8n:execute_workflow",
    "arguments": {
      "workflow_id": "12345",
      "data": {
        "email": "[email protected]",
        "subject": "Weekly Report"
      }
    }
  }
}

{
  "jsonrpc": "2.0",
  "id": 1,
  "result": {
    "content": [
      {
        "type": "text",
        "text": "Workflow executed successfully. Execution ID: exec_abc123"
      }
    ],
    "isError": false
  }
}

┌─────────────────────────────────────────────────────────────┐
│                      AI Agent Client                         │
│  (Claude Desktop, Cursor, ChatGPT, Custom MCP Clients)      │
└──────────────────────┬──────────────────────────────────────┘
                       │ MCP Protocol (stdio / HTTP/SSE)
                       ▼
┌─────────────────────────────────────────────────────────────┐
│                    n8n MCP Server                          │
│  ┌─────────────┐  ┌─────────────┐  ┌─────────────────────┐ │
│  │   Schema   │  │   Tools    │  │     Resources       │ │
│  │  Registry  │  │  Registry   │  │      Provider       │ │
│  └─────────────┘  └─────────────┘  └─────────────────────┘ │
└──────────────────────┬──────────────────────────────────────┘
                       │
        ┌──────────────┼──────────────┐
        ▼              ▼              ▼
┌──────────────┐ ┌──────────┐ ┌──────────────┐
│   Workflow   │ │ Execution│ │  Credential  │
│    Engine    │ │  Engine  │ │    Store     │
└──────────────┘ └──────────┘ └──────────────┘

# เปิดใช้งาน MCP Server
N8N_MCP_SERVER_ENABLED=true

# โหมด Transport: 'stdio' (ค่าเริ่มต้น) หรือ 'http'
N8N_MCP_TRANSPORT=stdio

# การตั้งค่า HTTP Transport (หากใช้โหมด HTTP)
N8N_MCP_HTTP_PORT=5679
N8N_MCP_HTTP_PATH=/mcp

# การตรวจสอบสิทธิ์สำหรับโหมด HTTP
N8N_MCP_AUTH_TOKEN=your-secure-random-token-here

# ระดับ Logging: 'debug', 'info', 'warn', 'error'
N8N_MCP_LOG_LEVEL=info

# การจำกัดอัตรา
N8N_MCP_RATE_LIMIT_REQUESTS=100
N8N_MCP_RATE_LIMIT_WINDOW=60000  # มิลลิวินาที

# ขีดจำกัดการดำเนินการ Workflow ผ่าน MCP
N8N_MCP_MAX_CONCURRENT_EXECUTIONS=50
N8N_MCP_EXECUTION_TIMEOUT=300000  # 5 นาที

version: '3.8'
services:
  n8n:
    image: n8nio/n8n:1.50.0
    environment:
      - N8N_MCP_SERVER_ENABLED=true
      - N8N_MCP_TRANSPORT=http
      - N8N_MCP_HTTP_PORT=5679
      - N8N_MCP_AUTH_TOKEN=${MCP_AUTH_TOKEN}
      - N8N_BASIC_AUTH_ACTIVE=true
      - N8N_BASIC_AUTH_USER=${N8N_USER}
      - N8N_BASIC_AUTH_PASSWORD=${N8N_PASSWORD}
    ports:
      - "5678:5678"  # n8n Web UI
      - "5679:5679"  # MCP HTTP Endpoint
    volumes:
      - ~/.n8n:/home/node/.n8n
    networks:
      - n8n-network

# ตรวจสอบว่า MCP Server กำลังทำงาน
n8n mcp:status

# ผลลัพธ์ที่คาดหวัง:
# MCP Server Status: Active
# Transport: stdio
# Connected Clients: 0
# Uptime: 2h 34m

curl -X POST http://localhost:5679/mcp \
  -H "Authorization: Bearer your-token" \
  -H "Content-Type: application/json" \
  -d '{
    "jsonrpc": "2.0",
    "method": "tools/list",
    "id": 1
  }'

~/Library/Application Support/Claude/claude_desktop_config.json

%APPDATA%\Claude\claude_desktop_config.json

~/.config/Claude/claude_desktop_config.json

{
  "mcpServers": {
    "n8n-local": {
      "command": "n8n",
      "args": ["mcp:start"],
      "env": {
        "N8N_MCP_SERVER_ENABLED": "true"
      }
    }
  }
}

{
  "mcpServers": {
    "n8n-cloud": {
      "url": "https://your-instance.n8n.cloud/mcp",
      "headers": {
        "Authorization": "Bearer your-token-here"
      }
    }
  }
}

ผู้ใช้: สร้าง Workflow n8n ที่ส่งข้อความ Slack ให้ฉันเมื่อมีการเพิ่มแถวใหม่ 
ใน Google Sheet ของฉัน

Claude: ฉันจะสร้าง Workflow นั้นให้คุณ ให้ฉันตั้งค่า Trigger และ Action Nodes

[Claude ใช้เครื่องมือ create_workflow ด้วยโครงสร้างต่อไปนี้]

สร้าง Workflow สำเร็จแล้ว! 

ID: 67890
ชื่อ: "Google Sheets to Slack Notification"
Nodes: 
  - Google Sheets Trigger (ตรวจสอบทุกนาที)
  - Slack Message Send
  - Set Node สำหรับการจัดรูปแบบข้อความ

Workflow ถูกบันทึกแล้วแต่ยังไม่เปิดใช้งาน คุณต้องการให้ฉันเปิดใช้งานหรือไม่?

ผู้ใช้: Workflow "Customer Onboarding" ของฉันล้มเหลว 3 ครั้งในวันนี้ 
คุณตรวจสอบได้ไหมว่าทำไม?

Claude: ให้ฉันตรวจสอบ Executions ที่ล้มเหลวนั้นสำหรับคุณ

[Claude ใช้เครื่องมือ get_execution_logs พร้อมตัวกรองสำหรับสถานะผิดพลาด]

ฉันพบปัญหาแล้ว Workflow กำลังล้มเหลวที่ Node "Send Welcome Email" 
เพราะ Credentials SMTP กำลังส่งคืนข้อผิดพลาดการตรวจสอบสิทธิ์ 
ข้อความผิดพลาดระบุว่า: "535 5.7.8 Authentication credentials invalid"

คำแนะนำ:
1. อัปเดต Credentials SMTP ใน n8n
2. ตรวจสอบว่าผู้ให้บริการอีเมลของคุณต้องการรหัสผ่านเฉพาะแอปหรือไม่
3. ยืนยันว่าที่อยู่อีเมลได้รับอนุญาตให้ส่ง

คุณต้องการให้ฉันช่วยอัปเดตการกำหนดค่า Credential หรือไม่?

{
  "name": "n8n-workflows",
  "command": "n8n mcp:start --transport stdio",
  "transport": "stdio"
}

{
  "name": "n8n-cloud",
  "url": "https://your-instance.n8n.cloud/mcp",
  "headers": {
    "Authorization": "Bearer your-token"
  }
}

นักพัฒนา: ฉันต้องสร้าง API Endpoint สำหรับ Customer Signups และ 
Workflow n8n ที่สอดคล้องกันซึ่งส่งอีเมลต้อนรับและสร้างโปรไฟล์ 
ของพวกเขาใน CRM ของเรา

Cursor: ฉันจะช่วยคุณสร้างทั้ง API Endpoint และ Workflow n8n 
ให้ฉันเริ่มต้นด้วยการสร้าง Workflow

[Cursor ใช้ MCP Tool สำหรับ create_workflow]

สร้าง Workflow พร้อม:
- Webhook Trigger (รอการเรียกจาก API ของคุณ)
- Email Sending Node พร้อม Template
- CRM Integration สำหรับการสร้างโปรไฟล์
- Error Handling และ Retry Logic

ตอนนี้ให้ฉันสร้างโค้ด API Endpoint:

[Cursor สร้างโค้ด FastAPI/Python]

```python
from fastapi import FastAPI, HTTPException
import httpx

app = FastAPI()

@app.post("/api/customers/signup")
async def customer_signup(email: str, name: str):
    try:
        # ทริกเกอร์ Workflow n8n
        async with httpx.AsyncClient() as client:
            response = await client.post(
                "https://your-instance.n8n.cloud/webhook/signup",
                json={"email": email, "name": name}
            )
            return {"status": "success", "workflow_id": response.json()["executionId"]}
    except Exception as e:
        raise HTTPException(status_code=500, detail=str(e))

### แนวปฏิบัติที่ดีที่สุดสำหรับ Cursor + n8n MCP

1. **ใช้ไฟล์ .cursorrules**: เพิ่มบริบทเฉพาะของ n8n

2. **การผสานรวม Version Control**: ส่งออก Workflows เป็น JSON และ Commit พร้อมกับ Code:
```bash
# เพิ่มใน Scripts package.json
"n8n:export": "n8n export:workflow --all --output ./workflows/"

{
  "type": "object",
  "required": ["customer_email", "order_id"],
  "properties": {
    "customer_email": {
      "type": "string",
      "format": "email",
      "description": "ที่อยู่อีเมลลูกค้าสำหรับการแจ้งเตือน"
    },
    "order_id": {
      "type": "string",
      "description": "ตัวระบุคำสั่งซื้อที่ไม่ซ้ำกัน"
    },
    "priority": {
      "type": "string",
      "enum": ["low", "normal", "high"],
      "default": "normal",
      "description": "ระดับความสำคัญของการประมวลผล"
    }
  }
}

{
  "status": "success|error",
  "message": "คำอธิบายผลลัพธ์ที่อ่านได้โดยมนุษย์",
  "data": {
    "reference_id": "ตัวระบุการติดตาม",
    "processing_time": "ระยะเวลาเป็นมิลลิวินาที"
  }
}

┌─────────────┐     ┌─────────────┐     ┌─────────────┐
│   Agent A   │     │   Agent B   │     │   Agent C   │
│  (Research) │     │ (Analysis)  │     │  (Action)   │
└──────┬──────┘     └──────┬──────┘     └──────┬──────┘
       │                   │                   │
       └───────────────────┼───────────────────┘
                           │
                    ┌───────▼────────┐
                    │   n8n MCP      │
                    │  Orchestrator  │
                    └───────┬────────┘
                            │
              ┌─────────────┼─────────────┐
              ▼             ▼             ▼
        ┌─────────┐   ┌─────────┐   ┌─────────┐
        │ Workflow│   │ Workflow│   │ Workflow│
        │   #1    │   │   #2    │   │   #3    │
        └─────────┘   └─────────┘   └─────────┘

{
  "name": "Multi-Agent Task Router",
  "nodes": [
    {
      "type": "n8n-nodes-base.webhook",
      "name": "Agent Request",
      "path": "agent-router"
    },
    {
      "type": "n8n-nodes-base.switch",
      "name": "Route by Agent Role",
      "rules": {
        "rules": [
          {
            "value": "research",
            "output": 0
          },
          {
            "value": "analysis",
            "output": 1
          },
          {
            "value": "action",
            "output": 2
          }
        ]
      }
    },
    {
      "type": "n8n-nodes-base.executeWorkflow",
      "name": "Run Research Workflow",
      "workflowId": "wf-research-template"
    }
  ]
}

// MCP Tool Call สำหรับ create_workflow
{
  "name": "create_workflow",
  "arguments": {
    "name": "Generated-Social-Campaign-2026-06-18",
    "description": "Workflow ที่สร้างอัตโนมัติสำหรับ Social Media Campaign",
    "nodes": [
      // สร้างแบบไดนามิกตามความต้องการของ Campaign
    ],
    "tags": ["generated", "campaign", "temporary"]
  }
}

┌──────────────┐
│   Execute    │
│   Workflow   │
└──────┬───────┘
       │
       ▼
┌──────────────┐
│  Analyze     │
│  Performance │
└──────┬───────┘
       │
       ▼
┌──────────────┐
│  Identify    │
│  Bottlenecks │
└──────┬───────┘
       │
       ▼
┌──────────────┐
│  Suggest     │
│  Improvements│
└──────┬───────┘
       │
       ▼
┌──────────────┐
│  Update      │
│  Workflow    │
└──────────────┘

// Workflow Error Handling ที่ใช้ MCP
{
  "name": "AI-Driven Error Recovery",
  "nodes": [
    {
      "type": "n8n-nodes-base.executeCommand",
      "name": "Get Failed Executions",
      "command": "n8n list:executions --status=error --limit=10 --json"
    },
    {
      "type": "n8n-nodes-base.code",
      "name": "Classify Errors",
      "jsCode": "const executions = $input.all();\nreturn executions.map(exec => {\n  const error = exec.json.error;\n  let category = 'unknown';\n  let autoRecoverable = false;\n  \n  if (error.message.includes('ETIMEDOUT')) {\n    category = 'timeout';\n    autoRecoverable = true;\n  } else if (error.message.includes('ECONNREFUSED')) {\n    category = 'connection';\n    autoRecoverable = true;\n  }\n  \n  return { json: { ...exec.json, category, autoRecoverable } };\n});"
    }
  ]
}

# nginx.conf พร้อม Security Headers
server {
    listen 5679 ssl http2;
    server_name n8n-mcp.yourdomain.com;

    ssl_certificate /etc/ssl/certs/n8n.crt;
    ssl_certificate_key /etc/ssl/private/n8n.key;
    ssl_protocols TLSv1.3;
    ssl_ciphers 'TLS_AES_256_GCM_SHA384:TLS_CHACHA20_POLY1305_SHA256';

    location /mcp {
        limit_req zone=mcp_limit burst=20 nodelay;
        
        allow 10.0.0.0/8;
        allow 172.16.0.0/12;
        deny all;

        proxy_pass http://n8n:5679/mcp;
        proxy_http_version 1.1;
        
        add_header X-Frame-Options "SAMEORIGORIN" always;
        add_header X-Content-Type-Options "nosniff" always;
        add_header X-XSS-Protection "1; mode=block" always;
    }
}

#!/bin/bash
# rotate-mcp-token.sh

OLD_TOKEN=$(grep N8N_MCP_AUTH_TOKEN .env | cut -d= -f2)
NEW_TOKEN=$(openssl rand -hex 32)

# อัปเดต n8n
sed -i "s/N8N_MCP_AUTH_TOKEN=.*/N8N_MCP_AUTH_TOKEN=$NEW_TOKEN/" .env

# อัปเดต Clients
docker-compose restart n8n

echo "$(date): Rotated MCP token" >> /var/log/n8n-mcp-audit.log

{
  "workflowId": "sensitive-hr-workflow",
  "permissions": {
    "mcp_clients": {
      "allow": ["hr-assistant-claude"],
      "deny": ["general-purpose-claude"]
    }
  }
}

n8n-mcp-executor:
  image: n8nio/n8n:1.50.0
  networks:
    - mcp-isolated
    - no-external-internet
  security_opt:
    - no-new-privileges:true
  read_only: true

{
  "logging": {
    "level": "debug",
    "output": "console",
    "mcp": {
      "audit": {
        "enabled": true,
        "includeRequestBody": false,
        "includeResponseBody": false,
        "retentionDays": 90
      }
    }
  }
}

// MCP Tool Response สำหรับ credentials/list
{
  "credentials": [
    {
      "id": "creds-123",
      "name": "Production Database",
      "type": "postgres",
      "nodeAccess": ["postgres", "timescaledb"],
      "lastUsed": "2026-06-17T15:30:00Z"
    }
  ]
}

{
  "nodes": [
    {
      "type": "n8n-nodes-base.set",
      "name": "Mask PII",
      "values": {
        "string": [
          {
            "name": "email_masked",
            "value": "={{ $json.email.replace(/(.{2}).*(@.*)/, '$1***$2') }}"
          }
        ]
      }
    }
  ]
}

n8n-api:
  image: n8nio/n8n:1.50.0
  environment:
    - N8N_MCP_SERVER_ENABLED=false
  command: webhook
  deploy:
    replicas: 2

n8n-mcp:
  image: n8nio/n8n:1.50.0
  environment:
    - N8N_MCP_SERVER_ENABLED=true
    - N8N_MCP_TRANSPORT=http
    - N8N_MCP_HTTP_PORT=5679
    - N8N_MCP_AUTH_TOKEN=${MCP_TOKEN}
  command: mcp:start
  deploy:
    replicas: 3

n8n-worker:
  image: n8nio/n8n:1.50.0
  environment:
    - N8N_MCP_SERVER_ENABLED=false
  command: worker
  deploy:
    replicas: 5

┌─────────────────┐    ┌─────────────────┐    ┌─────────────────┐
│  EU Region      │    │  US Region      │    │  APAC Region    │
│  ┌───────────┐  │    │  ┌───────────┐  │    │  ┌───────────┐  │
│  │ n8n MCP   │  │    │  │ n8n MCP   │  │    │  │ n8n MCP   │  │
│  │  Server   │  │    │  │  Server   │  │    │  │  Server   │  │
│  │(Frankfurt)│  │    │  │ (Virginia)│  │    │  │(Singapore)│  │
└────────┼────────┘    └────────┼────────┘    └────────┼────────┘
         │                      │                      │
         └──────────────────────┼──────────────────────┘
                                │
                         ┌──────┴──────┐
                         │ Global Load │
                         │   Balancer  │
                         └─────────────┘

# Terraform สำหรับ AWS Deployment
resource "aws_lb" "n8n_mcp" {
  name               = "n8n-mcp-lb"
  internal           = true
  load_balancer_type = "application"
  
  health_check {
    path                = "/health"
    port                = 5678
    protocol            = "HTTP"
    healthy_threshold   = 2
    unhealthy_threshold = 3
    timeout             = 5
    interval            = 30
  }
}

- name: n8n_mcp_requests_total
  help: คำขอ MCP ทั้งหมดตาม Tool
  type: counter
  labels: [tool, status]

- name: n8n_mcp_request_duration_seconds
  help: Latency ของคำขอ MCP
  type: histogram

- name: n8n_mcp_active_connections
  help: จำนวนการเชื่อมต่อ MCP ที่ใช้งานอยู่
  type: gauge

groups:
  - name: n8n_mcp_alerts
    rules:
      - alert: MCPHighErrorRate
        expr: rate(n8n_mcp_requests_total{status="error"}[5m]) > 0.1
        for: 5m
        labels:
          severity: warning
        annotations:
          summary: "ตรวจพบอัตราข้อผิดพลาด MCP สูง"
          
      - alert: MCPConnectionSpike
        expr: n8n_mcp_active_connections > 100
        for: 2m
        labels:
          severity: critical
        annotations:
          summary: "จำนวนการเชื่อมต่อ MCP ผิดปกติ"

#!/bin/bash
# backup-mcp-config.sh

BACKUP_DIR="/backups/n8n/$(date +%Y%m%d)"
mkdir -p $BACKUP_DIR

# สำรอง Workflow Definitions
docker exec n8n n8n export:workflow --all --output /tmp/workflows.json
docker cp n8n:/tmp/workflows.json $BACKUP_DIR/

# สำรอง MCP Configuration
docker exec n8n cat /home/node/.n8n/config | grep -i mcp > $BACKUP_DIR/mcp-config.txt

# Sync ไปยัง S3
aws s3 sync $BACKUP_DIR s3://n8n-backups/mcp/$(date +%Y%m%d)/

# ล้าง Backups เก่า (เก็บ 30 วัน)
find /backups/n8n -type d -mtime +30 -exec rm -rf {} +

// MCP v1 (ปัจจุบัน)
{
  "jsonrpc": "2.0",
  "method": "tools/list",
  "id": 1
}

// MCP v2 (กำลังจะมาถึง)
{
  "jsonrpc": "2.0",
  "method": "tools/list",
  "id": 1,
  "context": {
    "session_id": "sess_abc123",
    "capabilities": ["streaming", "batch"],
    "auth_token": "token_here"
  }
}

{
  "extensions": [
    {
      "name": "n8n-advanced",
      "version": "2.0.0",
      "capabilities": [
        "workflow-versioning",
        "execution-streaming",
        "credential-validation"
      ]
    }
  ]
}

// เริ่ม Workflow ระยะยาว
{
  "jsonrpc": "2.0",
  "method": "tasks/create",
  "params": {
    "tool": "n8n:execute_workflow",
    "arguments": { "workflow_id": "long-running-etl" },
    "timeout": 3600
  },
  "id": 1
}

// การตอบกลับ
{
  "jsonrpc": "2.0",
  "id": 1,
  "result": {
    "task_id": "task_789",
    "status": "pending",
    "estimated_completion": "2026-07-28T15:30:00Z"
  }
}

AI Agent (Claude) → MCP → n8n Workflows

กิจวัตรประจำเช้า:
1. Agent รับการแจ้งเตือน: "รายงานการปฏิบัติตามรายวันจะครบกำหนดใน 2 ชั่วโมง"
2. Agent สืบค้น MCP: "รายการแหล่งข้อมูลการปฏิบัติตามที่มี"
3. Agent ค้นพบ: Workflows Core Banking, Trading, KYC, AML
4. Agent สร้าง Workflow รายงานผ่านเครื่องมือ create_workflow
5. Workflow ดำเนินการดึงข้อมูลจากระบบทั้งหมด
6. Agent ตรวจสอบผลลัพธ์กับ Templates กำกับดูแล
7. Agent ส่งผ่านช่องทางที่ปลอดภัย บันทึกความสำเร็จ

// AI Agent Logic
async function optimizePricing() {
  const workflows = await mcpClient.call('list_workflows', {
    tag: 'pricing'
  });
  
  const competitorPrices = await fetchCompetitorData();
  const strategy = await analyzeOptimalStrategy(competitorPrices);
  
  await mcpClient.call('update_workflow', {
    workflow_id: workflows[0].id,
    nodes: [
      // กฎการกำหนดราคาแบบไดนามิกตามตลาดปัจจุบัน
    ]
  });
  
  await mcpClient.call('execute_workflow', {
    workflow_id: workflows[0].id
  });
}

การจำหน่ายผู้ป่วน → AI Agent → MCP → n8n

1. เหตุการณ์การจำหน่ายทริกเกอร์ Workflow MCP
2. Agent ประเมินโปรไฟล์ความเสี่ยงของผู้ป่วย
3. Agent จัดกำหนดการติดตามต่อ
4. Agent จัดการดูแลที่บ้านหากจำเป็น
5. Agent ส่งการแจ้งเตือนยา
6. Agent ตรวจสอบการนัดหมายที่พลาด
7. Agent ขึ้นสถานะกรณีที่มีความเสี่ยงสูง

#!/bin/bash
# benchmark-mcp.sh

N8N_URL="http://localhost:5679"
TOKEN="your-token"

# ทดสอบการค้นพบ Workflow
echo "ทดสอบการค้นพบ Workflow..."
time curl -s -X POST $N8N_URL/mcp \
  -H "Authorization: Bearer $TOKEN" \
  -d '{"jsonrpc":"2.0","method":"tools/list","id":1}' | jq '.result.tools | length'

# ทดสอบ Latency การดำเนินการ Workflow
echo "ทดสอบ Latency การดำเนินการ..."
for i in {1..100}; do
  curl -s -X POST $N8N_URL/webhook/test \
    -d '{"test": true}' &
done
wait
echo "100 คำขอขนานเสร็จสมบูรณ์"

# การใช้หน่วยความจำ
echo "การใช้หน่วยความจำ:"
docker stats n8n --no-stream --format "table {{.MemUsage}}"

const { Pool } = require('mcp-client-pool');

const mcpPool = new Pool({
  maxConnections: 20,
  minConnections: 5,
  connectionTimeout: 5000,
  idleTimeout: 30000,
  serverUrl: 'http://n8n:5679/mcp',
  authToken: process.env.MCP_TOKEN
});

// การใช้งาน
const client = await mcpPool.acquire();
try {
  const result = await client.call('execute_workflow', {...});
} finally {
  await mcpPool.release(client);
}

const NodeCache = require('node-cache');
const workflowCache = new NodeCache({ stdTTL: 300 });

async function getWorkflow(id) {
  let workflow = workflowCache.get(id);
  if (!workflow) {
    workflow = await mcpClient.call('get_workflow', { workflow_id: id });
    workflowCache.set(id, workflow);
  }
  return workflow;
}

// แทนการเรียกแยกกัน 100 ครั้ง
const promises = ids.map(id => mcpClient.call('get_execution_status', { execution_id: id }));
const results = await Promise.all(promises);

// MCP v2 จะรองรับ Batching แบบ Native:
const results = await mcpClient.call('batch', {
  operations: ids.map(id => ({
    method: 'get_execution_status',
    params: { execution_id: id }
  }))
});

-- เพิ่ม Indexes สำหรับคำขอ MCP
CREATE INDEX CONCURRENTLY idx_executions_mcp ON execution_entity(workflowId, status, startedAt);
CREATE INDEX CONCURRENTLY idx_workflows_mcp ON workflow_entity(updatedAt, active);

-- Partition Execution Logs
CREATE TABLE execution_entity_partitioned (
  LIKE execution_entity INCLUDING ALL
) PARTITION BY RANGE (startedAt);

n8n-mcp:
  deploy:
    replicas: 2
    resources:
      limits:
        memory: 2G
        cpus: '1.0'

n8n-worker:
  deploy:
    replicas: 10
    resources:
      limits:
        memory: 4G
        cpus: '2.0'

// mcp-load-test.js
import http from 'k6/http';
import { check } from 'k6';

export const options = {
  stages: [
    { duration: '2m', target: 10 },
    { duration: '5m', target: 50 },
    { duration: '10m', target: 100 },
    { duration: '5m', target: 200 },
    { duration: '2m', target: 0 },
  ],
  thresholds: {
    http_req_duration: ['p(95)<500'],
    http_req_failed: ['rate<0.01'],
  },
};

export default function () {
  const payload = JSON.stringify({
    jsonrpc: '2.0',
    method: 'tools/call',
    params: {
      name: 'execute_workflow',
      arguments: {
        workflow_id: __ENV.WORKFLOW_ID,
        data: { test: true }
      }
    },
    id: 1
  });

  const res = http.post('http://n8n:5679/mcp', payload, {
    headers: { 
      'Content-Type': 'application/json',
      'Authorization': `Bearer ${__ENV.MCP_TOKEN}`
    },
  });

  check(res, {
    'status is 200': (r) => r.status === 200,
    'response time < 500ms': (r) => r.timings.duration < 500,
  });
}

k6 run --env WORKFLOW_ID=12345 --env MCP_TOKEN=secret mcp-load-test.js

# ตรวจสอบว่า MCP Server กำลังทำงาน
curl http://localhost:5679/mcp/health

# ตรวจสอบการผูก Port
netstat -tlnp | grep 5679

# ตรวจสอบกฎ Firewall
sudo iptables -L | grep 5679

N8N_LOG_LEVEL=debug
N8N_MCP_LOG_LEVEL=debug
N8N_LOG_OUTPUT=console

docker logs -f n8n | jq 'select(.module == "mcp")'

ผู้ใช้: "สร้าง Workflow ที่ตรวจสอบ Sentiment ของลูกค้าทั่วทุก 
Social Channel, ขึ้นสถานะ Mention ที่ลบกับฝ่ายสนับสนุน และอัปเดต 
Product Roadmap ของเราตาม Themes ที่เกิดขึ้นซ้ำ"

AI Agent: "ฉันจะสร้างสิ่งนั้นให้คุณ ตามความต้องการของคุณ 
ฉันกำลังออกแบบ Workflow ที่มี:

1. Social Listening Nodes (Twitter, LinkedIn, Reddit)
2. Sentiment Analysis โดยใช้ AI Model ของคุณ
3. Conditional Routing สำหรับ Sentiment < -0.5
4. Support Ticket Creation ใน Zendesk
5. Theme Extraction และ Clustering
6. Monday.com Integration สำหรับการอัปเดต Roadmap

Workflow รวมถึง Error Handling, Rate Limiting และ Audit Logging 
เวลาดำเนินการโดยประมาณ: 2-3 นาทีต่อ Batch"

┌──────────────┐         ┌──────────────┐         ┌──────────────┐
│  Sales Agent │◄───────►│  n8n MCP     │◄───────►│ Support Agent│
│   (Claude)   │   MCP   │ Orchestrator │   MCP   │   (Claude)   │
└──────────────┘         └──────┬───────┘         └──────────────┘
                                │
                       ┌────────┴────────┐
                       │  Operations   │
                       │    Agent      │
                       │   (OpenClaw)  │
                       └─────────────────┘