Как получить все отложенные задачи и очистить очередь в Pika RabbitMQ

Question

Я хочу получить все отложенные задачи в очереди для сохранения в базе данных.и удалите эти задачи из очереди.

Я знаю channel.purgeQueue, но он удалит их только.

Мне нужно знать ожидающие задачи в очереди.

Какчтобы получить их

Answer 1

Это базовая функциональность RabbitMQ, пожалуйста, прочитайте это:

https://www.rabbitmq.com/tutorials/tutorial-two-python.html

Код, который вы ищете:

def callback(ch, method, properties, body):
    print " [x] Received %r" % (body,)
    ### PUT_YOUR_CODE_HERE
    print " [x] Done"
    ch.basic_ack(delivery_tag = method.delivery_tag)

channel.basic_consume(callback,
                      queue='hello')

Когдавы выполняете ch.basic_ack сообщение удаляется из очереди