rogashova_ekaterina_lab_3 #106

Merged
Alexey merged 1 commits from rogashova_ekaterina_lab_3 into main 2024-10-26 13:00:05 +04:00
9 changed files with 294 additions and 0 deletions

2
rogashova_ekaterina_lab_3/.gitignore vendored Normal file
View File

@ -0,0 +1,2 @@
/.venv
/.idea

View File

@ -0,0 +1,27 @@
services:
task_service:
container_name: task_service
build:
context: .
dockerfile: ./task_service/Dockerfile
expose:
- 8081
teacher_service:
container_name: teacher_service
build:
context: .
dockerfile: ./teacher_service/Dockerfile
expose:
- 8082
nginx:
image: nginx:latest
ports:
- "80:80"
volumes:
- ./nginx.conf:/etc/nginx/nginx.conf
depends_on:
- task_service
- teacher_service

View File

@ -0,0 +1,25 @@
events { worker_connections 1024; }
http {
server {
listen 80;
listen [::]:80;
server_name localhost;
location /task_service/ {
proxy_pass http://task_service:8081/;
proxy_set_header Host $host;
proxy_set_header X-Real-IP $remote_addr;
proxy_set_header X-Forwarded-For $proxy_add_x_forwarded_for;
proxy_set_header X-Forwarded-Proto $scheme;
}
location /teacher_service/ {
proxy_pass http://teacher_service:8082/;
proxy_set_header Host $host;
proxy_set_header X-Real-IP $remote_addr;
proxy_set_header X-Forwarded-For $proxy_add_x_forwarded_for;
proxy_set_header X-Forwarded-Proto $scheme;
}
}
}

View File

