Kurz: Odesílání zpráv z prostředků do cloudu pomocí toku dat

V tomto kurzu použijete tok dat k přeposílá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 Microsoft Fabric Real-Time Řídicí panel, musíte data odeslat do cloudové služby, jako je Azure Event Hubs. Tok dat může odebírat téma MQTT a předávat zprávy do Event Hubu v rámci vašeho oboru názvů 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í

Ujistěte se, že jsou ve vašem shellu nastaveny následující proměnné:

Návod

Pokud chcete zobrazit uživatelsky přiřazené spravované identity, které jste vytvořili v rámci skupiny prostředků, spusťte v příkazovém řádku následující příkaz: az identity list -g $RESOURCE_GROUP -o table

Udeřit

# 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>

Prostředí 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 user-assigned managed identity that you created for cloud connections
USER_ASSIGNED_MI_NAME="<cloud-connection-uami>"

Vytvořte obor 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

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

Prostředí PowerShell

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

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

Udeřit

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

Prostředí PowerShell

$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

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

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

• Přejmenuje temperature pole v příchozí zprávě na TemperatureF.
• 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:

1. Přejděte do webového uživatelského rozhraní provozního prostředí a vyhledejte instanci. Pak vyberte koncové body toku dat a na dlaždici Azure Event Hubs vyberte + Nový:

   

2. V koncovém bodu Vytvořit nový tok dat: Azure Event Hubs zadejte jako název event-hubs-target a vyhledejte obor názvů Event Hubs, který jste vytvořili v poli Host.

3. Jako metodu ověřování vyberte spravovanou identitu přiřazenou uživatelem. Přidejte hodnoty klientského ID a tenanta ID spravované identity přiřazené uživatelem, kterou používáte pro připojení ke cloudu. Pomocí následujícího příkazu rozhraní příkazového řádku zobrazte ID klienta a ID tenanta přiřazených spravovaných identit ve vaší skupině prostředků: az identity list -g $RESOURCE_GROUP -o table

4. Vyberte Použít:

   

   Vytvoří se nový koncový bod toku dat a zobrazí se v seznamu na stránce koncových bodů toku dat.

5. Vyberte Toky dat a pak vyberte + Vytvořit tok dat. Zobrazí se <stránka nového toku> dat:

   

6. V editoru toku dat vyberte Vybrat zdroj. Pak vyberte aktivum termostatu, který jste vytvořili dříve, a vyberte Pokračovat.

7. V editoru toku dat vyberte Vybrat cíl. Pak vyberte koncový bod event-hubs-target , který jste vytvořili dříve, a vyberte Pokračovat.

8. Na další stránce zadejte destinationeh jako téma. Téma se týká hubu, který jste vytvořili v jmenném prostoru Event Hubs. Vyberte a použijte. Váš tok dat nyní má jako zdroj termostat a jako cíl rozbočovač ve vašem prostoru názvů Event Hubs.

9. Pokud chcete přidat transformaci, vyberte Přidat transformaci (volitelné).

10. Pokud chcete pole v příchozí zprávě přejmenovat temperature , vyberte + Přidat na dlaždici Přejmenovat .

11. Přidejte následující transformaci přejmenování:

    Datový bod	Nový název datového bodu
    teplota. Hodnota	TermostatTeplotaF

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

    Datový bod	Nový název datového bodu
    $metadata.user_property.jedinečnýIdentifikátorExterníhoAktiva	ID majetku

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

    

    Vyberte a použijte.

13. Editor toku dat teď vypadá jako na následujícím snímku obrazovky:

    

14. Tok dat zahájíte tak, že jako název zadáte tutorial-data-flow a pak vyberete Uložit. Po několika minutách se stav zřizování změní na Úspěšný. Tok dat je teď spuštěný ve vašem clusteru.

Váš tok dat se přihlásí k odběru tématu MQTT, aby přijímal zprávy ze zařízení termostatu. Přejmenuje některá pole ve zprávě a přeposílá transformované zprávy do událostního centra, 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 spustí tok dat a začnou zprávy proudit 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:

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

Návod

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 použili tok dat k připojení tématu 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čistěte zdroje

Pokud pokračujete k dalšímu tutoriálu, ponechte si všechny materiály.

Pokud chcete odebrat nasazení Azure IoT Operations, ale zachovat svůj 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ů Event Hubs, který jste vytvořili v tomto kurzu.

Další krok

Návod: Získejte přehled ze zpráv týkajících se aktiv