Tag: pika

Python-Pika ist eine Reine Python-Implementierung des AMQP 0-9-1-Protokoll, das versucht, zu bleiben, ziemlich unabhängig von der zugrunde liegenden Netzwerk-support-Bibliothek. Python-Pika wurde hauptsächlich für die Verwendung mit RabbitMQ, sollte aber auch mit anderen AMQP 0-9-1 Broker.

AMQP: Anerkennung und prefetching

Anzahl der Antworten 1 Antworten
Ich versuche zu verstehen, einige Aspekte des AMQP-Protokoll. Derzeit habe ich ein Projekt mit RabbitMQ und Nutzung von python-pika-Bibliothek. Also Frage ist im Hinblick auf die Anerkennung und die Nachricht prefetching. Betrachten wir eine Warteschlange mit nur

Richtige config mit rabbitmq als Sellerie-backend

Anzahl der Antworten 1 Antworten
Baue ich einen Kolben app mit Sellerie, mit rabbitmq als Sellerie-backend. meine conf für Sellerie ist CELERY_BROKER_URL='amqp://localhost:5672', CELERY_RESULT_BACKEND='amqp://', CELERY_QUEUE_HA_POLICY='all', CELERY_TASK_RESULT_EXPIRES=None Dann, deklarieren eine Warteschlange produziert eine ganze Reihe von Fehler connection = pika.BlockingConnection(pika.ConnectionParameters('localhost')) channel = connection.channel() channel.queue_declare(queue=new_task_id)

Verbrauchen Sie mehrere Warteschlangen in python / pika

Anzahl der Antworten 2 Antworten
Ich versuche zu erstellen, die Verbraucher würden abonnieren Sie mehrere Warteschlangen, und dann die Verarbeitung von Nachrichten, wie Sie ankommen. Das problem ist, dass, wenn es einige Daten, die bereits in der ersten Warteschlange verbraucht er die

Pika Arbeiter wirft exception beim ausführen Kanal.declare_queue

Anzahl der Antworten 3 Antworten
Ich Schreibe ein python-client für die Aufnahme einer Arbeit, die Nachrichten aus einer RabbitMQ-broker und verarbeiten die Aufträge, für die Rückgabe der Ergebnisse auf einen anderen server. Mein script sendet Nachrichten an den RabbitMQ-broker startet gut, aber

pika.Ausnahmen.ProbableAuthenticationError, wenn Sie versuchen, um Nachricht zu senden, um remote-queue

Anzahl der Antworten 1 Antworten
Ich versuche zu laufen RabbitMQ Python-tutorial aber mit Absender auf der virtualbox-host-Maschine und-Empfänger und die Warteschlange auf der virtualbox-Gast-Maschine. Also modifizierte ich erwähnt send.py code nur ersetzt localhost mit 192.168.1.5. Wenn ich es laufen lasse, erhalte ich

rabbitmq mehrere Verbraucher, die in einer Warteschlange - nur kriegt die Nachricht

Anzahl der Antworten 1 Antworten
Implementiert habe ich mehrere Verbraucher, die das abrufen von Nachrichten aus einer Warteschlange, ich mache das mit etwas ähnlich dieses Beispiel, außer, dass ich das Tue basic.Holen Sie sich in eine unendliche Schleife für die Abfrage an.

In Pika oder RabbitMQ, Wie kann ich überprüfen, ob alle Verbraucher sind derzeit in Anspruch genommen?

