Procesare în timp real cu Change Feed

Dezvoltare pentru Azure Storage

Shahzad Mian

Content developer, Datacamp

Change feed-ul Cosmos DB

  • Jurnal instantaneu al modificărilor.

Change feed

Dezvoltare pentru Azure Storage

Ce este Change Feed?

  • Flux continuu de modificări, sau „evenimente"
  • Urmărește inserările și actualizările în ordinea procesării

Bandă de ticker

Dezvoltare pentru Azure Storage

E-mailuri necitite

E-mail

Dezvoltare pentru Azure Storage

Cum utilizează dezvoltatorii Change Feed

Model pull

  • Aplicația extrage date din change feed.
  • Verifică periodic noile modificări.
  • Model pull = controlați când să preluați și să procesați modificările.

Model push

  • Sistemul transmite modificările automat
  • Exemplu:
    • Declanșator CosmosDB care rulează la apariția noilor modificări.
  • Proces bazat pe evenimente.
  • Nu necesită verificarea actualizărilor.
  • Model push = sistemul reacționează automat la modificări pe măsură ce apar.
Dezvoltare pentru Azure Storage

Exemplu: declanșator Azure Function

Imagine ChatGPT 6 nov. 2025

Dezvoltare pentru Azure Storage

Arhitectura Change Feed

Lease-uri - Înregistrarea progresului.

  • Urmăresc modificările deja procesate de aplicație.
  • Indică de unde se reia procesarea.
  • Consumatorii nu ratează și nu reprocesează evenimente.

Lease

Dezvoltare pentru Azure Storage

De ce să utilizați Change Feed?

  • Ideal când sistemul trebuie să reacționeze la modificări de date.
  • Funcționează fără intervenție umană.
  • Flux continuu de date.
  • Reacție instantanee a aplicațiilor.

Date în mișcare

Dezvoltare pentru Azure Storage

Cazuri de utilizare

Pipeline-uri bazate pe evenimente

Bazat pe evenimente

Analiză în timp real

Analiză

Sincronizare date

Sincronizare date

Integrări downstream

Date în mișcare

Dezvoltare pentru Azure Storage

Sursă de evenimente în timp real

  • Change Feed transformă Cosmos DB dintr-un depozit pasiv într-o sursă de evenimente în timp real.
  • Construiți aplicații care răspund instantaneu la evenimente de date.
  • Nu este necesară gestionarea infrastructurii.

CosmosDB + Functions

Dezvoltare pentru Azure Storage

Să exersăm!

Dezvoltare pentru Azure Storage

Preparing Video For Download...