IoT Platform:Reenviar datos a un grupo de consumidores AMQP

Requisitos previos

• Se creó una regla de reenvío de datos y se escribió la instrucción SQL correspondiente para procesar la información. Para obtener más detalles, consulte Configure a data forwarding rule.

• Se configuró un grupo de consumidores AMQP como destino del reenvío de datos. Para más información sobre cómo crear y gestionar grupos de consumidores, consulte Manage consumer groups.

Procedimiento

1. Inicie sesión en la consola de IoT Platform.

2. En la página Overview, localice la instancia que desea gestionar y haga clic en su ID o nombre.

3. En el panel de navegación izquierdo, seleccione Message Forwarding > Data Forwarding.

4. Haga clic en View junto a la regla deseada. Aparecerá la página Data Forwarding Rule.

   Importante

   Si se muestra la página Data Forwarding (New Version), haga clic en Back to Previous Version en la esquina superior derecha y luego haga clic en View junto a la regla correspondiente.

5. En la sección Forward Data, haga clic en Add Operation.

6. En el cuadro de diálogo Add Operation, seleccione Publish to AMQP Subscribed Consumer Group. Configure los parámetros obligatorios según las indicaciones y haga clic en OK.

   

   Parámetro	Descripción
   Select Operation	Seleccione Publish to AMQP Subscribed Consumer Group.
   Consumer Group	Elija un grupo de consumidores existente como destino del reenvío de datos. Haga clic en Create Consumer Group para crear uno nuevo.
   Tag	Si establece una etiqueta, esta se agregará a todos los mensajes que esta operación reenvíe al grupo de consumidores AMQP. La etiqueta debe tener entre 1 y 128 caracteres. Es posible especificar una constante o una variable. Una constante puede contener letras y dígitos. Si utiliza una variable, emplee el formato ${key}. ${key} indica que la variable hace referencia al valor de una clave en el resultado JSON de una instrucción SQL. Si el valor no está available, no se agregará ninguna etiqueta a los mensajes.

7. En la página Data Forwarding, localice la regla y haga clic en Start dentro de la columna Actions.

Configurar un cliente AMQP para consumir mensajes

Una vez que los datos se reenvían al grupo de consumidores AMQP, el servidor consume los mensajes mediante el cliente AMQP. Para obtener más información sobre cómo configurar un cliente AMQP, consulte Connect an AMQP client.

Para consultar ejemplos de código sobre la implementación del cliente AMQP, revise a continuación temas:

• Java SDK connection example

• .NET SDK connection example

• Node.js SDK connection example

• Python 2.7 SDK connection example

• Python 3 SDK connection example

• PHP SDK connection example

• Go SDK connection example