Чтение сообщений, пересылаемых с устройства в облако, из встроенной конечной точки
По умолчанию сообщения направляются во встроенную конечную точку, доступную для службы (/messages/events), которая совместима с Центрами событий. Центр Интернета вещей предоставляет встроенную конечную точку messages/events, с помощью которой внутренние службы считывают сообщения, отправляемые в Центр с устройства в облако. Эта конечная точка совместима с Центрами событий, поэтому можно использовать любой из механизмов для чтения сообщений, который поддерживает служба "Центры событий".
Если вы используете маршрутизацию сообщений, а резервный маршрут включен, сообщение, которое не соответствует запросу на любом маршруте, переходит к встроенной конечной точке. Если отключить этот резервный маршрут, сообщение, которое не соответствует запросу, удаляется.
Эта конечная точка в настоящее время предоставляется только через протокол AMQP для порта 5671 и AMQP через WebSocket для порта 443. Центр Интернета вещей позволяет управлять встроенной конечной точкой обмена сообщениями messages/events, совместимой с концентраторами событий, с помощью приведенных ниже свойств.
| Свойство | Description |
|---|---|
| Количество секций | Это свойство задается во время создания, чтобы определить количество разделов для приема событий, отправляемых с устройства в облако. |
| Время хранения | Это свойство задает время в днях, в течение которого сообщения хранятся в Центре Интернета вещей. Значение по умолчанию — один день, но это значение можно увеличить до семи дней. |
Центр Интернета вещей позволяет сохранять данные в встроенной конечной точке не более семи дней. Вы можете задать время хранения во время создания Центра Интернета вещей. Время хранения данных в Центре Интернета вещей зависит от уровня вашего Центра Интернета вещей и типа единицы. С точки зрения размера встроенная конечная точка может хранить сообщения максимального размера сообщения не менее 24 часов квоты. Например, один центр Интернета вещей единиц S1 предоставляет достаточно места для хранения по крайней мере 400 000 сообщений по 4 КБ на сообщение. Если ваши устройства отправляют небольшие сообщения, они могут храниться дольше (до семи дней) в зависимости от объема используемого хранилища. Мы гарантированно сохраняем данные за указанное время хранения как минимум. После истечения срока хранения сообщения истекают и становятся недоступными. Период хранения можно изменить на портале Azure или программно (с помощью интерфейсов REST API поставщика ресурсов Центра Интернета вещей).
Центр Интернета вещей также позволяет управлять группами потребителей на встроенной конечной точке. Для каждого центра Интернета вещей можно использовать до 20 групп потребителей.
Подключение встроенной конечной точке
Некоторые интеграции продуктов и пакеты SDK Центров событий осведомлены о Центре Интернета вещей и позволяют использовать строку подключения к службе Центра Интернета вещей для подключения к встроенной конечной точке.
При использовании пакетов SDK Центров событий или интеграций продуктов, которые не осведомлены о Центре Интернета вещей, вам потребуется конечная точка, совместимая с Центрами событий, и имя, совместимое с Центрами событий. Вы можете получить эти значения на портале следующим образом.
Войдите на портал Azure и перейдите к своему Центру Интернета вещей.
Выберите встроенные конечные точки в меню ресурсов в разделе "Параметры концентратора".
Встроенная рабочая область конечных точек содержит три раздела:
- В разделе "Сведения о концентраторе событий" содержатся следующие значения: секции, совместимые с концентратором событий, сохранение и группы потребителей.
- Раздел совместимой конечной точки Концентратора событий содержит следующие значения: политика общего доступа и конечная точка, совместимая с Концентратором событий.
- В разделе обмена сообщениями об облаке на устройство содержатся следующие значения: TTL по умолчанию, время хранения отзывов и максимальное количество доставки.
В рабочей области поле конечной точки, совместимой с Концентратором событий, содержит полные строка подключения Центров событий, которые выглядят следующим образом:
Endpoint=sb://abcd1234namespace.servicebus.windows.net/; SharedAccessKeyName=iothubowner; SharedAccessKey=keykeykey=; EntityPath=iothub-ehub-abcd-1234-123456
Используемому вами пакету SDK могут требоваться другие значения, которые перечислены ниже.
| Имя. | Значение |
|---|---|
| Конечная точка | sb://abcd1234namespace.servicebus.windows.net/ |
| Hostname (Имя узла) | abcd1234namespace.servicebus.windows.net |
| Пространство имен | abcd1234namespace |
Затем можно выбрать любую политику общего доступа в раскрывающемся списке политики общего доступа, как показано на предыдущем снимке экрана. В нем отображаются только политики, имеющие разрешения службы Подключение для подключения к указанному концентратору событий.
Примеры пакетов SDK
Ниже перечислены некоторые пакеты SDK, которые можно использовать для подключения к предоставленной Центром Интернета вещей встроенной конечной точке, совместимой с Центрами событий.
Ниже перечислены некоторые интеграции продуктов, которые можно использовать с предоставленной Центром Интернета вещей встроенной конечной точкой, совместимой с Центрами событий.
-
Дополнительные сведения см. в Центр Интернета вещей Azure привязках для Функции Azure.
-
Дополнительные сведения см. в разделе Stream Data as input в Stream Analytics.
Аналитика временных рядов Azure
Дополнительные сведения см. в статье "Добавление источника событий Центра Интернета вещей" в среду Аналитики временных рядов Azure.
-
Дополнительные сведения см. в руководстве разработчика Apache Kafka для Центры событий Azure.
Следующие шаги
Дополнительные сведения о конечных точках Центра Интернета вещей см. в статье Руководство. Конечные точки Центра Интернета вещей.
Сведения о перенаправлении сообщений, отправляемых с устройства в облако, на пользовательские конечные точки см. в статье Использование правил маршрутизации и пользовательских конечных точек для сообщений, отправляемых с устройства в облако.