У меня есть webAPI с балансировкой нагрузки, который принимает пользовательский ввод. В зависимости от типа ввода, я должен обрабатывать запрос с задержками. Например, Пользователь может сказать, обработать его сообщение через 20 минут. Другой пользователь может сказать, обработать его сообщение через 22 минуты. В течение 20 минут первый пользователь может попросить, чтобы его сообщение было отменено (не должно обрабатываться).
Я думал о планировщиках cron, но число событий может быть огромным, что вызывает скачки в использовании памяти. Кроме того, в случае сбоя системы события будут пропущены. Я также посмотрел на отложенные очереди в RabbitMQ, но отмена определенных сообщений не возможна ни в какой системе очередей.
Я ищу платформу, где я могу сбросить сообщения и задержку, и среда должна воспроизвести сообщение в обратном вызове после интервала задержки. Из-за размера проблемы требуется, чтобы платформа масштабировалась горизонтально без какой-либо одной точки отказа.
Если у кого-то есть опыт работы с такими фреймворками и он может перенаправить меня, было бы здорово.