Научись создавать систему обмена сообщениями для 1с на apache kafka за 5 часов.
Использование открытой платформой для распределенной потоковой передачи событий с возможностью создания высокопроизводительных конвейеров обработки данных для целей аналитики данных или их интеграции в бизнес-целях.
На вебинаре мы разберем 2 бизнес-кейса
«Потоковая передача и хранение данных о свободных остатках» между системами
«Потоковая передача и хранение данных о взаиморасчетах с клиентом» между системами
Что понадобится от слушателя:
Для воспроизведения показанного на вебинаре понадобится:
- Доступ к установленной службе Docker – как на собственной машине, так и на удаленном хосте
- Установленный GIT клиент для скачивания примером с GitHub
- Установленный Visual Studio Code
- Установленная платформа 1С редакции не ниже 8.3.15
- Все примеры специально для вебинара выполнены на языке 1С в конфигурации с режимом совместимости
- А также на платформе OScript.Web и OScript для эмуляции внешних сайтов и сервисов участвующих в интеграции
Чему вы научитесь:
Что такое eda platform:
- Что такое Apache Kafka Platform
- Какой глоссарий стоит использовать при потоковой интеграции
- Структура хранения данных и передаваемых данных
- Развертывание интеграционной платформы посредством Docker
Источники и форматы данных:
- Объект 1С «История данных» и потоковая отправка данных
- Единый по миру формат любого события для отправителя, чтобы не подставлять подписчика
- Отправляем изменения взаиморасчетов в режиме реального времени из 1С без внешних компонент
- Отправляем изменения остатков в режиме реального времени из 1С без внешних компонент
Подписчики и восстановление последовательности:
- Однопоточный подписчик на сайте посредством OScript.Web
- Многопоточный подписчик в «другой конфигурации 1С»
- Подписываемся на изменения свободных остатков в многопоточном режиме
- Подписываемся на изменение взаиморасчетов в многопоточном режиме
Трансформация и кеширование данных:
- Потоковая трансформация форматов на платформе Kafka
- Создадим кеширующую таблицу хранения информации об актуальных взаиморасчетах средствами KafkaTable
- Сохраняем на всякий случай движения свободных остатков в ElasticSearch
- Читаем через SQL взаиморасчеты и свободные остатки из Kafka средствами 1С и Oscript