Настройка конечных точек потока данных MQTT

Внимание

Предварительная версия операций Интернета вещей Azure, включенная Azure Arc в настоящее время в предварительной версии. Не следует использовать это программное обеспечение предварительной версии в рабочих средах.

Вам потребуется развернуть новую установку Операций Интернета вещей Azure, когда общедоступная версия станет доступной. Вы не сможете обновить предварительную установку.

Юридические условия, применимые к функциям Azure, которые находятся в бета-версии, предварительной версии или в противном случае еще не выпущены в общедоступную версию, см . в дополнительных условиях использования для предварительных версий Microsoft Azure.

Конечные точки потока данных MQTT используются для источников и назначений MQTT. Параметры конечной точки, tls, аутентификация и другие параметры можно настроить.

Необходимые компоненты

• Экземпляр предварительной версии операций Интернета вещей Azure
• Настроенный профиль потока данных

Локальный брокер MQTT операций Интернета вещей Azure

Операции Интернета вещей Azure предоставляют встроенный локальный брокер MQTT, который можно использовать с потоками данных. Брокер MQTT можно использовать в качестве источника для получения сообщений от других систем или в качестве назначения для отправки сообщений в другие системы.

Конечная точка по умолчанию

При развертывании операций Интернета вещей Azure создается конечная точка потока данных брокера MQTT с именем default с параметрами по умолчанию. Эту конечную точку можно использовать в качестве источника или назначения для потоков данных.

Внимание

Конечная точка по умолчанию всегда должна использоваться в качестве источника или назначения в каждом потоке данных. Дополнительные сведения см. в статье "Потоки данных" должны использовать локальную конечную точку брокера MQTT.

Конечная точка по умолчанию использует следующие параметры:

• Узел: aio-broker:18883 через прослушиватель брокера MQTT по умолчанию
• Проверка подлинности: маркер учетной записи службы (SAT) через ресурс BrokerAuthentication по умолчанию
• TLS: включено
• Доверенный сертификат ЦС: сертификат azure-iot-operations-aio-ca-trust-bundle ЦС по умолчанию из корневого ЦС по умолчанию

Внимание

Не удаляйте конечную точку по умолчанию. Если удалить конечную точку по умолчанию, необходимо повторно создать ее с теми же параметрами.

Чтобы просмотреть или изменить параметры конечной точки брокера MQTT по умолчанию, выполните следующие действия.

Портал

1. В интерфейсе операций выберите конечные точки потока данных.

2. Выберите конечную точку по умолчанию для просмотра или изменения параметров.

   

Bicep

Чтобы изменить конечную точку по умолчанию, создайте файл Bicep .bicep со следующим содержимым. Обновите параметры по мере необходимости и замените значения заполнителей, например <AIO_INSTANCE_NAME> собственные.

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

resource aioInstance 'Microsoft.IoTOperations/instances@2024-09-15-preview' existing = {
  name: aioInstanceName
}
resource customLocation 'Microsoft.ExtendedLocation/customLocations@2021-08-31-preview' existing = {
  name: customLocationName
}
resource defaultMqttBrokerDataflowEndpoint 'Microsoft.IoTOperations/instances/dataflowEndpoints@2024-09-15-preview' = {
  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'
      }
    }
  }
}

Затем развернитесь с помощью Azure CLI.

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

Kubernetes

Параметры конечной точки брокера MQTT по умолчанию можно просмотреть в кластере Kubernetes. Чтобы просмотреть параметры, используйте следующую команду:

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

Создание новой конечной точки

Вы также можете создать новые локальные конечные точки брокера MQTT с пользовательскими параметрами. Например, можно создать новую конечную точку брокера MQTT с помощью другого порта, проверки подлинности или авторизации. Однако всегда следует использовать конечную точку по умолчанию в качестве источника или назначения в каждом потоке данных, даже если вы создаете новые конечные точки.

Портал

1. В интерфейсе операций выберите конечные точки потока данных.

