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

Добавление настраиваемой конечной точки или назначения пользовательского приложения в поток событий

Если вы хотите подключить собственное приложение к потоку событий, можно добавить пользовательскую конечную точку или пользовательское приложение в качестве назначения. Затем можно получать события в режиме реального времени из eventstream в собственное приложение через конечную точку подключения, представленную на пользовательской конечной точке или в пользовательском приложении. Кроме того, с протоколом Apache Kafka, доступным как вариант для пользовательских конечных точек или пользовательских приложений, можно использовать события в режиме реального времени с помощью протокола Apache Kafka.

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

Примечание.

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

Предварительные условия

Перед началом работы убедитесь, что у вас есть доступ к рабочей области, в которой находится ваш поток событий. Рабочая область должна находиться в режиме Fabric capacity или пробном режиме.

  • Участник или пользователи с более высокими разрешениями должны иметь возможность изменять поток событий для добавления назначения настраиваемой конечной точки.
  • Если вы хотите использовать аутентификацию Entra ID для подключения вашего приложения, вам потребуются права Member или выше.

Если вы используете аутентификацию с использованием Entra ID, необходимо также убедиться, что управляемое удостоверение настраиваемой конечной точки имеет необходимые разрешения. Для этого настройте необходимые параметры на портале администрирования:

  1. Выберите параметры (значок шестеренки) в правом верхнем углу.

  2. Выберите портал администрирования в разделе "Управление и аналитика ".

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

  3. Активируйте следующий параметр клиента, чтобы предоставить субъекту-службе доступ к API Fabric для создания рабочих областей, подключений или конвейеров развертывания:

    • На странице параметров арендатора в разделе параметров разработчика разверните параметр Служебный принципал может использовать API Fabric.
    • Переключите на включено.
    • Применяется ко всей организации.
    • Выберите Применить.

    Снимок экрана с параметрами разработчика.

  4. Включите этот параметр для доступа ко всем другим API (включен по умолчанию для новых клиентов):

    • На странице настроек арендатора разверните параметр Разрешить служебным субъектам создавать и использовать профили.
    • Переключите на включено.
    • Применяется ко всей организации.
    • Выберите Применить.

Примечание.

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

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

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

Добавление настраиваемой конечной точки в качестве назначения

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

  1. Если вы находитесь в режиме реального времени, перейдите в режим редактирования, нажав кнопку "Изменить " на ленте.

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

  2. В режиме редактирования добавьте пользовательскую конечную точку в качестве назначения одним из следующих способов:

    • Выберите Добавить назначение на панели инструментов, выберите пользовательскую конечную точку, а затем подключите конечную точку к потоку по умолчанию или производному потоку.

      Снимок экрана: выбор настраиваемой конечной точки в качестве назначения на ленте.

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

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

  3. В поле "Имя назначения" введите имя настраиваемой конечной точки. Затем выберите Сохранить.

    Снимок экрана: панель ввода имени настраиваемой конечной точки.

  4. Подключите плитку потока по умолчанию к пользовательской плитке конечной точки, если нет существующего подключения.

    Снимок экрана, показывающий соединение с настраиваемым элементом конечной точки.

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

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

Получите сведения о конечной точке на панели сведений для обработки событий

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

Снимок экрана: панель сведений для пользовательской конечной точки.

Каждая вкладка протокола содержит три страницы: Базовая, идентификация ключа SAS и идентификация Entra ID. Эти страницы предоставляют сведения о конечной точке, относящиеся к выбранному протоколу.

  • На странице «Основной» отображается имя, тип и состояние пользовательской конечной точки.

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

  • Аутентификация с использованием ключа SAS и Проверка подлинности Entra ID — это два поддерживаемых метода аутентификации для подключения к приложению:

    • Проверка подлинности ключа SAS предоставляет информацию, необходимую для создания и использования данных Eventstream с помощью ключей SAS (Shared Access Signature).
    • Аутентификация Entra ID позволяет субъекту безопасности (например, пользователю или учетной записи службы) использовать данные Eventstream с помощью аутентификации Microsoft Entra ID.

Инструкции по использованию проверки подлинности Entra ID см. в разделе "Включение проверки подлинности Entra ID для приложения в Eventstream".
В следующем разделе описывается, как подключиться к назначению пользовательской конечной точки с помощью проверки подлинности ключа SAS.

