Корреляторы событий

Корреляция событий - это механизм, который позволяет обнаружить сложные схемы взаимодействия между событиями и реализовать для них алгоритмы обработки.

Коррелятор событий:

• "Слушает" события из входных потоков. Это события, порождаемые контекстами, или необработанные события, поступающие от поддерживаемых движком коррелятора протоколов.
• Парсит, коррелирует и обрабатывает эти события согласно набору определенных правил. Эти правила определены в языке скрипта, используемом движком коррелятора.
• Отправляет события в выходные потоки, которые являются результатом корреляции и обработки, осуществляемой коррелятором событий. И это снова события, порождаемые контекстами, или необработанные события, поступающие от поддерживаемых протоколов.

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

Контексты Коррелятора событий хранятся к контейнере Коррелятора событий в Системном дереве. Каждый контекст определяет только один коррелятор событий.

Поскольку коррелятор может объединять несколько сходных потоков и обрабатывать каждый из них отдельно от других, необязательно создавать коррелятор для каждого входного потока, который вы хотите обработать.

Расширения - это модули, установив которые можно расширить базовый функционал движка коррелятора. Например, вы можете установить расширение с функциями, позволяющими работать с регулярными выражениями или с необработанными данными событий из протокола Kafka.

Технически, расширения представляют собой автономные JAR файлы и могут быть установлены отдельно.

Чтобы узнать больше об использовании расширений, см. раздел Плагин корреляторов событий. Информацию о доступных расширениях см. в документации по расширениям движка коррелятора.