Блог

У меня очередь из 2 потребителей. Я хочу, чтобы сообщения обрабатывались в том порядке, в котором они были получены потребителем, однако мои сообщения в конечном итоге выходят из строя, потому что потребитель обрабатывает их параллельно (я полагаю, используя циклическую обработку).

Я наткнулся на это в документах rabbitmq, которые заставляют меня поверить, что есть способ использовать мои сообщения в том порядке, в котором они были получены. Я использую python3.7 с комбу.

Я попробовал следующее, но это не работает для меня, так как сообщения все еще используются не по порядку.

 from kombu import Queue as KombuQueue

KombuQueue(
            name="my_queue_name",
            exchange="my_exchange_name",
            routing_key=None,
            durable=True,
            exclusive=False,
            auto_delete=False,
            queue_arguments={"x-single-active-consumer": True}
)