[AI 엔지니어링 심층 분석] 사내 데이터베이스와 노션, 슬랙을 연결하는 로컬 MCP(Model Context Protocol) 보안 에이전트 구축 실전

프롤로그: 왜 기업의 80%는 최고 성능의 LLM을 도입하고도 실무 자동화에 실패하는가?

수많은 스타트업과 엔터프라이즈 조직이 유료 AI 라이선스를 전사 도입했지만, 정작 현업 실무자의 하루 업무 풍경은 크게 달라지지 않았습니다. 매주 금요일 오후가 되면 데이터 분석가와 PM은 여전히 사내 리드 레플리카(Read Replica) DB에서 SQL 쿼리를 수동으로 실행해 엑셀로 내려받고, 그 숫자를 노션(Notion) 주간 회의록과 대조한 뒤, 다시 슬랙(Slack) 보고용 요약문으로 다듬기 위해 똑같은 데이터를 챗봇 창에 복사해 붙여넣기를 반복합니다.

이처럼 AI가 사내 업무의 '진짜 손발'이 되지 못하는 이유는 모델의 추론 지능이 부족해서가 아닙니다. 첫째, 사내 데이터베이스와 협업 툴을 연결할 때마다 모델별로 제각각인 커스텀 API 연동 코드를 짜야 하는 N×M 통합 파편화가 개발팀의 발목을 잡습니다. 둘째, 보안팀 입장에서는 LLM 에이전트에게 DB 접속 권한을 열어주었다가 자칫 DROP이나 UPDATE 쿼리가 실행되거나 고객의 이메일·전화번호 같은 개인식별정보(PII)가 외부 모델 컨텍스트로 유출될까 봐 연동을 불허하기 때문입니다.

앤스로픽(Anthropic)이 개방형 표준으로 제시하고 업계 전체가 채택한 MCP(Model Context Protocol)는 이 두 가지 난제를 동시에 해결합니다. 사내망 내부에 읽기 전용(Read-Only) SQL 가드레일과 PII 마스킹 필터가 내장된 로컬 MCP 서버를 세우고, 외부 알림 및 문서 생성은 n8n 워크플로우 웹훅에 위임하면 보안 규정 위반 제로(Zero) 상태를 유지하면서도 주간 KPI 리포팅 시간을 3시간에서 30초로 단축할 수 있습니다.

1. 레거시 챗봇 연동 vs 엔터프라이즈 MCP 보안 게이트웨이 비교 매트릭스

사내 데이터를 AI와 연결하는 세 가지 대표 아키텍처의 개발 공수, 보안 통제력, 그리고 감사 추적성을 정량 비교한 매트릭스입니다.

2. 로컬 MCP 클라이언트 설정 (claude_desktop_config.json)

가장 먼저 로컬 워크스테이션이나 사내 배스천(Bastion) 환경에서 MCP 클라이언트가 사내 게이트웨이 프로세스를 표준 입출력(stdio)으로 호출할 수 있도록 구성 파일을 등록합니다. 이때 데이터베이스 접속 정보는 반드시 SELECT 권한만 부여된 리드 레플리카(Read-Only Replica) 전용 계정으로 주입합니다.

{
  "mcpServers": {
    "alphapulse-enterprise-guard": {
      "command": "node",
      "args": ["/opt/mcp-servers/dist/enterprise-mcp-sql-guard.js"],
      "env": {
        "PG_READONLY_URI": "postgresql://ai_readonly_bot:REDACTED@replica-db.internal:5432/analytics",
        "N8N_REPORT_WEBHOOK_URL": "https://n8n.internal.company.com/webhook/weekly-kpi-sync",
        "MCP_AUDIT_LOG_PATH": "/var/log/mcp/enterprise-audit.jsonl",
        "MAX_QUERY_ROWS": "100"
      }
    }
  }
}

3. 프로덕션 3중 보안 가드레일 MCP 서버 구현 코드 (TypeScript)

아래 코드는 ① INSERT, UPDATE, DELETE, DROP 등 데이터 변경 키워드와 다중 구문(;) 주입을 차단하는 SQL 검증기, ② 이메일, 전화번호, 계좌번호 등 민감 컬럼을 LLM에 전달하기 전에 마스킹하는 maskSensitiveRows(), ③ 모든 쿼리 실행 주체와 타임스탬프를 JSONL로 기록하는 감사 로거, 그리고 ④ 분석 결과를 n8n 웹훅으로 전송해 노션 페이지와 슬랙 알림을 동시에 트리거하는 핵심 구현체입니다.

