Veröffentlichen Sie mehrere Nachrichten zu RabbitMQ aus einer Datei

Publishing einzelnen Nachrichten zu einem RabbitMQ Warteschlange kann leicht getan werden mit der Benutzeroberfläche, indem Sie die Nachricht in der Benutzeroberfläche und klicken auf "Nachricht Veröffentlichen" - button.

Wie veröffentlichen Sie einen Stapel von Nachrichten?

Ich habe eine Datei mit Nachrichten zu RabbitMQ. Jede Linie hat eine Botschaft.

Wie kann ich veröffentlichen, alle Nachrichten aus der Datei zu meinem RabbitMQ-server?

Gibt es einen Weg, um es von der Kommandozeile aus?

InformationsquelleAutor summerbulb | 2015-11-02

  1. 8

    Müssen Sie rabbitmqadmin cli-tool:

    https://www.rabbitmq.com/management-cli.html

    rabbitmqadmin publish exchange=amq.default routing_key=test payload="hello, world"

    Wie funktioniert dieses snippet veröffentlichen, die Nachrichten - /Nutzlasten von der Datei?
    versuchen smth like this: while read line; do rabbitmqadmin publish exchange=amq.default routing_key=test payload="$line"; done < file
    payload="$line" brechen würde JSON - \- escapes wie {"foo": "\"nested quotes\""} (weil Sie in der shell interpretiert die \-escapes). Aber Sie können passieren Nutzlast rabbitmqadmin stdin.
    Ja, wie erwähnt, es ist bedauerlich, dass rabbitmqadmin erfordert die Eingabe von text (durch Eingabe von der shell aus), nicht zu erwähnen, dass es verwendet das http-api für die Veröffentlichung/verbrauchen so neigt Sie dazu, ziemlich langsam für größere Nutzung.

    InformationsquelleAutor aeryaguzov

  2. 7

    Mit rabbitmqadmin

    while read -r line; do 
  echo $line | rabbitmqadmin publish exchange=amq.default routing_key=my_queue ; 
done < messages

    Nicht die Angabe der Nutzlast-parameter rabbitmqadmin publish heißt, es liest die Nutzlast von stdin.

    InformationsquelleAutor looseend

  3. 1

    Habe ich aktualisiert rabbitmqadmin-Datei, um Unterstützung für die Datei-Inhalte veröffentlichen. Versuchen Sie finden eine Zeile mit EXTRA_VERBS = { sowie def invoke_publish(self): und aktualisieren Sie Ihren code wie folgt

    EXTRA_VERBS = {
    'publish': {'mandatory': ['routing_key'],
                'optional':  {'payload': None,
                              'pfile': None,
                              'properties': {},
                              'exchange': 'amq.default',
                              'payload_encoding': 'string'},
                'json':      ['properties'],
                'uri':       '/exchanges/{vhost}/{exchange}/publish'},
    'get':     {'mandatory': ['queue'],
                'optional':  {'count': '1', 'requeue': 'true',
                              'payload_file': None, 'encoding': 'auto'},
                'uri':       '/queues/{vhost}/{queue}/get'}
}

    und

    def invoke_publish(self):
    (uri, upload) = self.parse_args(self.args, EXTRA_VERBS['publish'])
    if not 'payload' and 'pfile' in upload:
        data = sys.stdin.read()
        upload['payload'] = b64(data)
        upload['payload_encoding'] = 'base64'
    elif not 'payload' in upload:
        with open('populate/' + upload['pfile']) as f: data = f.read()
        upload['payload'] = b64(data)
        upload['payload_encoding'] = 'base64'
    resp = json.loads(self.post(uri, json.dumps(upload)))
    if resp['routed']:
        self.verbose("Message published")
    else:
        self.verbose("Message published but NOT routed")

    Entfernen 'populate/' + aus der folgenden Zeile, wenn Sie möchten-Datei mit absoluten Pfad.

    with open('populate/' + upload['pfile']) as f: data = f.read()

    Ohne updates zu öffnen(...) folgenden Befehl funktionierte für mich in Ordnung, vorausgesetzt, dass die Datei-Regeln.json gesetzt wurde, im relativen Verzeichnis "Auffüllen"

    python rabbitmqadmin.py publish exchange=feed-mgmt-in routing_key='#' properties='{"type":"domain-collections/rules"}' pfile="rules.json"

    InformationsquelleAutor Keynash

  4. 1

    können Sie curl und rabbitmq-api:

    curl -u login:pass -i -H "content-type:application/json" -X POST http://localhost:15672/api/exchanges/%2Fvhost/exchange/publish -d'{"properties":{},"routing_key":"","payload":"you message","payload_encoding":"string"}'

    dies ist ein Beispiel für eine Nachricht, die von Analogie, können Sie ein Skript schreiben

    InformationsquelleAutor Oleg SH

  5. -1

    Verwenden Sie einfach amqp-Tools:

    npm install amqp-tool -g

amqp-tool --host rabbitmq.local -u <user> -p <password> -q <queue name> --import file.json

    InformationsquelleAutor matagus

Schreibe einen Kommentar