MQTT veri akışı uç noktalarını yapılandırma

1. İşlem deneyiminde Veri akışı uç noktalarını seçin.

2. Ayarları görüntülemek veya düzenlemek için varsayılan uç noktayı seçin.

   

Varsayılan uç noktayı düzenlemek için aşağıdaki içeriğe sahip bir Bicep .bicep dosyası oluşturun. Ayarları gerektiği gibi güncelleştirin ve gibi <AIO_INSTANCE_NAME> yer tutucu değerlerini kendi yer tutucunuzla değiştirin.

param aioInstanceName string = '<AIO_INSTANCE_NAME>'
param customLocationName string = '<CUSTOM_LOCATION_NAME>'

resource aioInstance 'Microsoft.IoTOperations/instances@2024-11-01' existing = {
  name: aioInstanceName
}
resource customLocation 'Microsoft.ExtendedLocation/customLocations@2021-08-31-preview' existing = {
  name: customLocationName
}
resource defaultMqttBrokerDataflowEndpoint 'Microsoft.IoTOperations/instances/dataflowEndpoints@2024-11-01' = {
  parent: aioInstance
  name: 'default'
  extendedLocation: {
    name: customLocation.id
    type: 'CustomLocation'
  }
  properties: {
    endpointType: 'Mqtt'
    mqttSettings: {
      host: 'aio-broker:18883'
      authentication: {
        method: 'ServiceAccountToken'
        serviceAccountTokenSettings: {
          audience: 'aio-internal'
        }
      }
      tls: {
        mode: 'Enabled'
        trustedCaCertificateConfigMapRef: 'azure-iot-operations-aio-ca-trust-bundle'
      }
    }
  }
}

Ardından Azure CLI aracılığıyla dağıtın.

az deployment group create --resource-group <RESOURCE_GROUP> --template-file <FILE>.bicep

Kubernetes kümesinde varsayılan MQTT aracı uç noktası ayarlarını görüntüleyebilirsiniz. Ayarları görüntülemek için aşağıdaki komutu kullanın:

kubectl get dataflowendpoint default -n azure-iot-operations -o yaml

1. İşlem deneyiminde Veri akışı uç noktalarını seçin.

2. Yeni veri akışı uç noktası oluştur'un altında Azure IoT İşlemleri Yerel MQTT>Yeni'yi seçin.

   

   Uç nokta için aşağıdaki ayarları girin:

   Ayar	Tanım
   Ad	Veri akışı uç noktasının adı.
   Ana Bilgisayar	MQTT aracısının ana bilgisayar adı ve bağlantı noktası. Biçimi kullanma <hostname>:<port>
   Kimlik doğrulama yöntemi	Kimlik doğrulaması için kullanılan yöntem. Hizmet hesabı belirteci veya X509 sertifikası seçin
   Hizmet hedef kitlesi	Hizmet hesabı belirtecinin hedef kitlesi. Hizmet hesabı belirteci kullanılıyorsa gereklidir.
   X509 istemci sertifikası	Kimlik doğrulaması için kullanılan X.509 istemci sertifikası. X509 sertifikası kullanılıyorsa gereklidir.
   X509 istemci anahtarı	X.509 istemci sertifikasına karşılık gelen özel anahtar. X509 sertifikası kullanılıyorsa gereklidir.
   X509 ara sertifikaları	X.509 istemci sertifika zinciri için ara sertifikalar. X509 sertifikası kullanılıyorsa gereklidir.

param aioInstanceName string = '<AIO_INSTANCE_NAME>'
param customLocationName string = '<CUSTOM_LOCATION_NAME>'
param endpointName string = '<ENDPOINT_NAME>'
param mqttBrokerHostname string = '<HOSTNAME>:<PORT>'
param trustedCA string = '<TRUST_BUNDLE>'
param serviceAccountAudience string = '<SA_AUDIENCE>'

resource aioInstance 'Microsoft.IoTOperations/instances@2024-11-01' existing = {
  name: aioInstanceName
}
resource customLocation 'Microsoft.ExtendedLocation/customLocations@2021-08-31-preview' existing = {
  name: customLocationName
}
resource MqttBrokerDataflowEndpoint 'Microsoft.IoTOperations/instances/dataflowEndpoints@2024-11-01' = {
  parent: aioInstance
  name: endpointName
  extendedLocation: {
    name: customLocation.id
    type: 'CustomLocation'
  }
  properties: {
    endpointType: 'Mqtt'
    mqttSettings: {
      host: mqttBrokerHostname
      authentication: {
        method: 'ServiceAccountToken'
        serviceAccountTokenSettings: {
          audience: serviceAccountAudience
        }
      }
      tls: {
        mode: 'Enabled'
        trustedCaCertificateConfigMapRef: trustedCA
      }
    }
  }
}

