Szybki start: wysyłanie danych telemetrycznych zasobów do chmury przy użyciu przepływu danych

Artykuł
08/07/2024

Ważne

Usługa Azure IoT Operations Preview — włączona przez usługę Azure Arc jest obecnie dostępna w wersji zapoznawczej. Nie należy używać tego oprogramowania w wersji zapoznawczej w środowiskach produkcyjnych.

Po udostępnieniu ogólnie dostępnej wersji należy wdrożyć nową instalację operacji usługi Azure IoT. Nie będzie można uaktualnić instalacji w wersji zapoznawczej.

Zobacz Dodatkowe warunki użytkowania wersji zapoznawczych platformy Microsoft Azure, aby zapoznać się z postanowieniami prawnymi dotyczącymi funkcji platformy Azure, które są w wersji beta lub wersji zapoznawczej albo w inny sposób nie zostały jeszcze wydane jako ogólnie dostępne.

W tym przewodniku Szybki start użyjesz przepływu danych do przekazywania komunikatów z brokera MQTT do centrum zdarzeń w usłudze Azure Event Hubs. Centrum zdarzeń może dostarczać dane do innych usług w chmurze na potrzeby magazynowania i analizy. W następnym przewodniku Szybki start użyjesz pulpitu nawigacyjnego w czasie rzeczywistym, aby zwizualizować dane.

Wymagania wstępne

Przed rozpoczęciem tego przewodnika Szybki start należy wykonać następujące przewodniki Szybki start:

Jaki problem rozwiążemy?

Aby użyć narzędzia, takiego jak pulpit nawigacyjny w czasie rzeczywistym do analizowania danych OPC UA, musisz wysłać dane do usługi w chmurze, takiej jak Azure Event Hubs. Przepływ danych może subskrybować temat MQTT i przekazywać komunikaty do centrum zdarzeń w przestrzeni nazw usługi Azure Event Hubs. W następnym przewodniku Szybki start pokazano, jak używać pulpitów nawigacyjnych czasu rzeczywistego do wizualizacji i analizowania danych.

Tworzenie przestrzeni nazw usługi Event Hubs

Aby utworzyć przestrzeń nazw usługi Event Hubs i centrum zdarzeń, uruchom następujące polecenia interfejsu wiersza polecenia platformy Azure w terminalu usługi Codespaces. Te polecenia tworzą przestrzeń nazw usługi Event Hubs w tej samej grupie zasobów co klaster Kubernetes:

az eventhubs namespace create --name ${CLUSTER_NAME:0:24} --resource-group $RESOURCE_GROUP --location $LOCATION

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

Aby udzielić rozszerzenia Operacje usługi Azure IoT w klastrze dostępu do przestrzeni nazw usługi Event Hubs, uruchom następujące polecenia interfejsu wiersza polecenia platformy Azure:

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

az deployment group create \
      --name assign-RBAC-roles \
      --resource-group $RESOURCE_GROUP \
      --template-file samples/quickstarts/event-hubs-config.bicep \
      --parameters aioExtensionName=$AIO_EXTENSION_NAME \
      --parameters clusterName=$CLUSTER_NAME \
      --parameters eventHubNamespaceName=${CLUSTER_NAME:0:24}

Tworzenie przepływu danych w celu wysyłania danych telemetrycznych do centrum zdarzeń

Aby utworzyć i skonfigurować przepływ danych w klastrze, uruchom następujące polecenia w terminalu usługi Codespaces. Ten przepływ danych przekazuje komunikaty z tematu MQTT do utworzonego centrum zdarzeń bez wprowadzania żadnych zmian:

sed 's/<NAMESPACE>/'"${CLUSTER_NAME:0:24}"'/' samples/quickstarts/dataflow.yaml > dataflow.yaml

kubectl apply -f dataflow.yaml

Jak rozwiązaliśmy ten problem?

W tym przewodniku Szybki start użyto przepływu danych do połączenia tematu MQTT z centrum zdarzeń w przestrzeni nazw usługi Azure Event Hubs. W następnym przewodniku Szybki start użyjesz analizy czasu rzeczywistego usługi Microsoft Fabric do wizualizacji danych.

Czyszczenie zasobów

Jeśli nie zamierzasz nadal korzystać z tego wdrożenia, usuń klaster Kubernetes, w którym wdrożono operacje usługi Azure IoT, i usuń grupę zasobów platformy Azure zawierającą klaster.

Możesz również usunąć obszar roboczy usługi Microsoft Fabric.

Następny krok

Szybki start: uzyskiwanie szczegółowych informacji z telemetrii zasobów

Udostępnij za pośrednictwem