2. В разделе "Создание новой конечной точки потока данных" выберите Azure IoT Operations Local MQTT>New.

   

   Введите следующие параметры для конечной точки:

   Параметр	Description
   Имя.	Имя конечной точки потока данных.
   Хост	Имя узла и порт брокера MQTT. Использование формата <hostname>:<port>
   Authentication method	Метод, используемый для проверки подлинности. Выбор маркера учетной записи службы или сертификата X509
   Аудитория служб	Аудитория маркера учетной записи службы. Требуется, если используется маркер учетной записи службы.
   Сертификат клиента X509	Сертификат клиента X.509, используемый для проверки подлинности. Требуется, если используется сертификат X509.
   Ключ клиента X509	Закрытый ключ, соответствующий сертификату клиента X.509. Требуется, если используется сертификат X509.
   Промежуточные сертификаты X509	Промежуточные сертификаты для цепочки сертификатов клиента X.509. Требуется, если используется сертификат X509.

Bicep

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-09-15-preview' existing = {
  name: aioInstanceName
}
resource customLocation 'Microsoft.ExtendedLocation/customLocations@2021-08-31-preview' existing = {
  name: customLocationName
}
resource MqttBrokerDataflowEndpoint 'Microsoft.IoTOperations/instances/dataflowEndpoints@2024-09-15-preview' = {
  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
      }
    }
  }
}

Kubernetes

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

Сетку событий Azure

Сетка событий Azure предоставляет полностью управляемый брокер MQTT, который работает с потоками данных Операций Интернета вещей Azure. Чтобы настроить конечную точку брокера MQTT Сетка событий Azure, рекомендуется использовать управляемое удостоверение для проверки подлинности.

Настройка пространства имен Сетки событий

Если вы этого еще не сделали, сначала создайте пространство имен Сетки событий.

Включение MQTT

Когда у вас есть пространство имен Сетки событий, перейдите к разделу "Конфигурация " и проверьте:

• Включите MQTT: установите флажок.
• Максимальное количество сеансов клиента на имя проверки подлинности: установлено значение 3 или более.

Параметр максимального числа клиентских сеансов важен, чтобы потоки данных могли масштабироваться и по-прежнему иметь возможность подключения. Дополнительные сведения см. в статье "Поддержка многосеансовой службы "Сетка событий MQTT".

Создание пространства разделов

Чтобы потоки данных отправляли или получали сообщения в брокер MQTT сетки событий, необходимо создать по крайней мере одно пространство тем в пространстве имен Сетки событий. Вы можете создать пространство тем в пространстве имен Сетки событий, выбрав >раздел "Новые пространства тем".

Чтобы быстро приступить к тестированию, можно создать пространство тем # с подстановочными знаками в качестве шаблона раздела.

Назначение разрешения управляемому удостоверению

Теперь, когда пространство тем создается, необходимо назначить управляемое удостоверение расширения Azure IoT Operations Arc пространству имен сетки событий или пространству тем.

В портал Azure перейдите в кластер Kubernetes, подключенный к Arc, и выберите "Расширения параметров>". В списке расширений найдите имя расширения Операций Интернета вещей Azure. Скопируйте имя расширения.

Затем перейдите к элементу управления доступом к пространству >имен сетки событий (IAM)>Добавить назначение ролей. Назначьте управляемое удостоверение расширения Azure IoT Operations Arc с соответствующей ролью, например EventGrid TopicSpaces Publisher или EventGrid TopicSpaces Subscriber. Это дает управляемому удостоверению необходимые разрешения для отправки или получения сообщений для всех пространств тем в пространстве имен.

Кроме того, можно назначить роль на уровне пространства тем. Перейдите к разделу >управления доступом (IAM)>Добавить назначение ролей. Назначьте управляемое удостоверение расширения Azure IoT Operations Arc с соответствующей ролью, например EventGrid TopicSpaces Publisher или EventGrid TopicSpaces Subscriber. Это дает управляемому удостоверению необходимые разрешения для отправки или получения сообщений для определенного пространства тем.

Создание конечной точки потока данных

После настройки пространства имен Сетки событий можно создать конечную точку потока данных для брокера MQTT сетки событий.

Портал

1. В интерфейсе операций выберите вкладку конечных точек потока данных.

2. В разделе "Создание новой конечной точки потока данных" выберите Сетка событий Azure MQTT>New.

   

   Введите следующие параметры для конечной точки:

   Параметр	Description
   Имя.	Имя конечной точки потока данных.
   Хост	Имя узла и порт брокера MQTT сетки событий. Использование формата <NAMESPACE>.<REGION>-1.ts.eventgrid.azure.net:8883
   Authentication method	Метод, используемый для проверки подлинности. Выбор управляемого удостоверения, назначаемого системой

