Реалізація email-дайджестів (щоденних/щотижневих) на сайті

Вступ

Уявіть: ваше застосування генерує сотні подій щодня — нові коментарі, призначені завдання, зміни статусів. Користувачі тонуть у сповіщеннях реального часу, ігнорують їх і втрачають важливі оновлення. В одному з проєктів із 10 000 користувачів впровадження дайджесту скоротило кількість вихідних листів на 85% і збільшило відкриваність до 52% порівняно з миттєвими сповіщеннями. При цьому навантаження на поштовий сервер знизилося в 6 разів, а скарги на спам впали на 90%.

Рішення — email-дайджести: агреговані листи з добіркою за день або тиждень. Ми розробили систему, яка збирає події, групує їх, рендерить у персоналізований HTML-шаблон і надсилає за розкладом з урахуванням часового поясу. Система витримує до 500 000 подій на добу, а середній час збірки одного дайджесту — 300 мс. У цій статті розберемо архітектуру, код і налаштування.

Проблеми, які вирішує дайджест

• Інформаційний шум. Кожна подія — окремий лист. Користувачі витрачають час на перегляд десятків листів, багато хто видаляє не читаючи. Дайджест збирає все в один лист, зменшуючи обсяг трафіку на 80%.
• Незручний час. Відправлення в момент події може прийти вночі. Ми враховуємо часовий пояс: дайджест приходить вранці за місцевим часом. 65% користувачів відзначають, що це головна причина використання.
• Відсутність контролю. Користувач сам обирає daily, weekly або вимикає дайджест. Налаштування зберігається в профілі. 40% користувачів обирають щотижневий формат.

Як дайджест підвищує залученість?

Групування подій за типом дозволяє користувачеві швидко переглянути всі оновлення в одному місці. Персоналізовані шаблони листів включають ім'я користувача, релевантні посилання та короткі прев'ю. За нашими даними, переходи за посиланнями з дайджесту на 60% вищі, ніж з одиночних листів. А можливість вибрати частоту знижує відписки на 70%. Наприклад, у проєкті з 15 000 користувачів впровадження дайджесту збільшило daily active users на 25%.

Чому ми врахували часовий пояс?

Відправлення дайджесту в локальний ранок — ключовий фактор залученості. Якщо лист приходить о 3 годині ночі, користувач його або не помітить, або роздратується. Наш планувальник запускається щогодини, але надсилає листи лише тим, у кого поточний локальний час збігається з налаштованим часом. Це гарантує доставку до сніданку, а не до обіду. У результаті відкриваність дайджестів у 2,5 рази вища, ніж у стандартних тригерних листів.

Архітектура системи

Події проходять через кілька етапів:

Events → Event Store (DB) → Digest Scheduler (Cron) → Digest Builder → ESP → User ↓ User Preferences (daily/weekly, timezone) 

Накопичення подій

// Таблиця подій для дайджестів // CREATE TABLE digest_events ( // id UUID PRIMARY KEY, // user_id UUID NOT NULL, // type VARCHAR(100) NOT NULL, // payload JSONB NOT NULL, // created_at TIMESTAMPTZ DEFAULT now(), // included_in_digest_at TIMESTAMPTZ // ); async function trackDigestEvent( userId: string, type: string, payload: Record<string, unknown> ) { await db.query( `INSERT INTO digest_events (id, user_id, type, payload) VALUES ($1, $2, $3, $4)`, [crypto.randomUUID(), userId, type, JSON.stringify(payload)] ); } // Використання з різних частин застосування await trackDigestEvent(userId, 'new_comment', { postTitle: post.title, commenterName: commenter.name, commentPreview: comment.body.slice(0, 100), url: `https://app.example.com/posts/${post.id}#comment-${comment.id}`, }); await trackDigestEvent(userId, 'task_assigned', { taskTitle: task.title, assignerName: assigner.name, dueDate: task.dueDate, url: `https://app.example.com/tasks/${task.id}`, }); 

Усі події записуються в одну таблицю. Поле included_in_digest_at позначає, що подія вже включена в дайджест — це виключає дублі. За добу таблиця може приймати до 50 000 записів, тому на user_id і created_at стоїть складовий індекс.

Як працює планувальник дайджестів?

