Kurz: Odeslání telemetrie prostředků do cloudu pomocí toku dat

Článek
11/20/2024

V tomto kurzu použijete tok dat k předávání zpráv z zprostředkovatele MQTT do centra událostí ve službě Azure Event Hubs. Centrum událostí může data doručovat do jiných cloudových služeb pro ukládání a analýzu. V dalším kurzu použijete řídicí panel v reálném čase k vizualizaci dat.

Požadavky

Než začnete s tímto kurzem, musíte dokončit kurz: Přidání prostředků OPC UA do clusteru Azure IoT Operations.

Jaký problém vyřešíme?

Pokud chcete k analýze dat OPC UA použít nástroj, jako je řídicí panel v reálném čase, musíte data odeslat do cloudové služby, jako je Azure Event Hubs. Tok dat se může přihlásit k odběru tématu MQTT a předávat zprávy do centra událostí v oboru názvů služby Azure Event Hubs. V dalším kurzu se dozvíte, jak pomocí řídicích panelů v reálném čase vizualizovat a analyzovat data.

Nastavení proměnných prostředí

Pokud používáte prostředí Codespaces, požadované proměnné prostředí jsou už nastavené a můžete tento krok přeskočit. V opačném případě v prostředí nastavte následující proměnné prostředí:

Udeřit
PowerShell

# 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 resource group where your Kubernetes cluster is deployed
$RESOURCE_GROUP = "<resource-group-name>"

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

Vytvoření oboru názvů služby Event Hubs

Pokud chcete vytvořit obor názvů služby Event Hubs a centrum událostí, spusťte ve svém prostředí následující příkazy Azure CLI. Tyto příkazy vytvoří obor názvů služby Event Hubs ve stejné skupině prostředků jako cluster Kubernetes:

Udeřit
PowerShell

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

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 false

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

Pokud chcete udělit rozšíření Azure IoT Operations v clusteru přístup k oboru názvů služby Event Hubs, spusťte následující příkazy Azure CLI:

Udeřit
PowerShell

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

PRINCIPAL=$(az k8s-extension list --resource-group $RESOURCE_GROUP --cluster-name $CLUSTER_NAME --cluster-type connectedClusters -o tsv --query "[?extensionType=='microsoft.iotoperations'].identity.principalId")

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 k8s-extension list --resource-group $RESOURCE_GROUP --cluster-name $CLUSTER_NAME --cluster-type connectedClusters -o tsv --query "[?extensionType=='microsoft.iotoperations'].identity.principalId")

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

Vytvoření toku dat pro odesílání telemetrie do centra událostí

Pomocí uživatelského rozhraní provozního prostředí vytvořte a nakonfigurujte tok dat v clusteru, který:

Přejmenuje Tag 10 pole v příchozí zprávě na Humidity.
Přejmenuje temperature pole v příchozí zprávě na Temperature.
Přidá pole s názvem AssetId , které obsahuje název prostředku.
Přepošluje transformované zprávy z tématu MQTT do centra událostí, které jste vytvořili.

Vytvoření toku dat:

Přejděte do uživatelského rozhraní provozního prostředí a vyhledejte svou instanci. Pak vyberte koncové body toku dat a na dlaždici Azure Event Hubs vyberte + Nový:
V koncovém bodu Vytvořit nový tok dat: Azure Event Hubs, jako název zadejte cíl event-hubs a aktualizujte pole Hostitel s adresou oboru názvů Event Hubs, který jste vytvořili. Vyberte Použít:

Vytvoří se nový koncový bod toku dat a zobrazí se v seznamu na stránce Koncové body toku dat.
Vyberte Toky dat a pak vyberte + Vytvořit tok dat. Zobrazí se <stránka nového toku> dat:
V editoru toku dat vyberte Vybrat zdroj. Pak vyberte termostat aktivum, které jste vytvořili dříve, a vyberte Použít.
V editoru toku dat vyberte vybrat koncový bod toku dat. Pak vyberte koncový bod event-hubs-target , který jste vytvořili dříve, a vyberte Použít.
Na další stránce zadejte jako téma cíl. Toto téma se týká centra, které jste vytvořili v oboru názvů služby Event Hubs. Vyberte Použít. Váš tok dat má teď jako zdroj termostatu a centrum ve vašem oboru názvů Event Hubs jako cíl.
Pokud chcete přidat transformaci, vyberte Přidat transformaci (volitelné).
Pokud chcete pole v temperature příchozí zprávě přejmenovatTag 10, vyberte + Přidat na dlaždici Přejmenovat.
Přidejte následující dvě transformace přejmenování:

Datapoint Nový název datového bodu

Značka 10.Value TermostatHumidita

teplota. Hodnota TermostatTemperature
Pokud chcete zkopírovat ID prostředku z metadat zprávy, přidejte následující transformaci přejmenování:

Datapoint Nový název datového bodu

$metadata.user_property.externalAssetId AssetId

Transformace přejmenování vypadá jako na následujícím snímku obrazovky:

Vyberte Použít.
Editor toku dat teď vypadá jako na následujícím snímku obrazovky:
Pokud chcete spustit tok dat, zadejte název toku dat tutorial-dataflow a pak vyberte Uložit. Po několika minutách se stav zřizování změní na Úspěch. Tok dat je teď spuštěný ve vašem clusteru.

Datapoint	Nový název datového bodu
Značka 10.Value	TermostatHumidita
teplota. Hodnota	TermostatTemperature

Datapoint	Nový název datového bodu
$metadata.user_property.externalAssetId	AssetId

Váš tok dat se přihlásí k odběru tématu MQTT, aby přijímal zprávy z termostatového prostředku. Přejmenuje některá pole ve zprávě a přepošla transformované zprávy do centra událostí, které jste vytvořili.

Ověření toku dat

Pokud chcete ověřit, že data proudí do cloudu, můžete instanci služby Event Hubs zobrazit na webu Azure Portal. Možná budete muset několik minut počkat, než se tok dat spustí, a na tok zpráv do centra událostí.

Pokud do instance proudí zprávy, uvidíte počet příchozích zpráv na stránce Přehled instance:

Snímek obrazovky znázorňující stránku přehledu instance služby Event Hubs s příchozími zprávami

Pokud zprávy proudí, můžete k zobrazení zpráv použít Průzkumník dat:

Snímek obrazovky se stránkou Instance služby Event Hubs **Průzkumník dat**.

Tip

Abyste mohli zobrazit zprávy, budete si možná muset přiřadit roli příjemce dat služby Azure Event Hubs pro obor názvů služby Event Hubs.

Jak jsme tento problém vyřešili?

V tomto kurzu jste pomocí toku dat připojili téma MQTT k centru událostí v oboru názvů Azure Event Hubs. V dalším kurzu použijete k vizualizaci dat inteligenci Microsoft Fabric v reálném čase.

Vyčištění prostředků

Pokud budete pokračovat k dalšímu kurzu, ponechte všechny prostředky.

Pokud chcete odebrat nasazení operací Azure IoT, ale zachovat cluster, použijte příkaz az iot ops delete :

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

Pokud chcete odstranit všechny prostředky, které jste vytvořili pro účely tohoto rychlého startu, odstraňte cluster Kubernetes, ve kterém jste nasadili operace Azure IoT, a pak odeberte skupinu prostředků Azure, která obsahovala cluster.

Pokud jste pro tyto rychlé starty použili Codespaces, odstraňte codespace z GitHubu.

Poznámka:

Skupina prostředků obsahuje obor názvů služby Event Hubs, který jste vytvořili v tomto kurzu.

Další krok

Kurz: Získání přehledů z telemetrie prostředků

Sdílet prostřednictvím