Руководство. Использование разделов пространства имен для маршрутизации сообщений MQTT в Центры событий Azure (портал Azure)

В этом руководстве описано, как использовать раздел пространства имен для маршрутизации данных из клиентов MQTT в Центры событий Azure. Ниже приведены основные действия.

Необходимые компоненты

  • Если у вас еще нет подписки Azure, создайте бесплатную учетную запись Azure, прежде чем начинать работу.
  • Если вы не знакомы с Сеткой событий, ознакомьтесь с обзором сетки событий перед началом работы с этим руководством.
  • Зарегистрируйте поставщик ресурсов сетки событий в соответствии с инструкциями, описанными в разделе "Регистрация поставщика ресурсов сетки событий".
  • Убедитесь, что порт 8883 открыт в брандмауэре. В этом руководстве используется протокол MQTT, который взаимодействует через порт 8883. Этот порт может быть заблокирован в некоторых корпоративных и образовательных сетевых средах.

Создание пространства имен на портале Azure

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

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

Создание пространства имен службы:

  1. Войдите на портал Azure.

  2. В поле поиска введите пространства имен сетки событий и выберите пространства имен сетки событий из результатов.

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

  3. На странице "Пространства имен сетки событий" нажмите кнопку "+ Создать" на панели инструментов.

    Снимок экрана: страница

  4. На странице "Основы" выполните следующие действия.

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

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

    3. Введите имя для пространства имен.

    4. Выберите регион или расположение , в котором нужно создать пространство имен.

    5. В нижней части страницы выберите Review + create (Проверить и создать).

      Снимок экрана: вкладка

  5. На вкладке "Просмотр и создание" просмотрите параметры и нажмите кнопку "Создать".

  6. На странице "Развертывание выполнено успешно" выберите "Перейти к ресурсу", чтобы перейти к пространству имен.

Создание раздела пространства имен

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

  2. На странице пространства имен сетки событий выберите пункт "Темы" в разделе брокера событий в меню слева.

  3. На странице "Темы" нажмите кнопку "+ Раздел" на панели команд.

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

  4. На странице "Создание раздела" введите имя темы, которую вы хотите создать, и нажмите кнопку "Создать".

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

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

  1. На странице пространства имен сетки событий выберите "Удостоверение" в разделе "Параметры" в меню слева.

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

  3. На панели инструментов нажмите кнопку Сохранить, чтобы сохранить параметры.

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

  4. Щелкните Да в сообщении подтверждения.

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

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

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

Включение брокера MQTT для пространства имен Сетки событий

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

  2. Установите флажок рядом с параметром "Включить брокер MQTT".

  3. Выберите "Применить" в нижней части страницы.

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

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

На отдельной вкладке веб-браузера или в отдельном окне используйте портал Azure для создания пространства имен Центров событий с концентратором событий.

Создание пространства имен в Центрах событий Azure

Пространство имен Центров событий предоставляет уникальный контейнер определения области, в котором можно создать один или несколько концентраторов событий. Чтобы создать пространство имен в группе ресурсов с использованием портала, выполните следующие действия:

  1. В портал Azure выберите все службы в меню слева и выберите звездочку (*) рядом с Центрами событий в категории "Аналитика". Убедитесь, что Центры событий были добавлены в раздел Избранное в меню навигации слева.

    Снимок экрана: выбор Центров событий на странице

  2. Выберите Центры событий в разделе ИЗБРАННОЕ в меню навигации слева и нажмите кнопку "Создать" на панели инструментов.

    Снимок экрана: выбор кнопки

  3. На странице Создание пространства имен выполните следующие действия.

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

    2. Выберите группу ресурсов, созданную на предыдущем шаге.

    3. Введите имя для пространства имен. Система немедленно проверяет, доступно ли оно.

    4. Выберите расположение для пространства имен.

    5. Выберите Базовый для ценового уровня. Если вы планируете использовать пространство имен из приложений Apache Kafka, используйте уровень "Стандартный". Базовый уровень не поддерживает рабочие нагрузки Apache Kafka. Чтобы узнать о различиях между уровнями, см. статьи Квоты и ограничения, Центры событий ценовой категории «Премиум» и Специальные центры событий.

    6. Оставьте настройки единиц пропускной способности (для стандартного уровня) или единиц обработки (для уровня премиум-класса) как есть. Сведения о единицах пропускной способности или единицах обработки см. в статье Масштабируемость Центров событий.

    7. В нижней части страницы выберите Просмотреть и создать.

      Снимок экрана: страница

    8. На странице Просмотр и создание проверьте параметры и нажмите кнопку Создать. Дождитесь завершения развертывания.

  4. На странице Развертывание нажмите Перейти к ресурсу, чтобы открыть страницу пространства имен.

    Снимок экрана: страница

  5. Убедитесь, что отображаемая страница Пространство имен Центров событий имеет похожий на следующий вид:

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

