az iot ops dataflowgraph

DataflowGraph-beheer.

Maak of vervang een DataflowGraph die is gekoppeld aan een gegevensstroomprofiel.

Een voorbeeld van de configuratiebestandsindeling is als volgt:

{
  "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" } }
  ]
}

In het bovenstaande voorbeeld wordt een grafiek gedefinieerd met een MQTT-bron die door een Graph-verwerkingsknooppunt stroomt dat naar een Kafka-bestemming en een OpenTelemetry-doel uitloopt. Graph-knooppunten verwijzen naar een artefact (indeling: <name>:<version>) vanuit een registereindpunt. Het bovenstaande voorbeeld bevat alleen graphSettings.configuration om de indeling te illustreren wanneer een artefact configuratieparameters vereist; Geef deze in dat geval op als een lijst met tekenreeksparen {"key", "value"}. Laat graphSettings.configuration volledig weg wanneer er geen configuratie nodig is. Ondersteunde nodeTypes zijn: Bron, Doel en Grafiek. Gegevensstroomgrafieken ondersteunen alleen MQTT-, Kafka- en OpenTelemetry-eindpunten. Het bestand kan ook de volledige ARM-resource-wrapper zijn (eigenschappen worden automatisch geëxtraheerd). extendedLocation wordt altijd automatisch ingevuld vanuit --instance en -g en mag niet worden opgenomen in het bestand.

Wanneer deze wordt gebruikt met het toepassen van de bovenstaande inhoud, wordt een doel-DataflowGraph-resource gemaakt of vervangen.

Verwijder een DataflowGraph die is gekoppeld aan een gegevensstroomprofiel.

Een lijst weergeven met DataflowGraphs die zijn gekoppeld aan een gegevensstroomprofiel.

Details weergeven van een DataflowGraph die is gekoppeld aan een gegevensstroomprofiel.