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