Adatfolyamvégpontok konfigurálása

Az adatfolyamok használatának megkezdéséhez először hozzon létre adatfolyamvégpontokat. Az adatfolyam végpontja az adatfolyam csatlakozási pontja. Használhat végpontot forrásként, célként vagy mindkettőként. Egyes végponttípusok forrásként és célként is használhatók, míg mások csak célhelyekre.

A konfigurálni kívánt végponttípus kiválasztásához használja az alábbi táblázatot:

Végpont típusa	Leírás	Forrásként használható	Használható célként	Adatfolyam-grafikonok támogatása
MQTT	Kétirányú üzenettovábbítás MQTT-közvetítőkkel, beleértve az Azure IoT műveletek és az Event Grid beépített rendszerét is.	Igen	Igen	Forrás és cél
Kafka	Kétirányú üzenetküldés Kafka-közvetítőkkel, beleértve a Azure Event Hubs.	Igen	Igen	Forrás és cél
OpenTelemetria	Az OpenTelemetry-gyűjtőknek és megfigyelhetőségi platformoknak, például Grafana és Azure Monitor, való metrikák és naplók küldéséhez.	Nem	Igen	Kizárólag célállomás
Data Lake	Adatok Azure Data Lake Gen2-tárfiókokba való feltöltéséhez.	Nem	Igen	Nem támogatott
Microsoft Fabric OneLake	Adatok feltöltése Microsoft Fabric OneLake lakehouse-ba.	Nem	Igen	Nem támogatott
Azure Data Explorer	Adatok Azure Data Explorer adatbázisokba való feltöltéséhez.	Nem	Igen	Nem támogatott
Helyi tároló	Adatok helyileg elérhető állandó kötetre való küldéséhez, opcionálisan konfigurálható Azure tárolótárolóval, amelyet a Azure Arc engedélyez.	Nem	Igen	Nem támogatott

Fontos

Adatfolyam-gráfok korlátozása: Az adatfolyam-gráfok (WASM) jelenleg csak az MQTT, a Kafka és az OpenTelemetry végpontokat támogatják. Az OpenTelemetry-végpontok csak adatfolyam-grafikonokon használhatók célként. Más végponttípusok nem támogatottak adatfolyam-gráfokhoz. További információ: Ismert problémák.

Fontos

A tárolási végpontok szerializálási sémát igényelnek. Ha Microsoft Fabric OneLake, Azure Data Lake Storage, Azure Data Explorer vagy Helyi tár használatával szeretné használni az adatfolyamot, meg kell adnia egy sémahivatkozást.

Ha egy mintaadatfájlból szeretné létrehozni a sémát, használja a Schema Gen súgóját.

Az adatfolyamnak helyi MQTT-közvetítővégpontot kell használnia

Adatfolyam létrehozásakor meg kell adnia a forrás- és célvégpontokat. Az adatfolyam átviszi az adatokat a forrásból a célhelyre. Ugyanazt a végpontot több adatfolyamhoz is használhatja, és ugyanazt a végpontot használhatja, mint a forrás és a cél.

Azonban nem használhat egyéni végpontokat forrásként és célként. A Azure IoT műveletek beépített MQTT-közvetítőjének legalább egy végpontnak (a forrásnak, a célnak vagy mindkettőnek) kell lennie. Az üzembe helyezési hibák elkerülése érdekében használja az alapértelmezett MQTT-adatfolyam-végpontot forrásként vagy célként minden adatfolyamhoz.

Minden adatfolyamnak rendelkeznie kell egy olyan forrással vagy célhellyel, amely egy aio-broker gazdagépet tartalmazó MQTT-végponttal van konfigurálva. Nem kell kifejezetten az alapértelmezett végpontot használnia. Helyi MQTT-közvetítőre mutató egyéb adatfolyam-végpontokat is létrehozhat, feltéve, hogy a gazdagép az aio-broker. Az alapértelmezett végpont használata azonban az ajánlott módszer.

Az alábbi táblázat a támogatott forgatókönyveket mutatja be:

