Tapahtumavirtojen käsittely

Event Stream Processing (ESP ) on joukko  teknologioita, jotka on suunniteltu rakentamaan tapahtumien käsittelyn tietojärjestelmiä. ESP-tekniikka sisältää tapahtumien visualisoinnin, tapahtumien tallennuksen, tapahtumapohjaisen väliohjelmiston ja tapahtumakäsittelyn ohjelmointikielet. ESP:n päätehtävänä on käsitellä tapahtumavirtoja (dataa) mielekkäiden kuvioiden löytämiseksi niistä käyttämällä sellaisia ​​menetelmiä kuin tapahtumien välisten suhteiden etsiminen, tapahtumien korrelaatio, tapahtumahierarkiat ja muut näkökohdat, kuten kausaalisuus, komposiitin analyysi. tapahtumia ja aikasarjoja.

ESP-teknologiaa käytetään erilaisissa sovelluksissa, kuten petosten varhaisessa havaitsemisessa rahoituspalvelualalla; Pörssin kauppapaikkojen toimintojen operatiiviseen analysointiin; arvioida laitteiden suorituskykyä esimerkiksi öljy- ja kaasuteollisuuden antureista ja antureista tulevan heterogeenisen tiedon perusteella; televiestinnässä asiakasvaihtuvuuden ja markkinointikampanjoiden operatiiviseen analysointiin jne.

Esimerkkejä

Esimerkkinä seuraavat koodinpätkät osoittavat kuvion havaitsemisen tapahtumavirrassa. Ensimmäinen esimerkki on tapahtumavirran käsittely jatkuvalla SQL-kyselyllä (kysely, joka käsittelee jatkuvasti saapuvaa dataa aikaleimojen perusteella). Tässä koodifragmentissa JOIN-toiminto yhdistää kaksi tietovirtaa, joista toinen sisältää osaketilaukset (Orders), toinen sisältää arvopaperitransaktioiden tulokset (Trades). Kyselyn tulos on tilausvirta, joka yhdistetään tapahtumiin, jotka tapahtuivat 1 sekunnin sisällä tilauksen tekemisestä. Tulosvirta lajitellaan Tilaukset-taulukon aikaleimojen mukaan.