n8n × AI エージェント連携 — セルフホストの詰まりどころと、崩れた JSON を拾い切る実装

# docker-compose.yml
services:
  n8n:
    image: docker.n8n.io/n8nio/n8n:2.35.5
    restart: unless-stopped
    ports:
      - "127.0.0.1:5678:5678"
    environment:
      - N8N_HOST=your-domain.com
      - N8N_PORT=5678
      - N8N_PROTOCOL=https
      - WEBHOOK_URL=https://your-domain.com/
      - GENERIC_TIMEZONE=Asia/Tokyo
      - TZ=Asia/Tokyo
      # 鍵は必ず自分で決めて .env から渡す（後述）
      - N8N_ENCRYPTION_KEY=${N8N_ENCRYPTION_KEY}
      # リバースプロキシ 1 段を信頼して X-Forwarded-* を読ませる
      - N8N_PROXY_HOPS=1
    volumes:
      - n8n_data:/home/node/.n8n
 
volumes:
  n8n_data:

# 鍵を作って .env に置く（この 1 行を飛ばすと後で泣きます）
echo "N8N_ENCRYPTION_KEY=$(openssl rand -hex 32)" > .env
chmod 600 .env
 
docker compose up -d
docker compose logs -f n8n

# /etc/nginx/sites-available/n8n
server {
    listen 443 ssl http2;
    server_name your-domain.com;
 
    ssl_certificate     /etc/letsencrypt/live/your-domain.com/fullchain.pem;
    ssl_certificate_key /etc/letsencrypt/live/your-domain.com/privkey.pem;
 
    # 添付ファイルを扱うフロー向けに上限を上げる
    client_max_body_size 32m;
 
    location / {
        proxy_pass http://127.0.0.1:5678;
        proxy_http_version 1.1;
        proxy_set_header Upgrade $http_upgrade;
        proxy_set_header Connection 'upgrade';
        proxy_set_header Host $host;
        proxy_set_header X-Forwarded-For $proxy_add_x_forwarded_for;
        proxy_set_header X-Forwarded-Proto $scheme;
        proxy_cache_bypass $http_upgrade;
        # エディタの実行結果は SSE で流れてくるのでバッファしない
        proxy_buffering off;
        proxy_read_timeout 300s;
    }
}
 
server {
    listen 80;
    server_name your-domain.com;
    return 301 https://$host$request_uri;
}

#!/usr/bin/env bash
# backup-verify.sh — 展開済みバックアップが本当に復旧に使えるか調べる
set -uo pipefail
DIR="${1:?usage: backup-verify.sh <dir>}"
fail=0
chk() { if [ -e "$2" ]; then echo "  OK   $1"; else echo "  MISS $1 ($2)"; fail=$((fail+1)); fi; }
 
echo "[1] 復旧に必要な3点が揃っているか"
chk "データベース"         "$DIR/database.sqlite"
chk "設定ファイル"         "$DIR/config"
chk "ワークフロー書き出し" "$DIR/export/workflows.json"
 
echo "[2] 暗号鍵が読めるか"
KEY=$(python3 -c "import json;print(json.load(open('$DIR/config')).get('encryptionKey',''))" 2>/dev/null)
if [ -z "$KEY" ]; then echo "  MISS encryptionKey が config にありません"; fail=$((fail+1))
else echo "  OK   encryptionKey 検出 (fingerprint: $(printf %s "$KEY" | sha256sum | cut -c1-12))"; fi
 
echo "[3] 前回のバックアップと鍵が同一か"
FP_FILE="$DIR/.key-fingerprint"
NOW=$(printf %s "$KEY" | sha256sum | cut -c1-12)
if [ -f "$FP_FILE" ]; then
  PREV=$(cat "$FP_FILE")
  if [ "$PREV" = "$NOW" ]; then echo "  OK   前回と一致 ($NOW)"
  else echo "  WARN 鍵が変わりました ($PREV -> $NOW)。古い認証情報は復号できません"; fail=$((fail+1)); fi
