Создание и чтение сообщений Центра Интернета вещей

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

Для реализация отправки сообщений с устройства в облако Центр Интернета вещей использует модель потоковой передачи сообщений. Сообщения Центра Интернета вещей, передаваемые через облако, больше похожи на событияЦентров событий, чем сообщенияслужебной шины, в том, что существует большой объем событий, передаваемых через службу, которую может читать несколько читателей.

Сообщение Центра Интернета вещей состоит из следующих компонентов.

• Предопределенный набор системных свойств , как описано далее в этой статье.

• Набор свойств приложения. Словарь свойств строки, которые приложение может задать и использовать без необходимости десериализации текста сообщения. Центр Интернета вещей никогда не изменяет эти свойства.

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

Каждый протокол устройства реализует свойства параметров различными способами. Дополнительные сведения см. в разделе "Обмен данными с центром Интернета вещей" с помощью протокола MQTT и взаимодействия с центром Интернета вещей с помощью протокола AMQP.

При отправке сообщений с устройства в облако с помощью протокола HTTPS или отправки сообщений из облака в устройство имена свойств и значения могут содержать только буквенно-цифровые символы ASCII, а также ! # $ % & ' * + - . ^ _ ` | ~ .

Отправка сообщений с устройства в облако с помощью Центра Интернета вещей имеет следующие характеристики:

• Сообщения, отправляемые с устройства в облако, устойчивы и хранятся в конечной точке по умолчанию messages/events Центра Интернета вещей до семи дней.

• Сообщения из устройства в облако могут составлять не более 256 КБ и группироваться в пакетах для оптимизации отправки. Размер пакетов не может превышать 256 КБ.

• Центр Интернета вещей не допускает произвольное секционирование. Сообщения, отправляемые с устройства в облако, секционируются по исходному идентификатору deviceId.

• Как описано в разделе "Управление доступом к Центру Интернета вещей" с помощью идентификатора Microsoft Entra, Центр Интернета вещей обеспечивает проверку подлинности на устройстве и управление доступом.

• Можно пометить сообщения данными, которые будут передаваться в свойства приложения. Дополнительные сведения см. в разделе "Обогащение сообщений" для сообщений Центра Интернета вещей в облаке.

Чтобы использовать текст сообщения в запросе маршрутизации в Центре Интернета вещей, укажите допустимый объект JSON для сообщения и задайте для свойства типа контента сообщения значение application/json;charset=utf-8.

В следующем примере показан допустимый, маршрутизируемый текст сообщения:

{
    "timestamp": "2022-02-08T20:10:46Z",
    "tag_name": "spindle_speed",
    "tag_value": 100
}

Системные свойства сообщений из устройства в облако

Свойства приложения сообщений из устройства в облако

Применение свойств приложения обычно заключается в отправке временной метки с устройства, используя свойство iothub-creation-time-utc, для фиксации времени отправки сообщения. Такая метка времени должна быть в формате UTC без сведений о часовом поясе. Например, значение 2021-04-21T11:30:16Z является допустимым, а 2021-04-21T11:30:16-07:00 — нет.

{
  "applicationId":"00001111-aaaa-2222-bbbb-3333cccc4444",
  "messageSource":"telemetry",
  "deviceId":"sample-device-01",
  "schema":"default@v1",
  "templateId":"urn:modelDefinition:mkuyqxzgea:e14m1ukpn",
  "enqueuedTime":"2021-01-29T16:45:39.143Z",
  "telemetry":{
    "temperature":8.341033560421833
  },
  "messageProperties":{
    "iothub-creation-time-utc":"2021-01-29T16:45:39.021Z"
  },
  "enrichments":{}
}

Системные свойства сообщений из облака на устройство

Имена системных свойств

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

Размер сообщения

Центр Интернета вещей измеряет размер сообщения вне зависимости от протокола, учитывая только фактический объем полезных данных. Размер в байтах вычисляется как сумма следующих значений:

• размер тела в байтах
• размер в байтах всех значений свойств системы сообщений;
• размер в байтах всех имен и значений свойств пользователей.

Имена и значения свойств ограничены символами ASCII, то есть длина строк равна размеру в байтах.

Свойства защиты от спуфинга

Чтобы избежать спуфинга устройств при работе с сообщениями, отправляемыми с устройства в облако, Центр Интернета вещей отмечает все сообщения такими свойствами:

• iothub-connection-device-id
• iothub-connection-auth-generation-id
• Метод iothub-connection-auth-method

Первые два свойства содержат параметры deviceId и generationId исходного устройства согласно разделу о свойствах удостоверений устройств.

Свойство iothub-connection-auth-method содержит сериализованный объект JSON, имеющий следующие свойства.

{
  "scope": "{ hub | device | module }",
  "type": "{ symkey | sas | x509 }",
  "issuer": "iothub"
}

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

• Сведения об ограничениях на размер сообщений в IoT Hub см. в Квоты и регулирование в IoT Hub.
• Сведения о создании и чтении сообщений Центра Интернета вещей на различных языках программирования см. в руководстве по отправке данных телеметрии с устройства IoT Plug and Play в Центр Интернета вещей Azure.
• Сведения о структуре событий, не связанных с телеметрией, созданных Центром Интернета вещей, см. в схемах событий, отличных от телеметрии Центра Интернета вещей Azure.