Process Complex Events

Question

У меня поток дискретных событий, входящих в мою систему, и мне нужно применять правила, основанные на содержании каждого события. Кроме того, я хочу применить сложную обработку событий для этих событий потока.

Ограничения 1. Эти правила предоставляются пользователем и будут динамически изменяться. 2. Я не хочу перезапускать систему всякий раз, когда применяется правило. 3. HA 4. Только зрелые решения с открытым исходным кодом

Возможные пути .. 1. Запустите Esper КЭП внутри грозовой болта
2. У Drools закладываемые в болтом Бури

• бы это сделать сингл обработки правил событий, а также сложных событий? Будет ли изменение правил изменено на мой шторм?

• Могу ли я динамически вставлять правила в штурмовые болты?

Другие решения? Спарк?

Answer 1

Оба Drools и Esper могут динамически вводить правила и не требуют перезапуска Storm или JVM.

И Esper, и Drools Fusion могут обрабатывать сложные события, как правило, с различными компромиссами.

В том же распределенном домене обработки потоковой обработки являются Spark streaming, Storm, Yahoo S4 и Apache Samza. Любой из них может использоваться для размещения Esper/Drools. Для Storm я думаю, что, поскольку он повторяет кортежи, которые вы хотите либо удалить дубликат перед отправкой в ​​Drools/Esper, либо спроектировать свои непрерывные запросы, ожидающие возможных дублированных поставок.