Process Complex Events

Question

Ho un flusso di eventi discreti che entrano nel mio sistema e ho bisogno di applicare regole basate sul contenuto di ciascun evento. Inoltre, voglio applicare l'elaborazione di eventi complessi su questi eventi di streaming.

Vincoli 1. Queste regole sono fornita dall'utente e cambieranno dinamicamente. 2. Non voglio riavviare il mio sistema ogni volta che viene applicata una regola. 3. HA 4. Solo maturare soluzioni open source

possibili modi .. 1. Eseguire Esper CEP all'interno bullone tempesta
2. Ha sbava gestite all'interno bullone tempesta

• Sarebbe questo fare singolo elaborazione di regole evento e eventi complessi? Le modifiche alle regole richiederanno il riavvio della mia tempesta?

• Posso inserire dinamicamente le regole nei bulloni tempesta?

Altre soluzioni? Scintilla?

Answer 1

Sia Drools e Esper può iniettare in modo dinamico le regole e non richiedono il riavvio del tempesta o la JVM.

Sia Esper che Drools Fusion sono in grado di gestire eventi complessi, in genere, con compromessi diversi.

nello stesso dominio soluzione di elaborazione distribuita flusso di streaming sono Spark, Tempesta, Yahoo S4 e Apache Samza. Ognuna di queste può essere utilizzata per ospitare Esper/Drools. Per Storm penso che dal momento che riproduce le tuple vorresti o de-duplicare prima di inviarlo a Drools/Esper o progettare le tue continue domande aspettando possibili consegne duplicate.