У меня есть 3 процесса - 2 производителя, которые записывают данные в очередь, и 1 потребитель, который читает данные из него:
queue = Queue()
consumer = ConsumerProcess(queue).start()
producer1 = ProducerAProcess(queue).start()
producer2 = ProducerBProcess(queue).start()
Интересно, как получить одну и ту же очередь внутри любого из этих процессов, если он выходит из строя?и перезапускается - например, получить экземпляр очереди по его идентификатору или имени или по пути к файлу ...
Например, предположим, что мой потребительский процесс по какой-то причине был прерван.Затем я хочу перезапустить его и продолжить чтение сообщений из одной и той же очереди.
Есть ли способ достичь этого без использования внешних брокеров сообщений, таких как RabbitMQ?