Loading repository data…
IlyaGrebenschikov / repository
FastAPI service with Clean Architecture, Dishka DI, async SQLAlchemy 2.0, JWT (RS256), Alembic, Redis rate limiting, email validation, and async email notifications via FastStream + Kafka; Docker Compose profiles with Loki/Promtail/Grafana.
A transparent discovery signal based on current public GitHub metadata.
This score does not audit code, security, maintainers, documentation quality, or suitability. Verify the repository and its current documentation before adoption.
Production-ready educational FastAPI service implementing Vertical Slices + CQRS + Onion Architecture patterns. Features async SQLAlchemy 2.0, JWT authentication, dependency injection (Dishka), Redis caching/rate limiting, asynchronous mail notifications via FastStream + Kafka, and comprehensive observability stack (Loki + Promtail + Grafana). Dockerized and fully automated.
Selected from shared topics, language and repository description—not editorial ratings.
fandangolas /
High-performance authentication service built with Clean Architecture and CQRS, optimized for extreme read-heavy workloads (1M+ token validations/minute). Features FastAPI + PostgreSQL with functional programming patterns.
48/100 healthThe project implements three complementary architectural patterns for scalability, maintainability, and testability:
Features are organized as independent, self-contained vertical slices. Each slice (e.g., users, auth) encapsulates all layers of functionality—from presentation to infrastructure—reducing coupling and enabling independent feature development. Each feature has its own commands/queries and handlers, organized under application/features/{feature}/{operation}/.
Requests are split into two types:
This separation provides:
The codebase is organized in concentric layers, each with well-defined responsibilities:
┌─────────────────────────────────────────┐
│ Presentation (API, Controllers) │ HTTP endpoints, routing
├─────────────────────────────────────────┤
│ Application (Features, Handlers) │ Business logic, use cases
├─────────────────────────────────────────┤
│ Domain (Entities, Business Rules) │ Core entities, invariants
├─────────────────────────────────────────┤
│ Infrastructure (Repositories, DB) │ External integrations
└─────────────────────────────────────────┘
domain/)User), value objects, business constants.User entity with core properties and domain mixins.application/)features/ — Vertical slices with commands, queries, and handlersinterfaces/ — Protocols for repositories, services, and external contractsservices/ — Domain services (rate limiting, JWT token handling)exceptions/ — Application-level exceptionsCreateUserHandler validates input, checks for duplicates, hashes password, persists via repository.infrastructure/)database/ — SQLAlchemy models, repository implementations, migrations, connection poolingcache/ — Redis client wrapper, rate limiter cache repositorysecurity/ — Password hasher implementationsservers/ — Uvicorn server configurationdi_providers/ — Dishka provider implementationsSQLAlchemyUsersRepository implements IUsersRepository, using SQLAlchemy ORM.presentation/)api/v1/ — API version management (routes, controllers, DTOs)controllers/ — Route handlers that instantiate commands/queries and invoke handlersdto/ — Request/response schemas (Pydantic models)middlewares/ — HTTP middlewares (CORS, logging, etc.)handlers/ — Exception handlers, error responsesPOST /api/v1/users endpoint creates CreateUserCommand, invokes handler, returns response DTO.Commands handle state-changing operations (create, update, delete). Queries handle state-reading operations (get, list). Each is defined as a simple dataclass and executed by a dedicated handler class. Controllers create the appropriate command/query, invoke the handler, and return the response.
fastapi_example/
├── src/fastapi_example/
│ ├── __init__.py
│ ├── __main__.py # Application entry point
│ │
│ ├── core/ # Application setup & composition
│ │ ├── di_container.py # DI container (Dishka) wiring
│ │ └── settings.py # Core settings loading
│ │
│ ├── domain/ # Domain layer (business rules, entities)
│ │ ├── entities/
│ │ │ ├── user.py # User aggregate root
│ │ │ └── mixins/ # Shared entity mixins (UUID, timestamps)
│ │ └── __init__.py
│ │
│ ├── application/ # Application layer (use cases, business logic)
│ │ ├── features/ # Vertical slices with CQRS
│ │ │ ├── users/
│ │ │ │ ├── create_user/ # Create user feature (command)
│ │ │ │ │ ├── command.py
│ │ │ │ │ └── handler.py
│ │ │ │ ├── get_user/ # Get user feature (query)
│ │ │ │ │ ├── query.py
│ │ │ │ │ └── handler.py
│ │ │ │ ├── update_user/ # Update user feature (command)
│ │ │ │ │ ├── command.py
│ │ │ │ │ └── handler.py
│ │ │ │ └── delete_user/ # Delete user feature (command)
│ │ │ │ ├── command.py
│ │ │ │ └── handler.py
│ │ │ └── auth/
│ │ │ └── create_access_token/
│ │ │ ├── command.py
│ │ │ └── handler.py
│ │ ├── interfaces/ # Protocols (contracts for external dependencies)
│ │ │ ├── database/ # Repository & transaction manager interfaces
│ │ │ │ ├── repositories/
│ │ │ │ │ ├── users.py # IUsersRepository protocol
│ │ │ │ │ └── mappers/ # Data mappers (domain ↔ persistence)
│ │ │ │ └── transaction_manager.py
│ │ │ ├── services/ # Service interfaces
│ │ │ │ ├── rate_limiter.py
│ │ │ │ └── token_jwt.py
│ │ │ ├── security/
│ │ │ │ └── hasher.py # IHasher protocol
│ │ │ ├── cache/
│ │ │ └── http_clients/
│ │ │ └── email_verifier.py # IEmailVerifier protocol
│ │ ├── services/ # Domain services
│ │ │ ├── rate_limiter.py
│ │ │ └── token_jwt.py
│ │ ├── di_providers/ # DI providers for features
│ │ │ ├── features/ # Feature handlers registration
│ │ │ │ ├── users.py
│ │ │ │ └── auth.py
│ │ │ └── services/ # Service providers
│ │ ├── exceptions/
│ │ │ └── http_exceptions.py # Application exceptions
│ │ ├── settings.py # Application settings
│ │ └── __init__.py
│ │
│ ├── infrastructure/ # Infrastructure layer (DB, cache, external services)
│ │ ├── database/
│ │ │ ├── connection.py # SQLAlchemy engine/session factory
│ │ │ ├── transaction_manager.py # Async transaction management
│ │ │ ├── exceptions.py
│ │ │ ├── models/ # SQLAlchemy models (ORM)
│ │ │ │ ├── base.py # Base model with common fields
│ │ │ │ ├── user.py # User model
│ │ │ │ └── mixins/ # Model mixins
│ │ │ ├── repositories/ # Repository implementations
│ │ │ │ ├── users.py # SQLAlchemyUsersRepository
│ │ │ │ └── mappers/ # Mappers: ORM model → domain entity
│ │ │ └── migrations/ # Alembic migration scripts
│ │ │ ├── env.py
│ │ │ ├── script.py.mako
│ │ │ └── versions/ # Migration version files
│ │ ├── cache/
│ │ │ ├── connection.py # Redis client creation
│ │ │ └── repositories/
│ │ │ └── rate_limiter.py # Redis rate limiter repository
│ │ ├── security/
│ │ │ └── argon_hasher.py # Argon2 hasher implementation
│ │ ├── http_clients/
│ │ │ └── email_verifier.py # AbstractAPI email verification client
│ │ ├── servers/
│ │ │ └── uvicorn_server.py # Uvicorn server configuration
│ │ ├── di_providers/ # DI providers for infrastructure
│ │ │ ├── database.py
│ │ │ ├── cache.py
│ │ │ ├── hasher.py
│ │ │ ├── http_clients.py
│ │ │ └── mappers.py
│ │ ├── settings.py # Infrastructure settings
│ │ └── __init__.py
│ │
│ └── presentation/ # Presentation layer (HTTP API)
│ └── api/
│ ├── common/
│ │ ├── docs.py # API documentation schemas
│ │ ├── handlers/ # Global exception handlers
│ │ └── middlewares/ # Global middlewares (CORS, logging)
│ └── v1/ # API version 1
│ ├── __init__.py
│ ├── setup.py # API initialization
│ ├── controllers/ # Route handlers
│ │ ├── users.py # User routes
│ │ └── auth.py # Auth routes
│ ├── dto/ # Request/Response schemas
│ │ └── ... # Pydantic models
│ ├── dependencies.py # Route dependencies
│ ├── handlers/ # Exception handlers
│ ├── middlew