IoT Platform le permite usar un grupo de consumidores para suscribirse a los mensajes de un tema y reenviarlos a un servidor Advanced Message Queuing Protocol (AMQP). Este tema describe cómo configurar y gestionar una suscripción AMQP del lado del servidor en la consola de IoT Platform.
Requisitos previos
Cree un grupo de consumidores. Este grupo se usa para suscribirse a los mensajes de los temas. Puede usar el grupo de consumidores predeterminado (DEFAULT_GROUP) o crear uno nuevo en IoT Platform. Para obtener más información, consulte Manage consumer groups.
Configurar una suscripción
Para especificar el tipo de mensajes al que desea suscribirse, siga estos pasos:
Inicie sesión en la consola de IoT Platform.
En la página Overview, busque la instancia que desea gestionar y haga clic en su ID o nombre.
En el panel de navegación izquierdo, elija .
En la página Server-side Subscription, haga clic en Create Subscription.
-
En el cuadro de diálogo Create Subscription, configure los parámetros y haga clic en OK. A continuación se describen los parámetros.
Parámetro
Descripción
Products
Seleccione el producto al que pertenecen los dispositivos. Los mensajes que envían los dispositivos se envían a los consumidores.
Subscription Type
Seleccione AMQP.
Consumer Group
Seleccione los grupos de consumidores. Puede especificar varios grupos de consumidores para un producto y crear varias suscripciones para distintos productos dentro de un mismo grupo.
IoT Platform proporciona un grupo de consumidores predeterminado para consumir mensajes. Si desea agrupar los consumidores, siga estos pasos para crear un grupo: en la esquina inferior derecha del cuadro de diálogo Select Consumer Groups, haga clic en Create Consumer Group y configure los parámetros según las indicaciones. Para obtener más información, consulte Manage consumer groups.
Message Type
Seleccione los tipos de mensajes. Puede suscribirse a los siguientes tipos de mensajes de dispositivo. Para obtener más información sobre los temas básicos de comunicación, los temas de reenvío de mensajes y los formatos de datos relacionados, consulte Data formats.
ImportanteSi utiliza productos y dispositivos de puerta de enlace en la nube, IoT Platform solo envía los mensajes Device Upstream Notification, Device Status Change Notification y Device Changes Throughout Lifecycle a dichos productos y dispositivos. Para obtener más información sobre los temas de reenvío de mensajes y los formatos de datos, consulte Messaging over open source MQTT, Messaging over JT/T 808 y Messaging over GB/T 32960.
Device Upstream Notification: los mensajes de los temas cuyo parámetro Allowed Operations está establecido en Publish. Para obtener más información, consulte What is a topic.
Estos mensajes incluyen datos personalizados y datos de Thing Specification Language (TSL) enviados por los dispositivos. Los datos TSL ascendentes incluyen datos de propiedades, datos de eventos, respuestas a solicitudes de configuración de propiedades y respuestas a llamadas de servicio. IoT Platform procesa los datos TSL que se envían a los servidores de usuario. Para obtener más información, consulte Data formats.
Por ejemplo, suponga que se definen las siguientes categorías de temas para un producto:
/${YourProductKey}/${YourDeviceName}/user/get. El parámetro Allowed Operations de esta categoría de temas está establecido en Subscribe./${YourProductKey}/${YourDeviceName}/user/update. El parámetro Allowed Operations de esta categoría de temas está establecido en Publish./${YourProductKey}/${YourDeviceName}/thing/event/property/post. El parámetro Allowed Operations de esta categoría de temas está establecido en Publish.
La función de suscripción del lado del servidor envía los mensajes de las siguientes categorías de temas:
/${YourProductKey}/${YourDeviceName}/user/updatey/${YourProductKey}/${YourDeviceName}/thing/event/property/post.ImportanteSi desea suscribirse a los datos de respuesta de las llamadas de servicio asíncronas, compruebe que el ID de mensaje devuelto por el dispositivo coincida con el ID generado cuando IoT Platform envía los datos descendentes.
Device Status Change Notification: las notificaciones que envían los dispositivos cuando se conectan o desconectan.
Gateway's sub-devices discovery report: los datos de subdispositivos que envían las puertas de enlace cuando detectan nuevos subdispositivos. Las puertas de enlace deben contar con aplicaciones que puedan detectar subdispositivos. Este tipo de mensaje es exclusivo de las puertas de enlace.
Device Topological Relation Changes: las notificaciones que envían las puertas de enlace cuando se crean o eliminan relaciones topológicas entre los subdispositivos y dichas puertas de enlace. Este tipo de mensaje es exclusivo de las puertas de enlace.
Device Changes Throughout Lifecycle: las notificaciones que envían los dispositivos cuando se crean, eliminan, habilitan o deshabilitan.
TSL Historical Data Reporting: las propiedades y los eventos históricos que envían los dispositivos.
OTA Update Status Notification: las notificaciones que envían los dispositivos durante la verificación de firmware y la actualización por lotes. Se envía una notificación cuando una tarea de actualización de dispositivo es exitosa, falla, se cancela o está en ejecución.
Device tag change: los mensajes que envían los dispositivos cuando cambian sus etiquetas.
Submit a module version number: los mensajes que envían los dispositivos cuando cambian las versiones de los módulos de actualización inalámbrica (OTA).
Batch status notification: las notificaciones que envían los dispositivos cuando cambia el estado de los lotes de actualización OTA.
NotaCuando escucha los mensajes de los dispositivos, es posible que necesite filtrarlos o procesarlos. En ese caso, puede reenviar los mensajes a un grupo de consumidores AMQP mediante reglas de reenvío de datos. Después, podrá recibir los mensajes con el cliente AMQP. Para obtener más información, consulte Data forwarding.
Para obtener más información sobre cómo reenviar mensajes a un servidor AMQP y los temas de dispositivo a los que puede suscribirse, consulte Data formats.
Gestionar las suscripciones de un producto
Una vez configurada la suscripción, vaya a la página Server-side Subscription y busque el producto para el que la creó. Puede realizar varias operaciones en la suscripción. A continuación se describen estas operaciones.
Operación | Procedimiento |
Editar | Puede cambiar el grupo de consumidores y el tipo de mensaje.
|
Eliminar | Aviso Si los datos del dispositivo a los que se suscribió para el producto se usan en otras aplicaciones, sus servicios podrían dejar de estar disponibles o su negocio podría verse afectado. Proceda con precaución.
|
Pasos siguientes
Configure an AMQP client: Se recomienda usar el SDK de AMQP proporcionado por IoT Platform. Alibaba Cloud no admite los SDK de AMQP desarrollados por los usuarios.
Una vez completada la configuración y recibidos los datos del dispositivo en un cliente AMQP, siga estos pasos para consultar los registros en la consola de IoT Platform: elija . La pestaña Cloud run log muestra las entradas de registro generadas cuando un dispositivo envía datos, IoT Platform los reenvía al cliente AMQP y este devuelve un mensaje ACK.