Servicio Stream

Ahora puede usar un servicio Stream para publicar y suscribirse a flujos de registros de datos, almacenar flujos de registros y procesar datos en tiempo real. El servicio Stream está desarrollado a partir de la plataforma Apache Kafka. Con el servicio Stream, puede crear conductos de datos en flujo en tiempo real para transferir datos entre sistemas y aplicaciones. También puede desarrollar aplicaciones que transforman flujos de datos y que reaccionan ante ellos.

El servicio Stream ingiere, enruta y entrega grandes volúmenes de datos de latencia baja, como clics de páginas web, transacciones, datos de sensores, objetos de datos, páginas de datos e historiales de interacción con clientes. Como mecanismo de resiliencia para las operaciones, los mismos datos se replican a otros nodos en el clúster. La distribución y la replicación de los registros de datos de flujos aseguran la escalabilidad y la tolerancia ante fallos del servicio Stream. El servicio se ejecuta como un clúster en un servidor o más. Puede distribuir los servidores entre varios centros de datos para minimizar el tiempo de inactividad planificado o no planificado.

El servicio Stream posibilita el flujo asincrónico de datos entre procesos en Pega Platform™. El servicio Stream es un componente de varios nodos basado en Apache Kafka. Puede usar este servicio, por ejemplo, para transferir datos de correspondencia a canales de entrega de Pega Customer Decision Hub, procesar respuestas de clientes para el Adaptive Decision Manager (ADM) o iniciar procesos en segundo plano en cualquier aplicación de Pega.

Para asegurarse de que el servicio Stream funcione sin generar errores, supervise regularmente el estado de los nodos de Stream, además de las particiones, el espacio en el disco, el uso de la CPU y la disponibilidad de la base de datos.

Puede realizar una comprobación de estado sencilla y manual del servicio Stream; para ello, vaya a la landing page de Stream : en el encabezado de Dev Studio, haga clic en Configure > Decisioning > Infrastructure > Services > Stream (Configurar > Toma de decisiones > Infraestructura > Servicios > Stream). El servicio Stream depende de la disponibilidad de la base de datos de Pega Platform. Una base de datos lenta o que no está disponible podría tener un grave impacto en el servicio Stream.

Para comprender el estado del servicio Stream, supervise las consultas a las siguientes tres bases de datos:

• pr_data_stream_sessions
• pr_data_stream_nodes
• pr_data_stream_node_updates

Si las consultas toman más de 1 segundo, considere ajustar su base de datos. En el caso de que la base de datos no esté disponible, ya sea de manera planificada o no, considere reiniciar los nodos de flujo, sobre todo si nota que no están en buen estado.