eseményfolyamot

Az eseményfolyamot gyakran angol nevén event stream-ként említik, és olyan adatok folyamatos érkezését jelöli, amelyek egy vagy több forrásból származnak, és időrendben, általában időbélyeggel rendelkeznek. A folyamatosan érkező események lehetnek felhasználói interakciók, rendszerállapot-frissítések, IoT szenzoradatok vagy üzleti tranzakciók. Az eseményfolyamot gyakran unbounded adathalmazként kezelik, amely append-only logként vagy időrendi listaként olvasható.

A jellemzők közé tartozik az időalapú rend (t-ordered), a több forrásból érkező események összehangolása, és a szenzitív időfogalmak kezelése: event time és processing time. A feldolgozásban gyakori a valós idejű elemzés, ablakos lekérdezések, aggregációk és összekapcsolások. Események feldolgozása történhet stateless vagy stateful módon; a magas áteresztés és alacsony késleltetés érdekében a rendszer gyakran tart fenn állapotot és kezeli a késői adatok problémáit.

Kezelésére léteznek specializált architektúrák és eszközök, például üzenetközvetítő platformok (például Apache Kafka), illetve stream feldolgozó motorok (pl. Apache Flink, Apache Spark Structured Streaming, Akka Streams). A koncepció szorosan kapcsolódik az eseményalapú architektúrákhoz (EDA), az eseményforrás mint határozóigazság és a komplex eseményfeldolgozás (CEP) gyakorlataihoz.

Kihívások közé tartozik a megbízhatóság, a sorbarendezés és a késői adatok kezelése, valamint a skálázhatóság és a visszafordíthatóság kérdései. Előnyei közé tartozik a valós idejű insightok lehetővé tétele, a jól auditálható eseménytörténet és a komponensek közötti laza kötés.