Користувач реєструється, але через тиждень не активував акаунт — 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-розсилок — знайдемо точки зростання. Отримайте безкоштовну консультацію з тригерних ланцюжків. Оцінимо проект протягом дня.