az iot ops dataflowgraph

Gestion de DataflowGraph.

Créez ou remplacez un DataflowGraph associé à un profil de flux de données.

Voici un exemple de format de fichier de configuration :

{
  "mode": "Enabled",
  "nodes": [
    {
      "name": "source-mqtt",
      "nodeType": "Source",
      "sourceSettings": {
        "endpointRef": "default-broker",
        "dataSources": ["sensors/temperature/#"]
      }
    },
    {
      "name": "dest-broker",
      "nodeType": "Destination",
      "destinationSettings": {
        "endpointRef": "my-kafka-endpoint",
        "dataDestination": "telemetry/temperature"
      }
    },
    {
      "name": "dest-otel",
      "nodeType": "Destination",
      "destinationSettings": {
        "endpointRef": "my-otel-endpoint",
        "dataDestination": "telemetry/all"
      }
    },
    {
      "name": "graph-processor",
      "nodeType": "Graph",
      "graphSettings": {
        "registryEndpointRef": "my-registry-endpoint",
        "artifact": "my-processing-module:1.0.0",
        "configuration": [
          { "key": "paramName", "value": "paramValue" },
          { "key": "anotherParam", "value": "anotherValue" }
        ]
      }
    }
  ],
  "nodeConnections": [
    { "from": { "name": "source-mqtt" }, "to": { "name": "graph-processor" } },
    { "from": { "name": "graph-processor" }, "to": { "name": "dest-broker" } },
    { "from": { "name": "graph-processor" }, "to": { "name": "dest-otel" } }
  ]
}

L’exemple ci-dessus définit un graphique avec une source MQTT qui transite par un nœud de traitement Graph qui se déplace vers une destination Kafka et une destination OpenTelemetry. Les nœuds de graphique font référence à un artefact (format : <name>:<version>) à partir d’un point de terminaison de Registre. L’exemple ci-dessus inclut graphSettings.configuration uniquement pour illustrer le format lorsqu’un artefact nécessite des paramètres de configuration ; dans ce cas, fournissez-les sous la forme d’une liste de paires de chaînes {"key », « value"}. Omettez entièrement graphSettings.configuration quand aucune configuration n’est nécessaire. Les nodeTypes pris en charge sont : Source, Destination et Graph. Les graphiques de flux de données prennent uniquement en charge les points de terminaison MQTT, Kafka et OpenTelemetry. Le fichier peut également être le wrapper de ressources ARM complet (les propriétés sont extraites automatiquement). extendedLocation est toujours renseigné automatiquement à partir de --instance et -g et ne doit pas être inclus dans le fichier.

Lorsqu’elle est utilisée avec l’application du contenu ci-dessus, crée ou remplace une ressource DataflowGraph cible.

Supprimez un DataflowGraph associé à un profil de flux de données.

Répertorier les dataflowGraphs associés à un profil de flux de données.

Afficher les détails d’un DataflowGraph associé à un profil de flux de données.