apiVersion: connectivity.iotoperations.azure.com/v1
kind: DataflowEndpoint
metadata:
  name: <ENDPOINT_NAME>
  namespace: azure-iot-operations
spec:
  endpointType: Mqtt
  mqttSettings:
    host: "<HOSTNAME>:<PORT>"
    tls:
      mode: Enabled
      trustedCaCertificateConfigMapRef: <TRUST_BUNDLE>
    authentication:
      method: ServiceAccountToken
      serviceAccountTokenSettings:
        audience: <SA_AUDIENCE>

1. İşlem deneyiminde Veri akışı uç noktaları sekmesini seçin.

2. Yeni veri akışı uç noktası oluştur'un altında Azure Event Grid MQTT>Yeni'yi seçin.

   

   Uç nokta için aşağıdaki ayarları girin:

   Ayar	Tanım
   Ad	Veri akışı uç noktasının adı.
   Ana Bilgisayar	Event Grid MQTT aracısının ana bilgisayar adı ve bağlantı noktası. Biçimi kullanma <NAMESPACE>.<REGION>-1.ts.eventgrid.azure.net:8883
   Kimlik doğrulama yöntemi	Kimlik doğrulaması için kullanılan yöntem. Sistem tarafından atanan yönetilen kimlik veya Kullanıcı tarafından atanan yönetilen kimlik'i seçmenizi öneririz.

3. Uç noktayı sağlamak için Uygula'yı seçin.

Aşağıdaki içeriğe sahip bir Bicep .bicep dosyası oluşturun.

param aioInstanceName string = '<AIO_INSTANCE_NAME>'
param customLocationName string = '<CUSTOM_LOCATION_NAME>'
param endpointName string = '<ENDPOINT_NAME>'
param eventGridHostName string = '<NAMESPACE>.<REGION>-1.ts.eventgrid.azure.net:8883'

resource aioInstance 'Microsoft.IoTOperations/instances@2024-11-01' existing = {
  name: aioInstanceName
}
resource customLocation 'Microsoft.ExtendedLocation/customLocations@2021-08-31-preview' existing = {
  name: customLocationName
}
resource remoteMqttBrokerDataflowEndpoint 'Microsoft.IoTOperations/instances/dataflowEndpoints@2024-11-01' = {
  parent: aioInstance
  name: endpointName
  extendedLocation: {
    name: customLocation.id
    type: 'CustomLocation'
  }
  properties: {
    endpointType: 'Mqtt'
    mqttSettings: {
      host: eventGridHostName
      authentication: {
        // See available authentication methods section for method types
        // method: <METHOD_TYPE>
      }
      tls: {
        mode: 'Enabled'
      }
    }
  }
}

Ardından Azure CLI aracılığıyla dağıtın.

az deployment group create --resource-group <RESOURCE_GROUP> --template-file <FILE>.bicep

Aşağıdaki içeriğe sahip bir Kubernetes bildirim .yaml dosyası oluşturun.

apiVersion: connectivity.iotoperations.azure.com/v1
kind: DataflowEndpoint
metadata:
  name: <ENDPOINT_NAME>
  namespace: azure-iot-operations
spec:
  endpointType: Mqtt
  mqttSettings:
    host: <NAMESPACE>.<REGION>-1.ts.eventgrid.azure.net:8883
    authentication:
      # See available authentication methods section for method types
      # method: <METHOD_TYPE>
    tls:
      mode: Enabled

Ardından bildirim dosyasını Kubernetes kümesine uygulayın.

kubectl apply -f <FILE>.yaml

1. İşlem deneyiminde Veri akışı uç noktaları sekmesini seçin.

2. Yeni veri akışı uç noktası oluştur'un altında Özel MQTT Aracısı>Yeni'yi seçin.

   

3. Uç nokta için aşağıdaki ayarları girin:

   Ayar	Tanım
   Ad	Veri akışı uç noktasının adı
   Ana Bilgisayar	biçiminde <hostname>.<port>MQTT aracı uç noktasının konak adı.
   Kimlik doğrulama yöntemi	Kimlik doğrulaması için kullanılan yöntem. Hizmet hesabı belirteci veya X509 sertifikası'nı seçin.
   Hizmet hedef kitlesi	Hizmet hesabı belirtecinin hedef kitlesi. Hizmet hesabı belirteci kullanılıyorsa gereklidir.
   X509 istemci sertifikası	Kimlik doğrulaması için kullanılan X.509 istemci sertifikası. X509 sertifikası kullanılıyorsa gereklidir.
   X509 istemci anahtarı	X.509 istemci sertifikasına karşılık gelen özel anahtar. X509 sertifikası kullanılıyorsa gereklidir.
   X509 ara sertifikaları	X.509 istemci sertifika zinciri için ara sertifikalar. X509 sertifikası kullanılıyorsa gereklidir.

