Worker для рассылки уведомлений

Реализовать worker на фреймворке FastStream.

Полезные ссылки:

Rabbit Routing - FastStream - документация про использование фреймворка в связке с RabbitMQ
Обработчик очереди уведомлений

Схема сообщения очереди notifications.general

{  
    "notification_id": "uuid"
}

@broker.subscriber("notifications.general", "default")  
async def handle_notification(message: NotificationMessage):  
    # Обработка сообщения

Логика обработчика:

Получить из БД уведомление и его содержание
Получить информацию о пользователе из сервиса профилей
- Либо, если указан user_group_id, получить всех пользователей из заданной группы
Получить из БД шаблон уведомления
Исключить пользователей, которые отключили каналы уведомлений.
Отрендерить шаблон, используя переменные из содержания уведомления
Отправить сообщения в очереди для указанных каналов:
- notifications.sms, (не будем реализовывать - заглушка)
- notifications.email,
- notifications.websocket (не будем реализовывать - заглушка)
- notifications.push (не будем реализовывать - заглушка)
Пометить в БД уведомление как отправленное (обновить поле sent_at)
Обработчик очереди email

Схема сообщения очереди notifications.email

{  
    "notification_id": "uuid",    
    "body": "Отрендеренный шаблон",    
    "email": "vasya@example.com",    
    "user_id": "uuid"
}

@broker.subscriber("notifications.email", "default")  
async def handle_email(msg: EmailMessage):  
    # Обработка сообщения

Логика обработчика:

a1d4r / practicum-notifications