Стоимость не зависит от количества используемых вычислительных ресурсов, количества реализованных интеграционных сценариев, используемых коннекторов, пользователей и т.д.

Масштабируется горизонтально. Держит пиковые нагрузки без деградации

Промышленная ESB-шина для высоконагруженных ИТ-систем

Промышленная ESB-шина для высоконагруженных систем
50 000 сообщений/сек, задержка <5 мс, exactly-once. Подтверждено нагрузочными тестами
Промышленная ESB-шина для высоконагруженных систем
50 000 сообщений/сек, задержка <5 мс, exactly-once. Подтверждено нагрузочными тестами

«Под капотом»

«Интегра» построена на современном технологическом стеке, который сочетает в себе удобство интуитивно понятного интерфейса и гибкость микросервисной архитектуры.
Это даёт возможность гибкой адаптации к требованиям заказчика для обеспечения высокой производительности, масштабируемости и надежности
Системное ПО
Кластер ядер интеграционной платформы
Интерфейс Low Code
Мониторинг
Логирование
RealTime взаимодействие
Микросервисные
обработчики и коннекторы
и другие
Кластер баз данных
Кластер брокера
Пользовательский интерфейс (React JS)
Точка взаимодействия пользователя с инструментами системы, такими как потоки, блоки, а также настроечные функции, функции мониторинга и администратора.

MongoDB

Документоориентированная система управления базами данных. Может быть заменена на RethinkDB, PostgreSQL и иные.

Ядро ИНТЕГРА (Spring Webflux, Java, Spring Integration, Apache Camel)

Основной модуль системы, обеспечивающий её функционирование, передачу данных, связь с запущенными экземплярами процессов, связь с модулей, а также базовую аутентификацию.

Модуль Keycloack аутентификации

IDM сервис входа для внутренних и внешних пользователей, обеспечивающий аутентификацию, управление пользователями и ведение модели доступов в рамках системы внешней IDM системы.

ActiveMQ

Брокер позволяющий работать над интеграциями нескольким разработчиками и наблюдать за поведением друг друга.

Поисковая система (OpenSearch)

Обеспечивает быстрый поиск и аналитику
по большим объемам данных.

Панель визуализации (Kibana)

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

Сервис сбора технических и бизнес-метрик (Prometheus)

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

Система мониторинга (Grafana)

Отображает ключевые метрики на удобных дашбордах

Брокер сообщений (Apache Kafka)

Обеспечивает обработку потоковых данных в реальном времени с высокой пропускной способностью

«Под капотом»

«Интегра» построена на современном технологическом стеке, который сочетает в себе удобство интуитивно понятного интерфейса и гибкость микросервисной архитектуры. Это даёт возможность гибкой адаптации к требованиям заказчика для обеспечения высокой производительности, масштабируемости и надежности
Пользовательский интерфейс (React JS)
Точка взаимодействия пользователя с инструментами системы, такими как потоки, блоки, а также настроечные функции, функции мониторинга и администратора.
MongoDB
Документоориентированная система управления базами данных. Может быть заменена на RethinkDB, PostgreSQL и иные.
Ядро ИНТЕГРА (Spring Webflux, Java, Spring Integration, Apache Camel)
Основной модуль системы, обеспечивающий её функционирование, передачу данных, связь с запущенными экземплярами процессов, связь с модулей, а также базовую аутентификацию.
Модуль Keycloack аутентификации
IDM сервис входа для внутренних и внешних пользователей, обеспечивающий аутентификацию, управление пользователями и ведение модели доступов в рамках системы внешней IDM системы.
Брокер позволяющий работать над интеграциями нескольким разработчиками и наблюдать за поведением друг друга.
ActiveMQ
Поисковая система (OpenSearch)
Обеспечивает быстрый поиск и аналитику
по большим объемам данных.
Панель визуализации (Kibana)
Применяется для анализа журналов и временных рядов, мониторинга приложений и текущих процессов
Сервис сбора технических и бизнес-метрик (Prometheus)
Применяется для анализа журналов и временных рядов, мониторинга приложений и текущих процессов
Система мониторинга (Grafana)
Отображает ключевые метрики на удобных дашбордах
Брокер сообщений (Apache Kafka)
Обеспечивает обработку потоковых данных в реальном времени с высокой пропускной способностью
Можно использовать весь заранее настроенный набор микросервисов
для авторизации, мониторинга, логирования, обмена сообщениями
и т.д. или заменить
их на имеющиеся
в ИТ-ландшафте организации системы

Взаимозаменяемость блоков

Отказоустойчивость

Ядро продукта, написано
на Spring Webflux
для легкого распараллеливания нагрузок по потокам
и поддержки большого количества одновременных соединений.
Для обеспечения безотказности работы «Интегры» вычислительные мощности можно объединить в кластер

