Alexey/DAS_2024_1

History

VictoriaPresnyakova fe8a57dc0d lab 4 done		2024-11-01 21:02:03 +04:00
..
lessons	lab 4 done	2024-11-01 21:02:03 +04:00
publisher_app	lab 4 done	2024-11-01 21:02:03 +04:00
screens	lab 4 done	2024-11-01 21:02:03 +04:00
readme.md	lab 4 done	2024-11-01 21:02:03 +04:00

readme.md

Лабораторная работа №4 - Работа с брокером сообщений

Lesson 1: Lesson 2: Lesson 3:

Задачи

Необходимо выбрать предметную область и разработать следующие приложения:

Publisher. Программа, которая создаёт один exchange с типом fanout. Программа должна раз в секунду генерировать сообщения в журнал событий согласно вашей предметной области. Например, событие "пришёл заказ" или "сообщение от пользователя" или "необходимо создать отчёт".
Consumer 1. Программа, которая создаёт под себя отдельную не анонимную (!) очередь (queue) (то есть имя queue НЕ пустая строка), создаёт binding на exchange и начинает принимать сообщения (consume). Программа должна обрабатывать сообщения 2-3 секунды. Можно реализовать через обычный Thread.Sleep (для C#).
Consumer 2. Аналогично Consumer 1, только сообщения необходимо обрабатывать моментально. Только имя очереди должно отличаться от Consumer 1.

Далее необходимо собрать и запустить приложения одновременно по одному экземпляру.

Запуск

Проект запускается в ide просто по нажатию у питон файла на функцию мейн. Нужно последовательно запустить функцию мейн у файлов app.py, consumer1.py, consumer2.py. Очередь сообщений запускается такой командой docker run -it --rm --name rabbitmq -p 5672:5672 -p 15672:15672 rabbitmq:3-management

Описание работы:

Развернули два приложения Сервисы используем из предыдущей работы Предметная область - Скрипты и дефекты

Consumer 1 - Скрипт 1:
Consumer 2 - Скрипт 2:

Оба скрипта обрабатывают дефекты.

Flask-приложение с RabbitMQ, использующего библиотеку pika для publisher и для consumers. Надо обязательно вызвать метод publish, иначе обработка дефектов не начнется. Приложение Flask (app.py), для источника дефектов (publisher) и двух скриптов-потребителей (consumer1.py и consumer2.py). Запускаем приложение Flask и обоих потребителей запускаем отдельно в разных терминалах. Consumer ы будут прослушивать сообщения, опубликованные publisher ом.

Ссылка на видео