kombu

0Hitze

1Antwort

Sellerie Kombu versagt nach self.connections.acquire

Wenn mein Sellerie-Service nach 7-10 Tagen läuft, habe ich diese Ausnahme aus dem Nichts erhalten, dadurch werden meine Aufgaben nicht bearbeitet. Ein Neustart von Sellerie behebt das Problem. INTERNA

6Hitze

1Antwort

Was ist der beste Weg, die Veröffentlichung von Nachrichten mit Kombu erneut zu versuchen?

Ich teste gerade wie Kombu funktioniert. Ich plane, Pika in mehreren Projekten zu ersetzen. Ich sehe, dass Kombu eine Menge Dokumentation hat, aber mit dem, was ich in der Dokumentation gefunden habe,

20Hitze

3Antwort

In-Memory-Broker für Sellerie-Unit-Tests

Ich habe eine REST-API in Django geschrieben, mit und Endpunkt, der eine Sellerie-Aufgabe in die Warteschlange stellt, wenn ich sie posten möchte. Die Antwort enthält die Aufgaben-ID, mit der ich test

0Hitze

1Antwort

So verwenden Sie den In-Memory-Transport für Komponententests richtig

Ich versuche, einige Tests zu schreiben, wo ich eine Nachricht an eine Warteschlange erstellen und sehen, ob die Nachricht in der Anwendung ordnungsgemäß verbraucht und verarbeitet wird. Dafür spiele

4Hitze

1Antwort

Sellerie: socket.error timed out

Ich verwende: celery==3.1.12 kombu==3.0.19 amqp==1.4.5 Sellerie Arbeiter gestartet wurde: celery worker --without-gossip --without-heartbeat --without-mingle Sellerie setiings: CELERY_ALWAYS_EAG

3Hitze

1Antwort

Mit Kombu ConsumerMixin, wie mehrere Bindungen deklarieren?

Ich habe einen RabbitMQ Themenaustausch namens experiment. Ich baue einen Verbraucher, wo ich alle Nachrichten empfangen möchte, deren Routing-Schlüssel mit "foo" beginnt und alle Nachrichten, deren R

0Hitze

1Antwort

Kombu beim Redisken von Nachrichten

Ich stelle ein Producer/Consumer-Setup mit Kombu auf Redis zusammen, aber ich stoße auf ein Problem. Wenn ich einen Verbraucher starte und dann den Producer mit der Reichweite (10000) starte, kann ich

0Hitze

1Antwort

Python Kombu Verbraucher get Nachrichten-Warteschlange aber der Rückruf auslösen kann nicht

Wenn ich gefolgt Code ausführen, fand ich, dass ich Nachricht aus der Warteschlange zu bekommen, aber die callback nicht ausgelöst from kombu.mixins import ConsumerMixin from kombu import Exchange, Q

1Hitze

1Antwort

Kombu nicht wieder an RabbitMQ

Ich habe zwei Server, nennen sie A und B. B läuft RabbitMQ, während A über Kombu zu RabbitMQ verbindet. Wenn ich RabbitMQ auf B neu starte, bricht die Kombu-Verbindung ab und die Nachrichten werden ni

7Hitze

1Antwort

RabbitMQ Heartbeat vs Verbindung Drain-Ereignisse Timeout

Ich habe eine Rabbitmq-Server und eine AMQP-Consumer (Python) mit Kombu. Ich habe meine App in einem System installiert, das eine Firewall hat, die inaktive Verbindungen nach 1 Stunde beendet. Dies is