Высокий показатель нагрузки

За счет масштабируемости, производительности
и гибкости, а также благодаря универсальности MongoDB, обеспечивается работа с большими объемами разнородных данных, а также гарантия их хранения, обработки
и анализа

Удобство обновления

Продукт постоянно развивается, модернизируется
и обновляется,
что позволяет ему быть функциональным, безопасным
и соответствовать требованиям регуляторов.

Установка новых версий
в кластере проходит «бесшовно», т.к. сервера обновляются поочередно

Готовые коннекторы
и обработчики

Коннекторы

Kafka

ActiveMQ

Подписка на Kafka
Получение сообщений из ActiveMQ

Mail

Cron Sheduler

Получение почты
Создание пакетов данных по Cron

Telegram

Получение данных из выбранного чата

RabbitMQ

Получение сообщений из RabbitMQ

HTTP

Создание входа для HTTP запросов

7tech MDM

Заполнение справочников MDM

FTP

Получение файлов с FTP сервера

Time Scheduler

SMB

Создание пакетов данных по Timer

SQL

Получение файлов
с SMB сервера
Синхронизация SQL базы данных

Запросить список всех компонентов

Коннекторы

Kafka
ActiveMQ
Подписка на Kafka
Получение сообщений из ActiveMQ
Mail
Cron Sheduler
Получение почты
Создание пакетов данных по Cron
Telegram
Получение данных из выбранного чата
RabbitMQ
Получение сообщений из RabbitMQ
HTTP
Создание входа для HTTP запросов
7tech MDM
Заполнение справочников MDM
FTP
Получение файлов с FTP сервера
Time Scheduler
SMB
Создание пакетов данных по Timer
SQL
Получение файлов
с SMB сервера
Синхронизация SQL базы данных
Запросить список всех компонентов
Обработчики данных

Checker

Mapping Data

SQL

Проверяет поток на выполнение условий
Пользовательская форма ввода
Обогащение результатом SQL запроса

Remover

Txtgenerator

DataFilter

Фильтр потока данных
Удаление значений из переменной
Генерация текстового файла

HTTP

Setter

Union

Обогащение результатом HTTP запроса
Запись значения в указанную переменную
Объединение одиночных пакетов в массив

Separation

Разделение массива на пакеты данных

ExcelGenerator

Генерация Excel

ExcelParser

Парсер Excel

Mongo

Обогащение результатом запроса в mongo

FileReader

Чтение текста из файла

Обработчики данных

Checker
Mapping Data
SQL
Проверяет поток на выполнение условий
Пользовательская форма ввода
Обогащение результатом SQL запроса
Remover
Txtgenerator
DataFilter
Фильтр потока данных
Удаление значений из переменной
Генерация текстового файла
HTTP
Setter
Union
Обогащение результатом HTTP запроса
Запись значения в указанную переменную
Объединение одиночных пакетов в массив
Separation
Разделение массива на пакеты данных
ExcelGenerator
Генерация Excel
ExcelParser
Парсер Excel
Mongo
Обогащение результатом запроса в mongo
FileReader
Чтение текста из файла

Встроенный мониторинг

Наглядный процесс преобразования данных на каждом этапе выполнения интеграционного сценария
Сохранение и отображение всей информации о передаваемом сообщении, включая тело, заголовки, дополнительные параметры
Отображение количества успешно переданных сообщений между системами, ошибок с возможностью вывода подробного отчета об ошибке (StackTrace)
Логирование информации о работе каждого коннектора и обработчика, находящегося в составе интеграции
Встроенный мониторинг
Наглядный процесс преобразования данных на каждом этапе выполнения интеграционного сценария
Сохранение и отображение всей информации о передаваемом сообщении, включая тело, заголовки, дополнительные параметры
Отображение количества успешно переданных сообщений между системами, ошибок с возможностью вывода подробного отчета об ошибке (StackTrace)
Логирование информации о работе каждого коннектора и обработчика, находящегося в составе интеграции

Производительность

1 000 000

Количество сообщений

Размер
сообщения

Время
(Интегра -> Kafka)

Время
(Kafka -> Интегра)

1kb
20 секунд
(800 нс при увеличенном heap RAM, 1000 потоках и 24 партициях)
35 секунд
1 000 000
100kb
9:15 минуты
(10 мс при увеличенном heap RAM, 1000 потоках и 24 партициях)
1:39 минуты
1 0 000
1mb
58 секунд
(1мкс при увеличенном heap RAM, 100 потоках и 24 партициях)
35 секунд
Получить технический доступ для тестирования платформы «Интегра»