Filtrowanie danych w przepływie danych

Użyj etapu filtru w przepływie danych, aby usunąć komunikaty zgodne z warunkiem. Gdy wyrażenie filtru zwróci wartość true, komunikat zostanie porzucony. Gdy wyrażenie przyjmie wartość false, komunikat przechodzi do następnego etapu.

Można zdefiniować wiele reguł filtrowania. Każda reguła określa pola wejściowe i wyrażenie logiczne. Reguły używają logiki OR: jeśli którakolwiek reguła zwróci wartość true, komunikat zostanie porzucony.

Konfigurowanie filtru

Każda reguła filtru ma następujące właściwości:

Majątek	Wymagane	Opis
`inputs`	Yes	Lista ścieżek pól do odczytu z przychodzącej wiadomości. Przypisane zmienne pozycyjne: pierwsze dane wejściowe to `$1`, drugie to `$2`, i tak dalej.
`expression`	Yes	Wyrażenie logiczne obliczane względem każdego komunikatu. Jeśli wartość true, komunikat zostanie porzucony.
`description`	Nie.	Czytelny dla człowieka opis reguły filtru.

Użyj ostatniej znanej wartości

Dołącz ? $last do danych wejściowych, aby użyć ostatniej znanej wartości, gdy brakuje pola w bieżącym komunikacie. Takie podejście jest przydatne w przypadku rozrzednia danych, w których nie każdy komunikat zawiera każde pole.

Examples

Filtrowanie według progu

Usuń komunikaty, gdy temperatura wynosi 20 lub mniej.

W obszarze Przekształć (opcjonalnie) wybierz pozycję Filtr>Dodaj.
Wprowadź następujące ustawienia:

Setting Opis

Warunek filtru temperature <= 20

Opis Pominięcie niskich odczytów temperatury

W polu warunek filtru wprowadź @ lub wybierz Ctrl + Spacja , aby wybrać punkty danych z listy rozwijanej.
Wybierz i zastosuj.

Setting	Opis
Warunek filtru	`temperature <= 20`
Opis	Pominięcie niskich odczytów temperatury

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

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

Ważna

Korzystanie z manifestów wdrożenia platformy Kubernetes nie jest obsługiwane w środowiskach produkcyjnych i powinno być używane tylko do debugowania i testowania.

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

Filtruj z ostatnią znaną wartością

Jeśli bieżący komunikat nie zawiera wartości temperatury, użyj ostatniej znanej wartości temperatury. Odrzucaj komunikaty, gdzie ostatnia znana temperatura wynosi 20 lub mniej.

W polu warunek filtru wprowadź wartość @temperature ? $last <= 20.

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

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

Ważna

Korzystanie z manifestów wdrożenia platformy Kubernetes nie jest obsługiwane w środowiskach produkcyjnych i powinno być używane tylko do debugowania i testowania.

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

Filtrowanie przy użyciu wielu warunków

Porzuć komunikaty, w których produkt temperatury i wilgotności wynosi 100 000 lub więcej.

W polu warunek filtru wprowadź wartość @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'
    }
  ]
}

Ważna

Korzystanie z manifestów wdrożenia platformy Kubernetes nie jest obsługiwane w środowiskach produkcyjnych i powinno być używane tylko do debugowania i testowania.

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

Filtrowanie przy użyciu wzbogaconych danych

Jeśli skonfigurowano zestaw danych wzbogacania, możesz użyć wzbogaconych pól w warunkach filtrowania. Na przykład przefiltruj zestaw danych w magazynie stanów według limitu specyficznego dla urządzenia:

Obecnie filtrowanie oparte na wzbogacaniu nie jest dostępne w doświadczeniu operacyjnym.

{
  "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'
    }
  ]
}

Ważna

Korzystanie z manifestów wdrożenia platformy Kubernetes nie jest obsługiwane w środowiskach produkcyjnych i powinno być używane tylko do debugowania i testowania.

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"

Ten przykład usuwa komunikaty, w których temperatura przekracza maksymalną wartość specyficzną dla urządzenia z magazynu stanów.

Wiele reguł filtrowania

Można zdefiniować wiele reguł filtrowania. Wszystkie reguły używają logiki OR: jeśli którakolwiek reguła ma wartość true, komunikat zostanie porzucony:

W obszarze Przekształć (opcjonalnie) wybierz pozycję Filtruj>dodaj wiele razy, aby dodać dodatkowe reguły filtrowania.

{
  "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'
    }
  ]
}

Ważna

Korzystanie z manifestów wdrożenia platformy Kubernetes nie jest obsługiwane w środowiskach produkcyjnych i powinno być używane tylko do debugowania i testowania.

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

Tworzenie przepływu danych

Opinia

Czy ta strona była pomocna?

Last updated on 2026-04-02

Filtrowanie danych w przepływie danych

Konfigurowanie filtru

Użyj ostatniej znanej wartości

Examples

Filtrowanie według progu

Filtruj z ostatnią znaną wartością

Filtrowanie przy użyciu wielu warunków

Filtrowanie przy użyciu wzbogaconych danych

Wiele reguł filtrowania

Treści powiązane

Opinia

Dodatkowe zasoby