Интеграционная платформа и схема передачи данных

1.

2.

3.

4.

5.

6.

7.

8.

9.

10.

11.

12.

13.

14.

15.

Схема передачи данных
Коннектор
Входящая
трансформация
Маршрут
Исходящая
трансформация
Коннектор
Маршрут
Исходящая
трансформация
Коннектор
Входящая
трансформация
Маршрут
Исходящая
трансформация
Коннектор
Входящая
трансформация
Маршрут
Исходящая
трансформация
Коннектор
Маршрут
Исходящая
трансформация
Коннектор
Исходящая
трансформация
Коннектор
ESB
Коннектор
Platform
Коннектор

16.

Источник сообщения
как получатель
А
Коннектор
ESB
Входящая
трансформация
Маршрут
Отправить в А
Ошибка
А
Platform
Коннектор
Входящая
трансформация
Исходящая
трансформация
Маршрут
Отправить в А

17.

Пример решения задачи
Platform
Служба
исполнения
заказов
Сайт
заказов обедов
REST сервер
REST сервер

18.

Процесс или маршрут
Маршрут – выполняются «вместе»,
рассылка только уникальным получателям.
● Маршрут А.
Получатель
Склад, ERP
● Маршрут Б.
Получатель
ERP
● Будет
отправлено:
Склад, ERP
Процесс – реализует бизнес-логику, каждый
процесс выполняется в своей ветке. Может
являться владельцем сообщения.
● Процесс А.
Получатель
Склад, ERP
● Процесс Б.
Получатель
ERP
● Будет
отправлено:
Склад, ERP, ERP

19.

Определение входящей
трансформации
На основе типа и источника
Входящая
трансформация
● Флаг «Автостарт»
● Может быть выбрано
несколько
● В разрезе источника
и типа сообщения
5
Входящее сообщение
Настройка
трансформации
Тип данных
= пусто
С указанием системы
Тип данных =
заполнено
Когда сработает?
Входящие данные = сообщение
Источник =
система
Источник = система
Входящие данные = пусто
Источник =
система
-
-
Источник = система
и входящие данные =
тип данных
Входящие данные = заполнено
Без указания системы
Когда сработает?
Входящие данные = сообщение
Всегда
Всегда
Входящие данные = пусто
Всегда
-
Входящие данные = заполнено
-
Тип = тип

20.

Определение исходящей
трансформации
На основе типа и получателя
Исходящая
трансформация
● Флаг «Автостарт»
● Может быть выбрано
несколько
● В разрезе получателя
и типа сообщения
6
Исходящее сообщение
Настройка
трансформации
Тип данных
= пусто
С указанием системы
Тип данных =
заполнено
Когда сработает?
Входящие данные = сообщение
Получатель =
система
Получатель =
система
Входящие данные = пусто
Получатель =
система
-
-
Получатель =
система и входящие
данные = тип данных
Входящие данные = заполнено
Без указания системы
Когда сработает?
Входящие данные = сообщение
Всегда
Всегда
Входящие данные = пусто
Всегда
-
Входящие данные = заполнено
-
Тип = тип

21.

Обработка сообщений
Коннектор
Очередь
необработанных
Трансформация
входящая
Определение
процесса
Процесс/
маршрут
Трансформация
исходящая
Очередь на
другие узлы
4
Очередь внешней
системы
Очередь внешней
системы
Коннектор
Коннектор

22.

Определение маршрутов
и процессов
На основе типа
Маршруты
Маршруты
и процессы
● Флаг
«Автостарт»
● Может быть
выбрано
несколько
7
Сообщение
Тип = пусто
Тип = заполнено
Входящий тип = пусто
Да
Да
Входящий тип = заполнено
Нет
Тип = тип
● В разрезе типа
сообщения
Процессы
Тип = пусто
Тип = заполнено
Входящий тип = сообщение
Да
Да
Входящий тип = пусто
Да
Нет
Входящий тип = заполнено
Нет
Тип = тип
● В маршруте
можно выбрать
несколько типов
Сообщение

23.

Переменные процессов
InitMessage – системная переменная
= исходное сообщение
Переменные обработки
● Для определения
автостартов
● Инициализация
из тела сообщения
Переменные
● Реализация пользовательской логики
Например, перемененная int cчетчик – для реализации циклов
8

24.

Шаги отправки в процессах
и маршрутах
Маршрут
Отправить подписчику = зарегистрировать в очереди
на отправку и забыть
Процесс
1)
3)
Отправка получателям
= зарегистрировать
в очереди на отправку
и забыть
Источник
10
2)
Инициировать
получение
данных и
продолжить
Забрать
данные и
4)
продолжить
Отправка получателю
Зарегистрировать в очереди
на отправку и забыть
Дождаться
доставки и
продолжить
Дождаться
ответа и
продолжить
Регистрация сообщения

25.

Шаги отправки в процессах
и маршрутах
Маршрут
По свойствам
сообщения
Тело необходимо
десериализовать
11
Процесс
По свойствам
сообщения
По полям типа

26.

Задача
Сайт
заказов обедов
Platform
Служба
заказов
REST сервер
Свойство сost
cost <100
12
REST сервер

27.

Задача
Platform
Сайт
заказов обедов
Служба
заказов
REST сервер
13
REST сервер
Обед X на сумму Y