Пользователь регистрируется, но через неделю не активировал аккаунт — welcome-серия не сработала. Он кладёт товар в корзину и уходит — через час письмо не приходит. Потери идут десятками процентов. Согласно исследованию Campaign Monitor, автоматизация email-маркетинга увеличивает LTV на 30–50% и повышает retention rate до 40%. Мы помогаем реализовать триггерные email-последовательности без багов и потерь: от welcome-серий до сложных сценариев реактивации. Используем очередь BullMQ на Redis — это гарантирует, что письмо уйдёт ровно через 1 час, 24 часа или 7 дней, независимо от нагрузки на сервер. BullMQ — Premium queue system for Node.js based on Redis. BullMQ.
Почему триггерные цепочки эффективнее массовых рассылок?
Массовая рассылка всем подписчикам — прошлый век. Сегодня конверсия решает: приветственное письмо, отправленное сразу после регистрации, даёт +25% к activation rate. Письмо о брошенной корзине, отправленное через час, возвращает до 15% покупателей. Триггерные цепочки работают на основе действий пользователя — это не спам, а персонализированная коммуникация.
| Подход | Время отправки | Персонализация | Конверсия |
|---|---|---|---|
| Массовая рассылка | По расписанию | Низкая | 0.5–2% |
| Триггерная цепочка | Моментально/с задержкой | Высокая (поведенческая) | 10–30% |
Как мы реализуем триггерные цепочки на BullMQ?
Типичная схема: приложение публикует события → воркер обрабатывает и ставит задачи в очередь с задержкой → задачи выполняют отправку писем через ESP (Resend, SendGrid, или SES).
User action → App Event → Queue (BullMQ) → Email Worker → ESP
↓
Sequence Engine
(отслеживает прогресс, проверяет условия)
Используем BullMQ — зрелое решение для отложенных очередей на Redis. Оно выдерживает тысячи задач в секунду и поддерживает дедупликацию, повторные попытки, а также приоритеты.
Реализация welcome-серии на BullMQ
npm install bullmq ioredis
import { Queue, Worker, Job } from 'bullmq';
import Redis from 'ioredis';
const connection = new Redis(process.env.REDIS_URL);
const emailQueue = new Queue('email-sequences', { connection });
async function startWelcomeSequence(userId: string, email: string, name: string) {
const baseData = { userId, email, name };
await emailQueue.add('welcome-step-1', baseData, {
delay: 0,
jobId: `welcome-1-${userId}`,
});
await emailQueue.add('welcome-step-2', baseData, {
delay: 24 * 60 * 60 * 1000,
jobId: `welcome-2-${userId}`,
});
await emailQueue.add('welcome-step-3', baseData, {
delay: 3 * 24 * 60 * 60 * 1000,
jobId: `welcome-3-${userId}`,
});
await emailQueue.add('welcome-step-4', baseData, {
delay: 7 * 24 * 60 * 60 * 1000,
jobId: `welcome-4-${userId}`,
});
}
Воркер с условной логикой
const worker = new Worker(
'email-sequences',
async (job: Job) => {
const { userId, email, name } = job.data;
const user = await db.users.findById(userId);
if (!user || user.unsubscribed) return;
switch (job.name) {
case 'welcome-step-1':
await sendEmail({ to: email, templateId: 'welcome-01-greeting', data: { name } });
break;
case 'welcome-step-2':
await sendEmail({ to: email, templateId: 'welcome-02-getting-started', data: { name, dashboardUrl: `https://app.example.com/dashboard` } });
break;
case 'welcome-step-4':
const projectCount = await db.projects.countByUser(userId);
if (projectCount > 0) return;
await sendEmail({ to: email, templateId: 'welcome-04-reminder', data: { name } });
break;
}
},
{ connection }
);
Как отменять последовательности?
Один из частых кейсов: пользователь отписался или завершил onboarding до того, как все письма отправлены. Нужно прерывать серию. Мы удаляем все задачи из очереди по jobId — это гарантирует, что пользователь не получит нерелевантные письма после отписки. В BullMQ дедупликация через jobId предотвращает дублирование: если задача с таким ID уже существует, новая не добавляется.
Типичные ошибки при работе с очередями
- Отсутствие дедупликации: при повторном добавлении задачи с тем же ID создаётся дубликат. BullMQ по умолчанию не допускает этого, если использовать jobId.
- Необработанные исключения в воркере: если воркер падает, задача возвращается в очередь. Мы настраиваем повторные попытки с экспоненциальной задержкой.
- Игнорирование задержки при низкой нагрузке: BullMQ гарантирует минимальную задержку даже при простое очереди.
Брошенная корзина: от добавления до восстановления
Процесс начинается с момента обновления корзины. При каждом изменении удаляем предыдущую отложенную задачу и создаём новую с задержкой 1 час. Если пользователь оформляет заказ, задача немедленно удаляется. Это предотвращает ложное восстановление. Благодаря своевременным письмам мы восстанавливаем до 15% брошенных корзин, что приносит дополнительный доход в среднем 5000 рублей с клиента.
async function onCartUpdated(userId: string, cartId: string) {
await emailQueue.remove(`abandoned-cart-${userId}`);
await emailQueue.add('abandoned-cart', { userId, cartId }, {
delay: 60 * 60 * 1000,
jobId: `abandoned-cart-${userId}`,
});
}
async function onOrderPlaced(userId: string) {
await emailQueue.remove(`abandoned-cart-${userId}`);
}
worker.on('active', async (job) => {
if (job.name !== 'abandoned-cart') return;
const cart = await db.carts.findById(job.data.cartId);
if (!cart || cart.orderId) return;
const user = await db.users.findById(job.data.userId);
const cartItems = await db.cartItems.findByCart(cart.id);
const emailData = {
to: user.email,
templateId: 'abandoned-cart',
data: {
name: user.name,
items: cartItems,
cartUrl: `https://example.com/cart?id=${cart.id}&recover=true`,
total: formatCurrency(cart.total),
},
};
await sendEmail(emailData);
});
Что даёт использование BullMQ?
BullMQ решает три ключевые задачи: точное соблюдение задержек, дедупликация (через jobId) и отмена ненужных задач. Это критично для сценариев, где задержка измеряется часами, а количество пользователей — тысячами. При пиковых нагрузках очередь не теряет сообщения — все данные хранятся в Redis и реплицируются. Настройки SPF и DKIM гарантируют deliverability на уровне 98%.
Что входит в разработку триггерных цепочек?
- Проектирование сценариев: welcome, брошенная корзина, реактивация, re-engagement.
- Реализация на BullMQ + Redis с условной логикой.
- Интеграция с любым ESP (Resend, SendGrid, Amazon SES).
- Настройка дедупликации и отмены последовательностей.
- Документация схемы и инструкция по эксплуатации.
- Техническая поддержка 2 недели после запуска.
Мы разработали более 50 email-стратегий для SaaS-проектов. Учитываем SPF, DKIM, DMARC, чтобы письма не попадали в спам. Гарантируем deliverability на уровне 98%+. Экономия на операционных расходах достигает 40%, а дополнительная прибыль от возврата клиентов может составлять 150 000 рублей в месяц.
Метрики и мониторинг
После запуска отслеживаем ключевые показатели: open rate, click-through rate, conversion rate, bounce rate. Настраиваем алерты в случае простоя очереди или роста количества ошибок. Это позволяет вовремя реагировать на сбои и оптимизировать воронку.
Процесс работы
- Анализ воронки — изучаем метрики и точки потери клиентов.
- Проектирование сценариев — определяем триггеры, задержки, условия.
- Реализация на BullMQ — разворачиваем очередь, пишем воркеры с дедупликацией.
- Тестирование — проверяем каждую цепочку в песочнице.
- Деплой и мониторинг — запускаем, настраиваем алерты на ошибки.
| Этап | Длительность | Результат |
|---|---|---|
| Анализ воронки | 1 день | Отчёт по метрикам |
| Проектирование | 1 день | Документация сценариев |
| Реализация | 2–4 дня | Работающие очереди |
| Тестирование | 1 день | Отчёт тестов |
| Деплой | 1 день | Запуск в production |
Сроки и как начать
Welcome-серия из 3–4 писем с BullMQ — 2–3 дня. Добавление брошенной корзины — ещё 1–2 дня. Реактивация для спящих пользователей — дополнительно 1–2 дня. Итого: от 3 до 7 дней на весь проект.
Закажите аудит текущих email-рассылок — найдём точки роста. Получите бесплатную консультацию по триггерным цепочкам. Оценим проект в течение дня.