Prozess komplexe Ereignisse

Question

Ich habe einen Strom von diskreten Ereignissen in mein System kommen und ich muss Regeln basierend auf dem Inhalt jedes Ereignisses anwenden. Außerdem möchte ich komplexe Ereignisverarbeitung für diese Stream-Ereignisse anwenden.

Einschränkungen 1. Diese Regeln werden vom Benutzer bereitgestellt und ändern sich dynamisch. 2. Ich möchte mein System nicht immer neu starten, wenn eine Regel angewendet wird. 3. HA 4. Nur ausgereifte Open-Source-Lösungen

Mögliche Wege .. 1. Führen Sie Esper CEP innen Sturm Schraube
2. Haben drools innerhalb Sturmschraube

laufen

• dieses einzelne tun würde Ereignisregelverarbeitung sowie komplexe Ereignisse? Würden Regeländerungen meinen Sturm neu starten?

• Kann ich Regeln dynamisch in Sturmbolzen einfügen?

Andere Lösungen? Funke?

Answer 1

Sowohl Drools als auch Esper können Regeln dynamisch einfügen und erfordern keinen Neustart von Storm oder der JVM.

Sowohl Esper als auch Drools Fusion können komplexe Ereignisse meist mit unterschiedlichen Kompromissen behandeln.

In der gleichen verteilte Stream-Processing-Lösung Domäne sind Spark-Streaming, Sturm, Yahoo S4 und Apache Samza. Irgendeines von diesen kann benutzt werden, um Esper/Drools zu bewirten. Für Storm denke ich, da es Tupel wiederholt, die du entweder de-duplizieren möchtest, bevor du Drools/Esper schickst, oder deine kontinuierlichen Anfragen entwirfst, um mögliche doppelte Lieferungen zu erwarten.