Filtrar dados num fluxo de dados

Use a fase de filtro num fluxo de dados para eliminar mensagens que correspondam a uma condição. Quando uma expressão de filtro é avaliada como verdadeira, a mensagem é descartada. Quando a expressão é avaliada como falsa, a mensagem passa para a fase seguinte.

Podes definir várias regras de filtro. Cada regra especifica campos de entrada e uma expressão booleana. As regras usam lógica OR: se alguma regra for avaliada como verdadeira, a mensagem é descartada.

Configurar um filtro

Cada regra de filtro tem as seguintes propriedades:

Propriedade	Obrigatório	Descrição
`inputs`	Sim	Lista de caminhos de campo a ler da mensagem recebida. Variáveis posicionais atribuídas: a primeira entrada é `$1`, a segunda é `$2`, e assim sucessivamente.
`expression`	Sim	A expressão booleana é avaliada em relação a cada mensagem. Se for verdade, a mensagem é descartada.
`description`	No	Descrição legível para humanos da regra do filtro.

Usar o último valor conhecido

Adicione ? $last a uma entrada para usar o último valor conhecido quando o campo estiver em falta na mensagem atual. Esta abordagem é útil para dados esparsos onde nem todas as mensagens contêm todos os campos.

Exemplos

Filtrar por um limiar

Eliminar mensagens em que a temperatura esteja a 20 ou abaixo.

Em Transformar (opcional), selecione Adicionar filtro>.
Introduza as seguintes definições:

Configuração Descrição

Condição do filtro temperature <= 20

Descrição Eliminar leituras de baixa temperatura

No campo de condição do filtro, insira @ ou selecione Ctrl + Espaço para escolher pontos de dados em uma lista suspensa.
Selecione Aplicar.

Configuração	Descrição
Condição do filtro	`temperature <= 20`
Descrição	Eliminar leituras de baixa temperatura

{
  "operationType": "BuiltInTransformation",
  "builtInTransformationSettings": {
    "filter": [
      {
        "inputs": [
          "temperature"
        ],
        "expression": "$1 <= 20"
      }
    ]
  }
}

builtInTransformationSettings: {
  filter: [
    {
      inputs: [
        'temperature'
      ]
      expression: '$1 <= 20'
    }
  ]
}

Importante

A utilização dos manifestos de implementação do Kubernetes não é suportada em ambientes de produção e deve ser usada apenas para depuração e testes.

builtInTransformationSettings:
  filter:
    - inputs:
        - temperature
      expression: "$1 <= 20"

Filtro com o último valor conhecido

Use o último valor de temperatura conhecido se a mensagem atual não o incluir. Descartar mensagens em que a última temperatura conhecida é 20 ou inferior.

No campo de condição do filtro, introduza @temperature ? $last <= 20.

{
  "operationType": "BuiltInTransformation",
  "builtInTransformationSettings": {
    "filter": [
      {
        "inputs": [
          "$source.temperature ? $last"
        ],
        "expression": "$1 <= 20"
      }
    ]
  }
}

builtInTransformationSettings: {
  filter: [
    {
      inputs: [
        'temperature ? $last'
      ]
      expression: '$1 <= 20'
    }
  ]
}

Importante

A utilização dos manifestos de implementação do Kubernetes não é suportada em ambientes de produção e deve ser usada apenas para depuração e testes.

builtInTransformationSettings:
  filter:
    - inputs:
        - temperature ? $last
      expression: "$1 <= 20"

Filtro com múltiplas condições

Eliminar mensagens onde o produto da temperatura e da humidade é 100.000 ou mais.

No campo de condição do filtro, introduza @temperature * @humidity >= 100000.

{
  "operationType": "BuiltInTransformation",
  "builtInTransformationSettings": {
    "filter": [
      {
        "inputs": [
          "temperature.Value",
          "humidity.Value"
        ],
        "expression": "$1 * $2 >= 100000"
      }
    ]
  }
}

