Basics

Разделение зависимостей

Propan поддерживает различные брокеры сообщений используя для этого специальные классы

RedisRabbitMQKafkaSQSNATS

from propan import RedisBroker

from propan import RabbitBroker

from propan import KafkaBroker

from propan import SQSBroker

from propan import NatsBroker

Будьте внимательные! Разные брокеры требуют разных зависимостей. Если вы не установили эти зависимости, импортируемый брокер будет иметь значение None.

Для установки Propan с необходимыми для вашего брокера зависимостями, выберите один из вариантов установки

RedisRabbitMQKafkaSQSNATS

pip install "propan[async-redis]"

pip install "propan[async-rabbit]"

pip install "propan[async-kafka]"

pip install "propan[async-sqs]"

pip install "propan[async-nats]"

Инициализации брокера

Данные для подключения Propan Broker к вашему брокеру сообщений могут быть переданы 2мя способами:

RedisRabbitMQKafkaSQSNATS

1. В конструкторе брокера

   from propan import RedisBroker
   broker = RedisBroker("redis://localhost:6379/")
   

2. В методе connect

   from propan import RedisBroker
   broker = RedisBroker()
   ...
   await broker.connect("redis://localhost:6379/")
   

1. В конструкторе брокера

   from propan import RabbitBroker
   broker = RabbitBroker("amqp://guest:guest@localhost:5672/")
   

2. В методе connect

   from propan import RabbitBroker
   broker = RabbitBroker()
   ...
   await broker.connect("amqp://guest:guest@localhost:5672/")
   

1. В конструкторе брокера

   from propan import KafkaBroker
   broker = KafkaBroker("localhost:9092")
   

2. В методе connect

   from propan import KafkaBroker
   broker = KafkaBroker()
   ...
   await broker.connect("localhost:9092")
   

1. В конструкторе брокера

   from propan import SQSBroker
   broker = SQSBroker("http://localhost:9324")
   

2. В методе connect

   from propan import SQSBroker
   broker = SQSBroker()
   ...
   await broker.connect("http://localhost:9324")
   

1. В конструкторе брокера

   from propan import NatsBroker
   broker = NatsBroker("nats://localhost:4222")
   

2. В методе connect

   from propan import NatsBroker
   broker = NatsBroker()
   ...
   await broker.connect("nats://localhost:4222")
   

В простейшем случае вам хватит первого способа передачи данных для подключения - через конструктор.

Однако, в более сложных сценариях: например, при конфигурировании проекта через переменные окружения вам может понадобиться и второй вариант. Полный пример разобран здесь

Note

Параметры, переданные в connect имеют приоритет над параметрами, переданными в конструктор. Будьте с этим аккуратны.

Кроме этого, повторный вызов connect не приведет ни к какому эффекту. Поэтому вы можете не опосаться, что вызов broker.start() (используется внутри PropanApp для запуска брокера) вызовет какие-либо ошибки.