Ler eventos com um cursor - Lerian

Leia seus eventos no seu próprio ritmo, sem expor um endpoint.

Participantes

Sua instituição. Seu sistema chama a API do Streaming Hub com um token do Access Manager.
Streaming Hub. O serviço de plataforma da Lerian que guarda seus eventos em ordem de chegada e os devolve página por página. A Lerian o configura para sua instituição.
Produto Lerian. O produto que publica o evento de negócio, por exemplo o Midaz.

Diagrama

Ler eventos com um cursor

Passo a passo

#	Origem	Destino	Mensagem	API da Lerian	O que acontece
1	Sua instituição	Streaming Hub	API da Lerian	`POST /v1/subscriptions`	Crie a subscription com um `name`, `sink_kind` `pull` e os `event_types` que você quer. Não envie endpoint. Envie um header `X-Idempotency` único.
2	Streaming Hub	Sua instituição	Resposta		A subscription fica `active` na hora. Uma subscription pull não precisa de ping e não tem segredo de assinatura.
3	Produto Lerian	Streaming Hub	Evento		O produto publica um evento de negócio.
4	Streaming Hub	Streaming Hub	Etapa interna		O Streaming Hub guarda o evento e dá a ele um número de sequência, `seq`, em ordem de chegada.
5	Sua instituição	Streaming Hub	API da Lerian	`GET /v1/events`	Leia uma página com `subscription_id`. O `limit` opcional vai de 1 a 500, e o padrão é 100.
6	Streaming Hub	Streaming Hub	Etapa interna		O Streaming Hub move o cursor da subscription para o maior `seq` da página. A leitura é a confirmação.
7	Streaming Hub	Sua instituição	Resposta		A página traz os eventos em ordem de `seq`, cada um com seu `ceId`, e o `next_cursor`.
8	Sua instituição	Sua instituição	Etapa interna		Processe os eventos. Ignore um `ceId` que você já processou.
9	Sua instituição	Streaming Hub	API da Lerian	`GET /v1/events`	Leia a próxima página. Envie o `next_cursor` como `after`, ou não envie `after` para continuar a partir do cursor.
10	Streaming Hub	Sua instituição	Resposta		Quando a página tem menos eventos que o `limit`, o `next_cursor` é `null`.

Como saber que terminou

Uma leitura devolve next_cursor null.

Seu sistema para depois de uma leitura. O cursor já passou daquela página. Leia de novo com after igual ao último seq que você processou. Essa leitura não move o cursor para trás.
A leitura é recusada por limite de taxa. A leitura responde 429 rate_limited. Espere os segundos de Retry-After e leia de novo.

Relacionados