Leer eventos con un cursor - Lerian

Lee tus eventos a tu propio ritmo, sin exponer un endpoint.

Participantes

Tu institución. Tu sistema llama a la API de Streaming Hub con un token de Access Manager.
Streaming Hub. El servicio de plataforma de Lerian que guarda tus eventos en orden de llegada y los devuelve página por página. Lerian lo configura para tu institución.
Producto Lerian. El producto que publica el evento de negocio, por ejemplo Midaz.

Diagrama

Leer eventos con un cursor

Pasos

#	Origen	Destino	Mensaje	API de Lerian	Qué ocurre
1	Tu institución	Streaming Hub	API de Lerian	`POST /v1/subscriptions`	Crea la suscripción con un `name`, `sink_kind` `pull` y los `event_types` que quieres. No envíes endpoint. Envía un header `X-Idempotency` único.
2	Streaming Hub	Tu institución	Respuesta		La suscripción queda `active` de inmediato. Una suscripción pull no necesita ping y no tiene secreto de firma.
3	Producto Lerian	Streaming Hub	Evento		El producto publica un evento de negocio.
4	Streaming Hub	Streaming Hub	Paso interno		Streaming Hub guarda el evento y le da un número de secuencia, `seq`, en orden de llegada.
5	Tu institución	Streaming Hub	API de Lerian	`GET /v1/events`	Lee una página con `subscription_id`. El `limit` opcional va de 1 a 500, y el predeterminado es 100.
6	Streaming Hub	Streaming Hub	Paso interno		Streaming Hub mueve el cursor de la suscripción al mayor `seq` de la página. La lectura es la confirmación.
7	Streaming Hub	Tu institución	Respuesta		La página trae los eventos en orden de `seq`, cada uno con su `ceId`, y el `next_cursor`.
8	Tu institución	Tu institución	Paso interno		Procesa los eventos. Ignora un `ceId` que ya procesaste.
9	Tu institución	Streaming Hub	API de Lerian	`GET /v1/events`	Lee la página siguiente. Envía el `next_cursor` como `after`, o no envíes `after` para seguir desde el cursor.
10	Streaming Hub	Tu institución	Respuesta		Cuando la página tiene menos eventos que el `limit`, el `next_cursor` es `null`.

Cómo saber que terminó

Una lectura devuelve next_cursor null.

Tu sistema se detiene después de una lectura. El cursor ya pasó esa página. Lee de nuevo con after igual al último seq que procesaste. Esa lectura no mueve el cursor hacia atrás.
La lectura se rechaza por rate limit. La lectura responde 429 rate_limited. Espera los segundos de Retry-After y lee de nuevo.

Relacionados