Zpracování proudu událostí - Event stream processing

Sloučit s Zpracování streamu

Zpracování proudu událostínebo ESP, je sada technologií určených k podpoře výstavby informační systémy založené na událostech. Technologie ESP zahrnují vizualizaci událostí, databáze událostí, middleware řízený událostmi a jazyky zpracování událostí nebo komplexní zpracování událostí (CEP). V praxi se výrazy ESP a CEP často používají zaměnitelně. ESP se zabývá úkolem zpracovávat proudy dat událostí s cílem identifikovat smysluplný vzorec v těchto proudech, přičemž využívá techniky, jako je detekce vztahů mezi více událostmi, korelace událostí, hierarchie událostí a další aspekty, jako je kauzalita, členství a načasování .

ESP umožňuje mnoho různých aplikací, jako je algoritmické obchodování ve finančních službách, identifikace frekvence rádia (RFID) aplikace pro zpracování událostí, detekce podvodů, monitorování procesu, a lokalizační služby v telekomunikacích.

Příklady

Pro ilustraci následující fragmenty kódu ukazují detekci vzorů v rámci proudů událostí. První z nich je příkladem zpracování datového proudu pomocí kontinuálního zpracování SQL dotaz (dotaz, který navždy provádí zpracování přicházejících dat na základě časových značek a doby trvání okna). Tento fragment kódu ilustruje PŘIPOJENÍ dvou datových toků, jednoho pro akciové objednávky a druhého pro výsledné akciové obchody. Dotaz vygeneruje proud všech Pokynů spárovaných Obchodem do jedné sekundy od zadání Objednávky. Výstupní proud je seřazen podle časového razítka, v tomto případě časového razítka ze streamu Objednávky.

VYBRAT Datový tok   Objednávky.Časové razítko, Objednávky.číslo objednávky, Objednávky.ticker,   Objednávky.množství, Obchod.množstvíZ ObjednávkyPŘIPOJIT SE Obchody PŘES (ROZSAH INTERVAL '1' DRUHÝ NÁSLEDUJÍCÍ)NA Objednávky.číslo objednávky = Obchody.číslo objednávky;

Další fragment ukázkového kódu detekuje svatby v proudu vnějších „událostí“, jako jsou zvonění kostelních zvonů, vzhled muže ve smokingu nebo ranním obleku, žena v splývavých bílých šatech a rýže létající vzduchem. „Složitá“ nebo „složená“ událost je to, co lze odvodit z jednotlivých jednoduchých událostí: koná se svatba.

KDYŽ Osoba.Rod ROVNÁ SE "muž" A Osoba.Oblečení ROVNÁ SE "smoking"NÁSLEDOVAL-PODLE  Osoba.Oblečení ROVNÁ SE "talár" A  (Church_Bell NEBO Rice_Flying)V RÁMCI 2 hodinAKCE Svatba

Viz také

  • Složité zpracování událostí (CEP) - Související technologie pro budování a správu informačních systémů řízených událostmi.
  • Systém pro správu datových toků (DSMS) - Typ softwarového systému pro správu a dotazování na datové toky
  • openPDC Kompletní sada aplikací pro zpracování datových proudů časových řad v reálném čase.
  • Výpočet v reálném čase - Systémy ESP jsou obvykle systémy v reálném čase
  • RFID - Radiofrekvenční identifikace neboli RFID doporučuje použití ESP, aby se zabránilo zaplavení dat
  • SCADA - Dozorčí řízení a sběr dat, podobná technologie používaná ve strojírenských aplikacích
  • Apache Flink - Rámec pro zpracování streamů open-source pro distribuované škálovatelné aplikace pro streamování dat
  • Procesor WSO2 Stream - Otevřený zdroj Napařování SQL založený rámec zpracování proudu pro distribuované, škálovatelné aplikace pro streamování dat

Reference

  • Projekt zpracování toku MIT / Brown / Brandeis "Aurora"
  • Projekt „PIPES“ na univerzitě v Marburgu
  • Síla událostí David Luckham (ISBN  0-201-72789-7), ze Stanford University, kniha o CEP.
  • Oddělení pšenice od plevy Článek o CEP aplikovaný na RFID se objevil v RFID Journal
  • Komplexní zpracování událostí a inteligence v reálném čase - Zdroj průmyslově neutrálních informací o aplikacích, výzkumu, případech použití, referenčních architekturách a vývoji v oblasti zpracování událostí, provozovaný Prof Davidem Luckhamem
  • Odysseus - Rámec otevřeného zdroje pro motory pro zpracování událostí založený na Javě