README, исправления, изображения

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)

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')

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()

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')

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')

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')

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)

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)

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')

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')

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"