3. Нажмите кнопку "Применить" , чтобы подготовить конечную точку.

Bicep

Создайте файл Bicep .bicep со следующим содержимым.

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-09-15-preview' existing = {
  name: aioInstanceName
}
resource customLocation 'Microsoft.ExtendedLocation/customLocations@2021-08-31-preview' existing = {
  name: customLocationName
}
resource remoteMqttBrokerDataflowEndpoint 'Microsoft.IoTOperations/instances/dataflowEndpoints@2024-09-15-preview' = {
  parent: aioInstance
  name: endpointName
  extendedLocation: {
    name: customLocation.id
    type: 'CustomLocation'
  }
  properties: {
    endpointType: 'Mqtt'
    mqttSettings: {
      host: eventGridHostName
      authentication: {
        method: 'SystemAssignedManagedIdentity'
        systemAssignedManagedIdentitySettings: {}
      }
      tls: {
        mode: 'Enabled'
      }
    }
  }
}

Затем развернитесь с помощью Azure CLI.

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

Kubernetes

Создайте файл манифеста .yaml Kubernetes со следующим содержимым.

apiVersion: connectivity.iotoperations.azure.com/v1beta1
kind: DataflowEndpoint
metadata:
  name: <ENDPOINT_NAME>
  namespace: azure-iot-operations
spec:
  endpointType: Mqtt
  mqttSettings:
    host: <NAMESPACE>.<REGION>-1.ts.eventgrid.azure.net:8883
    authentication:
      method: SystemAssignedManagedIdentity
      systemAssignedManagedIdentitySettings:
        {}
    tls:
      mode: Enabled

Затем примените файл манифеста к кластеру Kubernetes.

kubectl apply -f <FILE>.yaml

После создания конечной точки его можно использовать в потоке данных для подключения к брокеру MQTT сетки событий в качестве источника или назначения. Разделы MQTT настраиваются в потоке данных.

Использование проверки подлинности сертификата X.509 с сеткой событий

Мы рекомендуем использовать управляемое удостоверение для проверки подлинности. Вы также можете использовать проверку подлинности сертификата X.509 с брокером MQTT Сетки событий.

При использовании проверки подлинности X.509 с брокером MQTT сетки событий перейдите в конфигурацию пространства >имен Сетки событий и проверьте следующие параметры:

• Включите MQTT: установите флажок.
• Включите альтернативные источники имен проверки подлинности клиента: установите флажок.
• Имя субъекта сертификата: выберите этот параметр в раскрывающемся списке.
• Максимальное количество сеансов клиента на имя проверки подлинности: установлено значение 3 или более.

Альтернативные параметры проверки подлинности клиента и максимальные параметры сеансов клиента позволяют потокам данных использовать имя субъекта сертификата клиента для проверки подлинности вместо MQTT CONNECT Usernameпроверки подлинности. Эта возможность важна, чтобы потоки данных могли создавать несколько экземпляров и по-прежнему подключаться. Дополнительные сведения см. в статье "Проверка подлинности сертификата клиента MQTT в Сетке событий" и поддержка нескольких сеансов.

Затем выполните действия, описанные в сертификате X.509, чтобы настроить конечную точку с параметрами сертификата X.509.

Ограничение общей подписки сетки событий

Сетка событий Azure брокер MQTT не поддерживает общие подписки, что означает, что нельзя задать instanceCount значение больше, чем 1 в профиле потока данных, если сетка событий используется в качестве источника (где поток данных подписывается на сообщения) для потока данных. В этом случае, если задано instanceCount 1больше, поток данных не запускается.

Пользовательские брокеры MQTT

Для других брокеров MQTT можно настроить конечную точку, TLS, проверку подлинности и другие параметры по мере необходимости.

Портал

1. В интерфейсе операций выберите вкладку конечных точек потока данных.

2. В разделе "Создание новой конечной точки потока данных" выберите "Создать настраиваемый брокер>MQTT".

   

