Кейсы→
Платформа ИТС мегаполиса
Централизованная отказоустойчивая платформа сбора, долгосрочного хранения и интеллектуального анализа данных транспортной системы мегаполиса.
10 000
фиксаций в секунду — пиковый входящий поток в реальном времени
Сотни млн
записей с фотоматериалами каждые сутки
200 Кб
средняя транзакция — фиксация с фото высокого разрешения
20+ ТБ
новых медиаданных ежедневно
12+ Пбайт
общий объём хранилища
1–3 с
поиск по архиву глубиной 5 лет
Задача
Данные с дорожных камер со всей интеллектуальной транспортной системы (ИТС) мегаполиса нужно собирать в единый центр, хранить годами и делать доступными для мгновенного поиска и анализа.
Главные вызовы — огромный входящий поток медиаданных в реальном времени и мгновенный поиск по архиву глубиной в несколько лет.
Решение
- Микросервисная Highload-архитектура. Распределённое объектное хранилище Ceph для фотоматериалов, брокер очередей RabbitMQ и гибрид MongoDB + Redis/Valkey для быстрого доступа к индексам.
- Умный поиск. Полнотекстовый и геопространственный поиск по ГРЗ (госномеру), координатам и комбинированным фильтрам за весь 5-летний период — ответ за 1–3 секунды.
- Серверная ИИ-аналитика. Нейросети постобработки дораспознают ГРЗ в сложных условиях, определяют марку и модель автомобиля, классифицируют спецтранспорт — такси и экстренные службы.
- Предиктивное обслуживание камер. Алгоритмы анализируют поток данных и предсказывают отказы и некорректную работу: загрязнение объектива, аппаратный сдвиг, поворот ветром.
- Бизнес-логика и ГИС. Анализ профиля поведения транспортных средств и собственный картографический стек (OSM + Nominatim) — независимая геовизуализация, интерактивные графики и дашборды.
Результаты
- Пиковый поток до 10 000 фиксаций в секунду и сотни миллионов записей в сутки обрабатываются в реальном времени.
- Отказоустойчивое хранилище на 12+ Пбайт: данные хранятся 5 лет, фотоматериалы — 1 год.
- Поиск по 5-летнему архиву — 1–3 секунды по ГРЗ, координатам и фильтрам.
- Дораспознавание ГРЗ, определение марки и модели, классификация спецтранспорта выполняются автоматически на всём потоке.
- Карта обстановки в реальном времени на собственном картографическом стеке — без внешних зависимостей.
Стек
.NET MongoDB Redis / Valkey RabbitMQ Ceph gRPC Angular OpenLayers OSM Server Nominatim