Forgatókönyv	Támogatott
Alapértelmezett végpont forrásként	Igen
Alapértelmezett végpont célként	Igen
Egyéni végpont forrásként	Igen, ha a cél az alapértelmezett végpont, vagy egy MQTT-végpont a aio-broker gazdagéppel
Testreszabott végpont rendeltetési helyként	Igen, ha a forrás alapértelmezett végpont, vagy egy gazdagéppel rendelkező MQTT-végpont aio-broker
Egyéni végpont forrásként és célként	Nem, kivéve, ha az egyikük egy MQTT-végpont, ahol a gazdagép aio-broker

További információ arról, hogy a helyi MQTT-közvetítő hogyan puffereli az adatokat, ha egy célvégpont nem érhető el, olvassa el az adatfolyamok adatpufferelésének és lemezmegőrzésének konfigurálása című témakört.

Végpontok újrafelhasználása

Az egyes adatfolyam-végpontokat konfigurációs beállítások kötegének tekintheti: az adatok forrását vagy helyét (az értéket), a host hitelesítés módját és egyéb beállításokat, például a TLS-konfigurációt vagy a kötegelési beállításokat. Létrehozhat egy végpontot egyszer, és újra felhasználhatja több olyan adatfolyamban, amelyek ugyanazokat a beállításokat használják.

A végpontok újrafelhasználásának megkönnyítése érdekében az MQTT- vagy Kafka-témakörszűrő nem része a végpontkonfigurációnak. Ehelyett meg kell adnia a témakörszűrőt az adatfolyam-konfigurációban. Ez azt jelenti, hogy ugyanazt a végpontot több olyan adatfolyamhoz is használhatja, amelyek különböző témakörszűrőket használnak.

Használhatja például az alapértelmezett MQTT-közvetítő adatfolyam-végpontot. A forráshoz és a célhoz is használhatja különböző témakörszűrőkkel:

Üzemeltetési tapasztalat

Azure CLI-

Adatfolyam létrehozásához vagy módosításához használja az az iot ops-adatfolyam alkalmazás parancsát.

az iot ops dataflow apply --resource-group <ResourceGroupName> --instance <AioInstanceName> --profile <DataflowProfileName> --name <DataflowName> --config-file <ConfigFilePathAndName>

A --config-file paraméter az erőforrás-tulajdonságokat tartalmazó JSON-konfigurációs fájl elérési útja és fájlneve.

Ebben a példában feltételezzük, hogy egy konfigurációs fájl neve data-flow.json a következő tartalommal van tárolva a felhasználó kezdőlapján:

{
  "mode": "Enabled",
  "operations": [
    {
      "operationType": "Source",
      "sourceSettings": {
        "endpointRef": "default",
        "dataSources": [
          "example/topic/1"
        ]
      }
    },
    {
      "operationType": "Destination",
      "destinationSettings": {
        "endpointRef": "default",
        "dataDestination": "example/topic/2"
      }
    }
  ]
}

Bicep

resource dataflow 'Microsoft.IoTOperations/instances/dataflowProfiles/dataflows@2026-03-01' = {
  parent: <DEFAULT_PROFILE_RESOURCE>
  name: 'broker-to-broker'
  extendedLocation: {
    name: <CUSTOM_LOCATION_RESOURCE>.id
    type: 'CustomLocation'
  }
  properties: {
    mode: 'Enabled'
    operations: [
      {
        operationType: 'Source'
        sourceSettings: {
          endpointRef: 'default'
          dataSources: [
            'example/topic/1'
          ]
        }
      }
      {
        operationType: 'Destination'
        destinationSettings: {
          endpointRef: 'default'
          dataDestination: 'example/topic/2'
        }
      }
    ]
  }
}

Kubernetes (csak hibakeresés)

Fontos

A Kubernetes üzembehelyezési jegyzékfájljainak használata éles környezetekben nem támogatott, és csak hibakereséshez és teszteléshez használható.

apiVersion: connectivity.iotoperations.azure.com/v1
kind: Dataflow
metadata:
  name: broker-to-broker
  namespace: azure-iot-operations
