Построение потока обработки#

Содержание#

• Общая информация

• Виды потоков

  • Простой поток трансформации

  • Поток трансформации c БД

  • Поток трансформации c вызовом REST сервиса

  • Простой поток агрегации

  • Поток со слиянием, ветвлением и агрегацией

  • Поток с ветвлением, агрегацией и слиянием

  • Поток c фильтрацией и маршрутизацией без файла трансформации

• Общие правила заполнения файлов потока

  • Структура файла потока «*.conf»

  • Структура файла потока «*.yaml»

  • Файл параметров «defaults.json»

  • Указание группы консьюмеров

  • Пути до файлов в блоках трансформации и агрегации

  • Метки отдельных блоков

  • Имена отдельных блоков

  • Пример потока обработки

• Специальные правила построения потока

  • Источники событий

  • Точки назначения событий

  • Создание и объединение нескольких веток обработки событий

  • Трансформация событий

  • Агрегация событий

  • XSL. Преобразование событий в формате XML

  • Преобразование форматов событий на JavaScript

  • Валидация сообщений по схеме

  • Работа с базами данных

  • Обработка ошибок в шагах трансформации и агрегации событий

  • Вызов внешних сервисов по HTTP(s) из потоковых обработчиков