Перейти к содержанию

Monzo событийная аналитика

Раздел 05

Тип материала — корпоративный кейс F05. Исторический срез относится к описанию в публикации.

Компания и задача

Построить аналитические datasets из событий backend и дополнительных источников.

Первичный источник и период

2021-10-13 по публикации. Проверено 2026-11-03. Monzo data stack

Подтверждённые компоненты, технологии и числа

FACT — Backend events передаются в append-only BigQuery projects через firehose с Kafka и NSQ. Описаны processor с enrichment и sanitization, shipper, dbt и Looker.

Поток данных

INFERENCE — реконструкция по публикации. Стрелки описывают логическую связь компонентов.

flowchart LR
 A["Backend events"] --> B["Kafka and NSQ firehose"]
 B --> C["BigQuery then dbt and Looker"]

Отказы и границы гарантий

INFERENCE — При переобработке нужно различать raw и curated inputs, их ACL и семантику событий. Владельцы источника помогают расследовать изменение payload и пропуск данных.

Нераскрытые детали

UNKNOWN — sink commit protocol, дедупликация firehose, RPO, соответствие современному стеку и учетные гарантии.

Переносимость решения

INFERENCE — Разделить ingestion, transformation и presentation, сохраняя владельца события и provenance каждой версии dataset.