4. Uç noktayı sağlamak için Uygula'yı seçin.

mqttSettings: {
  authentication: {
    // See available authentication methods section for method types
    // method: <METHOD_TYPE>
  }
  host: '<HOST>:<PORT>'
  tls: {
    mode: 'Enabled' // or 'Disabled'
    trustedCaCertificateConfigMapRef: '<TRUSTED_CA_CERT_CONFIGMAP>'
  }
}

spec:
  endpointType: Mqtt
  mqttSettings:
    host: <HOST>:<PORT>
    authentication:
      # See available authentication methods section for method types
      # method: <METHOD_TYPE>
    tls:
      mode: Enabled # or Disabled
      trustedCaCertificateConfigMapRef: <TRUSTED_CA_CERT_CONFIGMAP>

İşlem deneyimi veri akışı uç noktası ayarları sayfasında Temel sekmesini ve ardından Sistem tarafından atanan yönetilen kimlik kimlik kimlik doğrulaması yöntemini>seçin.

mqttSettings: {
  authentication: {
    method: 'SystemAssignedManagedIdentity'
    systemAssignedManagedIdentitySettings: {}
  }
}

mqttSettings:
  authentication:
    method: SystemAssignedManagedIdentity
    systemAssignedManagedIdentitySettings:
      {}

Desteklenmiyor.

mqttSettings: {
  authentication: {
    method: 'SystemAssignedManagedIdentity'
    systemAssignedManagedIdentitySettings: {
      audience: 'https://<AUDIENCE>'
    }
  }
}

mqttSettings:
  authentication:
    method: SystemAssignedManagedIdentity
    systemAssignedManagedIdentitySettings:
      audience: https://<AUDIENCE>

İşlem deneyimi veri akışı uç noktası ayarları sayfasında Temel sekmesini ve ardından Kullanıcı tarafından atanan yönetilen kimlik kimlik kimlik doğrulama yöntemini>seçin.

mqttSettings: {
  authentication: {
    method: 'UserAssignedManagedIdentity'
    userAssignedManagedIdentitySettings: {
      clientId: '<ID>'
      tenantId: '<ID>'
      // Optional, defaults to 'https://eventgrid.azure.net/.default'
      // scope: 'https://<SCOPE_URL>' 
    }
  }
}

mqttSettings:
  authentication:
    method: UserAssignedManagedIdentity
    userAssignedManagedIdentitySettings:
      clientId: <ID>
      tenantId: <ID>
      # Optional, defaults to 'https://eventgrid.azure.net/.default'
      # scope: https://<SCOPE_URL>

İşlem deneyimi veri akışı uç noktası ayarları sayfasında Temel sekmesini ve ardından Kimlik doğrulama yöntemi Hizmet hesabı belirteci'ni> seçin.

Hizmet hedef kitlesini girin.

mqttSettings: {
  authentication: {
    method: 'ServiceAccountToken'
    serviceAccountTokenSettings: {
      audience: '<YOUR_SERVICE_ACCOUNT_AUDIENCE>'
    }
  }
}

mqttSettings:
  authentication:
    method: ServiceAccountToken
    serviceAccountTokenSettings:
      audience: <YOUR_SERVICE_ACCOUNT_AUDIENCE>

İşlem deneyimi veri akışı uç noktası ayarları sayfasında Temel sekmesini ve ardından Kimlik doğrulama yöntemi X509 sertifikası'nı> seçin.

Burada, Eşitlenen gizli dizi adı'nın altında gizli dizi için bir ad girin. Bu ad, veri akışı uç noktası ayarlarında gizli diziye başvurmak için kullanılır ve Kubernetes kümesinde depolandığı şekilde gizli dizinin adıdır.

Ardından, X509 istemci sertifikası, X509 istemci anahtarı ve X509 ara sertifikaları altında, Sertifikayı, özel anahtarı ve ara sertifikaları eklemek için Başvuru ekle'yi seçin. Sonraki sayfada Azure Key Vault'tan ekle veya Yeni gizli dizi oluştur ile Azure Key Vault'tan gizli diziyi seçin.

Yeni oluştur'u seçerseniz aşağıdaki ayarları girin:

Gizli diziler hakkında daha fazla bilgi edinmek için bkz . Azure IoT İşlemlerinde gizli dizi oluşturma ve yönetme.

mqttSettings: {
  authentication: {
    method: 'X509Certificate'
      x509CertificateSettings:
        secretRef: '<X509_SECRET_NAME>'
  }
}

mqttSettings:
  authentication:
    method: X509Certificate
    x509CertificateSettings:
      secretRef: <X509_SECRET_NAME>

