Pipeline

Entenda como um pipeline é construído.

Micaella Mazoni avatar
Escrito por Micaella Mazoni
Atualizado há mais de uma semana

IMPORTANTE: esta documentação foi descontinuada. Leia a documentação Pipeline atualizada no nosso novo portal de documentação.

A Plataforma 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:

  • 1 trigger

  • pelo menos mais 1 componente

IMPORTANTE: trigger e componentes precisam estar conectados entre si.

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 via agendamento.

Um componente é um elemento que recebe uma mensagem, podendo interagir ou utilizar as informações dela para executar uma das seguintes atividades:

  • chamar serviços externos (por exemplo, uma chamada a um endpoint REST);

  • processar mensagens (por exemplo, transformar o conteúdo da mensagem);

  • alterar o fluxo de execução (por exemplo, uma bifurcação que permite direcionar o fluxo do pipeline com base em uma condição, como o componente Choice faz);

  • percorre coleções (por exemplo, For Each).

Este último caso é um pouco mais sofisticado e para entendê-lo precisamos examiná-lo mais detalhadamente.

Quando você utiliza um componente que itera em coleções, a estrutura de pipeline torna-se um pouco cada elemento da coleção que é processado/tratado em um fluxo separado, que chamamos de subpipelines. Veja a imagem abaixo:

  1. a execução do processo principal vai acontecendo até chegar ao componente onde o subpipeline é criado (no exemplo acima, o componente é o For Each - Processa Registros);

  2. a execução passa para o subpipeline, onde um item da coleção será tratado individualmente;

  3. ao término da execução desse item, o controle volta ao início do subpipeline, que inicia o processamento do item seguinte e assim sucessivamente, até que a coleção seja totalmente processada;

  4. uma vez que toda a coleção tenha sido processada, o controle volta para o componente For Each que, com a sua execução finalizada, passa o processamento ao próximo componente do processo principal (no caso, o componente “Lê todos os Dados”).

Para saber como construir um subpipeline, é só clicar aqui.

Respondeu à sua pergunta?