Отложенное планирование сообщений в NATS — однократное, через Cron и выборочное отслеживание по т...
Synadia
0:00 / 0:00
Отложенное планирование сообщений в NATS — однократное, через Cron и выборочное отслеживание по т...
1 307 просмотров · 5 месяцев назад
Synadia
7,07 тыс. подписчиков
1 307 просмотров · 5 месяцев назад
Нужно отправить сообщение в определённое время? Хватит использовать cron-задания и обходные пути для задержки доставки. Начиная с NATS 2.12, JetStream имеет встроенный планировщик сообщений — опубликуйте сообщение с заголовком, и сервер доставит его точно в нужное время.
В этом видео мы подробно разберём, как это работает, рассмотрим каждый режим планирования с демонстрацией в реальном времени через CLI и создадим программу на Go, которая объединяет всё это воедино.
Что вы узнаете:
Однократная отложенная доставка с использованием заголовков Nats-Schedule
Повторяющиеся расписания с использованием выражений cron и фиксированных интервалов (NATS 2.14)
Выборка субъектов — сокращение высокочастотных данных без изменения кода производителя
Настройка потока: allow_msg_schedules, allow_msg_ttl и правила, связанные с ними
Подводные камни: просроченные расписания, истечение TTL, переходы на летнее время с cron
Временные метки
0:00 Проблема отложенной доставки
0:55 Как работает планировщик сообщений
2:17 Повторяющиеся расписания (cron, интервалы, псевдонимы)
2:46 Выборка субъектов для сокращения данных
3:12 Конфигурация и подводные камни
3:54 Краткий обзор режимов планирования
4:10 Демонстрация CLI: поток с поддержкой расписания
11:15 Разбор кода на Go
13:34 Заключение
Ресурсы
NATS Документация: https://docs.nats.io
NATS GitHub: https://github.com/nats-io
Synadia: https://www.synadia.com
CLI/Код: https://github.com/synadia-labs/topic...
#NATS #JetStream #Messaging #CloudNative #GoLang #Scheduling