Блог

Внедрение корпоративной шины передачи данных
на базе Apache Кafka в Галамарте: современное решение для интеграции систем

Компания «Диджи Тех» разработала и внедрила в сети «Галамарт» шину передачи данных на базе Apache Кafka для обеспечения безопасного и надежного обмена данными между различными системами и приложениями. Это решение позволяет компаниям с развитой филиальной сетью и многочисленными корпоративными приложениями оптимизировать передачу данных, повысить отказоустойчивость и безопасность.

Что такое шина передачи данных (ESB) и почему она важна?

Шина передачи данных (Enterprise Service Bus, ESB) — это программная платформа, которая служит связующим звеном между различными приложениями и системами внутри организации. Она упрощает обмен данными, стандартизирует взаимодействие, повышает надежность и масштабируемость, а также управляет потоками данных. ESB работает как централизованный хаб, принимая, маршрутизируя, преобразуя и обогащая сообщения, обеспечивая безопасность

и оптимизацию производительности.

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

с географически распределенной сетью филиалов или многочисленными приложениями.

Например, передача чеков продаж из магазинов или обмен данными между складскими и торговыми системами.

Еще одним примером применения ESB является интернет вещей (IoT). В таких сценариях происходит обмен данными между устройствами и центральными системами, что особенно актуально для здравоохранения — например, передача данных от носимых медицинских устройств в медицинские учреждения.

Как работает шина передачи данных и её компоненты

Шина передачи данных, основанная на Apache Кafka, является центром обработки сообщений, разделяя их на несколько ключевых компонентов:

1. Конверт сообщения - метаданные, которые помогают в маршрутизации

и унифицированной обработке сообщения.

2. Тело сообщения — это непосредственно передаваемые данные.

Пример использования шины для передачи больших файлов: файл сначала загружается в объектное хранилище (MinIO или S3), после чего получатель получает ссылку на этот файл через сообщение в брокере.

Основные функции адаптера сообщений

Адаптер сообщений отвечает за отправку и получение сообщений. В его задачи входит:

Особое внимание уделяется контролю за состоянием передачи сообщений

и выполнением команд ОС. Адаптер выполняет команды последовательно

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

Преимущества решения от «Диджи Тех»

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

Наша команда предлагает не просто внедрение брокера сообщений «из коробки», но и полную адаптацию решения под уникальные требования клиента:

1. Установка и настройка коннекторов (адаптеры) для каждой из используемых систем, будь то ERP, OMS, WMS, MDM, ваш сайт и т.д;

2. Трансформация, конвертация и обогащение данных в сообщении для специфических бизнес-логик клиента, что позволит решать задачи обмена

без дополнительных преобразований на принимающей стороне;

3. Понятный и легкий в освоении Web-интерфейс управления маршрутизатором (ITOPS), с помощью которого можно добавлять/редактировать узлы, создавать маршруты и правила отправки/получения сообщений, контролировать очередь недоставленных сообщений;

4. Расширение функционала под нужды клиента: при необходимости можно добавить модули мониторинга, аналитики, хранилище объектов на базе протокола S3 (MinIO, Amazon);

5. Готовая интеграция с государственными системами контроля, такими

как «Честный знак», «Меркурий».

Заключение

Решение от «Диджи Тех» предлагает проверенные временем и практикой технологии для обмена данными, которые могут быть адаптированы для нужд любой компании. Сложные интеграции, такие как передача больших файлов или подключение IoT-устройств, становятся проще и надежнее, а отказоустойчивость системы гарантирует непрерывную работу.





Алексей Сазонов
Руководитель отдела систем передачи данных