Добавление настраиваемой конечной точки или назначения пользовательского приложения в поток событий
Если вы хотите подключить собственное приложение к потоку событий, можно добавить пользовательскую конечную точку или пользовательское приложение в качестве назначения. Затем можно получать события в режиме реального времени из eventstream в собственное приложение через конечную точку подключения, представленную на пользовательской конечной точке или в пользовательском приложении. Кроме того, с протоколом Apache Kafka, доступным как вариант для пользовательских конечных точек или пользовательских приложений, можно использовать события в режиме реального времени с помощью протокола Apache Kafka.
В этой статье описано, как добавить пользовательскую точку назначения конечной точки или пользовательскую точку назначения приложения в поток событий Microsoft Fabric.
Примечание.
Расширенные возможности включены по умолчанию при создании потоков событий. Если у вас есть потоки событий, созданные с помощью стандартных возможностей, эти потоки событий будут продолжать работать. Вы по-прежнему можете изменять и использовать их как обычно. Рекомендуется создать новый поток событий для замены стандартных потоков событий, чтобы воспользоваться дополнительными возможностями и преимуществами расширенных потоков событий.
Предварительные условия
Перед началом работы необходимо получить доступ к рабочей области в режиме лицензии на использование ресурсов Fabric или в режиме пробной лицензии с разрешениями доступа или выше, где расположен ваш событийный поток.
Примечание.
Максимальное количество источников и назначений для одного потока событий — 11.
Добавление настраиваемой конечной точки в качестве назначения
Если вы хотите перенаправить данные событий в приложение, можно добавить пользовательскую конечную точку в качестве назначения потока событий:
Если вы находитесь в режиме реального времени, перейдите в режим редактирования, нажав кнопку "Изменить " на ленте.
В режиме редактирования добавьте пользовательскую конечную точку в качестве назначения одним из следующих способов:
Выберите Добавить назначение на панели инструментов, выберите пользовательскую конечную точку, а затем подключите конечную точку к потоку по умолчанию или производному потоку.
В редакторе выберите "Преобразовать события" или "Добавить назначение", а затем выберите пользовательскую конечную точку.
В поле "Имя назначения" введите имя настраиваемой конечной точки. Затем выберите Сохранить.
Подключите плитку потока по умолчанию к пользовательской плитке конечной точки, если нет существующего подключения.
Чтобы просмотреть подробные сведения о своей пользовательской конечной точке, выберите Опубликовать.
Получите сведения о конечной точке на панели сведений для обработки событий
В живом режиме выберите значок пользовательской конечной точки. В появившейся области сведений есть три вкладки протокола: Концентратор событий, AMQP и Kafka.
Каждая вкладка протокола содержит три страницы: "Базовый", "Ключи" и "Пример кода". Эти страницы предоставляют сведения о конечной точке с соответствующим протоколом для подключения.
Базовый показывает имя, тип и статус вашей пользовательской конечной точки.
Ключи предоставляют информацию о ключах подключения. Пример кода содержит встроенные ключи, которые вы можете использовать для потоковой передачи событий в ваш поток событий. Информация на этих страницах зависит от протокола.
концентратор событий;
Страница "Ключи" на вкладке "Концентратор событий" содержит сведения, связанные со строкой подключения концентратора событий. Сведения включают имя концентратора событий, имя ключа общего доступа, первичный ключ и строка подключения-первичный ключ.
Формат концентратора событий — это формат по умолчанию для строки подключения, который работает с пакетом SDK Azure Event Hubs. Этот формат позволяет подключаться к потоку событий через протокол Центров событий.
В следующем примере показано, как выглядит строка подключения в формате концентратора событий:
Endpoint=sb://eventstream-xxxx.servicebus.windows.net/; SharedAccessKeyName=key_xxxxxxxx;SharedAccessKey=xxxxx;EntityPath=es_xxxxxxx
На вкладке "Пример кода " на вкладке "Концентратор событий" предоставляется готовый код, содержащий необходимые сведения о ключах подключения в концентраторе событий. Просто скопируйте и вставьте его в приложение для использования.
Kafka
Формат Kafka совместим с протоколом Apache Kafka, который является популярной распределенной потоковой платформой, которая поддерживает обработку данных с высокой пропускной способностью и низкой задержкой. Ключи и примеры кода можно использовать для подключения к потоку событий и обработки событий в формате протокола Kafka.
Пример кодовой страницы на вкладке Kafka предоставляет готовый код, включая необходимые ключи подключения в формате Kafka. Просто скопируйте его для использования.
Четкое руководство по использованию пользовательской конечной точки с протоколом Kafka см. в этом руководстве. Он содержит подробные инструкции по потоковой передаче и потреблению событий, используя пользовательский конечный пункт с протоколом Kafka.
AMQP
Формат AMQP совместим с протоколом AMQP 1.0, который является стандартным протоколом обмена сообщениями, поддерживающим взаимодействие между различными платформами и языками. Этот формат можно использовать для подключения к потоку событий с помощью протокола AMQP.
Пример кодовой страницы на вкладке AMQP предоставляет готовый код с информацией ключа подключения в формате AMQP.
Вы можете выбрать формат протокола, соответствующий вашим потребностям и предпочтениям приложения, а затем скопировать и вставить строка подключения в приложение. Вы также можете открыть или скопировать пример кода на странице с примером кода, где показано, как отправлять или получать события с помощью различных протоколов.
Связанный контент
Как добавить другие назначения в поток событий, см. в следующих статьях:
Предварительные условия
Перед началом работы необходимо получить доступ к рабочей области eventstream в режиме лицензии емкости Fabric или в режиме пробной лицензии с правами участника или выше.
Примечание.
Максимальное количество источников и назначений для одного потока событий — 11.
Добавление настраиваемого приложения в качестве назначения
Если вы хотите перенаправить данные событий в приложение, можно добавить настраиваемое приложение в качестве назначения потока событий:
Выберите новое назначение на ленте или знак плюса (+) на холсте основного редактора и выберите "Пользовательское приложение".
В области настраиваемых приложений введите имя назначения для настраиваемого приложения и нажмите кнопку "Добавить".
Получение сведений о конечной точке на панели сведений для использования событий
После успешного создания настраиваемого приложения в качестве назначения можно просмотреть сведения на панели сведений .
В области сведений есть три вкладки протокола: Концентратор событий, AMQP и Kafka. Каждая вкладка протокола содержит три страницы: основные сведения, ключи и пример кода. Эти страницы предоставляют сведения о конечной точке с соответствующим протоколом для подключения.
В разделе "Базовый" отображается имя, тип и состояние пользовательского приложения.
Ключи предоставляют информацию о ключах соединения. Пример кода включает в себя встроенные ключи, которые можно использовать для потоковой передачи событий в ваш поток событий. Информация на этих страницах зависит от протокола.
концентратор событий;
Страница Ключи на вкладке Концентратор событий содержит сведения, связанные со строкой подключения концентратора событий. Сведения включают имя концентратора событий, имя ключа общего доступа, первичный ключ и строку подключения — первичный ключ.
Формат центра событий является форматом по умолчанию для строки подключения и работает с SDK Центров событий Azure. Этот формат позволяет подключаться к потоку событий через протокол Центров событий.
В следующем примере показано, как выглядит строка подключения в формате концентратора событий:
Endpoint=sb://eventstream-xxxx.servicebus.windows.net/; SharedAccessKeyName=key_xxxxxxxx;SharedAccessKey=xxxxx;EntityPath=es_xxxxxxx
На вкладке "Пример кода " на вкладке "Концентратор событий" предоставляется готовый код, содержащий необходимые сведения о ключах подключения в концентраторе событий. Просто скопируйте и вставьте его в приложение для использования.
Kafka
Формат Kafka совместим с протоколом Apache Kafka, который является популярной распределенной потоковой платформой, которая поддерживает обработку данных с высокой пропускной способностью и низкой задержкой. Можно использовать ключи и образцы кода для подключения к потоку событий и потребления событий в формате протокола Kafka.
Пример кодовой страницы на вкладке Kafka предоставляет готовый код, включая необходимые ключи подключения в формате Kafka. Просто скопируйте его для использования.
AMQP
Формат AMQP совместим с протоколом AMQP 1.0, который является стандартным протоколом обмена сообщениями, поддерживающим взаимодействие между различными платформами и языками. Этот формат можно использовать для подключения к потоку событий с помощью протокола AMQP.
Пример кодовой страницы на вкладке AMQP предоставляет готовый код с информацией ключа подключения в формате AMQP.
Вы можете выбрать формат протокола, соответствующий вашим потребностям и предпочтениям приложения, а затем скопировать и вставить строка подключения в приложение. Вы также можете обратиться к примерам кода или скопировать их на странице примеров, где показано, как отправлять или получать события с помощью различных протоколов.
Управление назначением
Вы можете изменить (с помощью команды "Изменить") или удалить (с помощью команды Remove) назначение потока событий с помощью области данных или холста.
При нажатии кнопки "Изменить" откроется область редактирования справа от основного редактора. Вы можете изменить конфигурацию по мере необходимости, включая логику преобразования событий с помощью редактора обработчика событий.
Связанный контент
Чтобы узнать, как добавить другие пункты назначения в поток событий, см. следующие статьи.