vladasabelnikova / rabbitmq_with_dlx Goto Github PK

И в докстринг и в md

Добавить интерпретатор и прицепить линтеры.

Добавить в demo функциях пример с отложенными сообщениями

В докстрингах hate speech и нужно добавить в README пункт «Зачем вам DLX?»

Создать схему и описать что происходит, какая у нас архитектура

Написать задуманный интерфейс.

Изменить корень проекта с /src на /

Сделать проверку линтерами при пуше и пулл реквесте

Всё

Был проставлен только на publish, а надо везде

Что сделать:
В RabbitMessageBroker.consume добавить аргумент parallel: bool = Fasle, который определит вариант вызова callback-а.

1. Для I/O задач parallel=True — running_loop.create_task(callback(message))
2. Для CPU и Memory задач parallel=False — await callback(message)

Зачем сделать:
Для тяжёлых CPU, а особенно Memory, задач одновременное загрузка их в event loop в виде Task-ов может перегрузить компьютер, поэтому их стоит грузить в event loop по одной. Получится нечто вроде синхронной обработки, но при этом не нужно будет писать отдельный, синхронный, консьюмер на основе pika.