SparkStreaming, RabbitMQ und MQTT in Python mit pika

Nur um es knifflig zu machen, möchte ich Nachrichten aus der rabbitMQ-Warteschlange konsumieren. Jetzt weiß ich, dass es ein Plugin für MQTT auf Rabbit gibt https: //www.rabbitmq.com/mqtt.htm [https://www.rabbitmq.com/mqtt.html]). Ich kann ...

Wie erstelle ich eine verzögerte Warteschlange in RabbitMQ?

Verbrauchen Sie mehrere Warteschlangen in Python / Pika

Ich versuche, einen Konsumenten zu erstellen, der mehrere Warteschlangen abonniert und dann Nachrichten verarbeitet, sobald sie ankommen. Das Problem ist, dass, wenn einige Daten bereits in der ersten Warteschlange vorhanden sind, diese die ...

Wie überprüfe ich in Pika oder RabbitMQ, ob Verbraucher aktuell konsumieren?

Ich würde gerne prüfen, ob aVerbraucher / Arbeitnehmer anwesend ist, a zu verbrauchenBotschaft Ich bin im Begriff zu senden.Wenn es keine gibtArbeitnehmerIch...

Pika blocking_connection.py zufällige Zeitüberschreitung beim Verbinden mit RabbitMQ

Wie mache ich eine einfache Pika SelectConnection, um eine Nachricht in Python zu senden?

Ich versuche, meinen Code zu konvertieren, um stattdessen Rabbitmq-Nachrichten über Pika zu senden. Ich habe große Probleme damit, eine einfache Nachricht über eine asynchrone Verbindung (z. B. SelectConnection) zu senden. In meinem alten Code, ...

RabbitMQ pika.exceptions.ConnectionClosed

Ich habe versucht, eine Nachricht mit RabbitMQ zu senden und zu empfangen. Ich habe keinen Informatik-Hintergrund. Die von mir verwendeten Begriffe könnten nicht sehr genau sein. Ich versuche, die Tutorial-Datei zu kopieren: Beim Senden ...

RabbitMQ ändert die Warteschlangenparameter auf einem Produktionssystem

Ich verwende RabbitMQ als Nachrichtenwarteschlange in einer serviceorientierten Architektur, in der viele separate Webdienste Nachrichten veröffentlichen, die an RabbitMQ-Warteschlangen gebunden sind. Diese Warteschlangen werden wiederum von ...