// enterprise-mcp-sql-guard.ts — Read-Only SQL AST Guard + PII Masking + n8n Dispatcher
import fs from 'node:fs/promises';

const FORBIDDEN_SQL_PATTERN =
  /\b(INSERT|UPDATE|DELETE|DROP|ALTER|TRUNCATE|GRANT|REVOKE|CREATE|EXEC|COPY|CALL)\b/i;
const PII_COLUMN_PATTERN = /email|phone|mobile|ssn|resident|password|secret|account_no|card_no/i;

export interface AuditLogEntry {
  timestamp: string;
  actor: string;
  toolName: string;
  sanitizedSql?: string;
  rowCount: number;
  status: 'ALLOWED' | 'BLOCKED';
  reason?: string;
}

/**
 * 1단계 가드레일: 오직 단일 SELECT 쿼리만 허용하며 LIMIT 절을 강제 주입합니다.
 */
export function validateReadOnlySqlQuery(rawSql: string, maxRows = 100): string {
  const normalized = rawSql.trim().replace(/;+$/, '');

  // 다중 쿼리(Stacked Queries) 및 주석 우회 차단
  if (normalized.includes(';') || normalized.includes('--') || normalized.includes('/*')) {
    throw new Error('[MCP Security Guard] Multi-statement or SQL comment injection blocked.');
  }
  if (!normalized.toUpperCase().startsWith('SELECT')) {
    throw new Error('[MCP Security Guard] Only SELECT queries are permitted.');
  }
  if (FORBIDDEN_SQL_PATTERN.test(normalized)) {
    throw new Error('[MCP Security Guard] Mutating or administrative SQL keyword blocked.');
  }
  if (!/\bLIMIT\s+\d+/i.test(normalized)) {
    return `${normalized} LIMIT ${maxRows}`;
  }
  return normalized;
}

/**
 * 2단계 가드레일: 개인식별정보(PII) 컬럼을 LLM 컨텍스트에 도달하기 전에 마스킹합니다.
 */
export function maskSensitiveRows>(rows: T[]): T[] {
  return rows.map((row) => {
    const masked: Record = { ...row };
    for (const [key, val] of Object.entries(masked)) {
      if (PII_COLUMN_PATTERN.test(key) && typeof val === 'string') {
        masked[key] = val.length > 3 ? `${val.slice(0, 2)}***REDACTED***` : '***REDACTED***';
      }
    }
    return masked as T;
  });
}

/**
 * 3단계 가드레일: 모든 도구 호출 이력을 불변 JSONL 감사 로그 파일에 기록합니다.
 */
export async function appendMcpAuditLog(entry: AuditLogEntry, logPath = '/var/log/mcp/enterprise-audit.jsonl') {
  const line = JSON.stringify({ ...entry, timestamp: new Date().toISOString() }) + '\n';
  await fs.appendFile(logPath, line, 'utf8');
}

/**
 * 4단계 액션 디스패처: 요약된 주간 KPI 리포트를 n8n 웹훅으로 전송하여 노션 DB 적재 및 슬랙 공지를 수행합니다.
 */
export async function dispatchReportToN8nWebhook(payload: {
  reportTitle: string;
  executiveSummary: string;
  kpiMetrics: Record;
}) {
  const webhookUrl = process.env.N8N_REPORT_WEBHOOK_URL;
  if (!webhookUrl) {
    throw new Error('Missing N8N_REPORT_WEBHOOK_URL environment variable.');
  }

  const response = await fetch(webhookUrl, {
    method: 'POST',
    headers: { 'Content-Type': 'application/json' },
    body: JSON.stringify({
      source: 'alphapulse-enterprise-mcp',
      dispatchedAt: new Date().toISOString(),
      ...payload
    })
  });

  if (!response.ok) {
    throw new Error(`n8n Webhook dispatch failed with HTTP ${response.status}`);
  }
  return await response.json();
}

4. 엔터프라이즈 AI 도입 시 반드시 점검할 4대 보안·운영 원칙

사내 데이터베이스와 협업 툴을 AI 에이전트에 연결할 때 정보보안 감사와 운영 안정성을 동시에 충족하기 위한 필수 점검 리스트입니다.

면책 조항: 사내 데이터베이스 연동 시에는 반드시 조직의 정보보안 규정과 최소 권한 원칙(Least Privilege)을 준수하시기 바랍니다.