PYTHON RABBITMQ ПРИМЕРЫ

Python rabbitmq — это комбинация языка программирования Python и программного обеспечения rabbitmq для работы с распределенными системами. Rabbitmq предоставляет реализацию среды очередей сообщений, которая реализует стандарт AMQP (Advanced Message Queuing Protocol).

При использовании python rabbitmq, создается соединение с брокером сообщений rabbitmq, а затем можно использовать очереди, обмены сообщений и привязки для отправки и получения сообщений на удаленные узлы.

Пример создания очереди и отправки сообщения с использованием python rabbitmq:

import pikaconnection = pika.BlockingConnection(pika.ConnectionParameters('localhost'))channel = connection.channel()channel.queue_declare(queue='hello')channel.basic_publish(exchange='', routing_key='hello', body='Hello World!')print(" [x] Sent 'Hello World!'")connection.close()

В этом примере мы создаем соединение с локальным брокером rabbitmq и объявляем очередь 'hello'. Затем мы отправляем сообщение "Hello World!" в эту очередь. Мы используем метод basic_publish для отправки сообщения с указанием обмена и ключа маршрутизации как пустые значения.

Пример получения сообщения из очереди:

import pikaconnection = pika.BlockingConnection(pika.ConnectionParameters('localhost'))channel = connection.channel()channel.queue_declare(queue='hello')def callback(ch, method, properties, body):    print(" [x] Received %r" % body)channel.basic_consume(queue='hello', on_message_callback=callback, auto_ack=True)print(' [*] Waiting for messages. To exit press CTRL+C')channel.start_consuming()

В этом примере мы также создаем соединение с локальным брокером rabbitmq и объявляем очередь 'hello'. Затем мы используем метод basic_consume для получения сообщений из очереди. Когда сообщение получено, мы выводим его содержимое в консоль.