Event Stream Processing (ESP ) je sada technologií navržených k budování informačních systémů pro zpracování událostí. Technologie ESP zahrnuje vizualizaci událostí, ukládání událostí, middleware řízený událostmi a programovací jazyky pro zpracování událostí. Hlavním úkolem ESP je zpracovávat proudy událostí (dat) za účelem nalezení smysluplných vzorců v nich pomocí metod, jako je hledání vztahů mezi událostmi, korelace událostí, hierarchie událostí a další aspekty, jako je kauzalita, analýza kompozitů. události a časové řady.
Technologie ESP se používá v různých aplikacích, jako je včasná detekce podvodů v odvětví finančních služeb; pro operativní analýzu aktivit na burzách; posuzovat výkonnost zařízení na základě heterogenních informací pocházejících ze senzorů a senzorů, například v ropném a plynárenském průmyslu; v telekomunikacích pro operativní analýzu zákaznických a marketingových kampaní atd.
Pro ilustraci, následující fragmenty kódu demonstrují detekci vzorů v proudu událostí. Prvním příkladem je zpracování proudu událostí pomocí kontinuálního SQL dotazu (dotazu, který průběžně zpracovává příchozí data na základě časových razítek). V tomto fragmentu kódu operace JOIN propojuje dva datové toky, jeden obsahuje příkazy k akciím (Orders), druhý obsahuje výsledky transakcí s cennými papíry (Obchody). Výstupem dotazu je proud objednávek spárovaných s transakcemi, ke kterým došlo do 1 sekundy po zadání objednávky. Výstupní proud je řazen podle časových razítek tabulky Objednávky.
SELECT DataStream objednávky . Časové razítko , objednávky . orderId , Orders . ticker , objednávky . částka , obchod . částka OD objednávek PŘIPOJTE SE k obchodům NAD ( INTERVAL ROZSAHU '1' DRUHÁ NÁSLEDUJÍCÍ ) NA Objednávkách . orderId = obchody . ID objednávky ;Dalším příkladem je úryvek kódu, který detekuje složenou událost „svatba“ v proudu vnějších událostí v důsledku událostí „zvonění zvonku“, vzhledu muže ve smokingu a nevěsty v bílých šatech a rýži. vyhozen do vzduchu, došlo do 2 hodin.
KDY Osoba . Pohlaví SE ROVNÁ „muž“ A Osoba . Oblečení ROVNÁ SE "smoking" NÁSLEDUJE - BY Osoba . Oblečení SE ROVNÁ „róba“ A ( Kostelní_Zvon NEBO Rýže_Létající ) DO 2 hodin AKCE Svatba