В качестве способа изучения RabbitMQ и python я работаю над проектом, который позволяет мне распределять кодировку h264 между несколькими компьютерами. Основы выполнены, у меня есть демон, работающий на Linux или Mac, который подключается к очереди, принимает задания и кодирует их с помощью HandBrakeCLI и подтверждает сообщение после завершения кодирования. Я также создал простой инструмент для добавления элементов в очередь.
Теперь я хочу расширить возможности инструмента, помещающего элементы в очередь, чтобы я мог просматривать, что находится в очереди. Я знаю о возможности видеть, сколько элементов находится в очереди, но я хочу иметь возможность получать фактические сообщения, чтобы я мог показать, какой фильм или телешоу еще ждут кодирования. Идея состоит в том, что администратор очередей будет получать сообщения от клиентов кодировщика после завершения задания, а затем обновлять список очередей.
Я знаю, что существует запутанный способ синхронизации списка диспетчера очередей с фактической рабочей очередью, но я хотел бы, чтобы он был «постоянным» в том смысле, что я должен иметь возможность закрыть диспетчер очередей и снова открыть его позже, чтобы увидеть очередь .