Создан базовый функционал сервиса и настроен docker

1. Созданы модели:
* Film
* Genre
* Person
2. Добавлен базовый функционал сервиса:
* настроен конфиг
* настроен сервисы для подключения к Redis и ES
* создан сервис `FilmService`
* реализован endpoint детальной страницы фильма (`film_details`)
3. Добавлен Dockerfile для приложения
4. Добавлен docker-compose.yml

Author: xczdenis

.dockerignore

@@ -0,0 +1,94 @@
+.pytest_cache
+tests
+docker
+src_local
+
+# Git
+.git
+.gitignore
+.gitattributes
+
+
+# CI
+.codeclimate.yml
+.travis.yml
+.taskcluster.yml
+
+# Docker
+docker-compose.yml
+Dockerfile
+.docker
+.dockerignore
+
+# Byte-compiled / optimized / DLL files
+**/__pycache__/
+**/*.py[cod]
+
+# C extensions
+*.so
+
+# Distribution / packaging
+.Python
+env/
+build/
+develop-eggs/
+dist/
+downloads/
+eggs/
+lib/
+lib64/
+parts/
+sdist/
+var/
+*.egg-info/
+.installed.cfg
+*.egg
+
+# PyInstaller
+#  Usually these files are written by a python script from a template
+#  before PyInstaller builds the exe, so as to inject date/other infos into it.
+*.manifest
+*.spec
+
+# Installer logs
+pip-log.txt
+pip-delete-this-directory.txt
+
+# Unit test / coverage reports
+htmlcov/
+.tox/
+.coverage
+.cache
+nosetests.xml
+coverage.xml
+
+# Translations
+*.mo
+*.pot
+
+# Django stuff:
+*.log
+
+# Sphinx documentation
+docs/_build/
+
+# PyBuilder
+target/
+
+# Virtual environment
+.env
+.venv/
+venv/
+
+# PyCharm
+.idea
+
+# Python mode for VIM
+.ropeproject
+**/.ropeproject
+
+# Vim swap files
+**/*.swp
+
+# VS Code
+.vscode/

Dockerfile

@@ -0,0 +1,16 @@
+FROM python:3.10-alpine
+
+ENV PYTHONDONTWRITEBYTECODE=1 PYTHONUNBUFFERED=1
+
+ARG HOME_DIR=/app
+
+WORKDIR $HOME_DIR
+
+EXPOSE 8000
+
+COPY requirements.txt requirements.txt
+
+RUN apk update \
+    && apk add build-base \
+    && pip install --no-cache-dir --upgrade pip \
+    && pip install --no-cache-dir -r requirements.txt

README.md

@@ -14,3 +14,8 @@
 - Проходим ревью
 - Вливаем в ветку main (через squash & merge)
 - Оповещаем всех остальных (чтобы они подтянули изменения из main и сразу порешали merge conflict)
+
+## Запуск проекта
+1. Создать файл .env в корне проекта и заполнить его по шаблону .env.example
+2. Запустить базу данных, если она еще не запущена
+3. Выполнить `docker-compose up -d`. Эта команда поднимает следующие сервисы: само приложение, elasticsearch и redis

docker-compose.yml

@@ -0,0 +1,39 @@
+version: '3'
+
+services:
+    app:
+        build: .
+        command: uvicorn main:app --host 0.0.0.0 --port 8000
+        environment:
+            - REDIS_HOST=redis
+            - ELASTIC_HOST=es
+        ports:
+            - "8000:8000"
+        volumes:
+            - "./:/app"
+        depends_on:
+            - es
+            - redis
+    es:
+        image: docker.io/elastic/elasticsearch:7.7.0
+        env_file:
+            - .env
+        environment:
+            - discovery.type=single-node
+        volumes:
+            - esdata01:/usr/share/elasticsearch/data
+        ports:
+            - ${ELASTIC_PORT}:9200
+        deploy:
+            resources:
+                limits:
+                    memory: ${ELASTIC_MEM_LIMIT}
+    redis:
+        image: redis:7-alpine
+        env_file:
+            - .env
+        ports:
+            - ${REDIS_PORT}:6379
+
+volumes:
+    esdata01:

main.py

@@ -0,0 +1,43 @@
+import logging
+
+import aioredis
+import uvicorn as uvicorn
+from elasticsearch import AsyncElasticsearch
+from fastapi import FastAPI
+from fastapi.responses import ORJSONResponse
+
+from src.api.v1 import films
+from src.core.config import settings
+from src.core.logger import LOGGING
+from src.db import elastic, redis
+
+app = FastAPI(
+    title=settings.PROJECT_NAME,
+    docs_url='/api/openapi',
+    openapi_url='/api/openapi.json',
+    default_response_class=ORJSONResponse,
+)
+
+
+@app.on_event('startup')
+async def startup():
+    redis.redis = await aioredis.from_url(f'redis://{settings.REDIS_HOST}:{settings.REDIS_PORT}')
+    elastic.es = AsyncElasticsearch(hosts=[f'http://{settings.ELASTIC_HOST}:{settings.ELASTIC_PORT}'])
+
+
+@app.on_event('shutdown')
+async def shutdown():
+    await redis.redis.close()
+    await elastic.es.close()
+
+
+app.include_router(films.router, prefix='/api/v1/films', tags=['films'])
+
+if __name__ == '__main__':
+    uvicorn.run(
+        'main:app',
+        host='0.0.0.0',
+        port=8000,
+        log_config=LOGGING,
+        log_level=logging.DEBUG,
+    )

requirements.txt

@@ -1,5 +1,5 @@
 aioredis==2.0.1
-elasticsearch==7.9.1
+elasticsearch[async]==7.9.1
 fastapi==0.78.0
 orjson==3.7.7
 pydantic==1.9.1
@@ -11,3 +11,4 @@ flake8-broken-line==0.4.0
 flake8-quotes==3.3.1
 isort==5.10.1
 pre-commit==2.20.0
+loguru==0.6.0

src/main.py src/__init__.py

@@ -0,0 +1,30 @@
+from http import HTTPStatus
+from typing import List
+
+from fastapi import APIRouter, Depends, HTTPException
+from pydantic import BaseModel
+
+from src.models.film import Genre, Person
+from src.models.mixins import UUIDMixin
+from src.services.film import FilmService, get_film_service
+
+router = APIRouter()
+
+
+class FilmAPI(UUIDMixin, BaseModel):
+    title: str
+    imdb_rating: float
+    description: str
+    genre: List[Genre]
+    actors: List[Person]
+    writers: List[Person]
+    directors: List[Person]
+
+
+@router.get('/{film_id}', response_model=FilmAPI)
+async def film_details(film_id: str, film_service: FilmService = Depends(get_film_service)) -> FilmAPI:
+    film = await film_service.get_by_id(film_id)
+    if not film:
+        raise HTTPException(status_code=HTTPStatus.NOT_FOUND, detail='film not found')
+
+    return FilmAPI.parse_obj(film.dict(by_alias=True))

src/api/v1/films.py

@@ -1,24 +1,26 @@
 import os
 from logging import config as logging_config
+from pathlib import Path
 
 from pydantic import BaseSettings
 
-from core.logger import LOGGING
+from src.core.logger import LOGGING
+
+logging_config.dictConfig(LOGGING)
+
+BASE_DIR = Path(__file__).resolve().parent
 
 
 class Settings(BaseSettings):
-    PROJECT_NAME: str
-    REDIS_HOST: str
-    REDIS_PORT: str
-    ELASTIC_HOST: str
-    ELASTIC_PORT: str
-    BASE_DIR = os.path.dirname(os.path.dirname(os.path.abspath(__file__)))
+    PROJECT_NAME: str = 'movies'
+    REDIS_HOST: str = '127.0.0.1'
+    REDIS_PORT: str = '6379'
+    ELASTIC_HOST: str = '127.0.0.1'
+    ELASTIC_PORT: str = '9200'
 
     class Config:
-        env_file = '.env'
+        env_file = os.path.join(BASE_DIR, '.env')
         env_file_encoding = 'utf-8'
 
 
 settings = Settings()
-
-logging_config.dictConfig(LOGGING)

src/core/config.py

@@ -0,0 +1,22 @@
+from typing import List
+
+import orjson
+
+from src.models.genre import Genre
+from src.models.mixins import UUIDMixin
+from src.models.person import Person
+from src.models.utils import orjson_dumps
+
+
+class Film(UUIDMixin):
+    title: str
+    imdb_rating: float
+    description: str = ''
+    genre: List[Genre] = []
+    actors: List[Person] = []
+    writers: List[Person] = []
+    directors: List[Person] = []
+
+    class Config:
+        json_loads = orjson.loads
+        json_dumps = orjson_dumps

src/models/film.py

@@ -0,0 +1,12 @@
+import orjson
+
+from src.models.mixins import UUIDMixin
+from src.models.utils import orjson_dumps
+
+
+class Genre(UUIDMixin):
+    name: str
+
+    class Config:
+        json_loads = orjson.loads
+        json_dumps = orjson_dumps

src/models/genre.py

@@ -0,0 +1,5 @@
+from pydantic import BaseModel, Field
+
+
+class UUIDMixin(BaseModel):
+    uuid: str = Field(alias='id')

src/models/mixins.py

@@ -0,0 +1,13 @@
+import orjson
+from pydantic import Field
+
+from src.models.mixins import UUIDMixin
+from src.models.utils import orjson_dumps
+
+
+class Person(UUIDMixin):
+    full_name: str = Field(alias='name')
+
+    class Config:
+        json_loads = orjson.loads
+        json_dumps = orjson_dumps

src/models/person.py

@@ -0,0 +1,5 @@
+import orjson
+
+
+def orjson_dumps(v, *, default):
+    return orjson.dumps(v, default=default).decode()