Streaming Hub en Lerian Console

El módulo Streaming Hub en Lerian Console muestra cómo el Hub entrega tus eventos. Úsalo para seguir la entrega, leer el catálogo de eventos y gestionar suscripciones. Gestión de suscripciones cubre las mismas tareas de suscripción con la API.

Acceder a Streaming Hub

El módulo funciona solo cuando Streaming Hub está activado para tu organización. Un administrador lo activa en Settings > Products. Consulta Productos. Abre el selector de productos en Lerian Console y selecciona Streaming Hub. La barra lateral tiene tres entradas: Dashboard, Event catalog y Subscriptions. Cuando Streaming Hub está desactivado, las páginas del módulo muestran un aviso que remite a esta configuración.

Dashboard

El módulo abre en el Dashboard. Muestra la entrega de eventos, tal como la midió el Hub. Una línea de estado en la parte superior muestra el número de suscripciones. También cuenta las suscripciones con estado Paused y las suscripciones que necesitan a una persona: Stopped by the Hub y Awaiting verification. Selecciona el período en la parte superior: 1h, 6h, 24h o 48h. El predeterminado es 24 horas. Para otra ventana, elige Custom y define un Start y una Duration. El inicio debe estar en el pasado. Debajo de los períodos, la Console muestra dónde empieza el historial que el Hub todavía guarda. Un período predefinido más amplio que ese historial no está disponible, y un Start anterior a él se rechaza. Cuando el Hub rechaza un período, el dashboard puede ofrecer un período que cabe, por ejemplo View the last 24 hours. El dashboard muestra:

Current state: las suscripciones en el momento de la captura, contadas por tipo de destino.
Events received: los eventos que el Hub recibió en el período, con un gráfico por hora o por día UTC. No es un conteo de entregas.
Push delivery: los jobs de entrega creados y los intentos de entrega por resultado, como Delivered o Failed.
Push backlog: los jobs de entrega en espera y cuánto tiempo lleva esperando el más antiguo.
Pull eligibility: los eventos que los consumidores pull tenían derecho a leer y los eventos ofrecidos a las suscripciones pull. El Hub no informa lo que leyó un consumidor.

Debajo, Needs attention lista las suscripciones que necesitan la atención de un operador en el período. Cada fila muestra la suscripción, su estado y sus motivos, y su último fallo. La columna Status and reasons dice por qué la fila está ahí, por ejemplo Repeated delivery failures o Destination not verified. Una fila ofrece Verify now cuando la suscripción lo necesita. Cuando no tienes ninguna suscripción, el dashboard ofrece View catalog.

Catálogo de eventos

Event catalog lista los eventos que anuncian los productores y qué tan actual es cada uno. La página agrupa los eventos por tema. Cada evento muestra su clave de evento, su versión de schema, una descripción, su recurso y su origen. La clave de evento es el valor que una suscripción toma como tipo de evento. Cada tema muestra un badge de actualización para cada productor, como Refreshed o Out of date. Usa Search the catalog para filtrar por clave de evento, descripción, tema o productor. Producers advertising no events lista los productores que el Hub recorre pero de los que no tiene ningún evento. Los botones Subscribe abren el asistente de creación con el productor o el evento ya elegido.

Suscripciones

Subscriptions lista adónde entrega el Hub tus eventos. La tabla muestra Name, Status, Destination y Created, con acciones por fila. La columna de destino muestra el tipo y el host. Filtra la lista por Exact name, Destination kind, Delivery y Verification. Cada suscripción tiene un estado: Delivering, Failing, Awaiting verification, Paused o Stopped by the Hub. Para abrir una suscripción, haz clic en su nombre.

Crear una suscripción

En la página Subscriptions, haz clic en New subscription. El asistente tiene tres pasos: Destination, Event types y Review and confirm.

Define el destino

Escribe un Name. La lista muestra ese nombre. Elige el Destination kind: Webhook, Pull, Amazon SQS, RabbitMQ o Amazon EventBridge. Luego escribe la dirección del tipo:

Endpoint para un webhook: una dirección https que Streaming Hub pueda alcanzar.
Queue URL para Amazon SQS. La Console rechaza una cola FIFO.
Exchange and routing key para RabbitMQ.
Event bus para Amazon EventBridge.

Una suscripción pull no tiene dirección. Para un webhook, también puedes definir un Delivery timeout de 1000 a 20000 milisegundos. El valor predeterminado es 10000.

Elige los tipos de evento

Define el Producing application: Any producer o un productor. Define el Schema version. Déjalo vacío para usar la versión 1. Luego elige todos los tipos de evento, incluidos los que se publiquen después en esta versión de schema. O elige solo los tipos de evento que selecciones del catálogo, cada uno con su propia versión de schema. Next espera hasta que el catálogo responda.

Revisa y confirma

Revisa las opciones. Luego haz clic en Create subscription.