3. Введите следующие параметры для конечной точки:

   Параметр	Description
   Имя.	Имя конечной точки потока данных
   Хост	Имя узла конечной точки брокера MQTT в формате <hostname>.<port>.
   Authentication method	Метод, используемый для проверки подлинности. Выберите управляемое удостоверение, назначаемое системой, назначенное пользователем управляемое удостоверение или маркер учетной записи службы.
   Аудитория служб	Аудитория маркера учетной записи службы. Требуется, если используется маркер учетной записи службы.
   Client ID	Идентификатор клиента управляемого удостоверения, назначаемого пользователем. Обязательно, если используется управляемое удостоверение, назначаемое пользователем.
   Идентификатор клиента	Идентификатор клиента управляемого удостоверения, назначаемого пользователем. Обязательно, если используется управляемое удостоверение, назначаемое пользователем.
   Имя секрета маркера доступа	Имя секрета Kubernetes, содержащего маркер SAS. Требуется, если используется маркер доступа.

4. Нажмите кнопку "Применить" , чтобы подготовить конечную точку.

Bicep

mqttSettings: {
  authentication: {
    // See available authentication methods below
  }
  host: '<HOST>:<PORT>'
  tls: {
    mode: 'Enabled' // or 'Disabled'
    trustedCaCertificateConfigMapRef: '<TRUSTED_CA_CERT_CONFIGMAP>'
  }
}

Kubernetes

spec:
  endpointType: Mqtt
  mqttSettings:
    host: <HOST>:<PORT>
    authentication:
      # See available authentication methods below
    tls:
      mode: Enabled # or Disabled
      trustedCaCertificateConfigMapRef: <TRUSTED_CA_CERT_CONFIGMAP>

Чтобы настроить параметры конечной точки MQTT, дополнительные сведения см. в следующих разделах.

Доступные методы проверки подлинности

Для конечных точек потока данных брокера MQTT доступны следующие методы проверки подлинности. Дополнительные сведения о включении безопасных параметров путем настройки Azure Key Vault и включения удостоверений рабочих нагрузок см. в статье "Включение безопасных параметров в развертывании Azure IoT Operations Preview".

Сертификат X.509

Многие брокеры MQTT, такие как Сетка событий, поддерживают проверку подлинности X.509. Потоки данных могут представлять сертификат X.509 клиента и согласовывать связь TLS.

Портал

На странице параметров конечной точки потока данных для операций выберите вкладку "Базовый" и выберите сертификат X509 метода>проверки подлинности.

Введите следующие параметры для конечной точки:

Параметр	Description
Сертификат клиента X509	Сертификат клиента X.509, используемый для проверки подлинности.
Промежуточные сертификаты X509	Промежуточные сертификаты для цепочки сертификатов клиента X.509.
Ключ клиента X509	Закрытый ключ, соответствующий сертификату клиента X.509.

Bicep

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

Kubernetes

Чтобы использовать проверку подлинности сертификата X.509, необходимо создать секрет с сертификатом и закрытым ключом. Используйте секрет TLS Kubernetes, содержащий открытый сертификат и закрытый ключ. Например:

kubectl create secret tls my-tls-secret -n azure-iot-operations \
  --cert=path/to/cert/file \
  --key=path/to/key/file

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

Управляемое удостоверение, назначаемое системой

Чтобы использовать назначаемое системой управляемое удостоверение для проверки подлинности, вам не нужно создавать секрет. Управляемое удостоверение, назначаемое системой, используется для проверки подлинности с помощью брокера MQTT.

Перед настройкой конечной точки убедитесь, что управляемое удостоверение Операций Интернета вещей Azure имеет необходимые разрешения для подключения к брокеру MQTT.

1. В портал Azure перейдите к экземпляру Операций Интернета вещей Azure и выберите "Обзор".
2. Скопируйте имя расширения, указанного после расширения Azure IoT Operations Arc. Например, azure-iot-operations-xxxx7.
3. Найдите управляемое удостоверение в портал Azure с помощью имени расширения. Например, выполните поиск azure-iot-operations-xxxx7.
4. Назначьте роль управляемому удостоверению расширения Azure IoT Operations Arc, которое предоставляет разрешение на подключение к брокеру MQTT. Например, с помощью брокера MQTT Сетка событий Azure назначьте управляемое удостоверение пространству имен сетки событий или пространству разделов с соответствующей ролью.
5. Настройте конечную точку с параметрами управляемого удостоверения, назначаемого системой.

