Pi.One берет на себя сбор, подготовку и обработку данных всех систем потребителей
- 01
Собирает информацию из разнородных источников
Пакетный и потоковый приём из файловых систем, объектных хранилищ, API, брокеров сообщений и сетевых интерфейсов — единая точка входа для корпоративных и телеком-данных.
- Local Disk, FTP/SFTP/SCP, S3/Hadoop-коннекторы, Kafka, MQTT, JMS, MSMQ
- REST/SOAP, HTTP/WebSocket, TCP/UDP
- File/S3 Collector и Forwarder, Mail Sender, Telegram Bot Collector/Sender
- 02
Проверяет целостность данных и приводит в единый формат для внутренней обработки
Описание моделей данных, проверки на входе и подготовка записей к обработке в batch- и real-time-контурах.
- Универсальный формат описания данных (УФД)
- Контроль целостности и профили качества
- Профили подключения, аудит и трассировка
- 03
Преобразует данные в соответствии с бизнес-логикой
Визуальные и программные цепочки: декодирование, маршрутизация, сессии, пользовательские сценарии на Pi.Lang и Groovy.
- Decoder, Encoder, Groovy, Record Router, Session
- Агрегация, корреляция, слияние, обнаружение дубликатов
- Архивирование и сжатие
- 04
Формирует и доставляет выходные данные в заданном формате
Пакетная и оперативная выдача в биллинг, CRM, хранилища, аналитику и внешние API с контролируемой доставкой.
- Кодирование под форматы систем-потребителей
- Расписания, события и подписки на выгрузки
- Мониторинг конвейеров и SLA
Скачать описание платформы (PDF)
Презентация архитектуры, типовых сценариев и области интеграции Pi.One
Потоки данных и обработка (Mediation)
Пример цепочки: источники → декодирование → валидация → бизнес-логика → выдача в системы потребителей.
Таблица 1: Область интеграции Core и Batch
| Бизнес-задачи | Доступные опции | Типовые результаты |
|---|---|---|
| Сбор и доставка файлов, объектов и сообщений | Local Disk/FTP/SFTP/SCP, S3/Hadoop-коннекторы, File Collector, File Forwarder, S3 Collector, S3 Forwarder, Mail Sender, Telegram Bot Collector, Telegram Bot Sender | Пакетная загрузка и контролируемая доставка через файловые системы, объектные хранилища и внешние каналы коммуникации. |
| Преобразование данных и пользовательская трансформация | Decoder, Encoder, Groovy, Record Router, Session, архивирование и сжатие, агрегация/корреляция/слияние, обнаружение дубликатов | Декодирование/кодирование на базе Pi.Lang, пользовательская обработка, маршрутизация, сессионная агрегация и контроль качества данных в сквозных batch-потоках. |
| Интеграция доступа к данным и хранения | Коннекторы к БД и SQL, профильные настройки подключения, аудит данных и опции операционного хранения | Пакетная выгрузка/загрузка, обогащение и процессы жизненного цикла корпоративных данных. |
Pi.One Real-time
Таблица 2: Область интеграции Real-time
| Бизнес-задачи | Доступные опции | Типовые результаты |
|---|---|---|
| Интеграция API и событийных сервисов | REST, SOAP, HTTP и WebSocket-паттерны интеграции с HTTP Server, REST Router и агентами оркестрации | Публикация API в реальном времени, запуск по расписанию/событиям и оркестрация рабочих потоков во время выполнения. |
| Сообщения и стриминг | JMS, Kafka, MSMQ и MQTT-паттерны интеграции, включая Kafka Consumer, Kafka Producer и MQTT Collector | Потоковая загрузка и распределение событий для низколатентных конвейеров. |
| Сетевые и сокетные интеграции | TCP/IP и UDP-паттерны интеграции, маршрутизация на уровне протоколов и обработка по событиям | Взаимодействие между системами и управляющие процессы в режиме near real-time. |
Получите бесплатный аудит за 3 дня
Подберём решение под вашу задачу и рассчитаем стоимость
Определим скрытые потери и упущенные возможности в существующей IT-инфраструктуре
Предложим решения, которые напрямую влияют на рост прибыли, снижение расходов и повышение управляемости бизнеса
Подготовим дорожную карту с приоритетами внедрения изменений, ориентированную на быструю отдачу инвестиций