Veri akışı uç noktalarını yapılandırma

Veri akışlarını kullanmaya başlamak için önce veri akışı uç noktaları oluşturun. Veri akışı uç noktası, veri akışının bağlantı noktasıdır. Bir uç noktayı veri akışı için kaynak veya hedef olarak kullanabilirsiniz. Bazı uç nokta türleri hem kaynak hem de hedef olarak kullanılabilirken, diğerleri yalnızca hedeflere yöneliktir. Veri akışı için en az bir kaynak uç nokta ve bir hedef uç nokta gerekir.

Yapılandıracak uç nokta türünü seçmek için aşağıdaki tabloyu kullanın:

Veri akışları yerel MQTT aracı uç noktasını kullanmalıdır

Veri akışı oluşturduğunuzda, kaynak ve hedef uç noktaları belirtirsiniz. Veri akışı, verileri kaynak uç noktadan hedef uç noktaya taşır. Birden çok veri akışı için aynı uç noktayı kullanabilir ve bir veri akışındaki hem kaynak hem de hedefle aynı uç noktayı kullanabilirsiniz.

Ancak veri akışında hem kaynak hem de hedef olarak özel uç noktaların kullanılması desteklenmez. Bu kısıtlama, Azure IoT İşlemleri'ndeki yerleşik MQTT aracısının her veri akışının kaynağı veya hedefi olması gerektiği anlamına gelir. Veri akışı dağıtım hatalarını önlemek için her veri akışının kaynağı veya hedefi olarak varsayılan MQTT veri akışı uç noktasını kullanın.

Belirli bir gereksinim, her veri akışının kaynağı veya hedefi konağı aio-brokerolan bir MQTT uç noktasıyla yapılandırılmış olması gerektiğidir. Bu nedenle varsayılan uç noktayı kullanmak kesinlikle gerekli değildir ve konak olduğu aio-brokersürece yerel MQTT aracısını işaret eden ek veri akışı uç noktaları oluşturabilirsiniz. Ancak, karışıklık ve yönetilebilirlik sorunlarını önlemek için varsayılan uç nokta önerilen yaklaşımdır.

Aşağıdaki tabloda desteklenen senaryolar gösterilmektedir:

Uç noktaları yeniden kullanma

Her veri akışı uç noktasını, verilerin nereden gelmesi veya nereye gitmesi gerektiğini ( host değer), uç noktayla kimlik doğrulamasının nasıl yapılacağını ve TLS yapılandırması veya toplu işlem tercihi gibi diğer ayarları içeren bir yapılandırma ayarları paketi olarak düşünün. Bu nedenle yalnızca bir kez oluşturmanız gerekir ve ardından bu ayarların aynı olacağı birden çok veri akışında yeniden kullanabilirsiniz.

Uç noktaların yeniden kullanılmasını kolaylaştırmak için MQTT veya Kafka konu filtresi uç nokta yapılandırmasının bir parçası değildir. Bunun yerine, veri akışı yapılandırmasında konu filtresini belirtirsiniz. Bu, farklı konu filtreleri kullanan birden çok veri akışı için aynı uç noktayı kullanabileceğiniz anlamına gelir.

Örneğin, varsayılan MQTT aracısı veri akışı uç noktasını kullanabilirsiniz. Bunu farklı konu filtreleri olan hem kaynak hem de hedef için kullanabilirsiniz:

resource dataflow 'Microsoft.IoTOperations/instances/dataflowProfiles/dataflows@2024-09-15-preview' = {
  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'
        }
      }
    ]
  }
}

apiVersion: connectivity.iotoperations.azure.com/v1beta1
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

Benzer şekilde, diğer uç noktalar ve konular için aynı MQTT uç noktasını kullanan birden çok veri akışı oluşturabilirsiniz. Örneğin, bir Olay Hub'ı uç noktasına veri gönderen bir veri akışı için aynı MQTT uç noktasını kullanabilirsiniz.

resource dataflow 'Microsoft.IoTOperations/instances/dataflowProfiles/dataflows@2024-09-15-preview' = {
  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'
        }
      }
    ]
  }
}

apiVersion: connectivity.iotoperations.azure.com/v1beta1
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

MQTT örneğine benzer şekilde, farklı konular için aynı Kafka uç noktasını veya farklı tablolar için aynı Data Lake uç noktasını kullanan birden çok veri akışı oluşturabilirsiniz.

Sonraki adımlar

Veri akışı uç noktası oluşturma:

• MQTT veya Event Grid
• Kafka veya Event Hubs
• Data Lake
• Microsoft Fabric OneLake
• Yerel depolama