Pipeline
Aprenda mais sobre o conceito de pipeline na Digibee Integration Platform.
Atualizado
Isto foi útil?
Aprenda mais sobre o conceito de pipeline na Digibee Integration Platform.
Atualizado
Isto foi útil?
A Digibee Integration Platform tem como peça central o pipeline, que é uma sequência de componentes que permite conectar sistemas e estabelecer fluxos de dados entre eles.
Um pipeline é composto por:
Um trigger
Pelo menos um componente
O trigger precisa estar conectado aos componentes.
O trigger é a condição de disparo do pipeline, ou seja, é um elemento que define como a execução do pipeline será iniciada – por exemplo, através de uma chamada externa, em resposta a um evento ou por um agendamento. Para saber mais, leia a documentação sobre Triggers.
Um componente é um elemento que recebe uma mensagem, podendo interagir ou utilizar as informações contidas nela para executar uma das seguintes atividades:
Chamar serviços externos, como uma chamada a um endpoint REST.
Processar mensagens transformando o conteúdo da mensagem.
Alterar o fluxo de execução com uma bifurcação que permite direcionar o fluxo do pipeline com base em uma condição, como o componente Choice faz.
Percorrer coleções, como o componente For Each faz.
Este último caso é um pouco mais sofisticado e, para entendê-lo, precisamos examiná-lo mais de perto.
Quando você utiliza um componente que itera em coleções, cada item da coleção é processado em um fluxo separado chamado subpipeline. Veja a imagem abaixo:
A execução do fluxo principal acontece até chegar ao componente onde o subpipeline é criado (no exemplo acima, o componente é o For Each, que foi nomeado como “Processa registros”).
A execução passa para o subpipeline, onde cada item da coleção será tratado individualmente.
Ao término da execução do item 2, o controle volta ao início do subpipeline, que inicia o processamento do próximo item e assim sucessivamente, até que a coleção seja totalmente processada.
Uma vez que toda a coleção tenha sido processada, o controle retorna ao componente For Each, que direciona o fluxo para o próximo componente do fluxo principal (no caso, o componente Object Store nomeado como “Lê todos os dados”).
Para saber mais, leia o artigo Subpipelines.
