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