Реализация 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 пользователей.

Сравнение: самописное решение vs готовые сервисы

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

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 дней. Точная оценка зависит от количества типов событий и сложности шаблонов. Мы оцениваем проект бесплатно.

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