Amazon EventBridge Pipes
Os pipes do Amazon EventBridge conectam as origens aos destinos. Os pipes são destinados a funcionar como integrações ponto a ponto entre origens e destinos compatíveis, com suporte para transformações e enriquecimento avançados. Ele reduz a necessidade de conhecimento especializado e código de integração ao desenvolver arquiteturas orientadas por eventos, promovendo a consistência em todas as aplicações da sua empresa. Para configurar um pipe, a origem é escolhida, adiciona filtragem opcional, define o enriquecimento opcional e escolhe o destino para os dados do evento.
nota
Também é possível rotear eventos usando barramentos de eventos. Os barramentos de eventos são adequados para o roteamento de muitos para muitos eventos entre serviços orientados a eventos. Para ter mais informações, consulte Barramentos de eventos no Amazon EventBridge.
Como funcionam o EventBridge Pipes
Em um nível alto, veja como o EventBridge Pipes funciona:
Você cria um pipe na sua conta. Isso inclui:
Especificar uma das origens de eventos compatíveis da qual deseja que seu pipe receba eventos.
Opcionalmente, configurar um filtro para que o pipe processe somente um subconjunto dos eventos que recebe da origem.
Opcionalmente, configurar uma etapa de enriquecimento que aprimore os dados do evento antes de enviá-los ao destino.
Especificar um dos destinos compatíveis para os quais você deseja que seu pipe envie eventos.
A origem do evento começa a enviar eventos para o pipe e o pipe processa o evento antes de enviá-lo ao destino.
Se configurou um filtro, o pipe avalia o evento e só o envia para o destino se ele corresponder a esse filtro.
Somente há cobrança pelos eventos que correspondem ao filtro.
Se um enriquecimento foi configurado, o pipe executa esse enriquecimento no evento antes de enviá-lo ao destino.
Se os eventos forem agrupados, o enriquecimento manterá a ordem dos eventos no lote.
Por exemplo, um pipe pode ser usado para criar um sistema de comércio eletrônico. Supõe-se que tenha uma API que contém informações do cliente, como endereços de entrega.
É possível pode criar um pipe com o seguinte:
Um pedido do Amazon SQS recebeu uma fila de mensagens como origem do evento.
Um destino da API do EventBridge como um enriquecimento
Uma máquina de estado AWS Step Functions como o destino
Então, quando uma mensagem de pedido recebido do Amazon SQS aparece na fila, ela é enviada para o seu pipe.
O pipe envia esses dados para o enriquecimento de destino da API do EventBridge, que retorna as informações do cliente para esse pedido.
Por fim, o pipe envia os dados enriquecidos para a máquina de estado do AWS Step Functions, que processa o pedido.