Anzahl der Antworten 2 Antworten
Ich würde gerne überprüfen, ob eine Verbraucher/Arbeitnehmer anwesend ist, um zu konsumieren, ein Nachricht ich bin zu senden. Wenn es keine Arbeiter, würde ich anfangen, einige Arbeiter (sowohl die Konsumenten als auch Publisher sind auf einer einzigen

Verbindung geschlossen rabbitmq aus irgendeinem Grund nach einiger Zeit

Anzahl der Antworten 3 Antworten
Bin ich mit pika-python-Bibliothek, um eine Verbindung zu rabbitmq-server auf localhost. class BaseRabbitSender(MessageSender): __metaclass__ = ABCMeta def __init__(self, host): self.node = BaseMessagingNode(host) self.connection = pika.BlockingConnection(pika.ConnectionParameters( host=host)) self.channel = self.connection.channel() @abstractmethod def send_message(self, message): pass def close_connection(self): self.connection.close()

python keine Modul Namen pika beim importieren von pika

Anzahl der Antworten 5 Antworten
Ich installierte pika für python läuft auf einem mac sudo pip install pika==0.9.8 Ich sicher installiert ist, dies ist die Antwort, wenn Sie versuchen, neu zu installieren, Requirement already satisfied (use --upgrade to upgrade): pika==0.9.8 in /usr/local/lib/python2.7/site-packages

Wie die Verbindung von pika zu rabbitMQ remote-server? (python, pika)

Anzahl der Antworten 2 Antworten
In meiner lokalen Maschine, die ich haben kann: connection = pika.BlockingConnection(pika.ConnectionParameters('localhost')) für beide Skripts (send.py und recv.py), um die Kommunikation herzustellen, was aber eine Kommunikation von 12.23.45.67 zu 132.45.23.14 ? Ich weiß, über all die Parameter, die

Python und RabbitMQ - Beste Weg, um hören zu konsumieren Ereignisse, die von mehreren Kanälen?

Anzahl der Antworten 2 Antworten
Habe ich zwei, separate RabbitMQ-Instanzen. Ich bin versuchen zu finden der beste Weg, um zu hören, um Ereignisse aus beiden. Ich kann zum Beispiel verbrauchen Ereignisse zu eins mit dem folgenden: credentials = pika.PlainCredentials(user, pass) connection =

Fehlermeldung "unbekannter Lieferzeit-tag" tritt auf, wenn ich versuche ack-Nachrichten zu RabbitMQ mit pika (python)

Anzahl der Antworten 5 Antworten
Möchte ich die Verarbeitung von Nachrichten in paar threads aber ich bin immer ein Fehler während der Ausführung dieses Codes: from __future__ import with_statement import pika import sys from pika.adapters.blocking_connection import BlockingConnection from pika import connection, credentials

RabbitMQ, Pika und reconnection-Strategie

Anzahl der Antworten 1 Antworten
Bin ich mit Pika, um Prozess Daten von RabbitMQ. Als ich schien zu laufen, in verschiedene Art von Problemen habe ich mich dazu entschlossen eine kleine test-Anwendung, um zu sehen, wie ich damit umgehen kann, trennt. Schrieb

So erstellen Sie eine verzögerte queue RabbitMQ?

Anzahl der Antworten 5 Antworten
Was ist der einfachste Weg, eine delay (oder Parkplatz) - Warteschlange mit Python, Pika und RabbitMQ? Ich habe gesehen, dass ähnliche Fragenaber keine für Python. Ich finde das eine sehr nützliche Idee, beim entwerfen von Anwendungen, er

Umgang mit lang laufenden Aufgaben in pika / RabbitMQ

Anzahl der Antworten 4 Antworten
Wir versuchen, eine basic unter-queue-system, wo ein Produzent generiert mehrere Aufgaben und einem oder mehr Verbraucher greifen, eine Aufgabe zu einer Zeit, zu verarbeiten, und bestätigen Sie die Meldung. Das problem ist, kann die Verarbeitung dauert 10-20

Wie kann ich unbestätigte AMQP-Nachrichten von anderen als den eigenen Kanälen wiederherstellen?

Anzahl der Antworten 3 Antworten
Scheint es, desto länger behalte ich meine rabbitmq-server laufen, desto mehr Schwierigkeiten habe ich mit unbestätigten Nachrichten. Ich würde gerne requeue. In der Tat scheint es eine amqp-Befehl, um dies zu tun, aber es gilt nur für