Wie, um Nachrichten zu empfangen, zählen in Amazon SQS verwenden boto Bibliothek in Python?

Gibt es zumindest ein paar Möglichkeiten, dies zu tun.

Wenn Sie eine Nachricht Lesen, in boto, erhalten Sie ein Message-Objekt oder einige Unterklasse davon. Das Message-Objekt hat ein "Attribute" - Feld, das ist ein dict mit allen message-Attribute bekannt durch die SQS. Eines der Dinge, die SQS-tracks ist die Ungefähre Anzahl der Zeiten, die Nachricht wurde gelesen. So, könnten Sie diesen Wert verwenden, um zu bestimmen, ob die Nachricht gelöscht werden soll oder nicht, aber Sie müssen bequem sein mit der "Ungefähre" Natur des Wertes.

Alternativ können Sie die Aufnahme-message-ID ' s in einer Art Datenbank und die Schrittweite ein count-Feld in der Datenbank jedes mal, wenn Sie die Nachricht Lesen. Dies könnte geschehen in einem einfachen Python dict, wenn die Nachrichten werden immer gelesen wird, innerhalb eines einzelnen Prozesses oder es getan werden könnte, in so etwas wie SimpleDB, wenn Sie brauchen, um Messwerte aufzuzeichnen, der über Prozesse.

Hoffe, das hilft.

Hier einige Beispiel-code:

>>> import boto.sqs
>>> c = boto.sqs.connect_to_region()
>>> q = c.lookup('myqueue')
>>> messages = c.receive_message(q, num_messages=1, attributes='All')
>>> messages[0].attributes
{u'ApproximateFirstReceiveTimestamp': u'1365474374620',
 u'ApproximateReceiveCount': u'2',
 u'SenderId': u'419278470775',
 u'SentTimestamp': u'1365474360357'}
>>>

aws hat eingebaute Unterstützung für diese, Folgen Sie einfach den unten aufgeführten Schritte:

1. erstellen eines dead letter-Warteschlange
2. aktivieren Redrive Politik für die Quell-queue, indem Sie "Verwenden, Redrive Politik"
3. wählen Sie die dead letter-Warteschlange, die Sie erstellt in Schritt#1 für "Dead Letter Queue"
4. Set "Maximal Erhält", wie "3" oder einen beliebigen Wert zwischen 1 und 1000

Wie es funktioniert, ist, wenn eine Nachricht empfangen wird, die der Arbeitnehmer, die erhalten count inkrementiert. Sobald es erreicht "Maximum Erhält" zählen, wird die Nachricht gedrückt, um die dead letter-Warteschlange. Beachten Sie, auch wenn Sie auf die Nachricht über die aws-Konsole, die erhalten count inkrementiert.

Quelle Die Verwendung von Amazon SQS Dead Letter-Warteschlange

Bekommen ApproximateReceiveCount Attribut von Nachricht, die Sie Lesen.
verschieben Sie es an eine andere Warteschlange(als Sie verwalten können, Fehlermeldungen) oder löschen Sie es einfach.

foreach (var message in response.Messages){
       try{
           var notifyMessage = JsonConvert.DeserializeObject<NotificationMessage>(message.Body);
                    Global.Sqs.DeleteMessageFromQ(message.ReceiptHandle);
           }
       catch (Exception ex){
           var  receiveMessageCount = int.Parse(message.Attributes["ApproximateReceiveCount"]);
           if (receiveMessageCount >3 ) 
              Global.Sqs.DeleteMessageFromQ(message.ReceiptHandle);
            }
        }