spec:
  profileRef: default
  operations:
    - operationType: Source
      sourceSettings:
        endpointRef: default
        dataSources:
        - example/topic/1
    - operationType: Destination
      destinationSettings:
        endpointRef: default
        dataDestination: example/topic/2

Hasonlóképpen létrehozhat több adatfolyamot is, amelyek ugyanazt az MQTT-végpontot használják más végpontokhoz és témakörökhöz. Használhatja például ugyanazt az MQTT-végpontot egy olyan adatfolyamhoz, amely adatokat küld egy Event Hubs-végpontnak.

Üzemeltetési tapasztalat

Azure CLI-

Adatfolyam létrehozásához vagy módosításához használja az az iot ops-adatfolyam alkalmazás parancsát.

az iot ops dataflow apply --resource-group <ResourceGroupName> --instance <AioInstanceName> --profile <DataflowProfileName> --name <DataflowName> --config-file <ConfigFilePathAndName>

A --config-file paraméter az erőforrás-tulajdonságokat tartalmazó JSON-konfigurációs fájl elérési útja és fájlneve.

Ebben a példában feltételezzük, hogy egy konfigurációs fájl neve data-flow.json a következő tartalommal van tárolva a felhasználó kezdőlapján:

{
  "mode": "Enabled",
  "operations": [
    {
      "operationType": "Source",
      "sourceSettings": {
        "endpointRef": "default",
        "dataSources": [
          "example/topic/3"
        ]
      }
    },
    {
      "operationType": "Destination",
      "destinationSettings": {
        // The endpoint needs to be created before you can reference it here
        "endpointRef": "example-event-hub-endpoint",
        "dataDestination": "example/topic/4"
      }
    }
  ]
}

Bicep

resource dataflow 'Microsoft.IoTOperations/instances/dataflowProfiles/dataflows@2026-03-01' = {
  parent: <DEFAULT_PROFILE_RESOURCE>
  name: 'broker-to-eh'
  extendedLocation: {
    name: <CUSTOM_LOCATION_RESOURCE>.id
    type: 'CustomLocation'
  }
  properties: {
    mode: 'Enabled'
    operations: [
      {
        operationType: 'Source'
        sourceSettings: {
          endpointRef: 'default'
          dataSources: [
            'example/topic/3'
          ]
        }
      }
      {
        operationType: 'Destination'
        destinationSettings: {
          // The endpoint needs to be created before you can reference it here
          endpointRef: 'example-event-hub-endpoint'
          dataDestination: 'example/topic/4'
        }
      }
    ]
  }
}

Kubernetes (csak hibakeresés)

Fontos

A Kubernetes üzembehelyezési jegyzékfájljainak használata éles környezetekben nem támogatott, és csak hibakereséshez és teszteléshez használható.

apiVersion: connectivity.iotoperations.azure.com/v1
kind: Dataflow
metadata:
  name: broker-to-eh
  namespace: azure-iot-operations
spec:
  profileRef: default
  operations:
    - operationType: Source
      sourceSettings:
        endpointRef: default
        dataSources:
        - example/topic/3
    - operationType: Destination
      destinationSettings:
        # The endpoint needs to be created before you can reference it here
        endpointRef: example-event-hub-endpoint
        dataDestination: example/topic/4

Az MQTT-példához hasonlóan több olyan adatfolyamot is létrehozhat, amelyek ugyanazt a Kafka-végpontot használják különböző témakörökhöz, vagy ugyanazt a Data Lake végpontot különböző táblákhoz.

Következő lépések

Jótanács

Ha nyilvános végpontok helyett Private Link keresztül szeretné átirányítani az adatfolyam-forgalmat a felhőbeli célhelyekre, tekintse meg Adatfolyam-célhelyek konfigurálása privát végpontokkal.

Adatfolyam-végpont létrehozása:

• MQTT vagy Event Grid
• Kafka vagy Event Hubs
• OpenTelemetria
• Data Lake
• Microsoft Fabric OneLake
• Helyi tároló