Серверсный пайплайн ингестии и высокопроизводительный API-слой
Масштаб: Высоконагруженный бэкенд сбора событий и аналитическая платформа, обрабатывающие 600k+ транзакций в сутки в режиме serverless с нулевым простоем.
- Асинхронная ингестия: Разработал эндпоинты сбора событий на FastAPI (
asyncio,Pydantic,uvicorn,aiobotocore) в связке с AWS Lambda и S3 для автоматического масштабирования под пирками трафика. - Оптимизация БД и API: Спроектировал слои доступа и оптимизировал сложные SQL-запросы в PostgreSQL/Cloud DWH (сложные JOIN, CTE, тюнинг планов выполнения через
EXPLAIN ANALYZE, кэширование вRedis), снизив нагрузку на БД на 20% и сократив отклик API с 1.5 с до <200 мс. - Оркестрация ELT: Построил автоматизированные пакетные и потоковые пайплайны на Apache Airflow, dbt Core и AWS Glue (
Pandas) для каталогизации сырых событий и трансформации в витрины. - Наблюдаемость и качество: Внедрил кастомные операторы Airflow со структурированным логированием, метрики Prometheus/Grafana, трекинг ошибок
Sentryи автотесты (pytest,dbt testс покрытием 80%+), снизив инциденты на 15% и сократив MTTR.