Портал

На странице параметров конечной точки потока данных для операций выберите вкладку "Базовый", а затем выберите управляемое удостоверение, назначенное системой проверки подлинности>.

Bicep

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

Kubernetes

mqttSettings:
  authentication:
    method: SystemAssignedManagedIdentity
    systemAssignedManagedIdentitySettings:
      {}

В большинстве случаев при использовании с сеткой событий можно оставить параметры пустыми, как показано ниже. Это задает аудиторию управляемого удостоверения для общей аудитории https://eventgrid.azure.netСетки событий. Если необходимо задать другую аудиторию, ее можно указать в параметрах.

Портал

Не поддерживается.

Bicep

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

Kubernetes

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

Управляемое удостоверение, назначаемое пользователем

Чтобы использовать управляемое пользователем удостоверение для проверки подлинности, необходимо сначала развернуть операции Интернета вещей Azure с включенными безопасными параметрами. Дополнительные сведения см. в статье "Включение безопасных параметров в развертывании Azure IoT Operations Preview".

Затем укажите метод проверки подлинности управляемого удостоверения, назначаемый пользователем, а также идентификатор клиента и идентификатор клиента управляемого удостоверения.

Портал

На странице параметров конечной точки потока данных для операций выберите вкладку "Базовый" и выберите метод проверки подлинности>, назначенный пользователем.

Bicep

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

Kubernetes

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

Здесь область является необязательной и по умолчанию https://eventgrid.azure.net/.default используется для всех Сетка событий Azure пространств имен. Если необходимо задать другую область, ее можно указать в параметрах с помощью Bicep или Kubernetes.

Токен учетной записи службы Kubernetes (SAT)

Чтобы использовать маркер учетной записи службы Kubernetes (SAT) для проверки подлинности, вам не нужно создавать секрет. SAT используется для проверки подлинности с помощью брокера MQTT путем сопоставления аудитории.

Портал

На странице параметров конечной точки потока данных для операций выберите вкладку "Базовый" и выберите маркер учетной записи службы проверки подлинности.>

Введите аудиторию службы.

Bicep

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

Kubernetes

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

Анонимные

Чтобы использовать анонимную проверку подлинности, задайте для метода проверки подлинности значение Anonymous.

Портал

Пока не поддерживается в интерфейсе операций. См. раздел Известные проблемы.

Bicep

Пока не поддерживается в Bicep. См. раздел Известные проблемы.

Kubernetes

mqttSettings:
  authentication:
    method: Anonymous
    anonymousSettings:
      {}

Расширенные настройки

Дополнительные параметры для конечной точки потока данных брокера MQTT, например TLS, доверенного сертификата ЦС, параметров обмена сообщениями MQTT и CloudEvents. Эти параметры можно задать на вкладке "Расширенный портал потока данных" в пользовательском ресурсе конечной точки потока данных.

Портал

В интерфейсе операций выберите вкладку "Дополнительно " для конечной точки потока данных.

Bicep

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

Kubernetes

# 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

Параметры протокола TLS

Режим TLS

Чтобы включить или отключить TLS для конечной точки Kafka, обновите mode параметр в параметрах TLS.

Портал

На странице параметров конечной точки потока данных для операций выберите вкладку "Дополнительно ", а затем установите флажок рядом с режимом TLS.

Bicep

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

Kubernetes

mqttSettings:
  tls:
    mode: Enabled # or Disabled

Для режима TLS можно задать Enabled или Disabled. Если задан Enabledрежим, поток данных использует безопасное подключение к брокеру Kafka. Если задан Disabledрежим, поток данных использует небезопасное подключение к брокеру Kafka.

Сертификат доверенного ЦС

Настройте доверенный сертификат ЦС для конечной точки MQTT, чтобы установить безопасное подключение к брокеру MQTT. Этот параметр важен, если брокер MQTT использует самозаверяющий сертификат или сертификат, подписанный пользовательским ЦС, который по умолчанию не является доверенным.

Портал

На странице параметров конечной точки потока данных для операций выберите вкладку "Дополнительно ", а затем используйте поле карты конфигурации сертификата доверенного ЦС, чтобы указать ConfigMap, содержащий сертификат доверенного ЦС.

