Olay akışı işleme - Event stream processing

Akış işleme ile birleştirme

Olay akışı işleme veya ESP , olaya dayalı bilgi sistemlerinin oluşturulmasına yardımcı olmak için tasarlanmış bir dizi teknolojidir . ESP teknolojileri, olay görselleştirmeyi, olay veritabanlarını, olaya dayalı ara yazılımı ve olay işleme dillerini veya karmaşık olay işlemeyi (CEP) içerir. Pratikte, ESP ve CEP terimleri sıklıkla birbirinin yerine kullanılır. ESP, birden çok olay arasındaki ilişkilerin tespiti, olay korelasyonu, olay hiyerarşileri ve nedensellik, üyelik ve zamanlama gibi diğer yönler gibi teknikleri kullanarak, bu akışlar içindeki anlamlı kalıbı tanımlamak amacıyla olay verisi akışlarını işleme görevi ile ilgilenir. .

ESP, finansal hizmetlerde algoritmik ticaret , radyo frekansı tanımlama (RFID) olay işleme uygulamaları, dolandırıcılık tespiti , süreç izleme ve telekomünikasyonda konum tabanlı hizmetler gibi birçok farklı uygulamaya olanak tanır .

Örnekler

Örnekleme yoluyla, aşağıdaki kod parçaları, olay akışları içindeki kalıpların algılanmasını gösterir. Birincisi, sürekli bir SQL sorgusu (zaman damgalarına ve pencere süresine dayalı olarak gelen verileri sonsuza kadar işlemeyi yürüten bir sorgu) kullanarak bir veri akışını işlemenin bir örneğidir . Bu kod parçası, biri hisse senedi siparişleri için ve diğeri sonuçta ortaya çıkan hisse senedi alım satımları için olmak üzere iki veri akışından oluşan bir JOIN'i gösterir. Sorgu, Emir verildikten sonraki bir saniye içinde bir İşlem tarafından eşleşen tüm Emirlerin bir akışını verir. Çıktı akışı zaman damgasına göre sıralanır, bu durumda Siparişler akışındaki zaman damgası. 

SELECT DataStream
   Orders.TimeStamp, Orders.orderId, Orders.ticker,
   Orders.amount, Trade.amount
FROM Orders
JOIN Trades OVER (RANGE INTERVAL '1' SECOND FOLLOWING)
ON Orders.orderId = Trades.orderId;

Başka bir örnek kod parçası, kilise çanlarının çalması, smokin veya sabahlık giymiş bir adamın görünümü, uçuşan beyaz elbiseli bir kadın ve havada uçuşan pirinç gibi bir dış "olay" akışı arasındaki düğünleri tespit eder. "Karmaşık" veya "bileşik" bir olay, kişinin tek tek basit olaylardan çıkardığı sonuçtur: bir düğün gerçekleşiyor. 

WHEN Person.Gender EQUALS "man" AND Person.Clothes EQUALS "tuxedo"
FOLLOWED-BY
  Person.Clothes EQUALS "gown" AND
  (Church_Bell OR Rice_Flying)
WITHIN 2 hours
ACTION Wedding

Ayrıca bakınız

  • Karmaşık olay işleme (CEP) - Olaya dayalı bilgi sistemleri oluşturmak ve yönetmek için ilgili bir teknoloji.
  • Veri Akışı Yönetim Sistemi (DSMS) - Veri akışlarını yönetmek ve sorgulamak için bir tür yazılım sistemi
  • openPDC Akışlı zaman serisi verilerini gerçek zamanlı olarak işlemek için eksiksiz bir uygulama seti.
  • Gerçek zamanlı bilgi işlem - ESP sistemleri tipik olarak gerçek zamanlı sistemlerdir
  • RFID - Radyo frekansı tanımlaması veya RFID, veri taşmasını önlemek için ESP uygulamasını önerir
  • SCADA - Denetleyici kontrol ve veri toplama, mühendislik uygulamalarında kullanılan benzer bir teknoloji
  • Apache Flink - Dağıtılmış, ölçeklenebilir veri akışı uygulamaları için açık kaynaklı bir akış işleme çerçevesi
  • WSO2 Akış İşlemcisi - Dağıtılmış, ölçeklenebilir veri akışı uygulamaları için açık kaynaklı Steaming SQL tabanlı akış işleme çerçevesi

Referanslar

  • MIT/Brown/Brandeis "Aurora" Akış İşleme Projesi
  • Marburg Üniversitesi'nde "BORULAR" Projesi
  • The Power of Events , Stanford Üniversitesi'nden David Luckham ( ISBN  0-201-72789-7 ), CEP üzerine bir kitap.
  • Buğdayı Samandan Ayırmak, RFID'ye Uygulanan CEP ile ilgili Makale, RFID Journal'da yayınlandı
  • Karmaşık Olay İşleme ve Gerçek Zamanlı İstihbarat - Prof David Luckham tarafından yürütülen, uygulamalar, araştırmalar, kullanım senaryoları, referans mimariler ve olay işlemedeki gelişmeler hakkında endüstriden bağımsız bir bilgi kaynağı
  • Odysseus - Java tabanlı olay işleme motorları için açık kaynaklı bir çerçeve