İşlem deneyimi veri akışı uç noktası ayarları sayfasında Temel sekmesini ve ardından Kimlik doğrulama yöntemi Yok'u> seçin.

mqttSettings: {
  authentication: {
    method: 'Anonymous'
  }
}

mqttSettings:
  authentication:
    method: Anonymous
    anonymousSettings:
      {}

İşlem deneyiminde veri akışı uç noktası için Gelişmiş sekmesini seçin.

// See sections below for explanation of each setting
mqttSettings: {
  qos: 1
  retain: 'Keep'
  sessionExpirySeconds: 3600
  keepAliveSeconds: 60
  maxInflightMessages: 100
  protocol: WebSockets
  clientIdPrefix: 'dataflow'
  cloudEventAttributes : 'Propagate' // or 'CreateOrRemap'
}

# See sections below for explanation of each setting
mqttSettings:
  qos: 1
  retain: Keep
  sessionExpirySeconds: 3600
  keepAliveSeconds: 60
  maxInflightMessages: 100
  protocol: WebSockets
  clientIdPrefix: dataflow
  cloudEventAttributes : Propagate # or CreateOrRemap

İşlem deneyimi veri akışı uç noktası ayarları sayfasında Gelişmiş sekmesini seçin ve TLS modu etkin seçeneğinin yanındaki onay kutusunu kullanın.

mqttSettings: {
  tls: {
    mode: 'Enabled' // or 'Disabled'
  }
}

mqttSettings:
  tls:
    mode: Enabled # or Disabled

İşlem deneyimi veri akışı uç noktası ayarları sayfasında Gelişmiş sekmesini seçin, ardından Güvenilen CA sertifikası yapılandırma eşlemesi alanını kullanarak güvenilen CA sertifikasını içeren ConfigMap'i belirtin.

mqttSettings: {
  tls: {
    trustedCaCertificateConfigMapRef: '<YOUR_CA_CERTIFICATE>'
  }
}

mqttSettings:
  tls:
    trustedCaCertificateConfigMapRef: <YOUR_CA_CERTIFICATE>

İşlem deneyimi veri akışı uç noktası ayarları sayfasında Gelişmiş sekmesini seçin ve ardından ön eki belirtmek için İstemci Kimliği ön eki alanını kullanın.

mqttSettings: {
  clientIdPrefix: '<YOUR_PREFIX>'
}

mqttSettings:
  clientIdPrefix: <YOUR_PREFIX>

İşlem deneyimi veri akışı uç noktası ayarları sayfasında Gelişmiş sekmesini seçin ve hizmet kalitesi (QoS) alanını kullanarak QoS düzeyini belirtin.

mqttSettings: {
  qos: 1 // Or 0
}

mqttSettings:
  qos: 1 # Or 0

İşlem deneyimi veri akışı uç noktası ayarları sayfasında Gelişmiş sekmesini seçin ve ardından Saklama alanını kullanarak saklama ayarını belirtin.

mqttSettings: {
  retain: Keep // or Never
}

mqttSettings:
  retain: Keep # or Never

İşlem deneyimi veri akışı uç noktası ayarları sayfasında Gelişmiş sekmesini seçin ve oturum süre sonu aralığını belirtmek için Oturum süre sonu alanını kullanın.

mqttSettings: {
  sessionExpirySeconds: 600
}

mqttSettings:
  sessionExpirySeconds: 600

İşlem deneyimi veri akışı uç noktası ayarları sayfasında Gelişmiş sekmesini seçin ve protokolü belirtmek için Protokol alanını kullanın.

mqttSettings: {
  protocol: 'WebSockets'
}

mqttSettings:
  protocol: WebSockets

İşlem deneyimi veri akışı uç noktası ayarları sayfasında Gelişmiş sekmesini seçin ve ardından En fazla uçuş içi ileti alanını kullanarak en fazla uçak içi ileti sayısını belirtin.

mqttSettings: {
  maxInflightMessages: 100
}

mqttSettings:
  maxInflightMessages: 100

İşlem deneyimi veri akışı uç noktası ayarları sayfasında Gelişmiş sekmesini seçin ve etkin tutma aralığını belirtmek için Etkin tut alanını kullanın.

mqttSettings: {
  keepAliveSeconds: 60
}

mqttSettings:
  keepAliveSeconds: 60

İşlem deneyimi veri akışı uç noktası ayarları sayfasında Gelişmiş sekmesini seçin ve cloud event attributes alanını kullanarak CloudEvents ayarını belirtin.

mqttSettings: {
  cloudEventAttributes : 'Propagate' // or 'CreateOrRemap'
}

mqttSettings:
  cloudEventAttributes : Propagate # or CreateOrRemap