Создание концентратора событий

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

  1. На странице "Обзор" выберите +Концентратор событий на панели команд.

    Снимок экрана: выбор кнопки

  2. Введите имя концентратора событий, а затем нажмите кнопку "Проверить и создать".

    Снимок экрана: страница

  3. На странице Отзыв и создание выберите Создать.

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

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

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

  1. На странице пространства имен Центров событий выберите элемент управления доступом (IAM) в меню слева.

  2. На странице управления доступом нажмите кнопку +Добавить на панели команд, а затем нажмите кнопку "Добавить назначение роли".

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

  3. На странице "Добавление назначения ролей" выберите Центры событий Azure "Отправитель данных" из списка ролей и нажмите кнопку "Далее" в нижней части страницы.

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

  4. На странице "Участники" выполните следующие действия:

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

    2. Выберите и выберите участников.

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

  5. На странице "Выбор управляемых удостоверений" выполните следующие действия.

    1. Выберите свою подписку Azure.

    2. Для управляемого удостоверения выберите пространство имен сетки событий.

    3. Выберите управляемое удостоверение, которое имеет то же имя, что и пространство имен Сетки событий.

    4. Выберите в нижней части страницы.

      Снимок экрана: страница

  6. На странице "Добавление назначения ролей" нажмите кнопку "Рецензирование" и "Назначить" в нижней части страницы.

  7. На странице "Рецензирование и назначение" выберите "Рецензирование и назначение".

Создание подписки на события с центрами событий в качестве конечной точки

  1. Перейдите на вкладку окна веб-браузера с открытым пространством имен сетки событий.

  2. На странице пространства имен сетки событий выберите разделы в меню слева.

  3. На странице разделов выберите созданный ранее раздел пространства имен.

    Снимок экрана: страница

  4. На странице раздела пространства имен сетки событий выберите +Подписка на панели команд в верхней части.

    Снимок экрана: страница

  5. На странице "Создание подписки" выполните следующие действия.

    1. Укажите имя для подписки на событие.

    2. В режиме доставки нажмите кнопку "Отправить".

    3. Убедитесь, что для типа конечной точки задан концентратор событий.

    4. Выберите " Настроить конечную точку".

      Снимок экрана: страница

    5. На вкладке "Выбор концентратора событий" выполните следующие действия.

      1. Выберите подписку Azure, которая имеет концентратор событий.

      2. Выберите группу ресурсов, которая имеет концентратор событий.

      3. Выберите пространство имен Центров событий.

      4. Выберите концентратор событий в пространстве имен Центров событий.

      5. Затем нажмите кнопку "Подтвердить выбор".

        Снимок экрана: страница

    6. Вернитесь на страницу "Создание подписки" , выберите "Назначенная системой" для типа управляемого удостоверения.

    7. В нижней части страницы выберите Создать.

      Снимок экрана: страница

Настройка маршрутизации в пространстве имен Сетки событий

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

  2. На странице пространства имен сетки событий выберите "Маршрутизация" в меню слева в разделе брокера MQTT.

  3. На странице "Маршрутизация" выберите "Включить маршрутизацию".

  4. Для типа раздела выберите раздел пространства имен.

  5. В разделе выберите раздел пространства имен сетки событий, созданный при маршрутизации всех сообщений MQTT.

  6. Выберите Применить.

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

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

Создание клиентов, пространства разделов и привязок разрешений

Выполните действия, описанные в кратком руководстве. Публикация и подписка на раздел MQTT:

  1. Создайте клиент. Вы можете создать второй клиент, если вы хотите, но это необязательно.

  2. Создайте пространство тем.

  3. Создание привязок разрешений издателя и подписчика.

  4. Используйте MQTTX для отправки нескольких сообщений.

  5. Убедитесь, что концентратор событий получил эти сообщения на странице обзора пространства имен Центров событий.

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

Просмотр перенаправленных сообщений MQTT в Центрах событий с помощью запроса Stream Analytics

Перейдите к экземпляру Центров событий (концентратору событий) в подписке на события в портал Azure. Обработка данных из концентратора событий с помощью Stream Analytics. Дополнительные сведения см. в разделе "Обработка данных из Центры событий Azure с помощью Stream Analytics " Центры событий Azure | Microsoft Learn. В запросе отображаются сообщения MQTT.

Снимок экрана: данные сообщений MQTT в Центрах событий с помощью средства запроса Stream Analytics.

Следующие шаги

Примеры кода см. в этом репозитории GitHub.