builtInTransformationSettings: {
  filter: [
    {
      inputs: [
        'temperature.Value'
        'humidity.Value'
      ]
      expression: '$1 * $2 >= 100000'
    }
  ]
}

Importante

A utilização dos manifestos de implementação do Kubernetes não é suportada em ambientes de produção e deve ser usada apenas para depuração e testes.

builtInTransformationSettings:
  filter:
    - inputs:
        - temperature.Value
        - humidity.Value
      expression: "$1 * $2 >= 100000"

Filtrar com dados enriquecidos

Se configurou um conjunto de dados de enriquecimento, pode usar campos enriquecidos em condições de filtro. Por exemplo, filtre contra um limite específico de dispositivo a partir de um conjunto de dados de armazenamento de estados:

Atualmente, a filtragem baseada em enriquecimento não está disponível na experiência operacional.

{
  "operationType": "BuiltInTransformation",
  "builtInTransformationSettings": {
    "datasets": [
      {
        "key": "device_limits",
        "inputs": [
          "$source.deviceId",
          "$context(device_limits).deviceId"
        ],
        "expression": "$1 == $2"
      }
    ],
    "filter": [
      {
        "inputs": [
          "temperature",
          "$context(device_limits).maxTemperature"
        ],
        "expression": "$1 <= $2"
      }
    ]
  }
}

builtInTransformationSettings: {
  datasets: [
    {
      key: 'device_limits'
      inputs: [
        '$source.deviceId'
        '$context(device_limits).deviceId'
      ]
      expression: '$1 == $2'
    }
  ]
  filter: [
    {
      inputs: [
        'temperature'
        '$context(device_limits).maxTemperature'
      ]
      expression: '$1 <= $2'
    }
  ]
}

Importante

A utilização dos manifestos de implementação do Kubernetes não é suportada em ambientes de produção e deve ser usada apenas para depuração e testes.

builtInTransformationSettings:
  datasets:
    - key: device_limits
      inputs:
        - $source.deviceId
        - $context(device_limits).deviceId
      expression: "$1 == $2"
  filter:
    - inputs:
        - temperature
        - $context(device_limits).maxTemperature
      expression: "$1 <= $2"

Este exemplo elimina mensagens do armazenamento de estados onde a temperatura excede o máximo permitido pelo dispositivo.

Múltiplas regras de filtro

Podes definir várias regras de filtro. Todas as regras usam lógica OR: se alguma regra for avaliada como verdadeira, a mensagem é descartada:

Em Transformar (opcional), selecione Adicionar Filtro> várias vezes para adicionar regras de filtro adicionais.

{
  "operationType": "BuiltInTransformation",
  "builtInTransformationSettings": {
    "filter": [
      {
        "inputs": ["temperature"],
        "expression": "$1 <= 20",
        "description": "Drop low temperatures"
      },
      {
        "inputs": ["humidity"],
        "expression": "$1 >= 80",
        "description": "Drop high humidity readings"
      }
    ]
  }
}

builtInTransformationSettings: {
  filter: [
    {
      inputs: ['temperature']
      expression: '$1 <= 20'
      description: 'Drop low temperatures'
    }
    {
      inputs: ['humidity']
      expression: '$1 >= 80'
      description: 'Drop high humidity readings'
    }
  ]
}

Importante

A utilização dos manifestos de implementação do Kubernetes não é suportada em ambientes de produção e deve ser usada apenas para depuração e testes.

builtInTransformationSettings:
  filter:
    - inputs:
        - temperature
      expression: "$1 <= 20"
      description: Drop low temperatures
    - inputs:
        - humidity
      expression: "$1 >= 80"
      description: Drop high humidity readings

Criar um fluxo de dados

Comentários

Esta página foi útil?

Last updated on 2026-05-29

Filtrar dados num fluxo de dados

Configurar um filtro

Usar o último valor conhecido

Exemplos

Filtrar por um limiar

Filtro com o último valor conhecido

Filtro com múltiplas condições

Filtrar com dados enriquecidos

Múltiplas regras de filtro

Conteúdo relacionado

Comentários

Recursos adicionais