az iot ops dataflowgraph

Gestione di DataflowGraph.

Creare o sostituire un dataflowGraph associato a un profilo del flusso di dati.

Di seguito è riportato un esempio del formato di file di configurazione:

{
  "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'esempio precedente definisce un grafo con un'origine MQTT che scorre attraverso un nodo di elaborazione Graph che consente di visualizzare una destinazione Kafka e una destinazione OpenTelemetry. I nodi del grafo fanno riferimento a un artefatto (formato: <name>:<version>) da un endpoint del Registro di sistema. L'esempio precedente include graphSettings.configuration solo per illustrare il formato quando un artefatto richiede parametri di configurazione; in tal caso, specificarli come elenco di coppie di stringhe {"key", "value"}. Omettere completamente graphSettings.configuration quando non è necessaria alcuna configurazione. I nodeType supportati sono: Origine, Destinazione e Grafico. I grafici del flusso di dati supportano solo endpoint MQTT, Kafka e OpenTelemetry. Il file può anche essere il wrapper completo delle risorse ARM (le proprietà vengono estratte automaticamente). extendedLocation viene sempre popolato automaticamente da --instance e -g e non deve essere incluso nel file.

Se usato con applica il contenuto precedente, verrà creata o sostituita una risorsa DataflowGraph di destinazione.

Eliminare un dataflowGraph associato a un profilo del flusso di dati.

Elencare dataflowGraphs associati a un profilo del flusso di dati.

Mostra i dettagli di un dataflowGraph associato a un profilo del flusso di dati.