Реализация «проблемного ковша» -подобного алгоритма для очередей сообщений

Question

У меня есть приложение на основе ruby, которое имеет много разных очередей сообщений (+200 разных очередей), которые все должны быть ограничены или ограничены по отдельности. Я попытался проиллюстрировать эту проблему с помощью этой конфеты вендинг машины аналогию

Теперь как бы я идти о реализации системы/алгоритм, как это? Я думал о том, чтобы помещать сообщения/«конфеты» в разные списки/наборы redis или очереди RabbitMQ, но выталкивать их из каждой очереди по отдельным ставкам, кажется, сложная задача. Есть ли какие-то технологии, которые лучше подходят для работы, чем redis?

Answer 1

Вы можете использовать Resque (который также использует Redis для сохранения). Вы можете использовать другую очередь для каждого типа «конфет» и запускать работника для каждой очереди с разными значениями для опции --interval.

$ bin/resque work --queues=blue --interval=10 
$ bin/resque work --queues=green --interval=2 
$ bin/resque work --queues=red --interval=5