Вступ
Уявіть: ваше застосування генерує сотні подій щодня — нові коментарі, призначені завдання, зміни статусів. Користувачі тонуть у сповіщеннях реального часу, ігнорують їх і втрачають важливі оновлення. В одному з проєктів із 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)
Ключові компоненти
| Компонент | Завдання |
|---|---|
| Збирач подій | Зберігає кожну подію в таблицю digest_events |
| Планувальник (cron) | Запускає формування дайджестів у задані інтервали |
| Збирач дайджесту | Запитує події за період, групує за типом |
| Рендерер шаблонів | Генерує HTML-лист на основі шаблону |
| Відправник | Передає лист в ESP (SendGrid, SES тощо) |
| API налаштувань | Зберігає вподобання користувача (частота, час) |
Накопичення подій
// Таблиця подій для дайджестів
// 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 користувачів.
Порівняння: власне рішення проти готових сервісів
| Критерій | Наше рішення | Готовий сервіс (Mailchimp, SendGrid) |
|---|---|---|
| Контроль даних | Повний — дані на ваших серверах | Дані у стороннього провайдера |
| Кастомізація | Безмежна — будь-який шаблон, логіка | Обмежена — лише доступні блоки |
| Залежність від API | Немає | Так — при збоях ESP розсилка зупиняється |
| Вартість при зростанні | Фіксована інфраструктура | Зростає з числом підписників |
| Продуктивність | 3× швидше при 100k подій/день | Залежить від сервера |
Що входить у нашу роботу
- Аналіз типів подій вашого застосування.
- Проектування таблиці
digest_eventsта інтеграція з поточною БД. - Реалізація трекера подій (
trackDigestEvent). - Налаштування cron-планувальника з урахуванням timezone.
- Розробка шаблонів листів (HTML + inline CSS).
- Інтеграція з ESP (SendGrid, AWS SES, SMTP).
- API керування вподобаннями користувача.
- Тестування під навантаженням — гарантуємо, що система витримає ваш обсяг.
- Документація та передача доступів.
- Підтримка протягом 2 тижнів після запуску.
Строки та вартість
Система дайджестів із накопиченням подій, планувальником, урахуванням timezone та налаштуваннями користувача — від 4 до 6 днів. Точна оцінка залежить від кількості типів подій та складності шаблонів. Ми оцінюємо проєкт безкоштовно.
Хочете таку саму систему для вашого проєкту? Отримайте консультацію інженера — ми проаналізуємо вашу інфраструктуру та запропонуємо оптимальне рішення. Замовте безкоштовну оцінку вже сьогодні.