Process Complex Events

Question

Mam strumień dyskretnych zdarzeń wchodzących do mojego systemu i muszę zastosować reguły na podstawie zawartości każdego zdarzenia. Ponadto chcę zastosować złożone przetwarzanie zdarzeń w tych zdarzeniach strumieniowych.

Ograniczenia 1. Te zasady są dostarczane przez użytkownika i zmieniają się dynamicznie. 2. Nie chcę ponownie uruchamiać systemu po zastosowaniu reguły. 3. HA 4. starsze rozwiązania open source tylko

Możliwe sposoby .. 1. Uruchom Esper CEP wewnątrz śrubą burzy
2. Czy Drools prowadzone wewnątrz przejaśnienia śrubą

• zrobi to pojedynczy przetwarzanie reguł zdarzeń, jak również złożone zdarzenia? Czy zmiany Reguł będą wymagać ponownego rozpoczęcia burzy?

• Czy mogę dynamicznie wstawiać reguły do ​​rygli burzowych?

Inne rozwiązania? Iskra?

Answer 1

Drools i Esper mogą dynamicznie wstrzykiwać reguły i nie wymagają restartu Storm lub JVM.

Zarówno Esper, jak i Drools Fusion mogą obsługiwać złożone zdarzenia, generalnie z różnymi kompromisami.

W tej samej domenie rozproszonego przetwarzania domeny są Spark streaming, Storm, Yahoo S4 i Apache Samza. Dowolny z nich może być używany do hostingu Esper/Drools. Jeśli chodzi o Storm, myślę, że od czasu powtórzenia krotek, powinieneś usunąć duplikat przed wysłaniem do Drools/Esper lub zaprojektować ciągłe zapytania oczekujące możliwych duplikatów dostaw.