Добавление источника MQTT в поток событий (предварительная версия)

В этой статье показано, как добавить источник транспорта телеметрии очереди сообщений (MQTT) в поток событий в Fabric Real-Time Intelligence.

Протокол MQTT (Message Queuing Telemetry Transport) — это легковесный протокол обмена сообщениями "подписка и публикация", предназначенный для использования в ограниченных средах и широко применяемый в сценариях Интернета вещей. Соединитель MQTT для Eventstream в Fabric позволяет подключаться к любому брокеру MQTT и получать сообщения непосредственно в Eventstream, что обеспечивает трансформацию и маршрутизацию в режиме реального времени в различные назначения в Fabric для аналитики и получения инсайтов.

Предпосылки

Перед началом работы необходимо выполнить следующие предварительные требования:

• Рабочая область с емкостью Fabric или рабочая область типа пробной версии Fabric Trial.
• Доступ к рабочей области с ролью 'Сотрудник' или более высокой ролью в рабочей области.
• Убедитесь, что брокер MQTT является общедоступным и не ограничен брандмауэром или виртуальной сетью. Если он находится в защищенной сети, подключитесь к нему с помощью инъекции виртуальной сети соединителя Eventstream.

В зависимости от сценария можно также использовать один из следующих подходов к потоковой передаче данных MQTT в Eventstream:

• Сетка событий Azure. Отправка данных MQTT в Сетку событий Azure и настройка соединителя Сетки событий Azure в eventstream. Дополнительные сведения см. в разделе «Добавление пространства имен Azure Event Grid как источника для потока событий».
• Операции Интернета вещей Azure: настройте конечную точку потока данных, которая подключается к пользовательской конечной точке Eventstream. Дополнительные сведения см. в разделе "Настройка конечных точек потока данных" для Microsoft Fabric Real-Time Intelligence.

Добавление соединителя MQTT

Соединитель MQTT можно добавить в eventstream двумя способами:

Из потока событий

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

1. В Fabric Real-Time Intelligence создайте новый поток событий или откройте существующий.

2. Выберите "Добавить источник " на холсте.

   

Из центра Real-Time

Подключитесь к источнику MQTT из центра Real-Time и создайте поток данных. Этот подход лучше всего подходит для обнаружения потока данных MQTT и управления ими вместе с другими источниками потоковой передачи.

1. В Fabric перейдите к центру в реальном времени.

2. Выберите «Добавить данные» и выполните поиск MQTT.

   

Настройка соединителя MQTT

1. На странице "Подключение" выберите "Создать подключение".

   

   Если есть существующее подключение к источнику MQTT, выберите это существующее подключение.

2. Чтобы создать новое облачное подключение, введите следующие сведения:

   

   1. URL-адрес брокера MQTT: введите URL-адрес брокера MQTT. Поддерживаемые протоколы: ssl://и wss://tcp://.

      Note

      Источник MQTT поддерживает защищенные соединения MQTT с использованием Transport Layer Security (TLS) или Secure Sockets Layer (SSL) между вашим брокером MQTT и Eventstream. TLS или SSL-подключения поддерживаются только в том случае, если сертификат сервера подписан центром сертификации (ЦС), включенным в список доверенных ЦС.

   2. Имя подключения: введите имя подключения к MQTT.

   3. Введите имя пользователя и пароль брокера MQTT.

   4. Нажмите Подключиться.

3. В поле "Имя раздела" введите раздел MQTT для подписки. Коннектор поддерживает только одну тему.

4. Для версии выберите версию V5 или V3 на основе версии протокола брокера MQTT.

Сведения о потоке или источнике

1. На странице "Подключение" выполните одно из этих действий на основе того, используете ли вы поток событий или концентратор Real-Time.

   • Eventstream:

     В области сведений о источнике справа выполните следующие действия:

     1. Чтобы изменить имя источника, нажмите кнопку Карандаш.

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

   • центрReal-Time:

     В разделе сведений о потоке справа выполните следующие действия.

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

     2. Для имени eventstream нажмите кнопку «Карандаш» и введите название для eventstream.

     3. Значение имени потока автоматически создается шляхом добавления -stream к имени eventstream. Этот поток отображается на странице "Все потоки данных " концентратора в режиме реального времени, когда мастер завершит работу.

2. Нажмите кнопку "Далее" в нижней части страницы "Настройка ".

Проверка и подключение

На экране "Обзор и подключение" просмотрите сводку и выберите "Добавить (Eventstream) или "Connect (Real-Time hub).

Просмотр обновленного потока событий

1. Источник MQTT отображается на холсте потока событий в режиме редактирования . Чтобы опубликовать, выберите "Опубликовать " на ленте.

   

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

   

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

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