Чтение сообщений, пересылаемых с устройства в облако, из встроенной конечной точки
По умолчанию сообщения направляются во встроенную конечную точку, доступную для службы (/messages/events), которая совместима с Центрами событий. Центр Интернета вещей предоставляет встроенную конечную точку messages/events, с помощью которой внутренние службы считывают сообщения, отправляемые в Центр с устройства в облако. Эта конечная точка совместима с Центрами событий, поэтому можно использовать любой из механизмов для чтения сообщений, который поддерживает служба "Центры событий".
Если вы используете маршрутизацию сообщений, а резервный маршрут включен, сообщение, которое не соответствует запросу на любом маршруте, переходит к встроенной конечной точке. Если отключить этот резервный маршрут, сообщение, которое не соответствует запросу, удаляется.
Эта конечная точка в настоящее время предоставляется только через протокол AMQP для порта 5671 и AMQP через WebSocket для порта 443. Центр Интернета вещей предоставляет следующие свойства, чтобы управлять встроенными сообщениями и событиями, совместимыми с центрами событий.
| Свойство | Description |
|---|---|
| Количество секций | Это свойство задается во время создания, чтобы определить количество разделов для приема событий, отправляемых с устройства в облако. |
| Время хранения | Это свойство указывает, сколько времени в днях Центр Интернета вещей сохраняет сообщения. Значение по умолчанию — один день, но это значение можно увеличить до семи дней. |
Центр Интернета вещей позволяет сохранять данные в встроенной конечной точке не более семи дней. Вы можете задать время хранения во время создания Центра Интернета вещей. Время хранения данных в Центре Интернета вещей зависит от уровня вашего Центра Интернета вещей и типа единицы. С точки зрения размера встроенная конечная точка может хранить сообщения максимального размера сообщения не менее 24 часов квоты. Например, один центр Интернета вещей единиц S1 предоставляет достаточно места для хранения по крайней мере 400 000 сообщений в 4 КБ на сообщение. Если ваши устройства отправляют небольшие сообщения, они могут храниться дольше (до семи дней) в зависимости от объема используемого хранилища. Мы гарантированно сохраняем данные за указанное время хранения как минимум. После срока хранения сообщения истекают и становятся недоступными. Время хранения можно изменить программным способом с помощью REST API поставщика ресурсов Центр Интернета вещей или с помощью портал Azure.
Центр Интернета вещей также позволяет управлять группами потребителей на встроенной конечной точке. Для каждого центра Интернета вещей можно использовать до 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 |
Затем можно выбрать любую политику общего доступа в раскрывающемся списке политики общего доступа, как показано на предыдущем снимке экрана. В нем отображаются только политики, имеющие разрешения ServiceConnect для подключения к указанному концентратору событий.
Примеры пакетов SDK
Пакеты SDK, которые можно использовать для подключения к встроенной конечной точке, совместимой с Центрами событий, которую предоставляет Центр Интернета вещей:
Подключение к другим службам и продуктам
Интеграции продукта, которые можно использовать со встроенной конечной точкой, совместимой с Центрами событий, которую предоставляет Центр Интернета вещей:
-
Дополнительные сведения см. в Центр Интернета вещей Azure привязках для Функции Azure.
-
Дополнительные сведения см. в разделе Stream Data as input в Stream Analytics.
Аналитика временных рядов Azure
Дополнительные сведения см. в статье "Добавление источника событий Центра Интернета вещей" в среду Аналитики временных рядов Azure.
-
Дополнительные сведения см. в руководстве разработчика Apache Kafka для Центры событий Azure.
Следующие шаги
Дополнительные сведения о конечных точках Центра Интернета вещей см. в статье Руководство. Конечные точки Центра Интернета вещей.
Сведения о перенаправлении сообщений, отправляемых с устройства в облако, на пользовательские конечные точки см. в статье Использование правил маршрутизации и пользовательских конечных точек для сообщений, отправляемых с устройства в облако.