Поделиться через


Добавьте цель назначения Eventhouse в поток событий

В этой статье показано, как добавить Eventhouse в качестве пункта назначения в поток событий Microsoft Fabric.

Необходимые условия

  • Доступ к рабочей области в режиме лицензии емкости Fabric или в режиме пробной лицензии с разрешениями уровня Участник или выше.
  • Доступ к Eventhouse, созданному в рабочей области Fabric, где у вас есть права уровня участника или выше.

Примечание.

Поток событий может поддерживать до 11 объединенных источников и назначений только при использовании следующих типов:

  • Источник: настраиваемая конечная точка.
  • Назначения: пользовательская конечная точка и Eventhouse с прямой загрузкой.

Любые источники или назначения , не включенные в приведенный выше список, и назначения, не добавленные к потоку по умолчанию, не учитываются в этом пределе.

Добавьте назначение Eventhouse в поток по умолчанию

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

Режим прямого приема

В режиме прямого приема ваши данные о событиях загружаются непосредственно в Eventhouse без предварительной обработки. Режим прямого приема можно использовать для добавления пункта назначения Eventhouse в основной или производный поток.

  1. В режиме Редактировать для вашего потока событий выберите "Добавить назначение" на ленте или выберите карточку Преобразовать события или добавить назначение на холсте, а затем выберите Eventhouse.

    Снимок экрана: выбор Eventhouse в раскрывающемся списке

  2. На экране Eventhouse выберите прямой ввод.

  3. Введите имя назначения , рабочую область и Eventhouse из выбранной рабочей области.

  4. Выберите Сохранить.

    Снимок экрана: экран конфигурации Eventhouse.

  5. Подключите новую карточку назначения Eventhouse к выходным данным потока событий, если оно еще не подключено, а затем нажмите кнопку "Опубликовать".

    Снимок экрана: поток событий с выделенной кнопкой

  6. В режиме реального временивыберите Настроить в узле назначения Eventhouse.

    Снимок экрана опубликованного потока событий с выделенной кнопкой

  7. Ваш дом событий откроется на экране Получение данных. Выберите существующую таблицу базы данных KQL или выберите новую таблицу для маршрутизации и приема данных.

  8. Укажите имя подключения к данным или сохраните имя, а затем нажмите кнопку "Далее". Для извлечения данных из потока событий может потребоваться несколько минут.

    Снимок экрана: экран получения данных для назначения базы данных KQL с выделенной кнопкой

  9. На экране проверки данных можно:

    • Выберите формат, чтобы предварительно просмотреть, как данные отправляются в Eventhouse.
    • Выберите "Изменить столбцы", чтобы настроить столбцы для данных.
    • Выберите "Дополнительно ", чтобы выбрать события для включения или выбора параметров сопоставления.

    Снимок экрана: форматы данных и дополнительные параметры на экране проверки данных.

  10. Если выбрать "Изменить столбцы", на экране "Изменить столбцы" можно:

    • Выберите " Добавить столбец", чтобы добавить столбец .
    • Выберите исходные столбцы для сопоставления.
    • Примените трансформацию сопоставления к столбцам.
    • Измените значения образцов данных.

    Затем выберите Применить.

    Снимок экрана: экран

  11. После завершения настройки данных нажмите кнопку "Готово " на экране проверки данных .

  12. На экране сводной информации просмотрите сведения и состояние приема ваших данных, включая таблицу с заданной вами схемой и подключением между потоковым событием и Eventhouse. Выберите Закрыть, чтобы завершить настройку Eventhouse.

    Снимок экрана: экран

Вы теперь можете увидеть место назначения Eventhouse на холсте в режиме реального времени.

Снимок экрана: настроенное назначение базы данных KQL в режиме реального времени.

Обработка событий перед поглощением

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

  1. В режиме редактирования для потока событий наведите указатель мыши на оператор или производный поток, выберите +, а затем выберите Eventhouse.

    Снимок экрана: выбор символа +для выходных данных оператора и выбор базы данных KQL.

  2. На экране Eventhouse уже должна быть выбрана обработка событий перед приемом. Заполните остальные сведения о вашем хранилище событий, а затем нажмите кнопку Сохранить.

    Снимок экрана экрана конфигурации базы данных KQL для обработки событий перед началом приема данных.

  3. Чтобы внедрить недавно добавленный пункт назначения Eventhouse, выберите Опубликовать.

    Снимок экрана потока событий в режиме редактирования с добавленным назначением базы данных KQL.

После выполнения этих действий поток событий с назначением Eventhouse доступен для визуализации в режиме живого просмотра.

Снимок экрана: настроенный поток обработки событий базы данных KQL в режиме реального времени.

Добавить назначение Eventhouse в производный поток

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

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

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

    Снимок экрана, показывающий, как добавить назначение Eventhouse из производного потока.

  • Выполните настройку для предпочтительных режимов приема. Процесс установки остается таким же, как описано выше для потока по умолчанию.

    Снимок экрана, показывающий конфигурации для точки назначения Eventhouse.

Примечание.

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

Типичным примером является источник для захвата измененных данных базы данных (CDC), где некоторые данные начального снимка могут оставаться в потоке событий Eventstream без перенаправления в конечный пункт.

Чтобы устранить эту проблему, выполните следующие действия.

  1. При настройке Eventhouse (обработка событий перед приемом данных) или точки назначения Lakehouse снимите флажок Активировать сбор данных после добавления источника данных.

    Снимок экрана базы данных KQL без выбора активации сбора данных после добавления источника данных.

  2. Активируйте инжестию вручную после публикации Eventstream.

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

    Снимок экрана: возобновление базы данных KQL. Дополнительные сведения см. в статье "Приостановка" и возобновление потоков данных

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