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.
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
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)
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
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
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
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.
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
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()
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
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
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 =
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
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
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
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
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