Transformação
É possível aplicar transformações nas mensagens trafegadas no fluxo. Pode ser aplicada em qualquer tipo de configuração, inclusive com uma configuração de Processamento em Streaming.
No momento, as transformações funcionam apenas com payloads com Content-Type application/json
.
Tipos
As seguintes transformações são aceitas:
HTTP
Permite que um endpoint HTTP externo seja consumido durante o processamento e atribui o resultado à mensagem.
Bloblang
Permite um mapeamento usando a sintaxe bloblang e atribui o resultado à mensagem.
Para realizar testes da sintaxe a ferramenta Bloblang Walkthrough pode ser utilizada.
Delete
Permite uma a sintaxe bloblang que retorne um valor booleano indicando se a mensagem deve ser excluída.
Parâmetros
Parâmetros aceitos na configuração de transformação:
Requisição
Para habilitar a transformação a seguinte requisição pode ser realizada:
No exemplo acima foi gerada uma configuração do Firehose que aplica 3 etapas de transformação de forma sequencial na mensagem.
A primeira etapa realiza uma requisição http e armazena o resultado no campo http
. A segunda etapa recupera o resultado do campo adicionado pela etapa anterior e armazena o resultado no campo bloblang
. A última etapa verifica se o valor do campo adicionado na etapa anterior é igual à OK
, em caso positivo a mensagem será apagada.
Last updated