Publier plusieurs messages à partir d'un fichier RabbitMQ

La publication de messages à un RabbitMQ file d'attente peut être fait facilement avec l'INTERFACE utilisateur, en mettant simplement le message dans l'INTERFACE utilisateur et en cliquant sur "Publier le Message".

Comment faites vous pour publier un lot de messages?

J'ai un fichier avec l'envoi de messages à RabbitMQ. Chaque ligne a un message.

Comment puis-je publier tous les messages dans le fichier de mon serveur RabbitMQ?

Est-il un moyen de le faire en ligne de commande?

OriginalL'auteur summerbulb | 2015-11-02

  1. 8

    Vous devez utiliser rabbitmqadmin outils cli:

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

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

    Comment cet extrait de publier les messages/charges à partir du fichier?
    essayez de qch comme ceci: while read line; do rabbitmqadmin publish exchange=amq.default routing_key=test payload="$line"; done < file
    payload="$line" de casser JSON \échappe comme {"foo": "\"nested quotes\""} (parce que vous le shell interprète \échappe). Mais vous pouvez passer à charge pour rabbitmqadmin de stdin.
    Ouais, comme l'a noté il est malheureux que les rabbitmqadmin nécessite d'entrée de texte (en raison de l'entrée de la coquille), pour ne pas mentionner qu'il utilise l'api http pour la publication, de consommer, de sorte qu'il a tendance à être assez lent pour la plus grande utilisation.

    OriginalL'auteur aeryaguzov

  2. 7

    À l'aide de rabbitmqadmin

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

    Ne spécifiez pas le paramètre de charge utile à rabbitmqadmin publish signifie qu'il lit la charge utile à partir de stdin.

    OriginalL'auteur looseend

  3. 1

    J'ai mis à jour rabbitmqadmin fichier de fichier de support de publication de contenu. Essayez de trouver la ligne contenant EXTRA_VERBS = { ainsi que def invoke_publish(self): et de mettre à jour leur code comme suit

    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'}
}

    et

    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")

    Supprimer 'populate/' + à partir de la ligne suivante si vous souhaitez fournir un fichier à l'aide du chemin d'accès absolu.

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

    Sans mises à jour pour ouvrir(...) à la suite de la commande a fonctionné pour moi amende, en supposant que le fichier de règles.json a été placée dans le répertoire relatif "remplir"

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

    OriginalL'auteur Keynash

  4. 1

    vous pouvez utiliser curl et 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"}'

    ceci est un exemple d'un message, par analogie, vous pouvez écrire un script

    OriginalL'auteur Oleg SH

  5. 0

    Comme une variation de la réponse de looseend vous pouvez également utiliser GNU Parallèle

    Cela va donner beaucoup de meilleures performances si vous avez un gros fichier.

      cat messages | parallel -j 100 \
  ./rabbitmqadmin -H $RABBITMQ_HOST \
                  -u $RABBITMQ_USERNAME \
                  -p $RABBITMQ_PASSWORD  \
                  publish exchange=amq.default \
                  routing_key=myqueue \
                  payload="{}"

    Cela va fonctionner avec 100 emplois. Omettre d'accueil et les informations d'identification si pas nécessaire.

    OriginalL'auteur Matt20013

  6. -1

    Suffit d'utiliser amqp-outil:

    npm install amqp-tool -g

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

    OriginalL'auteur matagus