Как сделать Nack в Python

Question

Я пытался использовать эти функции: - basic_nack - basic_reject, но я не смог этого сделать

Я хочу пример nack в python, используя pika с одной из следующих функций: - basic_nack - basic_reject

 def callback(ch, method, properties, body):
     ch.basic_reject(delivery_tag=method.delivery_tag) 

return pika.exceptions.ChannelClosed: (406, 'PRECONDITION_FAILED - unknown delivery tag 1')

Answer 1

Из документации pika отклонение сообщения может быть сделано следующим образом:

import pika

connection = pika.BlockingConnection()
channel = connection.channel()

for method_frame, properties, body in channel.consume('test'):
    channel.basic_reject(method_frame.delivery_tag)

Обратите внимание, что вам нужно передать delivery_tag значение из method_frame объекта, который указывает, какое сообщение отклоняется.

basic_reject() метод также принимает дополнительный аргумент requeue, который по умолчанию True.