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

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

Для реализация отправки сообщений с устройства в облако Центр Интернета вещей использует модель потоковой передачи сообщений. сообщения IoT Hub от устройств к облаку больше похожи на события Event Hubs, чем на сообщения Service Bus, поскольку через службу проходит большой объем событий, которые могут прочитать несколько читателей.

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

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

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

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

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

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

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

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

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

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

• Как поясняется в статье Управление доступом к Центру Интернета вещей, Центр Интернета вещей обеспечивает аутентификацию и контроль доступа для каждого устройства.

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

Чтобы использовать текст сообщения в запросе маршрутизации в Центре Интернета вещей, укажите допустимый объект 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 Hub на различных языках программирования, из раздела Быстрый старт.
• Сведения о структуре событий, не связанных с телеметрией, генерируемых Центром Интернета вещей, см. в разделе Схемы нетелеметрических событий Центра Интернета вещей.