Для реализации быстрого обмена сообщениями между скриптами на Python через RabbitMQ вам потребуется использовать библиотеку Pika, которая предоставляет удобный интерфейс для работы с RabbitMQ.
Прежде всего, убедитесь, что RabbitMQ установлен и работает на вашем сервере. Затем установите библиотеку Pika, используя pip:
$ pip install pika
После установки Pika вы можете приступить к написанию кода. Вот пример базовой реализации обмена сообщениями:
import pika
# Устанавливаем соединение с RabbitMQ
connection = pika.BlockingConnection(pika.ConnectionParameters('localhost'))
channel = connection.channel()
# Создаем очередь для отправки сообщений
channel.queue_declare(queue='queue_name')
# Функция для обработки входящих сообщений
def callback(ch, method, properties, body):
print("Received message:", body.decode())
# Подписываемся на очередь для получения сообщений
channel.basic_consume(queue='queue_name', on_message_callback=callback, auto_ack=True)
# Запускаем цикл получения сообщений
channel.start_consuming()
В этом примере мы создаем подключение к RabbitMQ, объявляем очередь для отправки сообщений и создаем функцию обратного вызова callback(), которая будет обрабатывать входящие сообщения. Затем мы подписываемся на очередь с помощью basic_consume() и запускаем цикл получения сообщений с помощью start_consuming().
Чтобы отправить сообщение, вам потребуется еще один скрипт. Вот пример:
import pika
# Устанавливаем соединение с RabbitMQ
connection = pika.BlockingConnection(pika.ConnectionParameters('localhost'))
channel = connection.channel()
# Отправляем сообщение в очередь
channel.basic_publish(exchange='', routing_key='queue_name', body='Hello, world!')
# Закрываем соединение
connection.close()
В этом примере мы также создаем подключение к RabbitMQ, а затем с помощью basic_publish() отправляем сообщение с заданным текстом в очередь с указанным именем.
Таким образом, вы можете использовать эти два скрипта для быстрого обмена сообщениями между скриптами на Python через RabbitMQ.