Sündmusvoogu

Sündmusvoog ehk sündmuste voog on järjestatud sündmuste jada, mis tekib erinevatest allikatest ning mida tarkvararakendused saab reaalajas või hiljem analüüsiks töödelda. Selline voog rõhutab sündmuste toimumise ajastust ja järjestust ning seda kasutatakse peamiselt event-driven arhitektuurides, reaktiivsetes süsteemides ja andmete analüüsis. Sündmusvoog võimaldab komponentidel olla omavahel eraldatud ning suhelda läbi sündmuste, mis suurendab paindlikkust ja skaleeritavust.

Arhitektuuriliselt hõlmab see tootjaid (producerid), transporti (kanalid) ja tarbijaid (consumerid). Sündmused pärinevad erinevatest allikatest nagu kasutajate tegevused, sensorid või logisõnumid ning liiguvad süsteemis edasi vastavalt vajadusele. Töötlemine võib toimuda reaalajas (stream processing) või partiidena; sageli kasutatakse pub-sub mudeleid, samuti event sourcingi, kus muudatused salvestatakse järjekindlasse logi.

Tehnoloogiliste lahenduste osas on populaarsed Apache Kafka, Apache Pulsar, AWS Kinesis ja Google Cloud Pub/Sub sündmusvoogude haldamiseks. Töötlemise komponendid hõlmavad Flinki, Spark Structured Streamingut, Beam'i ja reaktiivseid raamistikuid. Sündmuste voogudega seostatakse tihti ka logihoidlaid ja event store'e.

Kasutusvaldkonnad hõlmavad reaalajas analüüsi, monitorimist, kasutajate tegevuste jälgimist, IoT-andmete töötlemist ja logi kogumist. Sündmusvoogude eelised on paremini eraldatud komponendid, skaleeritavus ning viivituste vähendamine; väljakutsed kaasavad skeemimuutuste haldamist, järjekorra säilitamist ning täpsuse tagamist (exactly-once) ja backpressurei juhtimist.