Обработка событий#
Для выполнения сценария требуется роль администратора.
В данном сценарии выполняется обработка событий (фильтрация и/или преобразование формата).
Система-источник публикует событие, обработчик его вычитывает, выполняет необходимые преобразования и публикует результирующее событие в новый топик, к которому подключается потребитель. Правила обработки задаются с помощью языка DSL.
Для подписки на обработанное событие необходимо:
Создать конфигурацию потокового обработчика событий:
Конфигурация потокового обработчика событий состоит из:
одного файла *.conf, описывающего ход выполнения обработки событий (обязательный файл);
одного или нескольких файлов *.tr, описывающих шаги обработки событий (файлы трансформации и агрегации, ключи и триггеры агрегации и др). Данные файлы пишутся на языке DSL (для удобства разработан плагин, подключаемый к IDEA). Использование DSL описано подробнее в разделе DSL функции.
Формирование файла .conf и файлов *.tr описано в разделе Создание новых конфигураций обработчиков.
Подготовить zip-архив со всеми необходимыми конфигурационными файлами (.conf и *.tr). Название архива должно совпадать с названием файла .conf.
Установить обработчик. Установка обработчика описана в документе «Руководство по установке».