концентратор событий;

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

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

Формат концентратора событий — это формат по умолчанию для строки подключения, который работает с пакетом SDK Azure Event Hubs. Этот формат позволяет подключаться к потоку событий через протокол Центров событий.

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

Endpoint=sb://eventstream-xxxx.servicebus.windows.net/; SharedAccessKeyName=key_xxxxxxxx;SharedAccessKey=xxxxx;EntityPath=es_xxxxxxx

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

Скриншот, показывающий пример кода Event Hub на панели сведений в режиме реального времени просмотра событий.

Кафка

Формат Kafka совместим с протоколом Apache Kafka, который является популярной распределенной потоковой платформой, которая поддерживает обработку данных с высокой пропускной способностью и низкой задержкой. Ключи и примеры кода можно использовать для подключения к потоку событий и обработки событий в формате протокола Kafka.

Снимок экрана, демонстрирующий ключи Kafka на панели сведений в режиме просмотра событий в реальном времени.

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

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

Четкое руководство по использованию пользовательской конечной точки с протоколом Kafka см. в этом руководстве. Он содержит подробные инструкции по потоковой передаче и потреблению событий, используя пользовательский конечный пункт с протоколом Kafka.

AMQP

Формат AMQP совместим с протоколом AMQP 1.0, который является стандартным протоколом обмена сообщениями, поддерживающим взаимодействие между различными платформами и языками. Этот формат можно использовать для подключения к потоку событий с помощью протокола AMQP.

Снимок экрана: ключи AMQP на панели сведений в режиме трансляции событий.

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

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

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

Связанный контент

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

Предварительные условия

Перед началом работы необходимо получить доступ к рабочей области eventstream в режиме лицензии емкости Fabric или в режиме пробной лицензии с правами участника или выше.

Примечание.

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

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

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

Добавление настраиваемого приложения в качестве назначения

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

  1. Выберите новое назначение на ленте или знак плюса (+) на холсте основного редактора и выберите "Пользовательское приложение".

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

    Снимок экрана: панель настройки пользовательского приложения в качестве назначения.

Получите сведения о конечной точке на панели сведений для обработки событий

После успешного создания настраиваемого приложения в качестве назначения можно просмотреть сведения на панели сведений .

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

В области сведений есть три вкладки протокола: Концентратор событий, AMQP и Kafka. Каждая вкладка протокола содержит три страницы: основные сведения, ключи и пример кода. Эти страницы предоставляют сведения о конечной точке с соответствующим протоколом для подключения.

В разделе "Базовый" отображается имя, тип и состояние пользовательского приложения.

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

Ключи предоставляют информацию о ключах подключения. Пример кода содержит встроенные ключи, которые вы можете использовать для потоковой передачи событий в ваш поток событий. Информация на этих страницах зависит от протокола.

концентратор событий;

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

Снимок экрана, показывающий ключи центра событий на панели сведений потока событий.

Формат концентратора событий — это формат по умолчанию для строки подключения, который работает с пакетом SDK Azure Event Hubs. Этот формат позволяет подключаться к потоку событий через протокол Центров событий.

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

Endpoint=sb://eventstream-xxxx.servicebus.windows.net/; SharedAccessKeyName=key_xxxxxxxx;SharedAccessKey=xxxxx;EntityPath=es_xxxxxxx

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

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

Кафка

Формат Kafka совместим с протоколом Apache Kafka, который является популярной распределенной потоковой платформой, которая поддерживает обработку данных с высокой пропускной способностью и низкой задержкой. Ключи и примеры кода можно использовать для подключения к потоку событий и обработки событий в формате протокола Kafka.

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

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

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

AMQP

Формат AMQP совместим с протоколом AMQP 1.0, который является стандартным протоколом обмена сообщениями, поддерживающим взаимодействие между различными платформами и языками. Этот формат можно использовать для подключения к потоку событий с помощью протокола AMQP.

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

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

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

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

Управление назначением

Вы можете изменить (с помощью команды "Изменить") или удалить (с помощью команды Remove) назначение потока событий с помощью области данных или холста.

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

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

Связанный контент

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