Archivado | Responda a Mensajes y Maneje Flujos

Contenido archivado

Fecha de archivo: 2020-06-22

Este contenido ya no se actualiza ni se mantiene.
El contenido se proporciona “como está”.
Dada la rápida evolución de la tecnología, algunos contenidos, instrucciones o ilustraciones pueden haber cambiado.

Resumen

Las plataformas serverless, como Apache OpenWhisk, proporcionan un tiempo de ejecución que se escala automáticamente como respuesta a la demanda, lo que reduce el costo de los recursos en la nube y aumenta el valor empresarial. Uno de los principales casos de uso de OpenWhisk es la ejecución de la lógica como respuesta a eventos, como mensajes o flujos de datos.

Descripción

Este proyecto muestra el poder de las arquitecturas serverless basadas en eventos para ejecutar códigos como respuesta a mensajes o para manejar flujos de registros de datos.

La aplicación demuestra dos acciones de OpenWhisk (escritas en JavaScript) que leen y escriben mensajes con IBM Message Hub (basado en Apache Kafka). El caso práctico demuestra cómo las acciones pueden funcionar con servicios de datos y ejecutar lógica como respuesta a eventos de mensajes.

Una acción recibe los flujos de mensajes de uno o más registros de datos. Esos registros se canalizan hacia otra acción en una secuencia OpenWhisk (una forma de enlazar acciones de forma declarativa en una cadena). La segunda acción agrega el mensaje y publica en otro tema un mensaje con el resumen transformado.

Flujo

Diagrama de las etapas para crear la aplicación

  1. El desarrollador simula una aplicación de publicación del cliente y coloca una nueva matriz de objetos JSON en un tema de Apache Kafka.
  2. El mensaje lanza un evento llamado desencadenador, que escucha los mensajes que se envían a ese tema.
  3. Ese desencadenador es mapeado a la primera acción por una regla, que descarga y analiza la matriz de mensajes.
  4. Después, la matriz del mensaje se envía a otra acción en una secuencia para aumentar o reducir los datos a un único mensaje.
  5. La segunda acción envía el mensaje nuevo a otra fila del Message Hub para que lo procese otra aplicación.

Instrucciones

Encuentre los pasos detallados para este patrón en el archivo README.

Aviso

El contenido aquí presentado fue traducido de la página IBM Developer US. Puede revisar el contenido original en este link.