Руководство. Отправка сообщений из ресурсов в облако с помощью потока данных

В этом руководстве вы используете поток данных для пересылки сообщений из брокера MQTT в концентратор событий в службе Центры событий Azure. Концентратор событий может доставлять данные другим облачным службам для хранения и анализа. В следующем руководстве вы используете панель мониторинга в режиме реального времени для визуализации данных.

Предпосылки

Перед началом работы с этим руководством необходимо выполнить руководство . Добавление ресурсов OPC UA в кластер операций Интернета вещей Azure.

Какая проблема будет решена?

Чтобы использовать такой инструмент, как Microsoft Fabric Real-Time Панель мониторинга для анализа данных OPC UA, необходимо отправить данные в облачную службу, например, в Центры событий Azure. Поток данных может подписаться на раздел MQTT и перенаправить сообщения в концентратор событий в Центры событий Azure пространстве имен. В следующем руководстве показано, как использовать панели мониторинга реального времени для визуализации и анализа данных.

Настройка переменных среды

Убедитесь, что в оболочке заданы следующие переменные среды:

# The name of the resource group where your Kubernetes cluster is deployed
RESOURCE_GROUP=<resource-group-name>

# The name of your Kubernetes cluster
CLUSTER_NAME=<kubernetes-cluster-name>

# The name of the user-assigned managed identity that you created for cloud connections
USER_ASSIGNED_MI_NAME=<cloud-connection-uami>

# The name of the resource group where your Kubernetes cluster is deployed
$RESOURCE_GROUP = "<resource-group-name>"

# The name of your Kubernetes cluster
$CLUSTER_NAME = "<kubernetes-cluster-name>"

# The name of the user-assigned managed identity that you created for cloud connections
USER_ASSIGNED_MI_NAME="<cloud-connection-uami>"

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

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

az eventhubs namespace create --name ${CLUSTER_NAME:0:24} --resource-group $RESOURCE_GROUP --disable-local-auth true

az eventhubs eventhub create --name destinationeh --resource-group $RESOURCE_GROUP --namespace-name ${CLUSTER_NAME:0:24} --retention-time 1 --partition-count 1 --cleanup-policy Delete

az eventhubs namespace create --name $CLUSTER_NAME.Substring(0, [MATH]::Min($CLUSTER_NAME.Length, 24)) --resource-group $RESOURCE_GROUP --disable-local-auth true

az eventhubs eventhub create --name destinationeh --resource-group $RESOURCE_GROUP --namespace-name $CLUSTER_NAME.Substring(0, [MATH]::Min($CLUSTER_NAME.Length, 24)) --retention-time 1 --partition-count 1 --cleanup-policy Delete

Чтобы предоставить расширение Операций Интернета вещей Azure в кластере к пространству имен Центров событий, выполните следующие команды Azure CLI:

EVENTHUBRESOURCE=$(az eventhubs namespace show --resource-group $RESOURCE_GROUP --namespace-name ${CLUSTER_NAME:0:24} --query id -o tsv)

PRINCIPAL=$(az identity show --name $USER_ASSIGNED_MI_NAME --resource-group $RESOURCE_GROUP --query principalId --output tsv)

az role assignment create --role "Azure Event Hubs Data Sender" --assignee $PRINCIPAL --scope $EVENTHUBRESOURCE

$EVENTHUBRESOURCE = $(az eventhubs namespace show --resource-group $RESOURCE_GROUP --namespace-name $CLUSTER_NAME.Substring(0, [MATH]::Min($CLUSTER_NAME.Length, 24)) --query id -o tsv)

$PRINCIPAL = $(az identity show --name $USER_ASSIGNED_MI_NAME --resource-group $RESOURCE_GROUP --query principalId --output tsv)

az role assignment create --role "Azure Event Hubs Data Sender" --assignee $PRINCIPAL --scope $EVENTHUBRESOURCE

Создание потока данных для отправки сообщений в концентратор событий

Используйте веб-интерфейс интерфейса операций для создания и настройки потока данных в кластере, который:

• Переименовывает temperature поле в входящее сообщение TemperatureF.
• Добавляет поле AssetId , содержащее имя ресурса.
• Перенаправит преобразованные сообщения из раздела MQTT в созданный концентратор событий.

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

1. Перейдите к пользовательскому интерфейсу веб-опыта работы с операциями и найдите ваш экземпляр. Затем выберите конечные точки потока данных и нажмите кнопку +Создать на плитке Центры событий Azure:

   

2. В Создать новую конечную точку потока данных: Центры событий Azure введите event-hubs-target в качестве имени, и найдите пространство имен Центров событий в поле Узел.

3. Выберите управляемое удостоверение, назначаемое пользователем, в качестве метода проверки подлинности. Добавьте значения идентификатора клиента и идентификатора клиента назначаемого пользователем управляемого удостоверения, используемого для облачных подключений. Используйте следующую команду CLI для перечисления идентификатора клиента и идентификатора арендатора назначенных пользователем управляемых удостоверений в группе ресурсов: az identity list -g $RESOURCE_GROUP -o table

4. Нажмите кнопку "Применить":

   

   Новая конечная точка потока данных создается и отображается в списке на странице конечных точек потока данных.

5. Выберите потоки данных и нажмите кнопку "Создать поток данных". Откроется <страница потока> данных:

   

6. В редакторе потока данных выберите "Выбрать источник". Затем выберите созданный ранее ресурс термостата и нажмите кнопку "Применить".

7. В редакторе потока данных выберите конечную точку потока данных. Затем выберите созданную ранее конечную точку центров событий и нажмите кнопку "Продолжить".

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

9. Чтобы добавить преобразование, нажмите кнопку Добавить преобразование (необязательно).

10. Чтобы переименовать temperature поле в входящего сообщения, нажмите кнопку +Добавить в плитку "Переименовать ".

11. Добавьте следующее преобразование переименования:

    Точка данных	Новое имя точки данных
    температура. Ценность	ТермостатTemperatureF

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

    Точка данных	Новое имя точки данных
    $metadata.user_property.externalAssetId	Идентификатор актива

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

    

    Нажмите кнопку "Применить".

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

    

14. Чтобы запустить поток данных, введите поток данных учебника в качестве его имени и нажмите кнопку "Сохранить". Через несколько минут состояние подготовки изменится на "Успешно". Поток данных теперь выполняется в кластере.

Поток данных подписывается на раздел MQTT для получения сообщений из ресурса термостата. Он переименовывает некоторые поля в сообщении и пересылает преобразованные сообщения в созданный концентратор событий.

Проверка потока данных

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

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

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

Как мы решили проблему?

В этом руководстве вы использовали поток данных для подключения раздела MQTT к концентратору событий в пространстве имен Центры событий Azure. В следующем руководстве вы используете Аналитику в режиме реального времени Microsoft Fabric для визуализации данных.

Очистите ресурсы

Если вы продолжаете работу со следующим руководством, сохраните все ресурсы.

Если вы хотите удалить развертывание Операций Интернета вещей Azure, но сохранить кластер, используйте команду az iot ops delete :

az iot ops delete --cluster $CLUSTER_NAME --resource-group $RESOURCE_GROUP

Если вы хотите удалить все ресурсы, созданные для этого краткого руководства, удалите кластер Kubernetes, где вы развернули операции Интернета вещей Azure, а затем удалите группу ресурсов Azure, содержащую кластер.

Если вы использовали Codespaces для этих кратких руководств, удалите ваш Codespace из GitHub.

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

Руководство: Получите аналитику из сообщений о ресурсах