diff --git a/.idea/misc.xml b/.idea/misc.xml index 6e86672..a971a2c 100644 --- a/.idea/misc.xml +++ b/.idea/misc.xml @@ -1,5 +1,4 @@ + - - - + \ No newline at end of file diff --git a/antonov_dmitry_lab_3/README.md b/antonov_dmitry_lab_3/README.md new file mode 100644 index 0000000..8abd8a3 --- /dev/null +++ b/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 + +

+

Старт сервисов
+ +

+

+

Сервис врачей
+ +

+

+

Сервис пациентов
+ +

+

+

Связь сервисов через библиотеку requests
+ +

+ +# Ссылка на видео +https://disk.yandex.ru/i/3o4aLuqp1EpbJg + diff --git a/antonov_dmitry_lab_3/docker-compose.yml b/antonov_dmitry_lab_3/docker-compose.yml new file mode 100644 index 0000000..3b331e8 --- /dev/null +++ b/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 \ No newline at end of file diff --git a/antonov_dmitry_lab_3/nginx/nginx.conf b/antonov_dmitry_lab_3/nginx/nginx.conf new file mode 100644 index 0000000..23b3fa1 --- /dev/null +++ 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; + } +} diff --git a/antonov_dmitry_lab_3/screens/img1.png b/antonov_dmitry_lab_3/screens/img1.png new file mode 100644 index 0000000..5e59a8d Binary files /dev/null and b/antonov_dmitry_lab_3/screens/img1.png differ diff --git a/antonov_dmitry_lab_3/screens/img2.png b/antonov_dmitry_lab_3/screens/img2.png new file mode 100644 index 0000000..7aaa510 Binary files /dev/null and b/antonov_dmitry_lab_3/screens/img2.png differ diff --git a/antonov_dmitry_lab_3/screens/img3.png b/antonov_dmitry_lab_3/screens/img3.png new file mode 100644 index 0000000..4ec5c62 Binary files /dev/null and b/antonov_dmitry_lab_3/screens/img3.png differ diff --git a/antonov_dmitry_lab_3/screens/img4.png b/antonov_dmitry_lab_3/screens/img4.png new file mode 100644 index 0000000..0a1e85d Binary files /dev/null and b/antonov_dmitry_lab_3/screens/img4.png differ diff --git a/antonov_dmitry_lab_3/service_a/Dockerfile b/antonov_dmitry_lab_3/service_a/Dockerfile new file mode 100644 index 0000000..cb42ab3 --- /dev/null +++ b/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"] diff --git a/antonov_dmitry_lab_3/service_a/app.py b/antonov_dmitry_lab_3/service_a/app.py new file mode 100644 index 0000000..ab01af6 --- /dev/null +++ b/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/', 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/', 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//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//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) diff --git a/antonov_dmitry_lab_3/service_a/requirements.txt b/antonov_dmitry_lab_3/service_a/requirements.txt new file mode 100644 index 0000000..2077213 --- /dev/null +++ b/antonov_dmitry_lab_3/service_a/requirements.txt @@ -0,0 +1 @@ +Flask \ No newline at end of file diff --git a/antonov_dmitry_lab_3/service_b/Dockerfile b/antonov_dmitry_lab_3/service_b/Dockerfile new file mode 100644 index 0000000..54a28d8 --- /dev/null +++ b/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"] diff --git a/antonov_dmitry_lab_3/service_b/app.py b/antonov_dmitry_lab_3/service_b/app.py new file mode 100644 index 0000000..e4954f3 --- /dev/null +++ b/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/', 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/', 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/', 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) diff --git a/antonov_dmitry_lab_3/service_b/requirements.txt b/antonov_dmitry_lab_3/service_b/requirements.txt new file mode 100644 index 0000000..2077213 --- /dev/null +++ b/antonov_dmitry_lab_3/service_b/requirements.txt @@ -0,0 +1 @@ +Flask \ No newline at end of file