У меня на бэкенде есть функционал оповещений. Раз в час скрип проходит по записям в БД и обновляет информацию по товарам. Если определенная информация изменилась (Это может быть цена или остаток на складе), то создается таск на оповещение, пример:
# создания таска для оповещения пользователю
if price != self.price:
check_notifications.delay(poduct_id=self.pk, old_price=self.price, new_price=price)
В самом таске формируется сообщение на почту для определённой группы пользователей, исходя из полученных данных.
Столкнулся с такой проблемой. Товаров более 1млн, остаток может меняться часто и получается что раз в час почта разрывается от количества сообщений.
Какое решения я вижу: формирования списка товаров, у которых изменилась информация, по завершении скрипта формируется уже одно сообщение в котором скажем 1000 товаров, а не 1000 раздельных сообщений
Как в celery сформировать список тасков с каким-нибудь пояснением или флагом, который будет их объединять? Как такой список передать в функцию для создания сообщения? Как после завершения скрипта вызывать функцию, которая объединит информацию из всех тасков?
Буду очень благодарен за любую помощь
check_notifications_for_many_products.delay(products=products_list)