Какие используешь брокеры сообщений

В Python популярны несколько брокеров сообщений, выбор зависит от требований к производительности, масштабируемости и простоте использования:

1. RabbitMQ – надежный, поддерживает AMQP, удобен для сложных сценариев маршрутизации.
   Пример:
   python

   Копировать

   import pika
   connection = pika.BlockingConnection(pika.ConnectionParameters('localhost'))
   channel = connection.channel()
   channel.queue_declare(queue='hello')
   channel.basic_publish(exchange='', routing_key='hello', body='Hello World!')

2. Kafka – для высоконагруженных систем, потоковой обработки данных.
   Пример с confluent-kafka:

   python

   Копировать

   from confluent_kafka import Producer
   producer = Producer({'bootstrap.servers': 'localhost:9092'})
   producer.produce('topic', key='key', value='message')
   producer.flush()

3. Redis Pub/Sub – простой и быстрый, но без гарантий доставки.
   Пример:

   python

   Копировать

   import redis
   r = redis.Redis()
   r.publish('channel', 'message')

4. Celery (с брокерами Redis/RabbitMQ) – для асинхронных задач и распределенных вычислений.

Выбор зависит от задачи: RabbitMQ для надежности, Kafka для потоков, Redis для простоты.