Обработка в реальном времени с Change Feed

Разработка для Azure Storage

Shahzad Mian

Content developer, Datacamp

Change Feed в Cosmos DB

  • Мгновенный журнал изменений.

Change feed

Разработка для Azure Storage

Что такое Change Feed?

  • Непрерывный поток изменений, или «событий»
  • Отслеживает вставки и обновления по порядку для обработки

Ticker tape

Разработка для Azure Storage

Непрочитанная почта

Mail

Разработка для Azure Storage

Как разработчики используют Change Feed

Pull-модель

  • Приложение само запрашивает данные из Change Feed.
  • Периодически проверяет наличие новых изменений.
  • Pull-модель = вы управляете тем, когда получать и обрабатывать изменения.

Push-модель

  • Система автоматически передаёт изменения
  • Пример:
    • Триггер CosmosDB, срабатывающий при появлении новых изменений.
  • Событийно-ориентированный процесс.
  • Не требует проверки обновлений вручную.
  • Push-модель = система автоматически реагирует на изменения по мере их возникновения.
Разработка для Azure Storage

Пример: триггер Azure Function

ChatGPT Image Nov 6, 2025, 11_46_06 PM.png

Разработка для Azure Storage

Архитектура Change Feed

Leases — запись о прогрессе обработки.

  • Отслеживает изменения, уже обработанные приложением.
  • Знает, с какого места продолжить.
  • Потребители не пропускают и не обрабатывают события повторно.

Lease

Разработка для Azure Storage

Зачем использовать Change Feed?

  • Идеально подходит, когда система должна реагировать на изменения данных.
  • Работает без участия человека.
  • Непрерывный поток данных.
  • Мгновенная реакция приложений.

Data in motion

Разработка для Azure Storage

Сценарии использования

Событийно-ориентированные конвейеры

Event driven

Аналитика в реальном времени

Analytics

Синхронизация данных

Data syncing

Интеграции с внешними системами

Data moving

Разработка для Azure Storage

Источник событий реального времени

  • Change Feed превращает Cosmos DB из пассивного хранилища в источник событий реального времени.
  • Создавайте приложения, которые мгновенно реагируют на события с данными.
  • Управление инфраструктурой не требуется.

CosmosDB + Functions

Разработка для Azure Storage

Давайте потренируемся!

Разработка для Azure Storage

Preparing Video For Download...