Интеграция Discord и n8n: алерты, webhooks и защита каналов от спама ¶

Обновлено: 2026-05-30

Проблема: Discord webhook легко подключить к n8n, но без фильтров канал быстро превращается в шумный лог: повторы, stack trace, секреты и сотни одинаковых сообщений.

Решение: Production-интеграция Discord и n8n нормализует событие, рассчитывает severity, группирует повторы, маскирует токены и отправляет в нужный канал только полезное сообщение с action-кнопками или ссылкой на runbook.

Проблема: почему простая интеграция создаёт дубли и ручной хаос ¶

Discord часто используют как быстрый канал для DevOps, support и контент-команд: алерты из n8n, ошибки API, новые заявки, публикации, события GitHub или статусы оплаты. Проблема начинается, когда webhook работает как прямой dump всего payload.

Надёжная настройка webhook должна отвечать не на вопрос “как отправить сообщение”, а на вопрос “какое сообщение поможет человеку принять решение”. Поэтому в сценарии есть dedupe window, severity, route по каналам, компактный embed и маскирование персональных данных.

Архитектура workflow для n8n ¶

Discord webhook должен быть последней нодой после нормализации. Если отправлять raw payload, канал станет бесполезным именно в момент инцидента.

Контракт входных данных ¶

{
  "source": "n8n",
  "severity": "warning",
  "workflow": "YooKassa payment to CRM",
  "entity_id": "payment_2f3c6a99",
  "message": "CRM update failed after idempotency insert",
  "execution_url": "https://n8n.example.com/execution/48122",
  "runbook": "https://docs.example.com/runbooks/payment-alerts"
}

Контракт должен быть небольшим: source, severity, workflow, entity_id, message и ссылка на execution/runbook. Секреты, auth headers и полный request body в Discord отправлять нельзя.

Code Node: нормализация, mapping и guard-условия ¶

const src = $json.body ?? $json;
const severity = String(src.severity ?? 'info').toLowerCase();
const allowed = ['info', 'warning', 'critical'];
const level = allowed.includes(severity) ? severity : 'warning';
const safe = v => String(v ?? '').replace(/(token|secret|password)=([^&\s]+)/gi, '$1=***');
const workflow = safe(src.workflow ?? 'unknown workflow');
const entityId = safe(src.entity_id ?? src.id ?? 'no-entity');
const message = safe(src.message ?? 'No message');
const dedupeKey = `discord:${level}:${workflow}:${entityId}`.toLowerCase();
const color = level === 'critical' ? 15158332 : level === 'warning' ? 16776960 : 3447003;
return [{ json: {
  dedupe_key: dedupeKey,
  discord: {
    username: 'Nodbot Alert',
    embeds: [{
      title: `${level.toUpperCase()}: ${workflow}`,
      description: message.slice(0, 900),
      color,
      fields: [
        { name: 'Entity', value: entityId, inline: true },
        { name: 'Runbook', value: safe(src.runbook ?? 'not configured'), inline: false }
      ]
    }]
  }
}}];

Готовый workflow JSON: скачать и импортировать ¶

Скачать готовый workflow JSON Скачать тестовый payload

{
  "name": "Nodbot - Discord alerts with dedupe and safe embeds",
  "nodes": [
    {
      "name": "Webhook alert input",
      "type": "n8n-nodes-base.webhook",
      "purpose": "Принять событие от workflow"
    },
    {
      "name": "Normalize and sanitize alert",
      "type": "n8n-nodes-base.code",
      "purpose": "Собрать severity, context и скрыть секреты"
    },
    {
      "name": "Check dedupe window",
      "type": "n8n-nodes-base.postgres",
      "purpose": "Не отправлять повторный алерт"
    },
    {
      "name": "Build Discord embed",
      "type": "n8n-nodes-base.code",
      "purpose": "Сформировать короткий embed"
    },
    {
      "name": "Send Discord webhook",
      "type": "n8n-nodes-base.webhook",
      "purpose": "Отправить сообщение в канал"
    },
    {
      "name": "Respond to source",
      "type": "n8n-nodes-base.respondToWebhook",
      "purpose": "Вернуть безопасный ответ"
    }
  ],
  "connections": "Webhook alert input → Normalize and sanitize alert → Check dedupe window → Build Discord embed → Send Discord webhook → Respond to source"
}

Пошаговая настройка связки ¶

1. Создайте отдельный Discord webhook для production-канала, а не используйте общий канал команды.
2. Импортируйте workflow JSON и замените webhook URL через credential или ENV.
3. Определите severity-правила: info, warning, critical.
4. Настройте dedupe storage: Postgres, Redis или другой durable store.
5. Отправьте тестовый payload дважды и убедитесь, что второй алерт подавляется.

Тесты перед production ¶

curl -X POST "https://YOUR-N8N-DOMAIN/webhook/integration-discord-n8n-alerts-webhooks" \
  -H "Content-Type: application/json" \
  --data @integration-discord-n8n-alerts-webhooks-payload.json

1. Повторный payload не создаёт дубль и возвращает тот же output key.
2. Некорректный mapping останавливается до запроса к внешнему API.
3. Пустые необязательные поля не ломают workflow.
4. Ошибка API уходит в alert или DLQ с безопасным payload.
5. Execution data не содержит секретов, токенов и лишних персональных данных.

Production-риски ¶

• Webhook URL попал в репозиторий. Любой сможет писать в канал. Храните URL вне экспортируемого workflow.
• В Discord уходит raw payload. Так можно раскрыть токены, email, телефоны и внутренние URL.
• Нет rate limit/backoff. Массовая ошибка создаст лавину сообщений и 429.
• Все события идут в один канал. Support, DevOps и продажи перестают видеть свои важные алерты.
• Нет runbook. Сообщение сообщает о проблеме, но не помогает её решить.

Полезные ссылки и смежные материалы ¶

• Discord Webhook Resource
• Discord Incoming Webhooks
• Error workflow alert в Telegram
• Slack и n8n
• Mattermost и n8n
• Retry и DLQ для HTTP Request

Критерии готовности ¶

1. Webhook URL не хранится в открытом JSON.
2. Каждый алерт содержит severity, entity_id, workflow и runbook.
3. Повторы подавляются по dedupe key в течение окна.
4. PII и секреты маскируются до отправки в Discord.
5. Критичные события имеют отдельный канал или escalation-rule.