So senden Sie ein JSON-Nutzlast zu RabbitMQ mit dem web-plugin?

Ich habe eine RabbitMQ 3.4.2 Beispiel mit einem web-management-plugin installiert.

Wenn ich push-to-die Nachricht {'operationId': 194} an die Warteschlange über Python ' s kombu queue-Paket, wird die Nachricht Lesen, die am anderen Ende als ein Wörterbuch.

Allerdings, wenn ich die Nachricht senden, mit der web-Konsole:

So senden Sie ein JSON-Nutzlast zu RabbitMQ mit dem web-plugin?

Bekomme ich die folgende Fehlermeldung auf dem empfangenden Ende:

operation_id = payload['operationId']
TypeError: string indices must be integers

Ich habe versucht, das hinzufügen einer content-type header und Eigentum, aber ohne Erfolg.

Da der Leser code ist der gleiche, es bedeutet, dass der web-sender nicht markieren, wird die gesendete Nachricht als JSON /Wörterbuch Nutzlast, und es ist daher zu Lesen als einen string auf das andere Ende.

Keine Idee, wie markieren einer Nachricht als eine JSON Nachricht mit dem RabbitMQ-web-Konsole?

InformationsquelleAutor Adam Matan | 2015-12-10
  1. 20

    Musste ich content_type statt content-type (ein Unterstrich statt Bindestrich).

    Dies ist eine ziemlich fragwürdige design-Entscheidung, da die standard-jeder weiß, ist content-type.

    So senden Sie ein JSON-Nutzlast zu RabbitMQ mit dem web-plugin?

    • Es ist nicht ein HTTP-Header... Es ist zu unterscheiden, dass von den genannten Schlüssel sowie Einhaltung der RabbitMQ-Konvention verwenden, unterstreicht dessen Eigenschaften.
    InformationsquelleAutor Adam Matan
  2. 1

    Müssen Sie zum de-serialisieren der Ausgabe.

    import json
payload = json.loads(payload)
operation_id = payload['operationId']

    Zusätzlich {'operationId': 194} ist kein gültiges JSON. Obwohl es so aussieht, wie Sie doppelte Anführungszeichen verwenden in der Abbildung, aber stellen Sie sicher, ersetzen Sie die einfachen Anführungszeichen, mit doppelten Anführungszeichen.

    Edit:
    So sind Sie richtig, kombu sollte damit umgehen. Den code anzuschauen, ist es wahrscheinlich, dass der header groß-und Kleinschreibung. Ändern Sie die Eigenschaften header von Content-Type zu content-type.

    • Das lustige an der Sache ist, dass Nachrichten, die von Python-code erfordert keine Deserialisierung auf der Empfängerseite; also, ich denke, es gibt einige Metadaten, die nicht den job für mich. Wenn ich senden Sie {'operationId': 194} es empfangen wird, ein Wörterbuch, auf das andere Ende. Ich will diese Verhalten beim senden über die web-Konsole zu.
    • Du hast Recht. Ich denke, das könnte so dumm, wie die Header-Namen werden groß-und Kleinschreibung.
    • Ich hätte aufgegriffen. Ich habe die gleiche Umsetzung mit einem _ in meinem eigenen amqp Bibliothek. github.com/eandersson/amqp-storm/blob/master/amqpstorm/...
    • Nice one! Warum bauen Sie Ihre eigenen statt mit Kombu oder gleich?
    • Ich wollte etwas viel einfacher, mit einem hintergrund-thread zu verfolgen, Takte usw.
    InformationsquelleAutor eandersson
Schreibe einen Kommentar