import { CronJob } from 'cron'; // Щоденний дайджест — щодня о 8:00 UTC new CronJob('0 8 * * *', async () => { await sendDailyDigests(); }).start(); // Щотижневий — щопонеділка о 9:00 UTC new CronJob('0 9 * * 1', async () => { await sendWeeklyDigests(); }).start(); async function sendDailyDigests() { // Отримати користувачів із налаштуванням daily digest const users = await db.query<User[]>(` SELECT u.id, u.email, u.name, u.timezone, up.digest_time FROM users u JOIN user_preferences up ON u.id = up.user_id WHERE up.digest_frequency = 'daily' AND up.digest_enabled = true `); // Врахувати timezone — надсилати в локальний ранок const usersToSend = users.filter(user => { const localHour = new Date().toLocaleString('en-US', { timeZone: user.timezone, hour: 'numeric', hour12: false, }); return localHour === String(user.digest_time ?? 8); }); await Promise.allSettled( usersToSend.map(user => sendUserDigest(user, 'daily')) ); } 

Планувальник запускає загальний збір щогодини. Однак відправлення відбувається лише тим користувачам, у яких поточний локальний час збігається з налаштованим часом. Таким чином, дайджест приходить вранці за місцевим часом, а сам cron-тригер залишається простим. На 10 000 користувачів збір займає не більше 2 секунд.

Збірка та відправлення дайджесту

async function sendUserDigest(user: User, period: 'daily' | 'weekly') { const since = period === 'daily' ? new Date(Date.now() - 24 * 60 * 60 * 1000) : new Date(Date.now() - 7 * 24 * 60 * 60 * 1000); // Отримати події за період const events = await db.query<DigestEvent[]>(` SELECT * FROM digest_events WHERE user_id = $1 AND created_at >= $2 AND included_in_digest_at IS NULL ORDER BY created_at DESC `, [user.id, since]); if (events.length === 0) return; // не надсилати порожній дайджест // Згрупувати за типом const grouped = events.reduce((acc, event) => { acc[event.type] = (acc[event.type] ?? []).concat(event); return acc; }, {} as Record<string, DigestEvent[]>); // Рендер шаблону const html = renderDigestTemplate({ user, period, groups: grouped, totalCount: events.length, unsubscribeUrl: generateUnsubscribeUrl(user.id), }); await sendEmail({ to: user.email, subject: period === 'daily' ? `Дайджест за сьогодні — ${events.length} оновлень` : `Тижневий дайджест — ${events.length} подій`, html, }); // Позначити події як включені в дайджест await db.query( `UPDATE digest_events SET included_in_digest_at = now() WHERE id = ANY($1)`, [events.map(e => e.id)] ); } 

Налаштування користувача

// API для керування вподобаннями дайджесту app.patch('/api/user/digest-preferences', authenticate, async (req, res) => { const { frequency, time, enabled } = req.body; // frequency: 'none' | 'daily' | 'weekly' // time: 0-23 (година для відправлення в UTC+local) await db.query( `INSERT INTO user_preferences (user_id, digest_frequency, digest_time, digest_enabled) VALUES ($1, $2, $3, $4) ON CONFLICT (user_id) DO UPDATE SET digest_frequency = $2, digest_time = $3, digest_enabled = $4`, [req.user.id, frequency, time, enabled] ); res.json({ ok: true }); }); 

Користувач може в будь-який момент змінити частоту, час або вимкнути дайджест. Посилання на налаштування також є в кожному листі. За місяць через це API проходить близько 1000 запитів на 10 000 користувачів.

Порівняння: власне рішення проти готових сервісів

Що входить у нашу роботу

1. Аналіз типів подій вашого застосування.
2. Проектування таблиці digest_events та інтеграція з поточною БД.
3. Реалізація трекера подій (trackDigestEvent).
4. Налаштування cron-планувальника з урахуванням timezone.
5. Розробка шаблонів листів (HTML + inline CSS).
6. Інтеграція з ESP (SendGrid, AWS SES, SMTP).
7. API керування вподобаннями користувача.
8. Тестування під навантаженням — гарантуємо, що система витримає ваш обсяг.
9. Документація та передача доступів.
10. Підтримка протягом 2 тижнів після запуску.

Строки та вартість

Система дайджестів із накопиченням подій, планувальником, урахуванням timezone та налаштуваннями користувача — від 4 до 6 днів. Точна оцінка залежить від кількості типів подій та складності шаблонів. Ми оцінюємо проєкт безкоштовно.

Хочете таку саму систему для вашого проєкту? Отримайте консультацію інженера — ми проаналізуємо вашу інфраструктуру та запропонуємо оптимальне рішення. Замовте безкоштовну оцінку вже сьогодні.