adicionar campo¶
fábrica
cria uma ou mais colunas novas a partir de uma expressão sql, com o tipo de dado final já definido.
quando usar¶
- derivar métricas calculadas (ex:
valor_liquido = valor_bruto - desconto) - criar flags booleanas de negócio (ex:
is_cliente_vip = valor_total > 10000) - normalizar campos de data/hora ou concatenar colunas de texto (ex:
nome_completo)
configuração¶
| campo | tipo | obrigatório | descrição |
|---|---|---|---|
fields |
lista de {field, expression, field_type} |
sim | um item por coluna nova a ser criada |
cada item de fields tem:
| campo | tipo | descrição |
|---|---|---|
field |
string | nome da nova coluna |
expression |
string | expressão sql (pode referenciar outras colunas da tabela e variáveis {{pipeline.var}}) |
field_type |
enum | text, integer, decimal, boolean, date, datetime — aplica um cast automático sobre o resultado da expressão |
exemplo¶
{
"fields": [
{ "field": "valor_liquido", "expression": "valor_bruto - desconto", "field_type": "decimal" },
{ "field": "is_vip", "expression": "valor_total > 10000", "field_type": "boolean" },
{ "field": "ano_pedido", "expression": "EXTRACT(YEAR FROM data_pedido)", "field_type": "integer" }
]
}
produz três colunas novas, cada uma já convertida para o tipo de dado configurado — se a expressão não puder ser convertida para o tipo escolhido, o valor resultante fica nulo em vez de quebrar o pipeline.
expressões podem usar variáveis de pipeline
a expressão aceita {{pipeline.variavel}}, permitindo parametrizar cálculos (ex: uma taxa de câmbio ou uma data de referência configurada no pipeline).