Merge pull request 'antonov_dmitry_lab_3_ready' (#32) from antonov_dmitry_lab_3 into main

Reviewed-on: http://student.git.athene.tech/Alexey/DAS_2023_1/pulls/32

.idea/misc.xml

@@ -1,5 +1,4 @@
+<?xml version="1.0" encoding="UTF-8"?>
 <project version="4">
-  <component name="ProjectRootManager">
+  <component name="ProjectRootManager" version="2" project-jdk-name="Python 3.11" project-jdk-type="Python SDK" />
-    <output url="file://$PROJECT_DIR$/out" />
-  </component>
 </project>

antonov_dmitry_lab_3/README.md

@@ -0,0 +1,54 @@
+# Лабораторная работа №3 - REST API, Gateway и синхронный обмен между микросервисами
+
+Изучение шаблона проектирования gateway, построения синхронного обмена между микросервисами и архитектурного стиля RESTful API.
+
+Создать два микросервиса.
+
+Каждый сервис реализует CRUD-операции: список записей, подробности конкретной записи, создание, удаление и изменение записи.
+В качестве хранилища данных может выступать оперативная память приложения или база данных.
+Сущности необходимо подобрать по следующим критериям:
+
+Они должны быть связаны с предполагаемой темой диплома.
+Они должны быть связаны как "1-ко-многим".
+
+# Задачи
+
+* Создать 2 микросервиса, реализующих CRUD на связанных сущностях.
+* Реализовать механизм синхронного обмена сообщениями между микросервисами.
+* Реализовать шлюз на основе прозрачного прокси-сервера nginx.
+
+# Запуск
+
+Командой в консоли проекта "docker-compose up -d"
+
+# Описание работы:
+Развернули два приложения
+
+1. Сервис с врачами:
+- доступ на http://localhost:5000/
+
+2. Сервис с пациентами:
+- доступ на http://localhost:5001/
+
+Сервисы связываются друг с другом через ссылку и библиотеку requests
+
+<p>
+    <div>Старт сервисов</div>
+    <img src="screens/img1.png" width="650" title="Сервисы">
+</p>
+<p>
+    <div>Сервис врачей</div>
+    <img src="screens/img2.png" width="650" title="Сервис врачей">
+</p>
+<p>
+    <div>Сервис пациентов</div>
+    <img src="screens/img3.png" width="650" title="Сервис пациентов">
+</p>
+<p>
+    <div>Связь сервисов через библиотеку requests</div>
+    <img src="screens/img4.png" width="650" title="Связь сервисов">
+</p>
+
+# Ссылка на видео
+https://disk.yandex.ru/i/3o4aLuqp1EpbJg
+

antonov_dmitry_lab_3/docker-compose.yml

@@ -0,0 +1,22 @@
+version: '3'
+
+services:
+  service_a:
+    build: ./service_a
+    ports:
+      - "5000:5000"
+
+  service_b:
+    build: ./service_b
+    ports:
+      - "5001:5001"
+
+  nginx:
+    image: nginx
+    ports:
+      - "80:80"
+    volumes:
+      - ./nginx/nginx.conf:/etc/nginx/conf.d/default.conf
+    depends_on:
+      - service_a
+      - service_b

antonov_dmitry_lab_3/nginx/nginx.conf

@@ -0,0 +1,17 @@
+server {
+        listen 80;
+
+        location /app1/ {
+            proxy_pass http://localhost:5000/;
+            proxy_set_header Host $host;
+            proxy_set_header X-Real-IP $remote_addr;
+            proxy_set_header X-Forwarded-For $proxy_add_x_forwarded_for;
+        }
+
+        location /app2/ {
+            proxy_pass http://localhost:5001/;
+            proxy_set_header Host $host;
+            proxy_set_header X-Real-IP $remote_addr;
+            proxy_set_header X-Forwarded-For $proxy_add_x_forwarded_for;
+        }
+}

antonov_dmitry_lab_3/service_a/Dockerfile

@@ -0,0 +1,13 @@
+FROM python:3.8-slim
+
+WORKDIR /app
+
+COPY . /app
+
+RUN pip install --no-cache-dir -r requirements.txt
+
+EXPOSE 5000
+
+ENV NAME service_a
+
+CMD ["python", "app.py"]

antonov_dmitry_lab_3/service_a/app.py

@@ -0,0 +1,99 @@
+from flask import Flask, jsonify, request
+import requests
+
+app = Flask(__name__)
+
+# набор данных докторов с их пациентами
+doctors_data = [
+    {
+        'id': 1,
+        'name': 'Doctor A',
+        'email': 'doctor.a@example.com',
+        'patients': [
+            {'id': 1, 'name': 'Patient A1', 'email': 'patient.a1@example.com'},
+            {'id': 2, 'name': 'Patient A2', 'email': 'patient.a2@example.com'},
+        ],
+    },
+    {
+        'id': 2,
+        'name': 'Doctor B',
+        'email': 'doctor.b@example.com',
+        'patients': [
+            {'id': 3, 'name': 'Patient B1', 'email': 'patient.b1@example.com'},
+            {'id': 4, 'name': 'Patient B2', 'email': 'patient.b2@example.com'},
+        ],
+    },
+    {
+        'id': 3,
+        'name': 'Doctor C',
+        'email': 'doctor.c@example.com',
+        'patients': [
+            {'id': 5, 'name': 'Patient C1', 'email': 'patient.c1@example.com'},
+        ],
+    },
+]
+
+# URL для сервиса пациентов
+patients_service_url = "http://localhost/app2/patients"
+
+@app.route('/', methods=['GET'])
+def get_index():
+    return "это первый сервис"
+
+
+@app.route('/doctors', methods=['GET'])
+def get_doctors():
+    return jsonify(doctors_data)
+
+
+@app.route('/doctors', methods=['POST'])
+def create_doctor():
+    new_doctor = request.json
+    # уникальный id для нового доктора
+    new_doctor['id'] = len(doctors_data) + 1
+    new_doctor['patients'] = []
+    doctors_data.append(new_doctor)
+    return jsonify(new_doctor), 201
+
+
+@app.route('/doctors/<int:id>', methods=['PUT'])
+def update_doctor(id):
+    for doctor in doctors_data:
+        if doctor['id'] == id:
+            doctor.update(request.json)
+            return jsonify(doctor), 200
+    return jsonify({'error': 'Доктор не найден'}), 404
+
+
+@app.route('/doctors/<int:id>', methods=['DELETE'])
+def delete_doctor(id):
+    global doctors_data
+    doctors_data = [doctor for doctor in doctors_data if doctor['id'] != id]
+    return jsonify({'message': 'Доктор удален'}), 200
+
+
+@app.route('/doctors/<int:id>/patients', methods=['GET'])
+def get_doctor_patients(id):
+    for doctor in doctors_data:
+        if doctor['id'] == id:
+            return jsonify(doctor['patients'])
+    return jsonify({'error': 'Доктор не найден'}), 404
+
+
+@app.route('/doctors/<int:id>/patients', methods=['POST'])
+def create_doctor_patient(id):
+    for doctor in doctors_data:
+        if doctor['id'] == id:
+            new_patient = request.json
+            # назначить уникальный id новому пациенту
+            new_patient['id'] = len(doctor['patients']) + 1
+            doctor['patients'].append(new_patient)
+
+            requests.post(patients_service_url, json=new_patient)
+
+            return jsonify(new_patient), 201
+    return jsonify({'error': 'Доктор не найден'}), 404
+
+
+if __name__ == '__main__':
+    app.run(host='0.0.0.0', port=5000)

antonov_dmitry_lab_3/service_a/requirements.txt

@@ -0,0 +1 @@
+Flask

antonov_dmitry_lab_3/service_b/Dockerfile

@@ -0,0 +1,13 @@
+FROM python:3.8-slim
+
+WORKDIR /app
+
+COPY . /app
+
+RUN pip install --no-cache-dir -r requirements.txt
+
+EXPOSE 5001
+
+ENV NAME service_b
+
+CMD ["python", "app.py"]

antonov_dmitry_lab_3/service_b/app.py

@@ -0,0 +1,70 @@
+from flask import Flask, jsonify, request
+import requests
+
+app = Flask(__name__)
+
+# набор данных пациентов и их врачей
+patients_data = [
+    {'id': 1, 'name': 'Patient A', 'email': 'patient.a@example.com', 'doctor_id': 1},
+    {'id': 2, 'name': 'Patient B', 'email': 'patient.b@example.com', 'doctor_id': 2},
+    {'id': 3, 'name': 'Patient C', 'email': 'patient.c@example.com', 'doctor_id': 1},
+]
+
+# URL сервиса докторов
+doctor_service_url = "http://localhost:5000"
+
+
+@app.route('/', methods=['GET'])
+def get_index():
+    return "это второй сервис"
+
+
+@app.route('/patients', methods=['GET'])
+def get_patients():
+    return jsonify(patients_data)
+
+
+@app.route('/patients/<int:id>', methods=['GET'])
+def get_patient(id):
+    for patient in patients_data:
+        if patient['id'] == id:
+            return jsonify(patient)
+    return jsonify({'error': 'Пациент не найден'}), 404
+
+
+@app.route('/patients', methods=['POST'])
+def create_patient():
+    new_patient = request.json
+    # назначить уникальный id новому пациенту
+    new_patient['id'] = len(patients_data) + 1
+    patients_data.append(new_patient)
+
+    # отправляем запрос другому сервису
+    requests.post(f"{doctor_service_url}/doctors/1/patients", json=new_patient)
+
+    return jsonify(new_patient), 201
+
+
+@app.route('/patients/<int:id>', methods=['PUT'])
+def update_patient(id):
+    for patient in patients_data:
+        if patient['id'] == id:
+            patient.update(request.json)
+            # отправляем запрос другому сервису
+            requests.put(f"{doctor_service_url}/doctors/1/patients/{id}", json=request.json)
+            return jsonify(patient), 200
+    return jsonify({'error': 'Пациент не найден'}), 404
+
+
+@app.route('/patients/<int:id>', methods=['DELETE'])
+def delete_patient(id):
+    # отправляем запрос другому сервису
+    requests.delete(f"{doctor_service_url}/doctors/1/patients/{id}")
+
+    global patients_data
+    patients_data = [patient for patient in patients_data if patient['id'] != id]
+    return jsonify({'message': 'Пациент удален'}), 200
+
+
+if __name__ == '__main__':
+    app.run(host='0.0.0.0', port=5001)

antonov_dmitry_lab_3/service_b/requirements.txt

@@ -0,0 +1 @@
+Flask