+
+
++
+
++
+
++
+
+
+# Ссылка на видео
+https://disk.yandex.ru/i/3o4aLuqp1EpbJg
+
diff --git a/antonov_dmitry_lab4/docker-compose.yml b/antonov_dmitry_lab4/docker-compose.yml
new file mode 100644
index 0000000..0dd0527
--- /dev/null
+++ b/antonov_dmitry_lab4/docker-compose.yml
@@ -0,0 +1,6 @@
+version: "2.1"
+services:
+ rabbitmq:
+ image: rabbitmq:3.10.7-management
+ ports:
+ - 15672:15672
\ No newline at end of file
diff --git a/antonov_dmitry_lab4/rabbit/app.py b/antonov_dmitry_lab4/rabbit/app.py
new file mode 100644
index 0000000..48d5e59
--- /dev/null
+++ b/antonov_dmitry_lab4/rabbit/app.py
@@ -0,0 +1,21 @@
+from celery import Celery
+from flask import Flask, render_template
+
+app = Flask(__name__)
+
+# Celery конфигурация
+app.config['CELERY_BROKER_URL'] = 'pyamqp://guest:guest@localhost//'
+app.config['CELERY_RESULT_BACKEND'] = 'rpc://'
+
+# Создаем инстанс Celery
+celery = Celery(app.name, broker=app.config['CELERY_BROKER_URL'])
+celery.conf.update(app.config)
+
+
+@app.route('/')
+def index():
+ return render_template('index.html')
+
+
+if __name__ == '__main__':
+ app.run(debug=True)
diff --git a/antonov_dmitry_lab4/rabbit/consumer.py b/antonov_dmitry_lab4/rabbit/consumer.py
new file mode 100644
index 0000000..315e23e
--- /dev/null
+++ b/antonov_dmitry_lab4/rabbit/consumer.py
@@ -0,0 +1,33 @@
+from celery import Celery
+import time
+import pika
+
+app = Celery('consumer', broker='pyamqp://guest:guest@localhost//')
+
+
+@app.task
+def process_messages(queue_name, delay):
+ connection = pika.BlockingConnection(pika.ConnectionParameters('localhost'))
+ channel = connection.channel()
+
+ # Объявляем очередь с именем
+ channel.queue_declare(queue=queue_name)
+
+ # Привязываем очередь к 'logs' exchange
+ channel.queue_bind(exchange='logs', queue=queue_name)
+
+ def callback(ch, method, properties, body):
+ print(f" [x] Получено сообщение: {body}")
+ time.sleep(delay)
+ print(f" [x] Обработано сообщение: {body}")
+
+ # Устанавливаем consumer а чтобы получать сообщения из очереди
+ channel.basic_consume(queue=queue_name, on_message_callback=callback, auto_ack=True)
+
+ print(f' [*] Ожидаем сообщения от {queue_name}')
+ channel.start_consuming()
+
+
+if __name__ == '__main__':
+ process_messages.delay('consumer1_queue', 2) # Queue для Consumer 1 с задержкой 2 с
+ process_messages.delay('consumer2_queue', 0) # Queue для Consumer 2 без задержки
diff --git a/antonov_dmitry_lab4/rabbit/publisher.py b/antonov_dmitry_lab4/rabbit/publisher.py
new file mode 100644
index 0000000..1b419cd
--- /dev/null
+++ b/antonov_dmitry_lab4/rabbit/publisher.py
@@ -0,0 +1,23 @@
+import pika
+import time
+
+connection_params = pika.ConnectionParameters(
+ host='localhost', # RabbitMQ server hostname
+ port=15672, # RabbitMQ server port
+ credentials=pika.PlainCredentials('guest', 'guest') # credentials
+)
+
+connection = pika.BlockingConnection(connection_params)
+channel = connection.channel()
+
+# Объявляем exchange с именем 'logs' типа 'fanout'
+channel.exchange_declare(exchange='logs', exchange_type='fanout')
+
+# Отдаем сообщение в 'logs' exchange каждую секунду
+while True:
+ message = "Пациент прибыл" # Сообщение
+ channel.basic_publish(exchange='logs', routing_key='', body=message)
+ print(f" [x] Отправлено сообщение: {message}")
+ time.sleep(1)
+
+connection.close()