Para un webhook, el cuadro de diálogo Subscription created muestra el secreto de firma. Streaming Hub lo devuelve exactamente una vez. Cópialo y luego selecciona I have copied the signing secret and stored it safely. Después haz clic en Verify now para enviar una solicitud firmada a tu endpoint, o en Verify later. Streaming Hub no entrega nada al destino hasta que una solicitud firmada llegue a él y tenga éxito. Para una suscripción pull, el cuadro de diálogo Pull subscription created muestra el ID de la suscripción. Una suscripción pull no tiene secreto de firma: tu consumidor se autentica con su propio token. Consulta Consumo de eventos. Para una suscripción de cola, la Console abre la página de la suscripción. Allí defines su credencial.

La página de la suscripción

El encabezado muestra la acción que corresponde al estado: Verify now, Set credential, Rotate signing secret o Resume. También tiene un botón Edit y un menú. La página tiene dos pestañas, Overview y Delivery health. La pestaña Overview tiene estas tarjetas:

Destination: el host, el tipo de destino y el estado. Show full destination muestra la dirección completa en la tarjeta. Exige el permiso para crear suscripciones.
Delivery: los tipos de evento, el productor, la versión de schema, la versión de firma, el plan, el timeout de entrega de un webhook, la última verificación, la próxima verificación automática, la fecha de creación y la fecha del último cambio.
Credential: el tipo de credencial, como Cross-account role o Stored queue credential, y la última vez que cambió la credencial. El Hub nunca devuelve material secreto en una lectura, así que la tarjeta no puede mostrarlo.
How to consume this subscription: para una suscripción pull, cómo la lee tu servicio.

La pestaña Delivery health muestra la tasa de éxito por intento, el último éxito y el último fallo, los intentos en dead-letter, los eventos en cuarentena, el retraso del consumidor y los resultados de los intentos. La pestaña dice qué intervalo cubren los conteos. Una suscripción que espera verificación, o que el Hub detuvo, muestra un aviso en la parte superior con la acción que hay que tomar. El Streaming Hub también vuelve a enviar una solicitud firmada a un webhook que sigue pendiente, y un éxito activa la suscripción, salvo que la suscripción esté en pausa.

Editar una suscripción

Haz clic en Edit para cambiar el Name, el destino (no en una suscripción pull), los tipos de evento, el Schema version y, para un webhook, el Delivery timeout. La suscripción conserva su ID y su credencial. En una suscripción activa, el Hub prueba el destino nuevo antes de guardarlo, y una prueba fallida no cambia nada. Una suscripción que espera verificación guarda el destino nuevo, y el Hub lo verifica como a una suscripción nueva. Para cambiar el tipo de destino, crea una suscripción nueva.

Definir la credencial de una suscripción de cola

Una suscripción de cola es una suscripción de Amazon SQS, RabbitMQ o Amazon EventBridge. No entrega nada hasta que Streaming Hub alcance el destino con una credencial. Haz clic en Set credential.

RabbitMQ pide un AMQP URI.
Amazon SQS y Amazon EventBridge piden una AWS region, un Access key ID y una Secret access key. El panel lista los permisos de AWS que necesita la clave.

Streaming Hub prueba el login antes de guardar la credencial. Si la prueba falla, el Hub conserva la credencial anterior y el panel muestra el resultado. Cuando el Hub guarda la credencial, la Console verifica el destino, salvo que la suscripción esté en pausa. El Hub nunca devuelve la credencial en una lectura. Una suscripción con rol entre cuentas no ofrece Set credential.

Pausar o reanudar una suscripción

Selecciona Pause en el menú de la fila o en el menú de la página de la suscripción y confirma. El Hub detiene la entrega de inmediato. No entrega las entregas que esperan en la cola ni los eventos que llegan mientras la suscripción está en pausa. Una suscripción en pausa muestra un aviso en la parte superior. Haz clic en Resume en el encabezado para reiniciarla. El Hub entonces entrega solo los eventos que llegan después de la reanudación. En una suscripción pull, la posición de lectura pasa al evento más reciente, así que se omite todo evento que tu consumidor aún no leyó. Tu consumidor todavía puede leer esos eventos con ?after= dentro de la retención. Consulta Pausa y reanudación de una suscripción. Una suscripción que el Hub detuvo no ofrece Pause: usa Verify now.

Verificar, rotar o eliminar una suscripción

Verify now verifica el destino. Para un webhook, envía una solicitud real y firmada a tu endpoint. La Console no la ofrece para un webhook que está activo y con su interruptor encendido. Es la única acción que reinicia una suscripción que el Hub detuvo.
Rotate signing secret es para un webhook que tiene un secreto de firma. El cuadro de diálogo Rotate the signing secret emite un secreto nuevo y lo muestra una vez. El Hub firma cada entrega con los dos secretos hasta el plazo que muestra el cuadro de diálogo. Haz clic en Rotate the secret para confirmar.
Delete subscription detiene la entrega. Escribe el nombre de la suscripción para confirmar y luego haz clic en Delete subscription. El cuadro de diálogo dice qué cuesta la eliminación para el tipo. Si creas una suscripción webhook de nuevo, recibe un secreto de firma nuevo. Una suscripción pull pierde la posición hasta la que leyó tu consumidor.

Introducción

Access Manager

Console

Streaming Hub

Multi-tenancy

Observabilidad

Lifecycle Management

Licenciamiento