Ubuntu 24.04
Sponsored Link

RabbitMQ : Python पर प्रयोग करें2024/07/22

 
यह Python पर RabbitMQ का उपयोग करने का एक उदाहरण है।
[1] AMQP क्लाइंट लाइब्रेरी स्थापित करें।
root@dlp:~#
apt -y install python3-pika
[2] यह Python पर संदेश भेजने का एक उदाहरण है।
उदाहरण के लिए, एक उपयोगकर्ता [serverworld], वर्चुअलहोस्ट [my_vhost] के साथ [localhost] पर RabbitMQ से जुड़ें।
ubuntu@dlp:~$
vi send_msg.py
import pika

credentials = pika.PlainCredentials(
    'serverworld',
    'password'
)

connection = pika.BlockingConnection(
    pika.ConnectionParameters(
        'localhost',
        5672,
        '/my_vhost',
        credentials
    )
)

channel = connection.channel()
channel.queue_declare(queue='Hello_World')

channel.basic_publish(
    exchange='',
    routing_key='Hello_World',
    body='Hello RabbitMQ World!'
)

print(" [x] Sent 'Hello_World'")

connection.close()

ubuntu@dlp:~$
python3 send_msg.py

 [x] Sent 'Hello_World'
[3] यह Python पर संदेश प्राप्त करने का एक उदाहरण है।
ubuntu@node01:~$
vi receive_msg.py
import signal
import pika

signal.signal(signal.SIGPIPE, signal.SIG_DFL)
signal.signal(signal.SIGINT, signal.SIG_DFL)

credentials = pika.PlainCredentials(
    'serverworld',
    'password'
)

connection = pika.BlockingConnection(
    pika.ConnectionParameters(
        '10.0.0.30',
        5672,
        '/my_vhost',
        credentials
    )
)

channel = connection.channel()
channel.queue_declare(queue='Hello_World')

def callback(ch, method, properties, body):
    print(" [x] Received %r" % body
)

channel.basic_consume('Hello_World', callback, auto_ack=True)

print(' [*] Waiting for messages. To exit press CTRL+C')
channel.start_consuming()

ubuntu@node01:~$
python3 receive_msg.py

 [*] Waiting for messages. To exit press CTRL+C
 [x] Received b'Hello RabbitMQ World!'
मिलान सामग्री