Обзор бизнес-событий (предварительная версия)

Business events — это возможность в Fabric Real-Time Intelligence, которая позволяет командам определять, изучать и действовать над бизнес-сигналами в режиме реального времени, ускоряя разработку приложений на основе событий и ускоряя принятие решений.

Бизнес-события можно создавать из следующих источников:

  • Записные книжки Spark
  • Функции пользовательских данных

После публикации эти события доступны в центре Real-Time, где можно настроить оповещения для выполнения таких действий, как следующие:

  • Оповещение и автоматизация последующих процессов (Активатор — электронная почта, Teams)
  • Выполнение пользовательской логики (пользовательские функции данных)
  • Запуск аналитических рабочих процессов (записные книжки)
  • Предоставление контекста в режиме реального времени для ИИ/ML (записные книжки)
  • Выполнение распределенной обработки (задания Spark)
  • Подготовка и перемещение данных (потоки данных 2-го поколения)
  • Автоматизация бизнес-процессов (Power Automate)

На следующей схеме показано, как производственная система обнаруживает ненормальную вибрацию с помощью Spark Notebook, анализирует ее и публикует VibrationCriticalDetected бизнес-событие, которое активирует пользовательскую бизнес-логику в функции данных пользователя (UDF) через Activator.

Схема, показывающая производственную систему, обнаруживающую ненормальную вибрацию с помощью записной книжки Spark, анализируя ее и публикуя бизнес-событие VibrationCriticalDetected, которое активирует пользовательскую бизнес-логику в функции пользовательских данных с помощью активатора.

Это важно

Эта функция доступна в предварительной версии.

Что такое бизнес-событие?

Бизнес-событие — это критическое событие или изменение состояния, которое имеет значение для бизнеса. Он захватывает что-то значимое, что подчиненный рабочий процесс должен реагировать на него. Бизнес-события помогают выполнять критически важные бизнес-решения, автоматизировать рабочие процессы, активировать оповещения, включить аналитику и обеспечить контекст в режиме реального времени для искусственного интеллекта (ИИ). Эта возможность обеспечивает единое представление бизнес-событий, инициированных клиентом, в Fabric.

Почему бизнес-события имеют значение

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

Бизнес-события предоставляют ценность, позволяя:

  • Скорость реагирования в режиме реального времени: приложения и команды реагируют немедленно, когда происходят важные события, уменьшая задержки и разблокировку автоматизации.

  • Несоединяемая архитектура: издатели и потребители работают независимо, позволяя командам добавлять новых потребителей без изменения исходного издателя.

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

  • Сквозная наблюдаемость: Предварительный просмотр данных предоставляет окно реального времени для полезных данных, перемещаемых между издателями и потребителями, помогая командам подтверждать правильность, устранять проблемы и подтверждать, что события следуют ожидаемому энд-то-энд маршруту.

В следующих разделах подробно описаны основные преимущества и основные понятия, лежащие в основе бизнес-событий в Microsoft Fabric.

Скорость реагирования в режиме реального времени

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

Категория Примеры
Коммерция и платежи Платёж не прошёл, Возврат средств
Жизненный цикл пользователя УчётнаяЗаписьСоздана, ПрофильПользователяОбновлён
Операции, цепочка поставок и производство ЗадержкаОтгрузки, ПревышениеПорога
Путешествия, транспорт РейсЗадержан, ИзмениласьВорота
Сигналы рынка, финансов и данных Выпущено предупреждение о погоде, Обнаружено отклонение прогноза спроса

В следующей таблице показаны примеры не бизнес-событий:

Категория Примеры
Телеметрия датчика Интернета вещей ТекущаяТемпература, СостояниеСистемы
Журнал приложений или диагностические события ОшибкаЧтенияДиска, ЗарегистрированНеобработанноеИсключение
Метрики или агрегированные события Процент использования памяти, Длина очереди диска

Отсоединяемая архитектура

Бизнес-события позволяют реализовать полностью слабо связанную архитектуру, где издатели и потребители в Fabric работают независимо. Издатели отправляют события один раз, и любой потребитель может подписаться, не внося изменений в источник или не создавая тесной связи.

В Microsoft Fabric:

  • Eventstream, Notebook и Пользовательская функция данных (UDF) выступает в качестве издателей, генерируя бизнес-события в экосистему реального времени.
  • Активатор выполняется как потребитель, подписываясь на события и запуская автоматизированные рабочие процессы, действия или подчиненные процессы.

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

Согласованное моделирование в организации

Одним из основных преимуществ бизнес-мероприятий в Microsoft Fabric является возможность создания общего доступа, согласованной модели событий во всей организации. Вместо того, чтобы каждая система определяла собственную версию события "OrderDelayed" или "InventoryMovement", что может привести к несоответствиям в полях данных, несовместимым форматам и сложному процессу сопоставления данных, Fabric централизует управление с помощью Schema Registry в узле в режиме реального времени.

Реестр схем — это централизованный репозиторий, в котором команды определяют, хранят и управляют схемами, связанными с типами бизнес-событий.

Согласованная интерпретация между издателями и потребителями

При использовании реестра схем в качестве единственного источника истины каждый компонент Fabric, независимо от того, производит он или потребляет события, зависит от того же контракта :

  • Издатели , такие как Eventstream, Notebook и Пользовательские функции данных, выбирают соответствующую схему из реестра при публикации бизнес-события.
  • Потребители, такие как Активатор, могут уверенно подписываться, зная, что имена полей, типы данных, структура и семантика всегда выровнены.

Это использование реестра схем устраняет наиболее распространенные проблемы интеграции:

  • Сопоставление полей между неконсистентными схемами.

  • Управление разовыми проверками среди издателей и потребителей.

  • Обработка несоответствий версий или структурных смещений.

  • Обслуживание пользовательских адаптеров для каждого издателя-потребителя.

Снижение сложности интеграции

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

  • Потребители могут немедленно обнаруживать бизнес-события и их схемы в центре Real-Time.

  • Управление версиями управляется централизованно, обеспечивая плавное развитие определений событий с течением времени.

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

Общий бизнес-язык

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

  • Команды аналитики получают чистые, структурированные и прогнозируемые данные.

  • Действия триггера активатора основаны на хорошо сформированных и стандартизированных нагрузках данных с полноценным бизнес-контекстом.

  • Инженерные команды избегают смещения схем и рабочих трений.

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

Сквозная наблюдаемость

Сквозная наблюдаемость гарантирует, что пользователи могут проверять бизнес-события — от того, что издатели отправляют в то, что потребители получают. Предварительный просмотр данных предоставляет прямой доступ в реальном времени к нагрузкам данных, перемещаемым между издателями и потребителями, помогая командам проверять правильность, устранять проблемы и подтверждать, что события следуют ожидаемому от начала до конца пути.