Pipeline Executor

Descubra mais sobre o componente Pipeline Executor e saiba como usá-lo na Digibee Integration Platform.

O componente Pipeline Executor realiza chamadas síncronas ou assíncronas a outros pipelines já implantados. Utilizando abordagem síncrona, é possível obter o resultado do pipeline chamado.

Parâmetros

Dê uma olhada nas opções de configuração do componente. Parâmetros suportados por expressões Double Braces estão marcados com (DB).

Parâmetro	Descrição	Valor padrão	Tipo de dado
Operation	SYNC para chamadas síncronas ao pipeline e ASYNC para chamadas assíncronas ao pipeline.	SYNC	String
Pipeline Name	Nome do pipeline a ser chamado.	N/A	String
Version Major	Versão major do pipeline a ser chamado.	1	Inteiro
Payload	Payload a ser enviado no chamado do pipeline.	N/A	Qualquer
Timeout	Tempo máximo de execução do pipeline (em milissegundos).	20000	Inteiro
Expiration	Tempo de permanência da mensagem em fila ao tentar executar o pipeline (em milissegundos).	30000	Inteiro
Fail On Error	Se a opção estiver ativada, a execução do pipeline com erro será interrompida; do contrário, a execução do pipeline continua, mas o resultado mostrará um valor falso para a propriedade "success".	False	Booleano

Fluxo de mensagens

Entrada

Não se espera nenhum payload específico na entrada desse componente. A entrada será configurada dinamicamente no campo Payload conforme a necessidade do pipeline a ser chamado.

Saída

{
   "operation": "SYNC",
   "pipelineName": "pipeline-example",
   "versionMajor": 1,
   "success": true,
   "payload": {},
   "pipelineResponse": {}
}

• operation: operação selecionada, SYNC ou ASYNC.

• pipelineName: nome do pipeline chamado.

• versionMajor: versão major do pipeline chamado.

• success: se a chamada foi feita com sucesso.

• payload: payload utilizado para chamar o pipeline configurado.

• pipelineResponse: resposta do pipeline executado. Essa propriedade é retornada apenas na operação SYNC.

Pipeline Executor em ação

Veja abaixo como o componente se comporta em determinadas situações e como é configurado em cada caso.

Realizando uma chamada assíncrona

Operation: ASYNC

Pipeline Name: nome do pipeline a ser chamado

Version Major: 1

Payload: {}

Timeout: 20000

Expiration: 30000

Fail On Error: false

No cenário acima, será feita uma chamada assíncrona ao pipeline configurado e o fluxo atual seguirá normalmente sem esperar a resposta do pipeline chamado. Você poderá ver a execução e os logs da chamada desse pipeline na tela de logs da Digibee Integration Platform.

Saída

{
   "operation": "ASYNC",
   "pipelineName": "nome do pipeline a ser chamado",
   "versionMajor": 1,
   "success": true,
   "payload": {}
}

Realizando uma chamada síncrona

Operation: SYNC

Pipeline Name: nome do pipeline a ser chamado

Version Major: 1

Payload: {}

Timeout: 20000

Expiration: 30000

Fail On Error: false

Saída

{
   "operation": "SYNC",
   "pipelineName": "nome do pipeline a ser chamado",
   "versionMajor": 1,
   "success": true,
   "payload": {},
   "pipelineResponse": {}
}

Ao realizar implantações de pipelines que utilizem o Pipeline Executor, esteja atento às configurações de execuções simultâneas tanto no pipeline de origem como no de destino, especialmente quando o parâmetro Operation estiver configurado com o valor SYNC.

Para evitar erros de enfileiramento de chamadas e timeout ao pipeline de destino, é recomendável que a mesma configuração de execuções simultâneas seja adotada para ambos os pipelines (origem e destino).

Exemplos de Red Flags

pipeline1(Medium) <-> pipeline2(Small) pipeline1(Large) <-> pipeline2(Medium) pipeline1(Large) <-> pipeline2(Small)

Limite de Execuções Simultâneas por tipo de implantação

Small - max 10 Medium - max 20 Large - max 40