diff --git a/bogdanov_dmitry_lab_4/README.md b/bogdanov_dmitry_lab_4/README.md new file mode 100644 index 0000000..1efa097 --- /dev/null +++ b/bogdanov_dmitry_lab_4/README.md @@ -0,0 +1,34 @@ +# Богданов Дмитрий ПИбд-42 +# Лабораторная работа №4 + + +## Предметная область: +Автоматизация работы теплицы + +## Результаты выполнения туториалов: + +- Первый туториал: +![изображение 1](./images/tut1.png) + +- Второй туториал: +![изображение 2](./images/tut2.png) + +- Третий туториал: +![изображение 3](./images/tut3.png) + + +## Данные из RabbitMQ: + +![изображение 1](./images/rmq1.png) +![изображение 2](./images/rmq2.png) +![изображение 3](./images/rmq3.png) +![изображение 3](./images/rmq4.png) + +### Вывод: +Из-за моментальной обработки сообщений в Consumer2, его очередь никогда не заполняется. +Consumer1 же тратит на обработку 2 секунды, из-за чего соответствующая очередь существенно заполняется при одном +запущенном экземпляре. +При нескольких запущенных экземплярах Consumer1 очередь заполняется существенно медленнее, и перестаёт заполняться совсем при определенном кол-ве запущенных экземпляров. + + +## [Видео](https://drive.google.com/file/d/1KWHHYWiK8OX48OfhDnEKDtMz-Umfs0uj/view?usp=sharing) \ No newline at end of file diff --git a/bogdanov_dmitry_lab_4/Sample Program/publisher.py b/bogdanov_dmitry_lab_4/Sample Program/publisher.py index 9d85842..cb5debe 100644 --- a/bogdanov_dmitry_lab_4/Sample Program/publisher.py +++ b/bogdanov_dmitry_lab_4/Sample Program/publisher.py @@ -2,7 +2,7 @@ import pika import time def publish_events(): - connection = pika.BlockingConnection(pika.ConnectionParameters(host='localhost')) + connection = pika.BlockingConnection(pika.ConnectionParameters(host='localhost', port=5672, credentials=pika.PlainCredentials("user", "password"))) channel = connection.channel() channel.exchange_declare(exchange='greenhouse_events', exchange_type='fanout') diff --git a/bogdanov_dmitry_lab_4/Sample Program/receiver.py b/bogdanov_dmitry_lab_4/Sample Program/receiver.py index 1b894e3..2151864 100644 --- a/bogdanov_dmitry_lab_4/Sample Program/receiver.py +++ b/bogdanov_dmitry_lab_4/Sample Program/receiver.py @@ -7,8 +7,8 @@ def callback(ch, method, properties, body): print('Receiver 2 закончил обработку') -def consume_events_1(): - connection = pika.BlockingConnection(pika.ConnectionParameters(host='localhost')) +def consume_events_2(): + connection = pika.BlockingConnection(pika.ConnectionParameters(host='localhost', port=5672, credentials=pika.PlainCredentials("user", "password"))) channel = connection.channel() channel.queue_declare(queue='receiver2_queue') @@ -21,4 +21,4 @@ def consume_events_1(): if __name__ == "__main__": - consume_events_1() + consume_events_2() diff --git a/bogdanov_dmitry_lab_4/Sample Program/receiver_delay.py b/bogdanov_dmitry_lab_4/Sample Program/receiver_delay.py index 6ee0433..7defb87 100644 --- a/bogdanov_dmitry_lab_4/Sample Program/receiver_delay.py +++ b/bogdanov_dmitry_lab_4/Sample Program/receiver_delay.py @@ -5,13 +5,13 @@ import time def callback(ch, method, properties, body): print(f'Receiver 1: получено сообщение. {body.decode()}') - time.sleep(2) + time.sleep(3) print('Receiver 1 закончил обработку') def consume_events_1(): - connection = pika.BlockingConnection(pika.ConnectionParameters(host='localhost')) + connection = pika.BlockingConnection(pika.ConnectionParameters(host='localhost', port=5672, credentials=pika.PlainCredentials("user", "password"))) channel = connection.channel() channel.queue_declare(queue='receiver1_queue') diff --git a/bogdanov_dmitry_lab_4/Tutorial 1/receive.py b/bogdanov_dmitry_lab_4/Tutorial 1/receive.py index 309b0e7..03b817d 100644 --- a/bogdanov_dmitry_lab_4/Tutorial 1/receive.py +++ b/bogdanov_dmitry_lab_4/Tutorial 1/receive.py @@ -1,7 +1,7 @@ import pika, sys, os def main(): - connection = pika.BlockingConnection(pika.ConnectionParameters(host='localhost')) + connection = pika.BlockingConnection(pika.ConnectionParameters(host='localhost', port=5672, credentials=pika.PlainCredentials("user", "password"))) channel = connection.channel() channel.queue_declare(queue='hello') diff --git a/bogdanov_dmitry_lab_4/Tutorial 1/send.py b/bogdanov_dmitry_lab_4/Tutorial 1/send.py index 6b15dc8..64b411d 100644 --- a/bogdanov_dmitry_lab_4/Tutorial 1/send.py +++ b/bogdanov_dmitry_lab_4/Tutorial 1/send.py @@ -1,6 +1,6 @@ import pika -connection = pika.BlockingConnection(pika.ConnectionParameters('localhost')) +connection = pika.BlockingConnection(pika.ConnectionParameters(host='localhost', port=5672, credentials=pika.PlainCredentials("user", "password"))) channel = connection.channel() channel.queue_declare('hello') diff --git a/bogdanov_dmitry_lab_4/Tutorial 2/new_task.py b/bogdanov_dmitry_lab_4/Tutorial 2/new_task.py index a2444e0..5ed2d91 100644 --- a/bogdanov_dmitry_lab_4/Tutorial 2/new_task.py +++ b/bogdanov_dmitry_lab_4/Tutorial 2/new_task.py @@ -2,7 +2,7 @@ import pika import sys connection = pika.BlockingConnection( - pika.ConnectionParameters(host='localhost')) + pika.ConnectionParameters(host='localhost', port=5672, credentials=pika.PlainCredentials("user", "password"))) channel = connection.channel() channel.queue_declare(queue='task_queue', durable=True) diff --git a/bogdanov_dmitry_lab_4/Tutorial 2/worker.py b/bogdanov_dmitry_lab_4/Tutorial 2/worker.py index 8f8ab64..d83d59a 100644 --- a/bogdanov_dmitry_lab_4/Tutorial 2/worker.py +++ b/bogdanov_dmitry_lab_4/Tutorial 2/worker.py @@ -2,7 +2,7 @@ import pika import time connection = pika.BlockingConnection( - pika.ConnectionParameters(host='localhost')) + pika.ConnectionParameters(host='localhost', port=5672, credentials=pika.PlainCredentials("user", "password"))) channel = connection.channel() channel.queue_declare(queue='task_queue', durable=True) diff --git a/bogdanov_dmitry_lab_4/Tutorial 3/emit_log.py b/bogdanov_dmitry_lab_4/Tutorial 3/emit_log.py index 45b6989..a02a070 100644 --- a/bogdanov_dmitry_lab_4/Tutorial 3/emit_log.py +++ b/bogdanov_dmitry_lab_4/Tutorial 3/emit_log.py @@ -2,7 +2,7 @@ import pika import sys connection = pika.BlockingConnection( - pika.ConnectionParameters(host='localhost')) + pika.ConnectionParameters(host='localhost', port=5672, credentials=pika.PlainCredentials("user", "password"))) channel = connection.channel() channel.exchange_declare(exchange='logs', exchange_type='fanout') diff --git a/bogdanov_dmitry_lab_4/Tutorial 3/receive_logs.py b/bogdanov_dmitry_lab_4/Tutorial 3/receive_logs.py index 60d881d..6363847 100644 --- a/bogdanov_dmitry_lab_4/Tutorial 3/receive_logs.py +++ b/bogdanov_dmitry_lab_4/Tutorial 3/receive_logs.py @@ -1,7 +1,7 @@ import pika connection = pika.BlockingConnection( - pika.ConnectionParameters(host='localhost')) + pika.ConnectionParameters(host='localhost', port=5672, credentials=pika.PlainCredentials("user", "password"))) channel = connection.channel() channel.exchange_declare(exchange='logs', exchange_type='fanout') diff --git a/bogdanov_dmitry_lab_4/compose.yaml b/bogdanov_dmitry_lab_4/compose.yaml new file mode 100644 index 0000000..7e7c284 --- /dev/null +++ b/bogdanov_dmitry_lab_4/compose.yaml @@ -0,0 +1,12 @@ +version: '3.8' + +services: + rabbitmq: + image: rabbitmq:3-management + container_name: rabbitmq + environment: + RABBITMQ_DEFAULT_USER: user + RABBITMQ_DEFAULT_PASS: password + ports: + - "5672:5672" + - "15672:15672" \ No newline at end of file diff --git a/bogdanov_dmitry_lab_4/images/rmq1.png b/bogdanov_dmitry_lab_4/images/rmq1.png new file mode 100644 index 0000000..0f89de7 Binary files /dev/null and b/bogdanov_dmitry_lab_4/images/rmq1.png differ diff --git a/bogdanov_dmitry_lab_4/images/rmq2.png b/bogdanov_dmitry_lab_4/images/rmq2.png new file mode 100644 index 0000000..916118c Binary files /dev/null and b/bogdanov_dmitry_lab_4/images/rmq2.png differ diff --git a/bogdanov_dmitry_lab_4/images/rmq3.png b/bogdanov_dmitry_lab_4/images/rmq3.png new file mode 100644 index 0000000..e9529ad Binary files /dev/null and b/bogdanov_dmitry_lab_4/images/rmq3.png differ diff --git a/bogdanov_dmitry_lab_4/images/rmq4.png b/bogdanov_dmitry_lab_4/images/rmq4.png new file mode 100644 index 0000000..4e1b089 Binary files /dev/null and b/bogdanov_dmitry_lab_4/images/rmq4.png differ diff --git a/bogdanov_dmitry_lab_4/images/tut1.png b/bogdanov_dmitry_lab_4/images/tut1.png new file mode 100644 index 0000000..90be8e5 Binary files /dev/null and b/bogdanov_dmitry_lab_4/images/tut1.png differ diff --git a/bogdanov_dmitry_lab_4/images/tut2.png b/bogdanov_dmitry_lab_4/images/tut2.png new file mode 100644 index 0000000..ce16eda Binary files /dev/null and b/bogdanov_dmitry_lab_4/images/tut2.png differ diff --git a/bogdanov_dmitry_lab_4/images/tut3.png b/bogdanov_dmitry_lab_4/images/tut3.png new file mode 100644 index 0000000..847cddf Binary files /dev/null and b/bogdanov_dmitry_lab_4/images/tut3.png differ