antonov_dmitry_lab_4_ready

antonov_dmitry_lab4/README.md

@@ -17,6 +17,7 @@
 # Запуск
 
 Проект запускается в ide просто по нажатию у питон файла на функцию мейн.
+Нужно последовательно запустить функцию мейн у файлов app.py, consumer1.py, consumer2.py.
 Очередь сообщений запускается такой командой
 docker run -it --rm --name rabbitmq -p 5672:5672 -p 15672:15672 rabbitmq:3-management
 
@@ -30,28 +31,37 @@ docker run -it --rm --name rabbitmq -p 5672:5672 -p 15672:15672 rabbitmq:3-manag
 
 Оба врача принимают пациентов.
 
-Flask-приложение с RabbitMQ, использующего библиотеку pika для publisher и Celery для consumers. 
+Flask-приложение с RabbitMQ, использующего библиотеку pika для publisher и для consumers. 
-Приложение Flask (app.py), издателя (publisher.py) и двух потребителей (consumer.py). 
+Надо обязательно вызвать метод publish, иначе никакого приема пациентов не начнется.
-Потребители реализованы как задачи Celery. Можно запускать приложение Flask 
+Приложение Flask (app.py), для источника пациентов (publisher) и двух врачей-потребителей (consumer1.py и consumer2.py). 
-и обоих потребителей отдельно в разных терминалах. 
+Запускаем приложение Flask и обоих потребителей запускаем отдельно в разных терминалах. 
 Consumer ы будут прослушивать сообщения, опубликованные publisher ом.
 <p>
-    <div>App</div>
+    <div>Главное приложение источник приема пациентов</div>
-    <img src="screens/img1.png" width="650" title="App">
+    <img src="screens/img.png" width="650" title="Главное приложение">
 </p>
 <p>
-    <div>Consumer</div>
+    <div>Прибытие пациентов</div>
-    <img src="screens/img2.png" width="650" title="Consumer">
+    <img src="screens/img_1.png" width="650" title="Прибытие пациентов">
-</p>
-<p>
-    <div>Publisher</div>
-    <img src="screens/img3.png" width="650" title="Publisher">
 </p>
 <p>
     <div>RabbitMQ</div>
-    <img src="screens/img4.png" width="650" title="RabbitMQ">
+    <img src="screens/img_2.png" width="650" title="RabbitMQ">
+</p>
+<p>
+    <div>Врач 1</div>
+    <img src="screens/img_3.png" width="650" title="Врач 1">
+</p>
+<p>
+    <div>Врач 2</div>
+    <img src="screens/img_4.png" width="650" title="Врач 2">
+</p>
+<p>
+    <div>Отчет ui</div>
+    <img src="screens/img_5.png" width="650" title="Отчет ui">
 </p>
 
-# Ссылка на видео
+
-https://disk.yandex.ru/i/3o4aLuqp1EpbJg
+# Ссылка на видео
+https://disk.yandex.ru/i/-6Ecl5T28IGmFA
 

antonov_dmitry_lab4/rabbitmq/app.py

@@ -1,19 +1,18 @@
 from flask import Flask, render_template, request
-from publisher import publish_message
+from publisher import publish_messages
 
 app = Flask(__name__)
 
 
 @app.route('/')
 def index():
-    return render_template('index.html')
+    return "это publisher"
 
 
 @app.route('/publish', methods=['GET'])
 def publish():
-    message = request.form['message']
+    publish_messages()
-    publish_message(message)
+    return 'Начало приема пациентов'
-    return 'Пациент прибыл: {}'.format(message)
 
 
 if __name__ == '__main__':

antonov_dmitry_lab4/rabbitmq/consumer1.py

@@ -1,18 +1,19 @@
 import pika
 
+
 def callback(ch, method, properties, body):
-    print(" [x] Врач 1 принимает пациента '{}'".format(body.decode()))
+    print("Врач 1 принимает пациента '{}'".format(body.decode()))
+
 
 def consume_messages():
-    connection = pika.BlockingConnection(pika.ConnectionParameters(
+    connection = pika.BlockingConnection(pika.ConnectionParameters('localhost'))
-        host='localhost',  # RabbitMQ server hostname
-        port=5672,  # RabbitMQ server port
-        credentials=pika.PlainCredentials('guest', 'guest')  # credentials
-    ))
     channel = connection.channel()
+
+    exchange_name = 'logs'
     channel.queue_declare(queue='example_queue')
+    channel.queue_bind(exchange=exchange_name, queue='example_queue')
     channel.basic_consume(queue='example_queue', on_message_callback=callback, auto_ack=True)
-    print(' [*] Врач 1 ожидает приема')
+    print('Врач 1 ожидает приема')
     try:
         channel.start_consuming()
     except KeyboardInterrupt:
@@ -20,6 +21,6 @@ def consume_messages():
         channel.stop_consuming()
         connection.close()
 
+
 if __name__ == '__main__':
     consume_messages()
-

antonov_dmitry_lab4/rabbitmq/consumer2.py

@@ -1,16 +1,17 @@
 import pika
 
+
 def callback(ch, method, properties, body):
-    print(" [x] Врач 2 принимает пациента '{}'".format(body.decode()))
+    print("Врач 2 принимает пациента '{}'".format(body.decode()))
+
 
 def consume_messages():
-    connection = pika.BlockingConnection(pika.ConnectionParameters(
+    connection = pika.BlockingConnection(pika.ConnectionParameters('localhost'))
-        host='localhost',  # RabbitMQ server hostname
-        port=5672,  # RabbitMQ server port
-        credentials=pika.PlainCredentials('guest', 'guest')  # credentials
-    ))
     channel = connection.channel()
+
+    exchange_name = 'logs'
     channel.queue_declare(queue='example_queue')
+    channel.queue_bind(exchange=exchange_name, queue='example_queue')
     channel.basic_consume(queue='example_queue', on_message_callback=callback, auto_ack=True)
     print(' Врач 2 ожидает пациента')
     try:
@@ -20,6 +21,6 @@ def consume_messages():
         channel.stop_consuming()
         connection.close()
 
+
 if __name__ == '__main__':
     consume_messages()
-

antonov_dmitry_lab4/rabbitmq/publisher.py

@@ -1,20 +1,19 @@
 import pika
 import time
 
-def publish_message(message):
+
-    connection = pika.BlockingConnection(pika.ConnectionParameters(
+def publish_messages():
-        host='localhost',  # RabbitMQ server hostname
+    connection = pika.BlockingConnection(pika.ConnectionParameters('localhost'))
-        port=15672,  # RabbitMQ server port
-        credentials=pika.PlainCredentials('guest', 'guest')  # credentials
-    ))
     channel = connection.channel()
+
+    exchange_name = 'logs'
+    channel.exchange_declare(exchange=exchange_name, exchange_type='fanout')
     channel.queue_declare(queue='example_queue')
-    channel.basic_publish(exchange='', routing_key='example_queue', body=message)
     # Отдаем сообщение в 'logs' exchange каждую секунду
     while True:
         message = "Пациент прибыл"  # Сообщение
         channel.basic_publish(exchange='logs', routing_key='', body=message)
-        print(f" [x] Отправлено сообщение: {message}")
+        print(f"Отправлено сообщение: {message}")
         time.sleep(1)
-    print(" [x] Отправлено '{}'".format(message))
+    print("Отправлено '{}'".format(message))
     connection.close()