az iot ops dataflowgraph

Gerenciamento do DataflowGraph.

Crie ou substitua um DataflowGraph associado a um perfil de fluxo de dados.

Um exemplo do formato de arquivo de configuração é o seguinte:

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

O exemplo acima define um grafo com uma origem MQTT fluindo por meio de um nó de processamento do Graph que se estende para um destino Kafka e um destino OpenTelemetry. Nós de grafo fazem referência a um artefato (formato: <name>:<version>) de um ponto de extremidade do Registro. O exemplo acima inclui graphSettings.configuration apenas para ilustrar o formato quando um artefato requer parâmetros de configuração; nesse caso, forneça-os como uma lista de pares de cadeia de caracteres {"key", "value"}. Omita grafSettings.configuration inteiramente quando nenhuma configuração é necessária. Os nodeTypes com suporte são: Origem, Destino e Grafo. Os grafos de fluxo de dados dão suporte apenas a pontos de extremidade MQTT, Kafka e OpenTelemetry. O arquivo também pode ser o wrapper de recurso arm completo (as propriedades são extraídas automaticamente). extendedLocation é sempre populado automaticamente de --instance e -g e não deve ser incluído no arquivo.

Quando usado com a aplicação, o conteúdo acima criará ou substituirá um recurso dataflowGraph de destino.

Exclua um DataflowGraph associado a um perfil de fluxo de dados.

Listar DataflowGraphs associados a um perfil de fluxo de dados.

Mostrar detalhes de um DataflowGraph associado a um perfil de fluxo de dados.