Maksimalno opterećenje: 25k čitanja / 5k zapisa u sekundi Obim novih podataka: 10 TB godišnje Maksimalni paralelizam: 120k istovremenih zahteva Godišnji rast korisnika: 30% Ciljno p99 kašnjenje: <150 ms za čitanja, <400 ms za zapise Ciljna dostupnost: 99.95% Vaš zadatak je da razvijete arhitektonsko rešenje koje će eliminisati trenutne probleme, obezbediti konzistentnost i otpornost na greške, kao i da implementira mehanizme praćenja za potpunu kontrolu životnog ciklusa narudžbine. Opisati mehanizam za upravljanje greškama, plan migracije sa trenutne arhitekture, i objasniti kako će predloženo rešenje poboljšati pouzdanost i transparentnost sistema.

Для обработки пиковых нагрузок (25k чтений и 5k записей в секунду) и обеспечения масштабируемости при 120k одновременных запросах, предлагается микросервисная архитектура с распределённым хранилищем данных и асинхронной обработкой записей.

Основные компоненты решения:

• База данных: Использовать масштабируемое распределённое хранилище (например, Cassandra, ScyllaDB или CockroachDB) с поддержкой горизонтального масштабирования и репликации для отказоустойчивости и согласованности.
• Кэширование: Внедрить распределённый кэш (Redis Cluster или Memcached) для снижения задержек чтения и разгрузки базы.
• Очереди сообщений: Для обработки записей использовать очередь (Kafka, RabbitMQ) с гарантией доставки и повторной попыткой, что обеспечит асинхронность и устойчивость к сбоям.
• Механизм согласованности: Использовать паттерн "Event Sourcing" или "CQRS" для разделения чтения и записи, что позволит оптимизировать производительность и обеспечить согласованность данных.
• Мониторинг и трассировка: Внедрить распределённую трассировку (Jaeger, Zipkin) и метрики (Prometheus + Grafana) для полного мониторинга жизненного цикла заказа, включая задержки, ошибки и пропускную способность.

Механизм обработки сбоев:

• Автоматическое переключение на резервные узлы базы данных при отказе.
• Повторная отправка сообщений в очередь при временных ошибках.
• Таймауты и circuit breaker для предотвращения каскадных сбоев.
• Логирование и алерты при превышении порогов задержек или ошибок.

План миграции:

1. Анализ текущей архитектуры и выявление узких мест.
2. Постепенное внедрение кэширования для снижения нагрузки на базу.
3. Внедрение очередей для асинхронной обработки записей.
4. Миграция данных в распределённую базу с минимальным временем простоя.
5. Интеграция системы трассировки и мониторинга.
6. Тестирование под нагрузкой и оптимизация.

Улучшения:

• Повышение отказоустойчивости за счёт репликации и автоматического failover.
• Снижение задержек чтения благодаря кэшу.
• Гарантированная доставка и обработка записей через очередь.
• Полная прозрачность жизненного цикла заказа через трассировку.
• Масштабируемость под рост пользователей и объёма данных.

---

Пример упрощённого кода на Go для записи в очередь с повторной попыткой:

func writeToQueue(ctx context.Context, msg Message) error {
    const maxRetries = 3
    var err error
    for i := 0; i < maxRetries; i++ {
        err = queue.Publish(ctx, msg)
        if err == nil {
            return nil
        }
        time.Sleep(time.Duration(i) * time.Second) // экспоненциальная задержка
    }
    return fmt.Errorf("failed to publish message after retries: %w", err)
}