@ -0,0 +1,37 @@
# Лабораторная работа №3
## Описание
Были использованы следующие сущности:
1. Учитель. Поля: email и ФИО
2. Задание. Поля: название, предмет и id учителя
Сущности связаны связью один ко многим. У одного учителя может быть несколько заданий, у задания только один учитель.
Для каждой сущности был написан отдельный сервис.
Код каждого сервиса представляет собой полноценное API для работы с задачами и учителями.
Они включают основные операции CRUD (создание, чтение, обновление, удаление). Дополнительно можно вывести задачу с полной информацией об учителе.
В качестве хранилища данных использовалась оперативная память приложения.
Запросы к сервисам проксирует шлюз на основе Nginx. Для этого перед запуском nginx был описан конфигурационный файл nginx.conf,
в котором описан прослушиваемый порт и название сервера (в блоке server), маршруты до микросервисов и параметры проксирования (в блоке location).
Конфигурация Nginx направлена на организацию и упрощение работы с микросервисами.
Тестирование производится через расширение RestMan.
## Как запустить это?
Для запуска данной конфигурации Docker Compose выполните следующие шаги:
1. Открыть терминал и перейти в директорию, где находится docker-compose.yml.
2. Выполнить команду
```
docker compose up --build
```
3. Дождаться, пока Docker Compose запустит все контейнеры.
## Видео
Работоспособность представлена на [видео](https://vk.com/video204968285_456240927).

View File

@ -0,0 +1,2 @@
Flask==3.0.3
requests==2.32.3

View File

@ -0,0 +1,17 @@
# Используем базовый образ Python
FROM python:3.12-slim
# Устанавливаем рабочую директорию
WORKDIR /app
# Копируем файл requirements.txt в контейнер
COPY requirements.txt .
# Устанавливаем зависимости
RUN pip install --no-cache-dir -r requirements.txt
# Копируем все файлы в контейнер
COPY task_service/task_service.py .
# Команда для запуска Python-скрипта
CMD ["python", "task_service.py"]

View File

@ -0,0 +1,119 @@
from flask import Flask, jsonify, request, abort
import uuid
import requests
app = Flask(__name__)
tasks = {}
teachers = {}
@app.route('/tasks', methods=['GET'])
def get_tasks():
# Получаем все задачи, но только с teacher_id.
return jsonify(list(tasks.values()))
@app.route('/tasks_with_teachers', methods=['GET'])
def get_tasks_with_teachers():
tasks_with_teachers = []
for task in tasks.values():
teacher_id = task.get('teacher_id')
teacher_info = None
if teacher_id:
try:
# Запрос информации об учителе
teacher_response = requests.get(f'http://teacher_service:8082/teachers/{teacher_id}')
if teacher_response.status_code == 200:
teacher_details = teacher_response.json()
# Формируем объект с нужной информацией об учителе
teacher_info = {
"fio": teacher_details.get("fio"),
"email": teacher_details.get("email")
}
except requests.exceptions.RequestException as e:
print(f"Error fetching teacher: {e}")
# Формируем ответ с нужной структурой
tasks_with_teachers.append({
'id': task.task_id,
'title': task.get('title'),
'subject': task.get('subject'),
'teacher_id': task.get('teacher_id'),
'teacherInfo': teacher_info # Упрощенная информация об учителе
})
return jsonify(tasks_with_teachers)
@app.route('/tasks/<string:task_id>', methods=['GET'])
def get_task(task_id):
task = tasks.get(task_id)
if task is None:
abort(404)
return jsonify(task)
@app.route('/task_with_teacher/<string:task_id>', methods=['GET'])
def get_task_with_teacher(task_id):
task = tasks.get(task_id)
if task is None:
abort(404)
# Получаем информацию о назначенном учителе из teacher_service
teacher_info = None
teacher_id = task.get('teacher_id')
if teacher_id:
try:
teacher_response = requests.get(f'http://teacher_service:8082/teachers/{teacher_id}')
if teacher_response.status_code == 200:
teacher_details = teacher_response.json()
# Формируем объект с нужной информацией об учителе
teacher_info = {
"fio": teacher_details.get("fio"),
"email": teacher_details.get("email")
}
except requests.exceptions.RequestException as e:
print(f"Error fetching teacher: {e}")
# Формируем ответ с нужной структурой
response = {
"id": task_id, # id задания
"title": task.get('title'),
"subject": task.get('subject'),
"teacher_id": teacher_id,
"teacherInfo": teacher_info # Упрощенная информация об учителе
}
return jsonify(response)
@app.route('/tasks', methods=['POST'])
def create_task():
data = request.get_json()
task_id = str(uuid.uuid4())
tasks[task_id] = {
'id': task_id,
'title': data['title'],
'subject': data['subject'],
'teacher_id': data['teacher_id'] # Принимаем teacher_id из запроса
}
return jsonify(tasks[task_id]), 201
@app.route('/tasks/<string:task_id>', methods=['PUT'])
def update_task(task_id):
data = request.get_json()
task = tasks.get(task_id)
if task is None:
abort(404)
task['title'] = data.get('title', task['title'])
task['subject'] = data.get('subject', task['subject'])
return jsonify(task)
@app.route('/tasks/<string:task_id>', methods=['DELETE'])
def delete_task(task_id):
task = tasks.pop(task_id, None)
if task is None:
abort(404)
return '', 200
if __name__ == '__main__':
app.run(host='0.0.0.0', use_reloader=False, port=8081)

View File

@ -0,0 +1,17 @@
# Используем базовый образ Python
FROM python:3.12-slim
# Устанавливаем рабочую директорию
WORKDIR /app
# Копируем файл requirements.txt в контейнер
COPY requirements.txt .
# Устанавливаем зависимости
RUN pip install --no-cache-dir -r requirements.txt
# Копируем все файлы в контейнер
COPY teacher_service/teacher_service.py .
# Команда для запуска Python-скрипта
CMD ["python", "teacher_service.py"]

View File

@ -0,0 +1,48 @@
from flask import Flask, jsonify, request, abort
import uuid
app = Flask(__name__)
teachers = {}
@app.route('/teachers', methods=['GET'])
def get_teachers():
return jsonify(list(teachers.values()))
@app.route('/teachers/<string:teacher_id>', methods=['GET'])
def get_teacher(teacher_id):
teacher = teachers.get(teacher_id)
if teacher is None:
abort(404)
return jsonify(teacher)
@app.route('/teachers', methods=['POST'])
def create_teacher():
data = request.get_json()
teacher_id = str(uuid.uuid4())
teachers[teacher_id] = {
'id': teacher_id,
'fio': data['fio'],
'email': data['email']
}
return jsonify(teachers[teacher_id]), 201
@app.route('/teachers/<string:teacher_id>', methods=['PUT'])
def update_teacher(teacher_id):
data = request.get_json()
teacher = teachers.get(teacher_id)
if teacher is None:
abort(404)
teacher['fio'] = data.get('fio', teacher['fio'])
teacher['email'] = data.get('email', teacher['email'])
return jsonify(teacher)
@app.route('/teachers/<string:teacher_id>', methods=['DELETE'])
def delete_teacher(teacher_id):
teacher = teachers.pop(teacher_id, None)
if teacher is None:
abort(404)
return '', 200
if __name__ == '__main__':
app.run(host='0.0.0.0', use_reloader=False, port=8082)