İletilerin teslim edilmesini nasıl sağlarsınız?

Question

Mesajların Pika ile teslim edilmesini nasıl sağlıyorsunuz? İleti başarıyla teslim edilmediyse, varsayılan olarak size bir hata vermez.

Bu örnekte pika'dan önce birkaç mesaj gönderilebilir, bağlantının kesildiğini onaylar. Eğer mesajlar yayımlamaya başlayacağı

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

channel.confirm_delivery() bayrak ayarlanması gerekir Pika kullanmadan önce. Bu önemlidir, böylece Pika her mesajın bir sonraki mesajı göndermeden önce başarıyla gönderildiğini onaylayacaktır. Ancak, programın bir sonraki mesaja devam etmeden önce teslimatın onaylanması gerektiğinden, bu mesajlar RabbitMQ mesajlarına gönderilme süresini uzatır.

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 mesajın gönderildiği veya olmasaydı bağlı olarak Boolean dönecektir. Ancak, bağlantı sırasında bağlantının kapalı olması ve uygun şekilde ele alınması durumunda potansiyel istisnaları yakalamak önemlidir. Bu gibi istisnalar program akışını kesintiye uğratır.