如何确保邮件传递？

Question

您如何确保消息与Pika一起交付？默认情况下,如果邮件未成功传递,则不会向您提供错误.

在此示例中,在pika确认连接断开之前,可以发送几条消息.

import pika

connection = pika.BlockingConnection(pika.ConnectionParameters(
        host='localhost'))
channel = connection.channel()
channel.queue_declare(queue='hello')
for index in xrange(10):
    channel.basic_publish(exchange='', routing_key='hello', 
                          body='Hello World #%s!' % index)
    print('Total Messages Sent: %s' % x)
connection.close()

Answer 1

使用Pika时,channel.confirm_delivery()需要在开始发布消息之前设置标志.这很重要,以便Pika在发送下一条消息之前确认每条消息都已成功发送.然而,这将增加向RabbitMQ发送消息所花费的时间,因为在程序继续下一条消息之前需要确认传递.

channel.confirm_delivery()

try:
   for index in xrange(10):
       channel.basic_publish(exchange='', routing_key='hello', 
                              body='Hello World #%s!' % index)
       print('Total Messages Sent: %s' % x)
except pika.exceptions.ConnectionClosed as exc:
    print('Error. Connection closed, and the message was never delivered.')

basic_publish将返回一个Boolean取决于邮件是否已发送.但是,如果在传输期间关闭连接并适当地处理它,则捕获潜在的异常非常重要.在这些情况下,异常将中断程序的流程.