Обработка событий#

Для выполнения сценария требуется роль администратора.

В данном сценарии выполняется обработка событий (фильтрация и/или преобразование формата).

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

Обработка событий

Для того, чтобы подписаться на обработанное событие необходимо:

  1. Создать конфигурацию потокового обработчика событий:

Конфигурация потокового обработчика событий состоит из:

  • одного файла *.conf, описывающего ход выполнения обработки событий (обязательный файл);

  • одного или нескольких файлов *.tr, описывающих шаги обработки событий (файлы трансформации и агрегации, ключи и триггеры агрегации и др). Данные файлы пишутся на языке DSL (для удобства разработан плагин, подключаемый к IDEA). Использование DSL описано подробнее в разделе DSL функции.

Формирование файла .conf и файлов *.tr описано в разделе Создание новых конфигураций обработчиков.

  1. Подготовить zip-архив со всеми необходимыми конфигурационными файлами (.conf и *.tr). Название архива должно совпадать с названием файла .conf.

  2. Установить обработчик. Установка обработчика описана в документе «Руководство по установке».