Bicep

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

Kubernetes

mqttSettings:
  tls:
    trustedCaCertificateConfigMapRef: <YOUR_CA_CERTIFICATE>

Этот ConfigMap должен содержать сертификат ЦС в формате PEM. ConfigMap должен находиться в том же пространстве имен, что и ресурс потока данных MQTT. Например:

kubectl create configmap client-ca-configmap --from-file root_ca.crt -n azure-iot-operations

---

Совет

При подключении к брокеру MQTT сетки событий сертификат ЦС не требуется, так как служба Центров событий использует сертификат, подписанный общедоступным ЦС, доверенным по умолчанию.

Префикс идентификатора клиента

Вы можете задать префикс идентификатора клиента для клиента MQTT. Идентификатор клиента создается путем добавления имени экземпляра потока данных в префикс.

Внимание

Большинство приложений не должны изменять префикс идентификатора клиента. Не изменяйте это после первоначального развертывания операций Интернета вещей. Изменение префикса идентификатора клиента после развертывания может привести к потере данных.

Портал

На странице параметров конечной точки потока данных для операций выберите вкладку "Дополнительно ", а затем используйте поле префикса идентификатора клиента, чтобы указать префикс .

Bicep

mqttSettings: {
  clientIdPrefix: '<YOUR_PREFIX>'
}

Kubernetes

mqttSettings:
  clientIdPrefix: <YOUR_PREFIX>

Качество обслуживания

Уровень качества обслуживания (QoS) можно задать для сообщений MQTT 1 или 0. Значение по умолчанию — 1.

Портал

На странице параметров конечной точки потока данных для операций выберите вкладку "Дополнительно ", а затем используйте поле "Качество обслуживания" (QoS), чтобы указать уровень качества обслуживания.

Bicep

mqttSettings: {
  qos: 1 // Or 0
}

Kubernetes

mqttSettings:
  qos: 1 # Or 0

Сохранять

retain Используйте параметр, чтобы указать, должен ли поток данных хранить флаг хранения в сообщениях MQTT. Значение по умолчанию — Keep.

Задайте для этого поля Keep значение, чтобы убедиться, что удаленный брокер содержит те же сообщения, что и локальный брокер, что может быть важно для сценариев единого пространства имен (UNS).

Если задано значение Never, флаг сохранения удаляется из сообщений MQTT. Это может быть полезно, если вы не хотите, чтобы удаленный брокер сохранял сообщения или если удаленный брокер не поддерживает сохранение.

Чтобы настроить параметры хранения, выполните следующие действия.

Портал

На странице параметров конечной точки потока данных для операций выберите вкладку "Дополнительно ", а затем используйте поле "Сохранить ", чтобы указать параметр сохранения.

Bicep

mqttSettings: {
  retain: Keep // or Never
}

Kubernetes

mqttSettings:
  retain: Keep # or Never

Параметр сохранения действует только в том случае, если поток данных использует конечную точку MQTT как источник, так и назначение. Например, в сценарии моста MQTT.

Внимание

Сетка событий Azure брокер MQTT в настоящее время не поддерживает флаг хранения. Это означает, что если для конечной точки брокера MQTT сетки событий задан флаг Keep хранения, а в качестве назначения они используются, сообщения отклоняются. Чтобы избежать этого, задайте флаг Never сохранения при использовании брокера MQTT Сетки событий в качестве назначения.

Срок действия сеанса

Интервал истечения срока действия сеанса можно задать для клиента MQTT потока данных. Интервал истечения срока действия сеанса — это максимальное время, которое поддерживается сеансом MQTT, если клиент потока данных отключается. Значение по умолчанию — 3600 секунд. Чтобы настроить интервал истечения срока действия сеанса, выполните следующие действия.

Портал

На странице параметров конечной точки потока данных для операций выберите вкладку "Дополнительно ", а затем используйте поле "Срок действия сеанса ", чтобы указать интервал истечения срока действия сеанса.

Bicep

mqttSettings: {
  sessionExpirySeconds: 3600
}

Kubernetes

mqttSettings:
  sessionExpirySeconds: 3600

Протокол MQTT или WebSockets

