Python Language Comment publier des messages sur RabbitMQ


Exemple

Commencez par importer la bibliothèque.

from amqpstorm import Connection
from amqpstorm import Message

Ensuite, nous devons ouvrir une connexion au serveur RabbitMQ.

connection = Connection('127.0.0.1', 'guest', 'guest')

Après cela, nous devons configurer un canal. Chaque connexion peut avoir plusieurs canaux et, en général, lors de l'exécution de tâches multithread, il est recommandé (mais pas obligatoire) d'en avoir une par thread.

channel = connection.channel()

Une fois notre chaîne configurée, nous pouvons commencer à préparer notre message.

# Message Properties.
properties = {
    'content_type': 'text/plain',
    'headers': {'key': 'value'}
}

# Create the message.
message = Message.create(channel=channel, body='Hello World!', properties=properties)

Maintenant, nous pouvons publier le message en appelant simplement publish et en fournissant une routing_key . Dans ce cas, nous allons envoyer le message à une file d'attente appelée simple_queue .

message.publish(routing_key='simple_queue')