Странный комменатрии оставленный в 5 утра...

Reviewed-on: Alexey/DAS_2024_1#33

bazunov_andrew_lab_1/.gitignore

@@ -0,0 +1,2 @@
+ollama
+./ollama

bazunov_andrew_lab_1/README.md

@@ -0,0 +1,33 @@
+# Распределенные вычисления и приложения Л1
+## _Автор Базунов Андрей Игревич ПИбд-42_
+
+В качестве сервисов были выбраны:
+- 1.Ollama (_Сервис для использования LLMs моделей_)
+- 2.Open Web Ui (_Сервис для удобного общения с моделью из сервиса Ollama_)
+- 3.Gitea (_Гит сервис_)
+
+# Docker
+
+>Перед исполнением вполняем установку docker и проверяем версию
+
+```sh
+docker-compose --version
+```
+
+>Далее производим настройку файла docker-compose.yaml и запускаем контейнер
+
+```sh
+docker-compose up -d
+```
+
+>Для завершения работы контейнера используем команду
+```sh
+docker-compose down
+```
+---
+> Замечание: после запуска контейнера, необходимо перейти в контейнер **ollamа** и выполнить установку модели [gemma2](https://ollama.com/library/gemma2:2b)
+> ```sh
+> docker-compose exec ollama ollama run ollama run gemma2:2b
+> ```
+---
+Далее можно использовать веб сервис Open Web Ui по адресу **localhost:8080** для общения с моделью и Gitea по адресу **localhost:3000** - [демонстрация работы](https://vk.com/video/@viltskaa?z=video236673313_456239574%2Fpl_236673313_-2)

bazunov_andrew_lab_1/docker-compose.yml

@@ -0,0 +1,61 @@
+services:
+  gitea: # Имя сервиса
+    image: gitea/gitea:latest # Имя образа
+    container_name: gitea # Имя контейнера, может быть произовольным
+    ports:
+      - "3000:3000"  # Проброс порта Gitea на хост
+    volumes: # хранилище
+      - data:/data
+    environment: # переменные окружения
+      USER_UID: 1000
+      USER_GID: 1000
+
+  ollama:
+    image: ollama/ollama:latest
+    container_name: ollama
+    restart: always
+    ports:
+      - 7869:11434
+    pull_policy: always
+    tty: true
+    volumes:
+      - .:/code
+      - ./ollama/ollama:/root/.ollama  # Директория для данных Ollama
+    environment:
+      - OLLAMA_KEEP_ALIVE=24h
+      - OLLAMA_HOST=0.0.0.0  # Указываем хост для API Ollama
+    networks:
+      - ollama-docker
+    command: ["serve"]  # Запускаем Ollama в режиме сервера
+
+  ollama-webui:
+    image: ghcr.io/open-webui/open-webui:main  # Образ Open Web UI
+    container_name: ollama-webui
+    restart: unless-stopped
+    volumes:
+      - ./ollama/ollama-webui:/app/backend/data
+    ports:
+      - 8080:8080  # Порт для веб-интерфейса
+    environment: # https://docs.openwebui.com/getting-started/env-configuration#default_models
+      - OLLAMA_BASE_URLS=http://host.docker.internal:7869
+      - ENV=dev
+      - WEBUI_AUTH=False
+      - WEBUI_NAME=Viltskaa AI
+      - WEBUI_URL=http://localhost:8080
+      - WEBUI_SECRET_KEY=t0p-s3cr3t
+    depends_on:
+      - ollama
+    extra_hosts:
+      - host.docker.internal:host-gateway
+    networks:
+      - ollama-docker
+
+networks:
+  ollama-docker:
+    external: false
+
+volumes:
+  ollama:
+    driver: local
+  data:
+    driver: local

kashin_maxim_lab_3/.gitignore

@@ -0,0 +1 @@
+.venv

kashin_maxim_lab_3/docker-compose.yml

@@ -0,0 +1,53 @@
+version: '3.8'
+services:
+  university_service:
+    build:
+      context: ./university_service
+    depends_on:
+      - university_db
+    environment:
+      - FLASK_APP=app.py
+    expose:
+      - 8081
+
+  faculty_service:
+    build:
+      context: ./faculty_service
+    depends_on:
+      - faculty_db
+    environment:
+      - FLASK_APP=app.py
+    expose:
+      - 8082
+
+  university_db:
+    image: postgres
+    environment:
+      POSTGRES_USER: university_user
+      POSTGRES_PASSWORD: password
+      POSTGRES_DB: universitydb
+    ports:
+      - "5433:5432"
+    volumes:
+      - ./university_service/init.sql:/docker-entrypoint-initdb.d/init.sql
+
+  faculty_db:
+    image: postgres
+    environment:
+      POSTGRES_USER: faculty_user
+      POSTGRES_PASSWORD: password
+      POSTGRES_DB: facultydb
+    ports:
+      - "5434:5432"
+    volumes:
+      - ./faculty_service/init.sql:/docker-entrypoint-initdb.d/init.sql
+
+  nginx:
+    image: nginx
+    ports:
+      - 8086:8086
+    volumes:
+      - ./nginx.conf:/etc/nginx/nginx.conf
+    depends_on:
+      - university_service
+      - faculty_service

kashin_maxim_lab_3/faculty_service/Dockerfile

@@ -0,0 +1,22 @@
+FROM python:3.9-slim
+
+# Установка зависимостей
+RUN apt-get update && apt-get install -y \
+    gcc \
+    libpq-dev \
+    && rm -rf /var/lib/apt/lists/*
+
+# Установка рабочей директории
+WORKDIR /app
+
+# Копирование файлов
+COPY requirements.txt requirements.txt
+
+# Установка Python-зависимостей
+RUN pip install --no-cache-dir -r requirements.txt
+
+# Копирование всех файлов приложения
+COPY . .
+
+# Запуск приложения
+CMD ["python", "app.py"]

kashin_maxim_lab_3/faculty_service/app.py

@@ -0,0 +1,57 @@
+from flask import Flask, jsonify, request, Response
+from service import FacultyService
+from db import db
+
+app = Flask(__name__)
+app.config['SQLALCHEMY_DATABASE_URI'] = 'postgresql://faculty_user:password@faculty_db:5432/facultydb'
+app.config['SQLALCHEMY_TRACK_MODIFICATIONS'] = False
+db.init_app(app)
+
+faculty_service = FacultyService()
+
+
+@app.route('/faculties', methods=['GET', 'POST'])
+def handle_faculties():
+    if request.method == 'POST':
+        dto = request.get_json()['dto']
+        faculty = faculty_service.create_faculty(dto['name'], dto['university_id'])
+
+        if isinstance(faculty, dict):
+            return jsonify({"id": faculty['id'], "name": faculty['name'], "university_id": faculty['university_id']})
+
+        return jsonify({"id": faculty.id, "name": faculty.name, "university_id": faculty.university_id})
+
+    return jsonify(faculty_service.get_all_faculties())
+
+@app.route('/faculties/<int:faculty_id>', methods=['GET', 'PUT', 'DELETE'])
+def handle_faculty(faculty_id):
+    if request.method == 'PUT':
+        dto = request.get_json()['dto']
+        updated_faculty = faculty_service.update_faculty(faculty_id, dto['name'])
+        if updated_faculty:
+            return jsonify(updated_faculty)
+        else:
+            return Response(status=404)
+
+    elif request.method == 'DELETE':
+        faculty_service.delete_faculty(faculty_id)
+        return Response(status=200)
+
+    university = faculty_service.get_faculty(faculty_id)
+    return jsonify({"id": university.id, "name": university.name, "university_id": university.university_id})
+
+@app.route('/faculties/<int:faculty_id>/universities', methods=['POST'])
+def add_university(faculty_id):
+    dto = request.get_json()
+    university_id = dto['university_id']
+    faculty_service.add_university_to_faculty(faculty_id, university_id)
+    return Response(status=204)
+
+@app.route('/faculties/<int:faculty_id>/universities/<int:university_id>', methods=['DELETE'])
+def remove_university(faculty_id, university_id):
+    faculty_service.remove_university_from_faculty(faculty_id, university_id)
+    return Response(status=204)
+
+
+if __name__ == '__main__':
+    app.run(host='0.0.0.0', use_reloader=False, port=8082)

kashin_maxim_lab_3/faculty_service/db.py

@@ -0,0 +1,19 @@
+from flask_sqlalchemy import SQLAlchemy
+
+db = SQLAlchemy()
+
+class Faculty(db.Model):
+    id = db.Column(db.Integer, primary_key=True)
+    name = db.Column(db.String(100), nullable=False)
+    university_id = db.Column(db.Integer, nullable=False)
+
+    def to_dict(self):
+        return {
+            "id": self.id,
+            "name": self.name,
+            "university_id": self.university_id
+        }
+
+class FacultyUniversity(db.Model):
+    faculty_id = db.Column(db.Integer, db.ForeignKey('faculty.id'), primary_key=True)
+    university_id = db.Column(db.Integer, db.ForeignKey('university.id'), primary_key=True)

kashin_maxim_lab_3/faculty_service/init.sql

@@ -0,0 +1,16 @@
+CREATE TABLE IF NOT EXISTS faculty (
+    id SERIAL PRIMARY KEY,
+    name VARCHAR(100) NOT NULL,
+    university_id INT NOT NULL
+);
+
+CREATE TABLE IF NOT EXISTS university (
+    id SERIAL PRIMARY KEY,
+    name VARCHAR(100) NOT NULL
+);
+
+CREATE TABLE IF NOT EXISTS faculty_university (
+    faculty_id INT REFERENCES faculty(id),
+    university_id INT REFERENCES university(id),
+    PRIMARY KEY (faculty_id, university_id)
+);

kashin_maxim_lab_3/faculty_service/requirements.txt

@@ -0,0 +1,3 @@
+flask
+flask_sqlalchemy
+psycopg2

kashin_maxim_lab_3/faculty_service/service.py

@@ -0,0 +1,39 @@
+from db import db, Faculty, FacultyUniversity
+
+
+class FacultyService:
+    def get_all_faculties(self):
+        return [faculty.to_dict() for faculty in Faculty.query.all()]
+
+    def get_faculty(self, faculty_id):
+        return Faculty.query.get(faculty_id)
+
+    def create_faculty(self, name, university_id):
+        faculty = Faculty(name=name, university_id=university_id)
+        db.session.add(faculty)
+        db.session.commit()
+        return faculty
+
+    def update_faculty(self, faculty_id, name):
+        faculty = self.get_faculty(faculty_id)
+        if faculty:
+            faculty.name = name
+            db.session.commit()
+            return faculty.to_dict()
+        return None
+
+    def delete_faculty(self, faculty_id):
+        faculty = self.get_faculty(faculty_id)
+        if faculty:
+            db.session.delete(Faculty.query.get(faculty_id))
+            db.session.commit()
+    def add_university_to_faculty(self, faculty_id, university_id):
+        association = FacultyUniversity(faculty_id=faculty_id, university_id=university_id)
+        db.session.add(association)
+        db.session.commit()
+
+    def remove_university_from_faculty(self, faculty_id, university_id):
+        association = FacultyUniversity.query.filter_by(faculty_id=faculty_id, university_id=university_id).first()
+        if association:
+            db.session.delete(association)
+            db.session.commit()

kashin_maxim_lab_3/nginx.conf

@@ -0,0 +1,27 @@
+events {
+    worker_connections 1024;
+}
+
+http {
+    server {
+        listen      8086;
+        listen      [::]:8086;
+        server_name localhost;
+
+        location /university_service/ {
+            proxy_pass       http://university_service:8081/;
+            proxy_set_header Host      $host;
+            proxy_set_header X-Real-IP $remote_addr;
+            proxy_set_header X-Forwarded-Proto $proxy_add_x_forwarded_for;
+            proxy_set_header X-Forwarded-Prefix $scheme;
+        }
+
+        location /faculty_service/ {
+            proxy_pass       http://faculty_service:8082/;
+            proxy_set_header Host      $host;
+            proxy_set_header X-Real-IP $remote_addr;
+            proxy_set_header X-Forwarded-Proto $proxy_add_x_forwarded_for;
+            proxy_set_header X-Forwarded-Prefix $scheme;
+        }
+    }
+}

kashin_maxim_lab_3/readme.md

@@ -0,0 +1,105 @@
+# Кашин Максим ПИбд-42
+
+# Проект "Университеты и Факультеты"
+
+## Часть 1: Создание Docker
+
+### Установка Docker и Docker Compose
+Перед началом нужно проверить, что Docker работает, иначе использовать инструцию для 1-ой лабораторной.
+
+### 1.1 Файл `docker-compose.yml`
+В корне проекта файл `docker-compose.yml`. Этот файл будет описывать, как должны быть организованы сервисы. В данном случае рассматриваем только университет, в факультетах анологично.
+
+```yaml
+version: '3.8'
+services:
+  university_service:
+    build:
+      context: ./university_service
+    depends_on:
+      - university_db
+    environment:
+      - FLASK_APP=app.py
+    expose:
+      - 8081
+  university_db:
+    image: postgres:13
+    environment:
+      POSTGRES_USER: university_user
+      POSTGRES_PASSWORD: password
+      POSTGRES_DB: universitydb
+    ports:
+      - "5432:5432"
+```
+
+Объяснение:
+- `version`: Указывает версию Docker Compose.
+- `services`: Определяет микросервисы. В данном случае, мы начинаем с `university_service`.
+- `build`: Указывает, что нужно построить образ для этого сервиса, используя Dockerfile из указанной директории.
+- `depends_on`: Указывает, что этот сервис зависит от `university_db` (базы данных), которая будет запущена первой.
+- `environment`: Определяет переменные окружения для сервиса, в данном случае указывая файл Flask.
+- `expose`: Указывает, что сервис будет доступен на порту 8081 внутри Docker-сети.
+
+### 1.2 Файл Dockerfile для сервиса университетов
+В каталоге `university_service` файл `Dockerfile`. Этот файл будет содержать инструкции для сборки образа сервиса университетов. В данном случае рассматриваем только университет, в факультетах анологично.
+
+```dockerfile
+FROM python:3.9-slim
+
+# Установка зависимостей
+RUN apt-get update && apt-get install -y \
+    gcc \
+    libpq-dev \
+    && rm -rf /var/lib/apt/lists/*
+
+# Установка рабочей директории
+WORKDIR /app
+
+# Копирование файлов
+COPY requirements.txt requirements.txt
+
+# Установка Python-зависимостей
+RUN pip install --no-cache-dir -r requirements.txt
+
+# Копирование всех файлов приложения
+COPY . .
+
+# Запуск приложения
+CMD ["python", "app.py"]
+```
+
+
+### 1.3 Создание файла requirements.txt
+В каталоге `university_service` файл `requirements.txt`, в котором перечислите все необходимые библиотеки для приложения. В данном случае рассматриваем только университет, в факультетах анологично.
+
+```txt
+flask
+flask_sqlalchemy
+psycopg2
+```
+
+### 1.5 Запуск Docker Compose
+Когда все файлы созданы, можно запустить сервисы с помощью команды:
+
+```bash
+docker-compose up
+```
+
+Эта команда создаст и запустит все указанные в `docker-compose.yml` сервисы.
+
+## Часть 2: Реализация функциональности
+
+### 2.1 Создание сервиса для университетов
+В каталоге `university_service` файл `app.py`,`service.py`,`db.py`. Этb файлы будут содержать код Flask приложения для управления университетами и базы данных для него.
+
+### 2.2 Создание сервиса для факультетов
+Каталог `faculty_service` и в нем файл `app.py`,`service.py`,`db.py`. Эти файлы будут содержать код для управления факультетами и базы данных для него.
+
+### 2.3 Создание таблиц базы данных
+Нужно создать таблицы базы данных для университетов и факультетов. Для этого созданы файлы init.sql для университета и для факультетов.
+
+### 2.4 Тестирование API
+Тестирование производится через расширение RestMan. В нем мы можем убедиться, что весь CRUD работает исправно.
+
+## Часть 3: Ссылка на видео
+[Видео-отчёт Кашин Максим ПИбд-42](https://disk.yandex.ru/i/F0Dh7RnpVL1Stg)

kashin_maxim_lab_3/university_service/Dockerfile

@@ -0,0 +1,22 @@
+FROM python:3.9-slim
+
+# Установка зависимостей
+RUN apt-get update && apt-get install -y \
+    gcc \
+    libpq-dev \
+    && rm -rf /var/lib/apt/lists/*
+
+# Установка рабочей директории
+WORKDIR /app
+
+# Копирование файлов
+COPY requirements.txt requirements.txt
+
+# Установка Python-зависимостей
+RUN pip install --no-cache-dir -r requirements.txt
+
+# Копирование всех файлов приложения
+COPY . .
+
+# Запуск приложения
+CMD ["python", "app.py"]

kashin_maxim_lab_3/university_service/app.py

@@ -0,0 +1,54 @@
+from flask import Flask, jsonify, request, Response
+from service import UniversityService
+from db import db
+
+app = Flask(__name__)
+app.config['SQLALCHEMY_DATABASE_URI'] = 'postgresql://university_user:password@university_db:5432/universitydb'
+app.config['SQLALCHEMY_TRACK_MODIFICATIONS'] = False
+db.init_app(app)
+
+university_service = UniversityService()
+
+
+@app.route('/universities', methods=['GET', 'POST'])
+def handle_universities():
+    if request.method == 'POST':
+        dto = request.get_json()['dto']
+        university = university_service.create_university(dto['name'])
+        return jsonify(university)
+
+    universities = university_service.get_all_universities()
+    return jsonify(universities)
+
+
+@app.route('/universities/<int:university_id>', methods=['GET', 'PUT', 'DELETE'])
+def handle_university(university_id):
+    if request.method == 'PUT':
+        dto = request.get_json()['dto']
+        updated_university = university_service.update_university(university_id, dto['name'])
+        return jsonify(updated_university) if updated_university else Response(status=404)
+
+    elif request.method == 'DELETE':
+        university_service.delete_university(university_id)
+        return Response(status=200)
+
+    university = university_service.get_university(university_id)
+    if university is None:
+        return Response(status=404)
+    return jsonify(university)
+
+@app.route('/universities/<int:university_id>/faculties', methods=['POST'])
+def add_faculty(university_id):
+    dto = request.get_json()
+    faculty_id = dto['faculty_id']
+    university_service.add_faculty_to_university(university_id, faculty_id)
+    return Response(status=204)
+
+@app.route('/universities/<int:university_id>/faculties/<int:faculty_id>', methods=['DELETE'])
+def remove_faculty(university_id, faculty_id):
+    university_service.remove_faculty_from_university(university_id, faculty_id)
+    return Response(status=204)
+
+
+if __name__ == '__main__':
+    app.run(host='0.0.0.0', use_reloader=False, port=8081)

kashin_maxim_lab_3/university_service/db.py

@@ -0,0 +1,20 @@
+from flask_sqlalchemy import SQLAlchemy
+from datetime import datetime
+
+db = SQLAlchemy()
+
+class University(db.Model):
+    id = db.Column(db.Integer, primary_key=True)
+    name = db.Column(db.String(100), nullable=False)
+    established_at = db.Column(db.DateTime, default=datetime.utcnow)
+
+    def to_dict(self):
+        return {
+            "id": self.id,
+            "name": self.name,
+            "established_at": self.established_at.isoformat()
+        }
+
+class FacultyUniversity(db.Model):
+    faculty_id = db.Column(db.Integer, db.ForeignKey('faculty.id'), primary_key=True)
+    university_id = db.Column(db.Integer, db.ForeignKey('university.id'), primary_key=True)

kashin_maxim_lab_3/university_service/init.sql

@@ -0,0 +1,17 @@
+CREATE TABLE IF NOT EXISTS university (
+    id SERIAL PRIMARY KEY,
+    name VARCHAR(100) NOT NULL,
+    established_at TIMESTAMP DEFAULT CURRENT_TIMESTAMP
+);
+
+
+CREATE TABLE IF NOT EXISTS faculty (
+    id SERIAL PRIMARY KEY,
+    name VARCHAR(100) NOT NULL
+);
+
+CREATE TABLE IF NOT EXISTS faculty_university (
+    faculty_id INT REFERENCES faculty(id),
+    university_id INT REFERENCES university(id),
+    PRIMARY KEY (faculty_id, university_id)
+);

kashin_maxim_lab_3/university_service/requirements.txt

@@ -0,0 +1,3 @@
+flask
+flask_sqlalchemy
+psycopg2

kashin_maxim_lab_3/university_service/service.py

@@ -0,0 +1,42 @@
+from db import db, University, FacultyUniversity
+
+
+class UniversityService:
+    def get_all_universities(self):
+        return [university.to_dict() for university in University.query.all()]
+
+    def get_university(self, university_id):
+        university = University.query.get(university_id)
+        return university.to_dict() if university else None
+
+    def create_university(self, name):
+        university = University(name=name)
+        db.session.add(university)
+        db.session.commit()
+        return university.to_dict()
+
+    def update_university(self, university_id, name):
+        university = self.get_university(university_id)
+        if university:
+            university_obj = University.query.get(university_id)
+            university_obj.name = name
+            db.session.commit()
+            return university_obj.to_dict()
+        return None
+
+    def delete_university(self, university_id):
+        university = self.get_university(university_id)
+        if university:
+            db.session.delete(University.query.get(university_id))
+            db.session.commit()
+
+    def add_faculty_to_university(self, university_id, faculty_id):
+        association = FacultyUniversity(university_id=university_id, faculty_id=faculty_id)
+        db.session.add(association)
+        db.session.commit()
+
+    def remove_faculty_from_university(self, university_id, faculty_id):
+        association = FacultyUniversity.query.filter_by(university_id=university_id, faculty_id=faculty_id).first()
+        if association:
+            db.session.delete(association)
+            db.session.commit()

tsukanova_irina_lab_2/.gitignore

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

tsukanova_irina_lab_2/README.md

@@ -0,0 +1,16 @@
+# Цуканова Ирина ПИбд-32
+# Лабораторная работа №2 - Разработка простейшего распределённого приложения  
+
+### Язык разработки приложений: Python
+
+## Выбранные варианты
+- Для программы 1: Ищет в каталоге ```/var/data``` самый большой по объёму файл и перекладывает его в ```/var/result/data.txt```. 
+- Для программы 2: Сохраняет произведение первого и последнего числа из файла ```/var/result/data.txt``` в ```/var/result/result.txt```.
+
+## Описание:
+Каждая программа лежит в своей папке, первая в worker-1, вторая в worker-2.
+В этих же папках лежат Dockerfile'ы с инструкциями по сборке. В них присутствуют комментарии для значимых строк.  
+Монтированные папки ```data``` для ```/var/data``` и ```result``` для ```/var/result```.
+
+
+## [Видео](https://drive.google.com/file/d/1eBbIDgTo3MF4EeM677EPEKgJEINekaC0/view?usp=drive_link)

tsukanova_irina_lab_2/data/file_1.txt

@@ -0,0 +1 @@
+34 905 63 92 74 9 3 25 8 0 2 4 24 452 94 6 2 4 2 65 83 73 672 47 23 21 1

tsukanova_irina_lab_2/data/file_2.txt

@@ -0,0 +1 @@
+4 9 6 320 75 348 12 75 94 63 45 23 3

tsukanova_irina_lab_2/data/file_3.txt

@@ -0,0 +1 @@
+5 34 7 9 6 43 5 768 4 23 1 3  657 534 4 3 87 6 9 8 56 37 525 5 7 3 2 65 4 86 7 295 473 254 633 4 45 2

tsukanova_irina_lab_2/docker-compose.yaml

@@ -0,0 +1,18 @@
+services:
+
+  worker_one:
+    container_name: worker_one
+    build:
+      dockerfile: ./worker-1
+    volumes:
+      - ./data:/var/data
+      - ./result:/var/result
+
+  worker_two:
+    container_name: worker_two
+    build:
+      dockerfile: ./worker-2
+    volumes:
+      - ./result:/var/result
+    depends_on:
+      - worker_one

tsukanova_irina_lab_2/result/data.txt

@@ -0,0 +1 @@
+5 34 7 9 6 43 5 768 4 23 1 3  657 534 4 3 87 6 9 8 56 37 525 5 7 3 2 65 4 86 7 295 473 254 633 4 45 2

tsukanova_irina_lab_2/result/result.txt

@@ -0,0 +1 @@
+10

tsukanova_irina_lab_2/worker-1/Dockerfile

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

tsukanova_irina_lab_2/worker-1/worker_1.py

@@ -0,0 +1,27 @@
+import os
+import shutil
+
+# Ищет в каталоге /var/data самый большой по объёму файл и перекладывает его в /var/result/data.txt.
+print("start worker_1")
+dir_data = "/var/data"
+dir_res = "/var/result"
+
+if not os.path.exists(dir_data):
+    os.mkdir(dir_data)
+
+if not os.path.exists(dir_res):
+    os.mkdir(dir_res)
+
+largest_file = None
+largest_size = 0
+
+for root, dirs, files in os.walk(dir_data):
+    for file in files:
+        file_path = os.path.join(root, file)
+        file_size = os.path.getsize(file_path)
+        if file_size > largest_size:
+            largest_size = file_size
+            largest_file = file_path
+
+if largest_file:
+    shutil.copyfile(largest_file, dir_res + "/data.txt")

tsukanova_irina_lab_2/worker-2/Dockerfile

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

tsukanova_irina_lab_2/worker-2/worker_2.py

@@ -0,0 +1,19 @@
+# Сохраняет произведение первого и последнего числа из файла /var/result/data.txt в /var/result/result.txt.
+
+print("start worker_2")
+
+with open('/var/result/data.txt', 'r') as f:
+    numbers = [int(num) for num in f.read().split() if num.isdigit()]
+
+if numbers:
+    first_number = numbers[0]
+    last_number = numbers[-1]
+
+    result = first_number * last_number
+
+    with open('/var/result/result.txt', 'w') as f:
+        f.write(f"{result}\n")
+
+    print(f"Получен результат - {result}")
+else:
+    print("Результат не получен. Файл не содержит чисел")

tsukanova_irina_lab_3/README.md

@@ -1,27 +0,0 @@
-# Цуканова Ирина ПИбд-32
-# Лабораторная работа №3 - REST API, Gateway и синхронный обмен между микросервисами 
-
-### Язык разработки приложений: Python
-
-## Выбранные сущности:
-
-- Автор. Содержит Uuid, Name, Surname 
-- Книга. Содержит Uuid, Title, Year, Author_id
-
-
-## Описание:
-Для каждой сущности были реализованы стандартные CRUD-операции: получение всех записей, получение конкретной записи,
-создание записи, изменение записи, удаление записи.  
-
-Дополнительно для сущности Автор прописаны:
-1. Получение автора со списком его книг(с полной информацией). При этом сервис взаимодействует с другим сервисом,
-чтобы получить список книг по идентификатору автора.
-2. Операция проверка наличия автора по идентификатору. Это нужно для сервиса книг.
-
-Дополнительно для сущности Книга прописаны:
-1. Получение списка записей с полной информацией об авторе (не только идентификатор).
-2. Получение списка записей по идентификатору автора. Это нужно для сервиса авторов.
-3. Получение конкретной записи с полной информацией об авторе.
-
-
-## [Видео](https://drive.google.com/file/d/10qXA-jS9QIX5DnYjSAHlEhLx0OyKEk0W/view?usp=sharing)

tsukanova_irina_lab_3/author_service/author_service.py

@@ -1,128 +0,0 @@
-from flask import Flask, jsonify, request
-from uuid import uuid4
-import uuid
-import requests
-
-
-class Author:
-    def __init__(self, name, surname, uuid_: uuid):
-        if uuid_ is None:
-            self.uuid_: uuid = uuid4()
-        else:
-            self.uuid_: uuid = uuid.UUID(uuid_)
-        self.name: str = name
-        self.surname: str = surname
-
-    def to_dict(self):
-        return {
-            "uuid": self.uuid_,
-            "name": self.name,
-            "surname": self.surname
-        }
-
-    def to_dict_with_books(self, books: list):
-        return {
-            "uuid": self.uuid_,
-            "name": self.name,
-            "surname": self.surname,
-            "books": books
-        }
-
-
-app = Flask(__name__)
-
-authors: list[Author] = [
-    Author(name='Leon', surname='Kane', uuid_='997aa4c5-ebb2-4794-ba81-e742f9f1fa30'),
-    Author(name='James', surname='Rasal', uuid_='694827e4-0f93-45a5-8f75-bad7ef2d21fe'),
-    Author(name='Tess', surname='Root', uuid_='eb815350-c7b9-4446-8434-4c0640c21995')
-]
-
-books_url = 'http://book_service:20002/'
-
-
-def list_jsonify():
-    return jsonify([author.to_dict() for author in authors])
-
-
-# получение списка всех авторов
-@app.route('/', methods=['GET'])
-def get_all():
-    return list_jsonify(), 200
-
-
-# получение автора по идентификатору
-@app.route('/<uuid:uuid_>', methods=['GET'])
-def get_one(uuid_):
-    for author in authors:
-        if author.uuid_ == uuid_:
-            return author.to_dict(), 200
-
-    return 'Автор с таким uuid не был найден', 404
-
-
-# получение автора со списком его книг
-@app.route('/with-books/<uuid:uuid_>', methods=['GET'])
-def get_one_with_books(uuid_):
-    for author in authors:
-        if author.uuid_ == uuid_:
-            response = requests.get(books_url + f'by-author/{uuid_}')
-            print(response.json())
-            return author.to_dict_with_books(response.json()), 200
-
-    return 'Автор с таким uuid не был найден', 404
-
-
-# проверка наличия автора по его идентификатору (для book_service)
-@app.route('/check/<uuid:uuid_>', methods=['GET'])
-def check_exist(uuid_):
-    for author in authors:
-        if author.uuid_ == uuid_:
-            return '', 200
-    return '', 404
-
-
-# создание автора
-@app.route('/', methods=['POST'])
-def create():
-    data = request.json
-    name = data.get('name', None)
-    surname = data.get('surname', None)
-    if name is None or surname is None:
-        return 'Недостаточно полей для создания нового автора', 404
-
-    new_author = Author(name, surname, None)
-    authors.append(new_author)
-    return get_one(new_author.uuid_)
-
-
-# изменение автора по идентификатору
-@app.route('/<uuid:uuid_>', methods=['PUT'])
-def update_by_id(uuid_):
-    data = request.json
-    new_name = data.get('name', None)
-    new_surname = data.get('surname', None)
-
-    for author in authors:
-        if author.uuid_ == uuid_:
-            if new_name is not None:
-                author.name = new_name
-            if new_surname is not None:
-                author.surname = new_surname
-            return get_one(author.uuid_)
-
-    return 'Автор с таким uuid не был найден', 404
-
-
-# удаление автора по идентификатору
-@app.route('/<uuid:uuid_>', methods=['DELETE'])
-def delete(uuid_):
-    for author in authors:
-        if author.uuid_ == uuid_:
-            authors.remove(author)
-            return 'Автор успешно удален', 200
-
-    return 'Автор с таким uuid не был найден', 404
-
-
-if __name__ == '__main__':
-    app.run(host='0.0.0.0', port=20001, debug=True)

tsukanova_irina_lab_3/book_service/book_service.py

@@ -1,163 +0,0 @@
-from flask import Flask, jsonify, request
-import requests
-from uuid import uuid4
-import uuid
-
-
-class Book:
-    def __init__(self, title, year, uuid_: uuid, author_id: uuid):
-        if uuid_ is None:
-            self.uuid_: uuid = uuid4()
-        else:
-            self.uuid_: uuid = uuid.UUID(uuid_)
-        self.title: str = title
-        self.year: int = year
-        self.author_id: uuid = uuid.UUID(author_id)
-
-    def to_dict(self):
-        return {
-            'title': self.title,
-            'year': self.year,
-            'author_id': self.author_id,
-            'uuid': self.uuid_
-        }
-
-    def to_dict_for_authors(self):
-        return {
-            'title': self.title,
-            'year': self.year,
-            'uuid': self.uuid_
-        }
-
-    def to_dict_with_info(self, author: dict):
-        return {
-            'title': self.title,
-            'year': self.year,
-            'author_id': self.author_id,
-            'author_info': author,
-            'uuid': self.uuid_
-        }
-
-
-app = Flask(__name__)
-
-books: list[Book] = [
-    Book(title='Garden', year=1977, uuid_='89fa1e7a-7e88-445e-a4d8-6d4497ea8f19',
-         author_id='997aa4c5-ebb2-4794-ba81-e742f9f1fa30'),
-    Book(title='New York', year=1989, uuid_='0351ee11-f11b-4d83-b2c8-1075b0c357dc',
-         author_id='694827e4-0f93-45a5-8f75-bad7ef2d21fe'),
-    Book(title='The story of flowers', uuid_='dfc17619-7690-47aa-ae8e-6a5068f8ddec', year=1977,
-         author_id='eb815350-c7b9-4446-8434-4c0640c21995'),
-    Book(title='Little Rock', year=1990, uuid_='3fad0e6b-cefc-40dd-99c0-adc5ec0290d2',
-         author_id='694827e4-0f93-45a5-8f75-bad7ef2d21fe'),
-    Book(title='One Piece', year=1994, uuid_='cf0cf26e-c1c6-43ea-bf59-1f8edb180e41',
-         author_id='694827e4-0f93-45a5-8f75-bad7ef2d21fe'),
-    Book(title='Black clover', year=1940, uuid_='2ac3c734-21ad-4450-884d-7de1f5452b9d',
-         author_id='eb815350-c7b9-4446-8434-4c0640c21995'),
-]
-
-authors_url = 'http://author_service:20001/'
-
-
-def list_jsonify():
-    return jsonify([book.to_dict() for book in books])
-
-
-# получить список книг без подробной инфы об авторе
-@app.route('/', methods=['GET'])
-def get_all():
-    return list_jsonify(), 200
-
-
-# получение всех книг с информацией об авторе
-@app.route('/full', methods=['GET'])
-def get_all_full():
-    authors: list[dict] = requests.get(authors_url).json()
-    response = []
-    for book in books:
-        for author in authors:
-            if book.author_id == uuid.UUID(author.get('uuid')):
-                response.append(book.to_dict_with_info(author))
-
-    return response, 200
-
-
-# получение списка книг по идентификатору автора (для author_service)
-@app.route('/by-author/<uuid:author_uuid>', methods=['GET'])
-def get_by_author_id(author_uuid):
-    return [book.to_dict_for_authors() for book in books if book.author_id == author_uuid], 200
-
-
-# получение книги по идентификатору
-@app.route('/<uuid:uuid_>', methods=['GET'])
-def get_one(uuid_):
-    for book in books:
-        if book.uuid_ == uuid_:
-            return book.to_dict(), 200
-
-    return 'Книга с таким uuid не была найдена', 404
-
-
-# получение книги по идентификатору с инфой об авторе
-@app.route('/full/<uuid:uuid_>', methods=['GET'])
-def get_one_full(uuid_):
-    for book in books:
-        if book.uuid_ == uuid_:
-            response = requests.get(authors_url + str(book.author_id))
-            return book.to_dict_with_info(response.json()), 200
-
-    return 'Книга с таким uuid не была найдена', 404
-
-
-# создание новой книги
-@app.route('/', methods=['POST'])
-def create():
-    data = request.json
-    title = data.get('title', None)
-    year = data.get('year', None)
-    author_id = data.get('author_id', None)
-    checking = requests.get(authors_url + f'/check/{author_id}')
-    print(checking)
-    if checking.status_code == 200:
-        new_book = Book(title, year, None, author_id)
-        books.append(new_book)
-        return get_one(new_book.uuid_)
-    if checking.status_code == 404:
-        return 'Автор с таким uuid не существует', 404
-
-    return 'Неизвестная ошибка', 500
-
-
-# изменение книги по идентификатору
-@app.route('/<uuid:uuid_>', methods=['PUT'])
-def update_by_id(uuid_):
-    data = request.json
-    new_title = data.get('title', None)
-    new_year = data.get('year', None)
-
-    for book in books:
-        print(book.uuid_)
-
-        if book.uuid_ == uuid_:
-            if new_title is not None:
-                book.title = new_title
-            if new_year is not None:
-                book.year = new_year
-            return get_one(book.uuid_)
-
-    return 'Книга с таким uuid не была найдена', 404
-
-
-# удаление книги по идентификатору
-@app.route('/<uuid:uuid_>', methods=['DELETE'])
-def delete(uuid_):
-    for book in books:
-        if book.uuid_ == uuid_:
-            books.remove(book)
-            return 'Книга успешно удалена', 200
-
-    return 'Книга с таким uuid не была найдена', 404
-
-
-if __name__ == '__main__':
-    app.run(host='0.0.0.0', port=20002, debug=True)

tsukanova_irina_lab_3/docker-compose.yaml

@@ -1,27 +0,0 @@
-services:
-
-  author_service:
-    container_name: author_service
-    build:
-      context: .
-      dockerfile: ./author_service/Dockerfile
-    expose:
-      - 20001
-
-  book_service:
-    container_name: book_service
-    build:
-      context: .
-      dockerfile: ./book_service/Dockerfile
-    expose:
-      - 20002
-
-  nginx:
-    image: nginx:latest
-    ports:
-      - "80:80"
-    volumes:
-      - ./nginx.conf:/etc/nginx/nginx.conf
-    depends_on:
-      - author_service
-      - book_service

tsukanova_irina_lab_3/nginx.conf

@@ -1,26 +0,0 @@
-
-events { worker_connections 1024; }
-
-http {
-    server {
-        listen      80;
-        listen      [::]:80;
-        server_name localhost;
-
-        location /author_service/ {
-            proxy_pass http://author_service:20001/;
-            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 /book_service/ {
-            proxy_pass http://book_service:20002/;
-            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;
-        }
-    }
-}