Mengonfigurasi titik akhir aliran data

Penting

Pratinjau Operasi Azure IoT – diaktifkan oleh Azure Arc saat ini dalam pratinjau. Anda tidak boleh menggunakan perangkat lunak pratinjau ini di lingkungan produksi.

Anda harus menyebarkan penginstalan Azure IoT Operations baru saat rilis yang tersedia secara umum tersedia. Anda tidak akan dapat memutakhirkan penginstalan pratinjau.

Untuk persyaratan hukum yang berlaku untuk fitur Azure yang beta, dalam pratinjau, atau belum dirilis ke ketersediaan umum, lihat Ketentuan Penggunaan Tambahan untuk Pratinjau Microsoft Azure.

Untuk mulai menggunakan aliran data, pertama-tama buat titik akhir aliran data. Titik akhir aliran data adalah titik koneksi untuk aliran data. Anda dapat menggunakan titik akhir sebagai sumber atau tujuan untuk aliran data. Beberapa jenis titik akhir dapat digunakan sebagai sumber dan tujuan, sementara yang lain hanya untuk tujuan. Aliran data memerlukan setidaknya satu titik akhir sumber dan satu titik akhir tujuan.

Gunakan tabel berikut untuk memilih jenis titik akhir untuk dikonfigurasi:

Jenis titik akhir	Deskripsi	Dapat digunakan sebagai sumber	Dapat digunakan sebagai tujuan
MQTT	Untuk olahpesan dua arah dengan broker MQTT, termasuk yang bawaan ke Azure IoT Operations dan Event Grid.	Ya	Ya
Kafka	Untuk olahpesan dua arah dengan broker Kafka, termasuk Azure Event Hubs.	Ya	Ya
Data Lake	Untuk mengunggah data ke akun penyimpanan Azure Data Lake Gen2.	Tidak	Ya
Microsoft Fabric OneLake	Untuk mengunggah data ke Microsoft Fabric OneLake lakehouses.	Tidak	Ya
Penyimpanan lokal	Untuk mengirim data ke volume persisten yang tersedia secara lokal, di mana Anda dapat mengunggah data melalui Azure Container Storage yang diaktifkan oleh volume edge Azure Arc.	Tidak	Ya

Aliran data harus menggunakan titik akhir broker MQTT lokal

Saat membuat aliran data, Anda menentukan titik akhir sumber dan tujuan. Aliran data memindahkan data dari titik akhir sumber ke titik akhir tujuan. Anda dapat menggunakan titik akhir yang sama untuk beberapa aliran data, dan Anda bisa menggunakan titik akhir yang sama dengan sumber dan tujuan dalam aliran data.

Namun, menggunakan titik akhir kustom sebagai sumber dan tujuan dalam aliran data tidak didukung. Pembatasan ini berarti broker MQTT bawaan di Azure IoT Operations harus menjadi sumber atau tujuan untuk setiap aliran data. Untuk menghindari kegagalan penyebaran aliran data, gunakan titik akhir aliran data MQTT default sebagai sumber atau tujuan untuk setiap aliran data.

Persyaratan khusus adalah setiap aliran data harus memiliki sumber atau tujuan yang dikonfigurasi dengan titik akhir MQTT yang memiliki host aio-broker. Jadi tidak benar-benar diperlukan untuk menggunakan titik akhir default, dan Anda dapat membuat titik akhir aliran data tambahan yang menunjuk ke broker MQTT lokal selama host adalah aio-broker. Namun, untuk menghindari masalah kebingungan dan pengelolaan, titik akhir default adalah pendekatan yang direkomendasikan.

Tabel berikut ini memperlihatkan skenario yang didukung:

Skenario	Didukung
Titik akhir default sebagai sumber	Ya
Titik akhir default sebagai tujuan	Ya
Titik akhir kustom sebagai sumber	Ya, jika tujuan adalah titik akhir default atau titik akhir MQTT dengan host aio-broker
Titik akhir kustom sebagai tujuan	Ya, jika sumber adalah titik akhir default atau titik akhir MQTT dengan host aio-broker
Titik akhir kustom sebagai sumber dan tujuan	Tidak, kecuali salah satunya adalah titik akhir MQTT dengan host aio-broker

Menggunakan kembali titik akhir

Anggap setiap titik akhir aliran data sebagai bundel pengaturan konfigurasi yang berisi dari mana data harus berasal atau masuk ke ( host nilai), cara mengautentikasi dengan titik akhir, dan pengaturan lain seperti konfigurasi TLS atau preferensi batching. Jadi Anda hanya perlu membuatnya sekali dan kemudian Anda dapat menggunakannya kembali dalam beberapa aliran data di mana pengaturan ini akan sama.

Untuk mempermudah penggunaan kembali titik akhir, filter topik MQTT atau Kafka bukan bagian dari konfigurasi titik akhir. Sebagai gantinya, Anda menentukan filter topik dalam konfigurasi aliran data. Ini berarti Anda dapat menggunakan titik akhir yang sama untuk beberapa aliran data yang menggunakan filter topik yang berbeda.

Misalnya, Anda dapat menggunakan titik akhir aliran data broker MQTT default. Anda dapat menggunakannya untuk sumber dan tujuan dengan filter topik yang berbeda:

Portal

Bicep

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'
        }
      }
    ]
  }
}

Kubernetes

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

Demikian pula, Anda dapat membuat beberapa aliran data yang menggunakan titik akhir MQTT yang sama untuk titik akhir dan topik lainnya. Misalnya, Anda dapat menggunakan titik akhir MQTT yang sama untuk aliran data yang mengirim data ke titik akhir Pusat Aktivitas.

Portal

Bicep

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'
        }
      }
    ]
  }
}

Kubernetes

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

Mirip dengan contoh MQTT, Anda dapat membuat beberapa aliran data yang menggunakan titik akhir Kafka yang sama untuk topik yang berbeda, atau titik akhir Data Lake yang sama untuk tabel yang berbeda.

Langkah berikutnya

Membuat titik akhir aliran data:

• MQTT atau Event Grid
• Kafka atau Event Hubs
• Data Lake
• Microsoft Fabric OneLake
• Penyimpanan lokal