eseményfolyamok

Az eseményfolyamok olyan folyamatosan érkező, időben rendezett események összessége, amelyek különböző forrásokból származnak. Minden esemény egy adott állapotváltozás vagy művelet történetét írja le, például felhasználói interakció, szenzoradat vagy üzleti tranzakció. Az ilyen adatsorok gyakran nagy mennyiségben érkeznek, és feldolgozásuk célja gyakran valós idejű vagy közel valós idejű elemzés.

Jellemzők közé tartozik az események idői sorrendje, az eseménytime és a feldolgozási idő közötti különbség, valamint a folyamatos érkezés és a skálázhatóság. A rendezés és a késő érkezések kezelése gyakran megkíván olyan koncepciókat, mint a watermarkok és ablakokra bontás (time windows).

Az architektúrák általában üzenetközvetítő rendszerekre és feldolgozó motorokra épülnek. Gyakori összetevők a publish–subscribe mintázatot használó üzenetfolyamok, illetve akkora teljesítményű feldolgozó motorok, mint az Apache Kafka, Apache Pulsar, Apache Flink vagy Spark Streaming. Az események gyakran forrásokból származó esemény-sourcing vagy CQRS megközelítések keretében kerülnek kiértékelésre.

Használati területek közé tartozik a valós idejű analitika, rendszermonitoring, csalásészlelés, rendelések valós idejű frissítése és személyre szabott ajánlatok megjelenítése.

Kihívások közé tartozik az események késleltetése, duplikációk kezelése, rendezési problémák, late events és a különböző garantált feldolgozási módok (at-least-once és exactly-once) közötti választás, továbbá a backpressure és a skálázási problémák.