По умолчанию WebSockets не включен. Чтобы использовать MQTT через WebSockets, задайте protocol для поля значение WebSockets.

Портал

На странице параметров конечной точки потока данных для операций выберите вкладку "Дополнительно ", а затем используйте поле "Протокол " для указания протокола.

Bicep

mqttSettings: {
  protocol: 'WebSockets'
}

Kubernetes

mqttSettings:
  protocol: WebSockets

Максимальное количество сообщений в полете

Можно задать максимальное количество сообщений в полете, которые может иметь клиент MQTT потока данных. Значение по умолчанию равно 100.

Портал

На странице параметров конечной точки потока данных для операций выберите вкладку "Дополнительно ", а затем используйте поле "Максимальное количество сообщений в полете", чтобы указать максимальное количество сообщений в полете.

Bicep

mqttSettings: {
  maxInflightMessages: 100
}

Kubernetes

mqttSettings:
  maxInflightMessages: 100

Для подписки, когда конечная точка MQTT используется в качестве источника, это максимальное значение получения. Для публикации, когда конечная точка MQTT используется в качестве назначения, это максимальное количество сообщений, отправляемых перед ожиданием подтверждения.

Проверка активности

Вы можете задать интервал сохранения активности для клиента MQTT потока данных. Интервал поддержания активности — это максимальное время, когда клиент потока данных может быть неактивен перед отправкой сообщения PINGREQ брокеру. Значение по умолчанию ― 60 секунд.

Портал

На странице параметров конечной точки потока данных для операций выберите вкладку "Дополнительно ", а затем используйте поле "Сохранить жизнь ", чтобы указать интервал сохранения активности.

Bicep

mqttSettings: {
  keepAliveSeconds: 60
}

Kubernetes

mqttSettings:
  keepAliveSeconds: 60

Источники облачных

CloudEvents — это способ описания данных событий распространенным способом. Параметры CloudEvents используются для отправки или получения сообщений в формате CloudEvents. Вы можете использовать CloudEvents для архитектур на основе событий, где разные службы должны взаимодействовать друг с другом в одном или разных поставщиках облачных служб.

Параметры CloudEventAttributes илиPropagateCreateOrRemap. Чтобы настроить параметры CloudEvents, выполните следующие действия.

Портал

На странице параметров конечной точки потока данных для операций выберите вкладку "Дополнительно ", а затем используйте поле атрибутов событий Cloud Для указания параметра CloudEvents.

Bicep

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

Kubernetes

mqttSettings:
  CloudEventAttributes: Propagate # or CreateOrRemap

В следующих разделах содержатся дополнительные сведения о параметрах CloudEvents.

Параметр распространения

Свойства CloudEvent передаются для сообщений, содержащих необходимые свойства. Если сообщение не содержит необходимых свойств, сообщение передается как есть.

имени	Обязательное поле	Пример значения	Выходное значение
specversion	Да	1.0	Передается как
type	Да	ms.aio.telemetry	Передается как
source	Да	aio://mycluster/myoven	Передается как
id	Да	A234-1234-1234	Передается как
subject	No	aio/myoven/telemetry/temperature	Передается как
time	No	2018-04-05T17:31:00Z	Передается как есть. Это не отдохнулось.
datacontenttype	No	application/json	Изменен на тип содержимого выходных данных после необязательного этапа преобразования.
dataschema	No	sr://fabrikam-schemas/123123123234234234234234#1.0.0	Если в конфигурации преобразования выходных данных задана схема преобразования выходных данных, dataschema изменится на выходную схему.

Параметр CreateOrRemap

Свойства CloudEvent передаются для сообщений, содержащих необходимые свойства. Если сообщение не содержит обязательных свойств, создаются свойства.

имени	Обязательное поле	Созданное значение, если отсутствует
specversion	Да	1.0
type	Да	ms.aio-dataflow.telemetry
source	Да	aio://<target-name>
id	Да	Созданный UUID в целевом клиенте
subject	No	Выходной раздел, в котором отправляется сообщение
time	No	Создано как RFC 3339 в целевом клиенте
datacontenttype	No	Изменен на тип содержимого выходных данных после необязательного этапа преобразования
dataschema	No	Схема, определенная в реестре схем

Следующие шаги

Дополнительные сведения о потоках данных см. в статье "Создание потока данных".