Adatok szűrése adatfolyamban

Az adatfolyam szűrési szakaszával elvetheti a feltételnek megfelelő üzeneteket. Ha egy szűrőkifejezés értéke igaz, a rendszer elveti az üzenetet. Ha a kifejezés értéke hamis, az üzenet a következő szakaszba kerül.

Több szűrőszabályt is meghatározhat. Minden szabály megadja a bemeneti mezőket és egy logikai kifejezést. A szabályok VAGY logikát használnak: ha valamelyik szabály igaznak bizonyul, a rendszer elveti az üzenetet.

Szűrő konfigurálása

Minden szűrőszabály a következő tulajdonságokkal rendelkezik:

Ingatlan	Szükséges	Leírás
inputs	Igen	A bejövő üzenetből beolvasandó mezőútvonalak listája. Hozzárendelt pozícióváltozók: az első bemenet, $1a második $2és így tovább.
expression	Igen	Az egyes üzenetek alapján kiértékelt logikai kifejezés. Ha igaz, a rendszer elveti az üzenetet.
description	No	A szűrőszabály ember által olvasható leírása.

Utolsó ismert érték használata

Fűzze hozzá ? $last egy bemenethez az utolsó ismert értéket, ha a mező hiányzik az aktuális üzenetből. Ez a módszer olyan ritkán használt adatok esetében hasznos, ahol nem minden üzenet tartalmaz minden mezőt.

Examples

Szűrés küszöbérték szerint

Olyan üzenetek elvetése, ahol a hőmérséklet 20 vagy alacsonyabb:

Üzemeltetési tapasztalat

1. Az Átalakítás (nem kötelező) területen válassza a Szűrő>Hozzáadása lehetőséget.

   

2. Adja meg a következő beállításokat:

   Setting	Leírás
   Szűrési feltétel	temperature <= 20
   Leírás	Alacsony hőmérsékleti értékek elvetése

   A Szűrőfeltétel mezőben adja meg @ vagy válassza a Ctrl + Szóköz billentyűkombinációt, ha egy legördülő listából szeretne adatpontokat választani.

3. Válassza az Alkalmaz lehetőséget.

Azure CLI-

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

Bicepsz

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

Kubernetes (csak hibakeresés)

Fontos

A Kubernetes üzembehelyezési jegyzékfájljainak használata éles környezetekben nem támogatott, és csak hibakereséshez és teszteléshez használható.

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

Szűrés az utolsó ismert értékkel

Használja az utolsó ismert hőmérsékleti értéket, ha az aktuális üzenet nem tartalmazza. Elhagyja azokat az üzeneteket, ahol az utolsó ismert hőmérséklet 20 fok vagy annál alacsonyabb:

Üzemeltetési tapasztalat

A szűrőfeltétel mezőbe írja be a következőt @temperature ? $last <= 20:

Azure CLI-

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

Bicepsz

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

Kubernetes (csak hibakeresés)

Fontos

A Kubernetes üzembehelyezési jegyzékfájljainak használata éles környezetekben nem támogatott, és csak hibakereséshez és teszteléshez használható.

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

Szűrés több feltétellel

Dobja el az üzeneteket, ahol a hőmérséklet és a páratartalom szorzata 100 000 vagy több:

Üzemeltetési tapasztalat

A szűrőfeltétel mezőbe írja be a következőt @temperature * @humidity >= 100000:

Azure CLI-

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

Bicepsz

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

Kubernetes (csak hibakeresés)

Fontos

A Kubernetes üzembehelyezési jegyzékfájljainak használata éles környezetekben nem támogatott, és csak hibakereséshez és teszteléshez használható.

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

Szűrés bővített adatokkal

Ha bővített adatkészletet konfigurált, a bővített mezőket szűrőfeltételek között használhatja. Például szűrjön egy állapottároló adatkészletből egy eszközhöz specifikus korlát ellen:

Üzemeltetési tapasztalat

A bővítésalapú szűrés jelenleg nem érhető el a műveleti felületen.

Azure CLI-

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

Bicepsz

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

Kubernetes (csak hibakeresés)

Fontos

A Kubernetes üzembehelyezési jegyzékfájljainak használata éles környezetekben nem támogatott, és csak hibakereséshez és teszteléshez használható.

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"

Ez a példa olyan üzeneteket távolít el, amelyek hőmérséklete meghaladja az eszközspecifikus maximális értéket az állapottárolóból.

Több szűrőszabály

Több szűrőszabályt is meghatározhat. Minden szabály VAGY logikát használ: ha valamelyik szabály igaznak számít, a rendszer elveti az üzenetet:

Üzemeltetési tapasztalat

Az Átalakítás (nem kötelező) területen válassza a Szűrő>hozzáadása többször lehetőséget további szűrőszabályok hozzáadásához.

Azure CLI-

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

Bicepsz

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

Kubernetes (csak hibakeresés)

Fontos

A Kubernetes üzembehelyezési jegyzékfájljainak használata éles környezetekben nem támogatott, és csak hibakereséshez és teszteléshez használható.

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

Kapcsolódó tartalom

• Adatok leképezése adatfolyamok használatával
• Adatok bővítése adatfolyamok használatával

• Adatfolyam létrehozása