else echo "  INIT 初回のため fingerprint を記録します"; fi
printf %s "$NOW" > "$FP_FILE"
 
echo "[4] 認証情報が中身ごと入っているか"
CRED="$DIR/export/credentials.json"
if [ -f "$CRED" ]; then
  N=$(python3 -c "import json;print(len(json.load(open('$CRED'))))" 2>/dev/null || echo 0)
  D=$(grep -c '"data"' "$CRED" 2>/dev/null || echo 0)
  echo "  件数 $N / data フィールドを持つもの $D"
  [ "$N" -gt 0 ] && [ "$D" -eq 0 ] && { echo "  WARN --decrypted なしの空エクスポートです"; fail=$((fail+1)); }
else echo "  MISS credentials.json"; fail=$((fail+1)); fi
 
echo
[ "$fail" -eq 0 ] && echo "RESULT: 復旧可能" || echo "RESULT: 要対応 $fail 件"
exit $fail

// Code ノード：受信メールから分類用プロンプトを組み立てる
const emailBody = $json.email_body ?? '';
const sender = $json.sender_name ?? '(unknown)';
 
// 長文メールをそのまま流すとトークンも遅延も膨らむので頭を切る
const excerpt = emailBody.slice(0, 4000);
 
return {
  json: {
    prompt: [
      '次のメールを分類してください。',
      '出力は JSON オブジェクト 1 個だけ。前後に説明文を付けないでください。',
      'category は support / sales / other のいずれか、priority は high / medium / low のいずれか。',
      '',
      `送信者: ${sender}`,
      `本文: ${excerpt}`,
      '',
      '形式: {"category":"...","priority":"...","summary":"..."}',
    ].join('\n'),
  },
};

// Code ノード：LLM 応答から JSON オブジェクトを取り出す
function extractJsonObject(text) {
  const t = String(text).replace(/^\uFEFF/, '');
  const start = t.indexOf('{');
  if (start < 0) throw new Error('オブジェクトが見つかりません');
 
  // 文字列リテラルとエスケープを見ながら対応する } を探す
  let depth = 0, inStr = false, esc = false, raw = null;
  for (let i = start; i < t.length; i++) {
    const c = t[i];
    if (esc) { esc = false; continue; }
    if (c === '\\') { esc = true; continue; }
    if (c === '"') { inStr = !inStr; continue; }
    if (inStr) continue;
    if (c === '{') depth++;
    else if (c === '}' && --depth === 0) { raw = t.slice(start, i + 1); break; }
  }
  if (raw === null) throw new Error('括弧が閉じていません');
 
  const repaired = raw
    .replace(/[\u201c\u201d]/g, '"')          // 全角ダブルクォート
    .replace(/[\u2018\u2019]/g, "'")          // 全角シングルクォート
    .replace(/'([^'\\]*)'(\s*[:,}])/g, '"$1"$2')
    .replace(/([{,]\s*)'([^'\\]*)'(\s*:)/g, '$1"$2"$3')
    .replace(/,(\s*[}\]])/g, '$1');           // 末尾カンマ
 
  return JSON.parse(repaired);
}
 
const ALLOWED_CATEGORY = ['support', 'sales', 'other'];
const ALLOWED_PRIORITY = ['high', 'medium', 'low'];
 
return $input.all().map((item) => {
  let parsed;
  try {
    parsed = extractJsonObject(item.json.text ?? item.json.response ?? '');
  } catch (e) {
    // 落とさずに other へ寄せる。原因調査用に生応答を残す
    return { json: { category: 'other', priority: 'low', summary: '', parse_error: e.message, raw: item.json.text } };
  }
  return {
    json: {
      category: ALLOWED_CATEGORY.includes(parsed.category) ? parsed.category : 'other',
      priority: ALLOWED_PRIORITY.includes(parsed.priority) ? parsed.priority : 'low',
      summary: String(parsed.summary ?? '').slice(0, 500),
    },
  };
});